Increase the transmit buffer size

CHANGES.md

@@ -25,6 +25,7 @@ Release Notes.
 * Downgrade the protocol of connection when protocol break in the access log module.
 * Bump up go version to `1.24` and eBPF library to `0.18.0`.
 * Support detect ztunnel environment in the inbound request.
+* Increase the transmit buffer size in the network profiling and access log module.
 
 #### Bug Fixes
 * Fix the base image cannot run in the arm64.

bpf/include/queue.h

@@ -28,7 +28,7 @@ struct {
 	__uint(type, BPF_MAP_TYPE_PERCPU_ARRAY);
 	__uint(max_entries, 1);
 	__uint(key_size, sizeof(__u32));
-	__uint(value_size, 10240); // all events are less than 10KB
+	__uint(value_size, 30960); // all events are less than 30KB
 } rover_data_heap SEC(".maps");
 
 static __always_inline void *rover_reserve_buf(void *map, __u64 size) {

bpf/include/socket_opts.h

@@ -43,7 +43,7 @@
 // for protocol analyze need to read
 #define MAX_PROTOCOL_SOCKET_READ_LENGTH 31
 // for transmit to the user space
-#define MAX_TRANSMIT_SOCKET_READ_LENGTH 2048
+#define MAX_TRANSMIT_SOCKET_READ_LENGTH 20480
 
 // unknown the connection type, not trigger the syscall connect,accept
 #define AF_UNKNOWN 0xff

pkg/accesslog/collector/protocols/http1.go

@@ -112,8 +112,8 @@ func (p *HTTP1Protocol) Analyze(connection *PartitionConnection, _ *AnalyzeHelpe
 			result = enums.ParseResultSkipPackage
 		}
 		if err != nil {
-			http1Log.Warnf("failed to handle HTTP/1.x protocol, connection ID: %d, random ID: %d, data id: %d, error: %v",
-				metrics.ConnectionID, metrics.RandomID, buf.Position().DataID(), err)
+			http1Log.Warnf("failed to handle HTTP/1.x protocol, connection ID: %d, random ID: %d, data id: %d, type: %d, error: %v",
+				metrics.ConnectionID, metrics.RandomID, buf.Position().DataID(), messageType, err)
 		}
 
 		http1Log.Debugf("readed message, messageType: %v, buf: %p, data id: %d, "+

pkg/accesslog/events/data.go

@@ -38,10 +38,10 @@ type SocketDataUploadEvent struct {
 	DataID0      uint64
 	PrevDataID0  uint64
 	TotalSize0   uint64
-	Buffer       [2048]byte
+	Buffer       [20480]byte
 }
 
-func (s *SocketDataUploadEvent) ReleaseBuffer() *[2048]byte {
+func (s *SocketDataUploadEvent) ReleaseBuffer() *[20480]byte {
 	return &s.Buffer
 }
 
@@ -59,7 +59,7 @@ func (s *SocketDataUploadEvent) ReadFrom(r btf.Reader) {
 	s.DataID0 = r.ReadUint64()
 	s.PrevDataID0 = r.ReadUint64()
 	s.TotalSize0 = r.ReadUint64()
-	r.ReadUint8Array(s.Buffer[:], 2048)
+	r.ReadUint8Array(s.Buffer[:], 20480)
 }
 
 func (s *SocketDataUploadEvent) Protocol() enums.ConnectionProtocol {

pkg/profiling/task/network/analyze/events/data.go

@@ -37,10 +37,10 @@ type SocketDataUploadEvent struct {
 	DataID0      uint64
 	PrevDataID0  uint64
 	TotalSize0   uint64
-	Buffer       [2048]byte
+	Buffer       [20480]byte
 }
 
-func (s *SocketDataUploadEvent) ReleaseBuffer() *[2048]byte {
+func (s *SocketDataUploadEvent) ReleaseBuffer() *[20480]byte {
 	return &s.Buffer
 }
 

pkg/tools/buffer/buffer.go

@@ -40,13 +40,13 @@ var (
 
 	PooledBuffer = sync.Pool{
 		New: func() any {
-			return &[2048]byte{}
+			return &[20480]byte{}
 		},
 	}
 )
 
-func BorrowNewBuffer() *[2048]byte {
-	return PooledBuffer.Get().(*[2048]byte)
+func BorrowNewBuffer() *[20480]byte {
+	return PooledBuffer.Get().(*[20480]byte)
 }
 
 type SocketDataBuffer interface {
@@ -82,7 +82,7 @@ type SocketDataBuffer interface {
 	// EndTime the data end timestamp
 	EndTime() uint64
 
-	ReleaseBuffer() *[2048]byte
+	ReleaseBuffer() *[20480]byte
 }
 
 type SocketDataDetail interface {