diff options
| author |  Yash Tibrewal <yashkt@google.com> | 2018-11-29 00:56:22 -0800 |
|---|---|---|
| committer | Yash Tibrewal <yashkt@google.com> | 2018-11-29 00:56:22 -0800 |
| commit | fe4ef31ac28f702755c67cb0d79140bc9cbaa552 (patch) | |
| tree | 9fbca4aa4085ad103ac1f7a7c86e2f5781b14836 /src/core/lib | |
| parent | e57f8aebcb343c36662da042d441a0dfceddbf4c (diff) | |
Do not add the TCP buffer length.
Diffstat (limited to 'src/core/lib')
| -rw-r--r-- | src/core/lib/iomgr/buffer_list.cc | 3 | ||||
| -rw-r--r-- | src/core/lib/iomgr/buffer_list.h | 2 | ||||
| -rw-r--r-- | src/core/lib/iomgr/tcp_posix.cc | 2 |
3 files changed, 3 insertions, 4 deletions
diff --git a/src/core/lib/iomgr/buffer_list.cc b/src/core/lib/iomgr/buffer_list.cc index b9e38f7dd2..e20dab15b1 100644 --- a/src/core/lib/iomgr/buffer_list.cc +++ b/src/core/lib/iomgr/buffer_list.cc @@ -30,10 +30,9 @@ namespace grpc_core { void TracedBuffer::AddNewEntry(TracedBuffer** head, uint32_t seq_no, - uint32_t length, void* arg) { + void* arg) { GPR_DEBUG_ASSERT(head != nullptr); TracedBuffer* new_elem = New<TracedBuffer>(seq_no, arg); - new_elem->ts_.length = length; /* Store the current time as the sendmsg time. */ new_elem->ts_.sendmsg_time = gpr_now(GPR_CLOCK_REALTIME); if (*head == nullptr) { diff --git a/src/core/lib/iomgr/buffer_list.h b/src/core/lib/iomgr/buffer_list.h index 9e2c1dcb24..9f62d988cc 100644 --- a/src/core/lib/iomgr/buffer_list.h +++ b/src/core/lib/iomgr/buffer_list.h @@ -58,7 +58,7 @@ class TracedBuffer { /** Add a new entry in the TracedBuffer list pointed to by head. Also saves * sendmsg_time with the current timestamp. */ static void AddNewEntry(grpc_core::TracedBuffer** head, uint32_t seq_no, - uint32_t length, void* arg); + void* arg); /** Processes a received timestamp based on sock_extended_err and * scm_timestamping structures. It will invoke the timestamps callback if the diff --git a/src/core/lib/iomgr/tcp_posix.cc b/src/core/lib/iomgr/tcp_posix.cc index 8f3403473e..ee339cdfc4 100644 --- a/src/core/lib/iomgr/tcp_posix.cc +++ b/src/core/lib/iomgr/tcp_posix.cc @@ -635,7 +635,7 @@ static bool tcp_write_with_timestamps(grpc_tcp* tcp, struct msghdr* msg, gpr_mu_lock(&tcp->tb_mu); grpc_core::TracedBuffer::AddNewEntry( &tcp->tb_head, static_cast<uint32_t>(tcp->bytes_counter + length), - static_cast<uint32_t>(length), tcp->outgoing_buffer_arg); + tcp->outgoing_buffer_arg); gpr_mu_unlock(&tcp->tb_mu); tcp->outgoing_buffer_arg = nullptr; } |