diff options
author | Determinant <ted.sybil@gmail.com> | 2018-11-15 00:24:38 -0500 |
---|---|---|
committer | Determinant <ted.sybil@gmail.com> | 2018-11-15 00:24:38 -0500 |
commit | 82bd1d81e918cc8a1a46b6c36a81cbba43750bb1 (patch) | |
tree | 046e0e51dd6a035a0bc8f4c2686f8e1a28caa43f /include/salticidae/network.h | |
parent | 389a9a56e00225b0e682d64cb05e5291c23892b0 (diff) |
use a simple worker selection policy; add todo-list
Diffstat (limited to 'include/salticidae/network.h')
-rw-r--r-- | include/salticidae/network.h | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/include/salticidae/network.h b/include/salticidae/network.h index 60d8f20..4f934cd 100644 --- a/include/salticidae/network.h +++ b/include/salticidae/network.h @@ -470,7 +470,7 @@ void PeerNetwork<O, _, __>::Conn::on_setup() { assert(!ev_timeout); ev_timeout = Event(worker->get_ec(), -1, [conn](int, int) { SALTICIDAE_LOG_INFO("peer ping-pong timeout"); - conn->terminate(); + conn->worker_terminate(); }); /* the initial ping-pong to set up the connection */ tcall_reset_timeout(worker, conn, pn->conn_timeout); @@ -508,7 +508,7 @@ void PeerNetwork<O, _, __>::Peer::reset_conn(conn_t new_conn) { //SALTICIDAE_LOG_DEBUG("moving send buffer"); //new_conn->move_send_buffer(conn); SALTICIDAE_LOG_INFO("terminating old connection %s", std::string(*conn).c_str()); - conn->cpool->terminate(conn); + conn->disp_terminate(); } addr = new_conn->get_addr(); conn = new_conn; @@ -557,7 +557,7 @@ bool PeerNetwork<O, _, __>::check_new_conn(const conn_t &conn, uint16_t port) { { if (conn != p->conn) { - conn->cpool->terminate(conn); + conn->disp_terminate(); return true; } return false; |