diff --git a/src/udprelay.c b/src/udprelay.c index b6184038..7d4d2d5b 100644 --- a/src/udprelay.c +++ b/src/udprelay.c @@ -493,7 +493,7 @@ static void remote_recv_cb (EV_P_ ev_io *w, int revents) buf = ss_encrypt_all(BUF_SIZE, buf, &buf_len, server_ctx->method); #endif - int s = sendto(remote_ctx->fd, buf, buf_len, 0, &remote_ctx->src_addr, sizeof(remote_ctx->src_addr)); + int s = sendto(server_ctx->fd, buf, buf_len, 0, &remote_ctx->src_addr, sizeof(remote_ctx->src_addr)); if (s == -1) { @@ -681,8 +681,8 @@ static void server_recv_cb (EV_P_ ev_io *w, int revents) #else - buf_len -= offset; - memmove(buf, buf + offset, buf_len); + buf_len -= (offset + addr_header_len); + memmove(buf, buf + (offset + addr_header_len), buf_len); if (remote_ctx == NULL) { @@ -701,7 +701,7 @@ static void server_recv_cb (EV_P_ ev_io *w, int revents) goto CLEAN_UP; } - struct query_ctx *query_ctx = new_query_ctx(query, buf + addr_header_len, buf_len - addr_header_len); + struct query_ctx *query_ctx = new_query_ctx(query, buf, buf_len); query_ctx->server_ctx = server_ctx; query_ctx->addr_header_len = addr_header_len; query_ctx->src_addr = src_addr; @@ -713,7 +713,7 @@ static void server_recv_cb (EV_P_ ev_io *w, int revents) else { - int s = sendto(remote_ctx->fd, buf + addr_header_len, buf_len - addr_header_len, 0, &remote_ctx->dst_addr, sizeof(remote_ctx->dst_addr)); + int s = sendto(remote_ctx->fd, buf, buf_len, 0, &remote_ctx->dst_addr, sizeof(remote_ctx->dst_addr)); if (s == -1) {