|
@@ -13,7 +13,9 @@
|
|
NetIO *g_netio = NULL;
|
|
NetIO *g_netio = NULL;
|
|
|
|
|
|
NodeIO::NodeIO(tcp::socket &&socket, nodenum_t nodenum) :
|
|
NodeIO::NodeIO(tcp::socket &&socket, nodenum_t nodenum) :
|
|
- sock(std::move(socket)), node_num(nodenum)
|
|
|
|
|
|
+ sock(std::move(socket)), node_num(nodenum), msgsize_inflight(0),
|
|
|
|
+ chunksize_inflight(0), recv_msgsize_inflight(0),
|
|
|
|
+ recv_chunksize_inflight(0)
|
|
{
|
|
{
|
|
}
|
|
}
|
|
|
|
|