Alawn/shadowsocks-libev
1
0
Fork 0
mirror of https://github.com/shadowsocks/shadowsocks-libev.git synced 2026-10-29 20:43:44 +00:00
Code Releases Activity

Fix #2449

Browse Source
This commit is contained in:
Max Lv
2019-08-09 14:52:54 +08:00
parent e3c6c80df0
commit 1c4ddd3724
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/server.c
+10 -10
View File
@@ -701,11 +701,6 @@ server_recv_cb(EV_P_ ev_io *w, int revents)
buffer_t *buf = server->buf;
// Ignore any new packet if the server is stopped
if (server->stage == STAGE_STOP) {
return;
}
if (server->stage == STAGE_STREAM) {
remote = server->remote;
buf = remote->buf;
@@ -731,6 +726,11 @@ server_recv_cb(EV_P_ ev_io *w, int revents)
}
}
// Ignore any new packet if the server is stopped
if (server->stage == STAGE_STOP) {
return;
}
tx += r;
buf->len = r;
@@ -1101,11 +1101,6 @@ remote_recv_cb(EV_P_ ev_io *w, int revents)
remote_t *remote = remote_recv_ctx->remote;
server_t *server = remote->server;
// Ignore any new packet if the server is stopped
if (server->stage == STAGE_STOP) {
return;
}
if (server == NULL) {
LOGE("invalid server");
close_and_free_remote(EV_A_ remote);
@@ -1134,6 +1129,11 @@ remote_recv_cb(EV_P_ ev_io *w, int revents)
rx += r;
// Ignore any new packet if the server is stopped
if (server->stage == STAGE_STOP) {
return;
}
server->buf->len = r;
int err = crypto->encrypt(server->buf, server->e_ctx, SOCKET_BUF_SIZE);