diff options
| author | zhengchao <[email protected]> | 2018-11-26 14:54:20 +0800 |
|---|---|---|
| committer | zhengchao <[email protected]> | 2018-11-26 14:55:39 +0800 |
| commit | ce9d7fa5ebc99a54e021eace0d76fd1a5f0da3fc (patch) | |
| tree | c561baef2428d4bc4c91bbeab5ac0a8d19a544f5 /platform/src/tcp_stream.cpp | |
| parent | 35c2559f8a4fdf19cdc38aea6b71661b3041c1cf (diff) | |
#64 key keeper增加evdnsbase参数。
避免创建大量dnsbase，耗尽fd。ssl stream/tcp stream/proxy也做了相应修改。
Diffstat (limited to 'platform/src/tcp_stream.cpp')
| -rw-r--r-- | platform/src/tcp_stream.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/platform/src/tcp_stream.cpp b/platform/src/tcp_stream.cpp index b844027..247d579 100644 --- a/platform/src/tcp_stream.cpp +++ b/platform/src/tcp_stream.cpp @@ -763,7 +763,6 @@ void ssl_downstream_create_on_fail(enum e_future_error err, const char * what, v void ssl_upstream_create_on_success(future_result_t * result, void * user) { struct tfe_stream_private * _stream = (struct tfe_stream_private *) user; - struct event_base * ev_base = _stream->thread_ref->evbase; struct ssl_stream * upstream = ssl_upstream_create_result_release_stream(result); struct bufferevent * bev = ssl_upstream_create_result_release_bev(result); @@ -785,7 +784,7 @@ void ssl_upstream_create_on_success(future_result_t * result, void * user) ssl_downstream_create_on_fail, _stream); ssl_async_downstream_create(_stream->future_downstream_create, _stream->ssl_mgr, - _stream->ssl_upstream, _stream->defer_fd_downstream, _stream->keyring_id, ev_base); + _stream->ssl_upstream, _stream->defer_fd_downstream, _stream->keyring_id, _stream->thread_ref->thread_id); } void ssl_upstream_create_on_fail(enum e_future_error err, const char * what, void * user) @@ -1021,7 +1020,6 @@ void __stream_fd_option_setup(struct tfe_stream_private * _stream, evutil_socket int tfe_stream_init_by_fds(struct tfe_stream * stream, evutil_socket_t fd_downstream, evutil_socket_t fd_upstream) { struct tfe_stream_private * _stream = container_of(stream, struct tfe_stream_private, head); - struct event_base * ev_base = _stream->thread_ref->evbase; _stream->defer_fd_downstream = fd_downstream; _stream->defer_fd_upstream = fd_upstream; @@ -1074,7 +1072,7 @@ int tfe_stream_init_by_fds(struct tfe_stream * stream, evutil_socket_t fd_downst /* Defer setup conn_downstream & conn_upstream in async callbacks. */ ssl_async_upstream_create(_stream->future_upstream_create, - _stream->ssl_mgr, fd_upstream, fd_downstream, ev_base); + _stream->ssl_mgr, fd_upstream, fd_downstream, _stream->thread_ref->thread_id); TFE_PROXY_STAT_INCREASE(STAT_STREAM_TCP_SSL, 1); } |