mirror of
https://github.com/kvazar-network/kevacoin.git
synced 2025-02-07 12:44:23 +00:00
drop the optimistic write counter hack
This is now handled properly in realtime.
This commit is contained in:
parent
ea3326891d
commit
5c2169cc3f
@ -1167,10 +1167,6 @@ void CConnman::ThreadSocketHandler()
|
|||||||
{
|
{
|
||||||
TRY_LOCK(pnode->cs_vSend, lockSend);
|
TRY_LOCK(pnode->cs_vSend, lockSend);
|
||||||
if (lockSend) {
|
if (lockSend) {
|
||||||
if (pnode->nOptimisticBytesWritten) {
|
|
||||||
RecordBytesSent(pnode->nOptimisticBytesWritten);
|
|
||||||
pnode->nOptimisticBytesWritten = 0;
|
|
||||||
}
|
|
||||||
if (!pnode->vSendMsg.empty()) {
|
if (!pnode->vSendMsg.empty()) {
|
||||||
FD_SET(pnode->hSocket, &fdsetSend);
|
FD_SET(pnode->hSocket, &fdsetSend);
|
||||||
continue;
|
continue;
|
||||||
@ -2582,7 +2578,6 @@ CNode::CNode(NodeId idIn, ServiceFlags nLocalServicesIn, int nMyStartingHeightIn
|
|||||||
minFeeFilter = 0;
|
minFeeFilter = 0;
|
||||||
lastSentFeeFilter = 0;
|
lastSentFeeFilter = 0;
|
||||||
nextSendTimeFeeFilter = 0;
|
nextSendTimeFeeFilter = 0;
|
||||||
nOptimisticBytesWritten = 0;
|
|
||||||
|
|
||||||
BOOST_FOREACH(const std::string &msg, getAllNetMessageTypes())
|
BOOST_FOREACH(const std::string &msg, getAllNetMessageTypes())
|
||||||
mapRecvBytesPerMsgCmd[msg] = 0;
|
mapRecvBytesPerMsgCmd[msg] = 0;
|
||||||
|
@ -596,7 +596,6 @@ public:
|
|||||||
CDataStream ssSend;
|
CDataStream ssSend;
|
||||||
size_t nSendSize; // total size of all vSendMsg entries
|
size_t nSendSize; // total size of all vSendMsg entries
|
||||||
size_t nSendOffset; // offset inside the first vSendMsg already sent
|
size_t nSendOffset; // offset inside the first vSendMsg already sent
|
||||||
uint64_t nOptimisticBytesWritten;
|
|
||||||
uint64_t nSendBytes;
|
uint64_t nSendBytes;
|
||||||
std::deque<CSerializeData> vSendMsg;
|
std::deque<CSerializeData> vSendMsg;
|
||||||
CCriticalSection cs_vSend;
|
CCriticalSection cs_vSend;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user