Instrument SourceStream using MemoryDumpProvider

net/filter/sdch_source_stream.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/filter/sdch_source_stream.h"
 
 #include "base/auto_reset.h"
 #include "base/bind.h"
 #include "base/logging.h"
 #include "base/numerics/safe_conversions.h"
+#include "base/strings/stringprintf.h"
+#include "base/trace_event/memory_allocator_dump.h"
+#include "base/trace_event/process_memory_dump.h"
 #include "base/values.h"
 #include "net/base/io_buffer.h"
 #include "net/log/net_log_capture_mode.h"
 #include "sdch/open-vcdiff/src/google/vcdecoder.h"
 
 namespace net {
 
 namespace {
 
 const size_t kServerIdLength = 9;
@@ skipping 26 matching lines @@
                                decoding_not_finished);
 }
 
 std::string SdchSourceStream::GetTypeAsString() const {
   if (type() == TYPE_SDCH)
     return kSdch;
   DCHECK_EQ(TYPE_SDCH_POSSIBLE, type());
   return kSdchPossible;
 }
 
+void SdchSourceStream::DumpMemoryStatsImpl(
+    base::trace_event::ProcessMemoryDump* pmd,
+    const std::string& parent_dump_absolute_name) const {
+  // Log pointer address to avoid duplication though in practice there is
+  // often only one SdchSourceStream per URLRequest.
+  base::trace_event::MemoryAllocatorDump* sdch_dump =
+      pmd->CreateAllocatorDump(base::StringPrintf(
+          "%s/sdch_%p", parent_dump_absolute_name.c_str(), this));
+  sdch_dump->AddScalar(base::trace_event::MemoryAllocatorDump::kNameSize,
+                       base::trace_event::MemoryAllocatorDump::kUnitsBytes,
+                       buffered_output_.size());
+}
+
 int SdchSourceStream::FilterData(IOBuffer* output_buffer,
                                  int output_buffer_size,
                                  IOBuffer* input_buffer,
                                  int input_buffer_size,
                                  int* consumed_bytes,
                                  bool /*upstream_end_reached*/) {
   DCHECK_LE(0, input_buffer_size);
   int input_data_size = input_buffer_size;
   char* input_data = input_buffer->data();
   int bytes_out = 0;
@@ skipping 119 matching lines @@
       input_state_ = STATE_PASS_THROUGH;
       break;
     case Delegate::REPLACE_OUTPUT:
       input_state_ = STATE_OUTPUT_REPLACE;
       break;
   }
   return true;
 }
 
 }  // namespace net