Skip to content

Commit 9c825bd

Browse files
committed
Update length check
1 parent 1364a8b commit 9c825bd

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

src/network/ReactorThread.c

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -771,16 +771,15 @@ int swReactorThread_onReceive_buffer_check_length(swReactor *reactor, swEvent *e
771771
else if(package_total_length == 0)
772772
{
773773
char recv_buf_again[SW_BUFFER_SIZE_BIG];
774-
int recv_n = 0;
775774
memcpy(recv_buf_again, (void *) tmp_ptr, (uint32_t) tmp_n);
776775

777776
for(;;)
778777
{
779778
//前tmp_n个字节存放不完整包头
780-
n = recv(event->fd, (void *) recv_buf_again + recv_n, SW_BUFFER_SIZE_BIG - recv_n, 0);
779+
n = recv(event->fd, (void *) recv_buf_again + tmp_n, SW_BUFFER_SIZE_BIG - tmp_n, 0);
781780
if (n > 0)
782781
{
783-
recv_n += n;
782+
tmp_n += n;
784783
}
785784
else if (n == 0)
786785
{
@@ -813,8 +812,6 @@ int swReactorThread_onReceive_buffer_check_length(swReactor *reactor, swEvent *e
813812
}
814813

815814
tmp_ptr = recv_buf_again;
816-
tmp_n = tmp_n + recv_n;
817-
818815
goto do_parse_package;
819816
}
820817
//complete package

0 commit comments

Comments
 (0)