Spaces:
Paused
Paused
xukc commited on
Commit ·
1255c0c
1
Parent(s): 2faa101
[fix]tcp
Browse files- tcp_inbound.cpp +1 -1
tcp_inbound.cpp
CHANGED
|
@@ -42,7 +42,7 @@ void tcp_on_accept(hio_t* io, hevent_t* ev) {
|
|
| 42 |
SOCKADDR_STR(hio_localaddr(io), localaddrstr),
|
| 43 |
SOCKADDR_STR(hio_peeraddr(io), peeraddrstr));
|
| 44 |
|
| 45 |
-
ConnMap<hio_t*, TcpClientBolt>::getInstance().add(io, std::
|
| 46 |
|
| 47 |
hio_setcb_close(io, tcp_on_close);
|
| 48 |
hio_setcb_read(io, tcp_on_recv);
|
|
|
|
| 42 |
SOCKADDR_STR(hio_localaddr(io), localaddrstr),
|
| 43 |
SOCKADDR_STR(hio_peeraddr(io), peeraddrstr));
|
| 44 |
|
| 45 |
+
ConnMap<hio_t*, TcpClientBolt>::getInstance().add(io, std::unique_ptr<TcpClientBolt>(new TcpClientBolt(io)));
|
| 46 |
|
| 47 |
hio_setcb_close(io, tcp_on_close);
|
| 48 |
hio_setcb_read(io, tcp_on_recv);
|