Debug OutstandingPackets
diff --git a/heron/common/src/cpp/network/connection.cpp b/heron/common/src/cpp/network/connection.cpp
index c03ea8d..71c4d3b 100644
--- a/heron/common/src/cpp/network/connection.cpp
+++ b/heron/common/src/cpp/network/connection.cpp
@@ -83,6 +83,8 @@
mOutstandingPackets.push_back(std::make_pair(packet, std::move(cb)));
mNumOutstandingPackets++;
mNumOutstandingBytes += packet->GetTotalPacketSize();
+ LOG(INFO) << "Pushing Outstanding packets: " << mOutstandingPackets.size() << " total bytes: "
+ << mNumOutstandingBytes;
if (mOnConnectionBufferChange) {
mOnConnectionBufferChange(this);
@@ -162,6 +164,8 @@
mSentPackets.push_back(pr);
mOutstandingPackets.pop_front();
mNumOutstandingPackets--;
+ LOG(INFO) << "Poping Outstanding packets: " << mOutstandingPackets.size()
+ << " total bytes: " << mNumOutstandingBytes;
} else {
pr.first->position_ += mIOVector[i].iov_len;
}
@@ -227,6 +231,7 @@
}
void Connection::handleDataWritten() {
+ LOG(INFO) << "Freeing SentPackets: " << mSentPackets.size();
while (!mSentPackets.empty()) {
auto pr = mSentPackets.front();
if (pr.second) {
