Alawn/shadowsocks-libev
1
0
Fork 0
mirror of https://github.com/shadowsocks/shadowsocks-libev.git synced 2026-10-28 19:53:46 +00:00
Code Releases Activity

refine the udp connection cache

Browse Source
This commit is contained in:
Max Lv
2014-11-25 19:17:13 +08:00
parent fe81ca5eb9
commit afac2089d3
1 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/udprelay.c
+9 -9
View File
@@ -440,15 +440,6 @@ static void query_resolve_cb(EV_P_ ev_io *w, int revents)
memcpy(remote_ctx->addr_header, query_ctx->addr_header,
query_ctx->addr_header_len);
// Add to conn cache
char *key = hash_key(remote_ctx->addr_header,
remote_ctx->addr_header_len,
&remote_ctx->src_addr);
cache_insert(query_ctx->server_ctx->conn_cache, key,
(void *)remote_ctx);
ev_io_start(EV_A_ & remote_ctx->io);
size_t addr_len = sizeof(struct sockaddr_in);
if (remote_ctx->dst_addr.ss_family == AF_INET6) {
addr_len = sizeof(struct sockaddr_in6);
@@ -460,6 +451,15 @@ static void query_resolve_cb(EV_P_ ev_io *w, int revents)
if (s == -1) {
ERROR("udprelay_sendto_remote");
close_and_free_remote(EV_A_ remote_ctx);
} else {
// Add to conn cache
char *key = hash_key(remote_ctx->addr_header,
remote_ctx->addr_header_len,
&remote_ctx->src_addr);
cache_insert(query_ctx->server_ctx->conn_cache, key,
(void *)remote_ctx);
ev_io_start(EV_A_ & remote_ctx->io);
}
} else {