@@ -385,7 +385,7 @@ void TcpConnectionImpl::send(const std::shared_ptr<std::string> &msgPtr)
385
385
loop_->queueInLoop ([thisPtr, msgPtr]() {
386
386
thisPtr->sendInLoop (msgPtr->data (), msgPtr->length ());
387
387
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
388
- thisPtr->sendNum_ -- ;
388
+ -- thisPtr->sendNum_ ;
389
389
});
390
390
}
391
391
}
@@ -397,7 +397,7 @@ void TcpConnectionImpl::send(const std::shared_ptr<std::string> &msgPtr)
397
397
loop_->queueInLoop ([thisPtr, msgPtr]() {
398
398
thisPtr->sendInLoop (msgPtr->data (), msgPtr->length ());
399
399
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
400
- thisPtr->sendNum_ -- ;
400
+ -- thisPtr->sendNum_ ;
401
401
});
402
402
}
403
403
}
@@ -418,7 +418,7 @@ void TcpConnectionImpl::send(const char *msg, uint64_t len)
418
418
loop_->queueInLoop ([thisPtr, buffer]() {
419
419
thisPtr->sendInLoop (buffer->data (), buffer->length ());
420
420
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
421
- thisPtr->sendNum_ -- ;
421
+ -- thisPtr->sendNum_ ;
422
422
});
423
423
}
424
424
}
@@ -431,7 +431,7 @@ void TcpConnectionImpl::send(const char *msg, uint64_t len)
431
431
loop_->queueInLoop ([thisPtr, buffer]() {
432
432
thisPtr->sendInLoop (buffer->data (), buffer->length ());
433
433
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
434
- thisPtr->sendNum_ -- ;
434
+ -- thisPtr->sendNum_ ;
435
435
});
436
436
}
437
437
}
@@ -451,7 +451,7 @@ void TcpConnectionImpl::send(const std::string &msg)
451
451
loop_->queueInLoop ([thisPtr, msg]() {
452
452
thisPtr->sendInLoop (msg.data (), msg.length ());
453
453
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
454
- thisPtr->sendNum_ -- ;
454
+ -- thisPtr->sendNum_ ;
455
455
});
456
456
}
457
457
}
@@ -463,7 +463,7 @@ void TcpConnectionImpl::send(const std::string &msg)
463
463
loop_->queueInLoop ([thisPtr, msg]() {
464
464
thisPtr->sendInLoop (msg.data (), msg.length ());
465
465
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
466
- thisPtr->sendNum_ -- ;
466
+ -- thisPtr->sendNum_ ;
467
467
});
468
468
}
469
469
}
@@ -483,7 +483,7 @@ void TcpConnectionImpl::send(std::string &&msg)
483
483
loop_->queueInLoop ([thisPtr, msg = std::move (msg)]() {
484
484
thisPtr->sendInLoop (msg.data (), msg.length ());
485
485
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
486
- thisPtr->sendNum_ -- ;
486
+ -- thisPtr->sendNum_ ;
487
487
});
488
488
}
489
489
}
@@ -495,7 +495,7 @@ void TcpConnectionImpl::send(std::string &&msg)
495
495
loop_->queueInLoop ([thisPtr, msg = std::move (msg)]() {
496
496
thisPtr->sendInLoop (msg.data (), msg.length ());
497
497
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
498
- thisPtr->sendNum_ -- ;
498
+ -- thisPtr->sendNum_ ;
499
499
});
500
500
}
501
501
}
@@ -516,7 +516,7 @@ void TcpConnectionImpl::send(const MsgBuffer &buffer)
516
516
loop_->queueInLoop ([thisPtr, buffer]() {
517
517
thisPtr->sendInLoop (buffer.peek (), buffer.readableBytes ());
518
518
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
519
- thisPtr->sendNum_ -- ;
519
+ -- thisPtr->sendNum_ ;
520
520
});
521
521
}
522
522
}
@@ -528,7 +528,7 @@ void TcpConnectionImpl::send(const MsgBuffer &buffer)
528
528
loop_->queueInLoop ([thisPtr, buffer]() {
529
529
thisPtr->sendInLoop (buffer.peek (), buffer.readableBytes ());
530
530
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
531
- thisPtr->sendNum_ -- ;
531
+ -- thisPtr->sendNum_ ;
532
532
});
533
533
}
534
534
}
@@ -549,7 +549,7 @@ void TcpConnectionImpl::send(MsgBuffer &&buffer)
549
549
loop_->queueInLoop ([thisPtr, buffer = std::move (buffer)]() {
550
550
thisPtr->sendInLoop (buffer.peek (), buffer.readableBytes ());
551
551
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
552
- thisPtr->sendNum_ -- ;
552
+ -- thisPtr->sendNum_ ;
553
553
});
554
554
}
555
555
}
@@ -561,7 +561,7 @@ void TcpConnectionImpl::send(MsgBuffer &&buffer)
561
561
loop_->queueInLoop ([thisPtr, buffer = std::move (buffer)]() {
562
562
thisPtr->sendInLoop (buffer.peek (), buffer.readableBytes ());
563
563
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
564
- thisPtr->sendNum_ -- ;
564
+ -- thisPtr->sendNum_ ;
565
565
});
566
566
}
567
567
}
@@ -622,7 +622,7 @@ void TcpConnectionImpl::sendFile(int sfd, size_t offset, size_t length)
622
622
thisPtr->writeBufferList_ .push_back (node);
623
623
{
624
624
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
625
- thisPtr->sendNum_ -- ;
625
+ -- thisPtr->sendNum_ ;
626
626
}
627
627
628
628
if (thisPtr->writeBufferList_ .size () == 1 )
@@ -643,7 +643,7 @@ void TcpConnectionImpl::sendFile(int sfd, size_t offset, size_t length)
643
643
644
644
{
645
645
std::lock_guard<std::mutex> guard1 (thisPtr->sendNumMutex_ );
646
- thisPtr->sendNum_ -- ;
646
+ -- thisPtr->sendNum_ ;
647
647
}
648
648
649
649
if (thisPtr->writeBufferList_ .size () == 1 )
0 commit comments