|
|
@@ -15,7 +15,9 @@ typedef void (*callback_t)(const char* data, int length);
|
|
|
#define CONFIG_UDP_BLOCKS (12)
|
|
|
#define FRAME_POINT_COUNT (3600)
|
|
|
|
|
|
-#define SUBPKT_BUF_COUNT (200)
|
|
|
+#define SUBPKT_BUF_COUNT (300)
|
|
|
+
|
|
|
+#define UDP_BUF_SIZE (1206)
|
|
|
|
|
|
// 结构体对齐设置
|
|
|
#pragma pack(push)
|
|
|
@@ -63,7 +65,7 @@ typedef struct {
|
|
|
char* ip;
|
|
|
int port;
|
|
|
callback_t callback;
|
|
|
- sub_packet_t* buffer[2]; // 双缓冲区
|
|
|
+ sub_packet_t buffer[2][SUBPKT_BUF_COUNT]; // 双缓冲区
|
|
|
int current; // 当前缓冲区索引
|
|
|
int valid_count[2]; // 每个缓冲区中有效数据的数量
|
|
|
pthread_mutex_t mutex;
|
