eagerly free slice buffer after write

7 years ago · 60b376849a
parent 54e8f37e53
commit 60b376849a
1 changed files with 2 additions and 1 deletions
--- a/src/core/lib/iomgr/tcp_posix.cc
+++ b/src/core/lib/iomgr/tcp_posix.cc
@ -605,9 +605,10 @@ static bool tcp_flush(grpc_exec_ctx* exec_ctx, grpc_tcp* tcp,

    if (tcp->outgoing_slice_idx == tcp->outgoing_buffer->count) {
      *error = GRPC_ERROR_NONE;
+      grpc_slice_buffer_reset_and_unref_internal(exec_ctx, tcp->outgoing_buffer);
      return true;
    }
-  };
+  }
 }

 static void tcp_handle_write(grpc_exec_ctx* exec_ctx, void* arg /* grpc_tcp */,