GitHub/netch
1
0
Fork 0
mirror of https://github.com/netchx/netch.git synced 2026-05-11 23:45:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Optimize buffer size

Browse Source
This commit is contained in:
Netch
2021-08-10 09:03:00 +08:00
parent bb6f7111db
commit 36787927ff
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Redirector/EventHandler.cpp
View File

@@ -404,14 +404,14 @@ void udpClosed(ENDPOINT_ID id, PNF_UDP_CONN_INFO info)
void udpBeginReceive(ENDPOINT_ID id, SOCKET client, PBYTE data)
{
auto buffer = new char[65535]();
auto buffer = new char[NF_TCP_PACKET_BUF_SIZE]();
while (true)
{
SOCKADDR_IN remote;
int remoteLength = sizeof(SOCKADDR_IN);
int length = recvfrom(client, buffer, sizeof(buffer), 0, (PSOCKADDR)&remote, &remoteLength);
int length = recvfrom(client, buffer, NF_TCP_PACKET_BUF_SIZE, 0, (PSOCKADDR)&remote, &remoteLength);
if (length == 0)
{
break;

10
Redirector/TCPHandler.cpp
View File

@@ -7,17 +7,17 @@ extern map<ENDPOINT_ID, PTCPINFO> tcpContext;
void IoConn(SOCKET client, SOCKET remote)
{
char buffer[1400];
auto buffer = new char[NF_TCP_PACKET_BUF_SIZE]();
while (true)
{
auto length = recv(client, buffer, 1400, 0);
auto length = recv(client, buffer, NF_TCP_PACKET_BUF_SIZE, 0);
if (!length)
{
if (length == SOCKET_ERROR)
{
printf("[Redirector][TCPHandler][IoConn] Receive failed: %d\n", WSAGetLastError());
return;
break;
}
continue;
@@ -27,9 +27,11 @@ void IoConn(SOCKET client, SOCKET remote)
if (!sended && sended != length)
{
printf("[Redirector][TCPHandler][IoConn] Send failed: %d\n", WSAGetLastError());
return;
break;
}
}
delete[] buffer;
}
BOOL TCPHandler::init()