Refactor net::NetLog to provide implementation of observer pattern, not just the interface.

net/base/capturing_net_log.cc

 // Copyright (c) 2012 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/base/capturing_net_log.h"
 
 #include "base/json/json_writer.h"
 #include "base/logging.h"
 #include "base/values.h"
 
 namespace net {
 
-CapturingNetLog::CapturedEntry::CapturedEntry(
-    EventType type,
+CapturingNetLogObserver::CapturedEntry::CapturedEntry(
+    NetLog::EventType type,
     const base::TimeTicks& time,
-    Source source,
-    EventPhase phase,
+    NetLog::Source source,
+    NetLog::EventPhase phase,
     scoped_ptr<DictionaryValue> params)
     : type(type),
       time(time),
       source(source),
       phase(phase),
       params(params.Pass()) {
 }
 
-CapturingNetLog::CapturedEntry::CapturedEntry(const CapturedEntry& entry) {
+CapturingNetLogObserver::CapturedEntry::CapturedEntry(
+    const CapturedEntry& entry) {
   *this = entry;
 }
 
-CapturingNetLog::CapturedEntry::~CapturedEntry() {}
+CapturingNetLogObserver::CapturedEntry::~CapturedEntry() {}
 
-CapturingNetLog::CapturedEntry&
-CapturingNetLog::CapturedEntry::operator=(const CapturedEntry& entry) {
+CapturingNetLogObserver::CapturedEntry&
+CapturingNetLogObserver::CapturedEntry::operator=(const CapturedEntry& entry) {
   type = entry.type;
   time = entry.time;
   source = entry.source;
   phase = entry.phase;
   params.reset(entry.params ? entry.params->DeepCopy() : NULL);
   return *this;
 }
 
-bool CapturingNetLog::CapturedEntry::GetStringValue(
+bool CapturingNetLogObserver::CapturedEntry::GetStringValue(
     const std::string& name,
     std::string* value) const {
   if (!params)
     return false;
   return params->GetString(name, value);
 }
 
-bool CapturingNetLog::CapturedEntry::GetIntegerValue(
+bool CapturingNetLogObserver::CapturedEntry::GetIntegerValue(
     const std::string& name,
     int* value) const {
   if (!params)
     return false;
   return params->GetInteger(name, value);
 }
 
-bool CapturingNetLog::CapturedEntry::GetNetErrorCode(int* value) const {
+bool CapturingNetLogObserver::CapturedEntry::GetNetErrorCode(int* value) const {
   return GetIntegerValue("net_error", value);
 }
 
-std::string CapturingNetLog::CapturedEntry::GetParamsJson() const {
+std::string CapturingNetLogObserver::CapturedEntry::GetParamsJson() const {
   if (!params)
     return std::string();
   std::string json;
   base::JSONWriter::Write(params.get(), &json);
   return json;
 }
 
-CapturingNetLog::CapturingNetLog()
-    : last_id_(0),
-      log_level_(LOG_ALL_BUT_BYTES) {
-}
+CapturingNetLogObserver::CapturingNetLogObserver() {}
 
-CapturingNetLog::~CapturingNetLog() {}
+CapturingNetLogObserver::~CapturingNetLogObserver() {}
 
-void CapturingNetLog::GetEntries(CapturedEntryList* entry_list) const {
+void CapturingNetLogObserver::GetEntries(CapturedEntryList* entry_list) const {
   base::AutoLock lock(lock_);
   *entry_list = captured_entries_;
 }
 
-void CapturingNetLog::GetEntriesForSource(NetLog::Source source,
+void CapturingNetLogObserver::GetEntriesForSource(NetLog::Source source,
                                           CapturedEntryList* entry_list) const {
   base::AutoLock lock(lock_);
   entry_list->clear();
   for (CapturedEntryList::const_iterator entry = captured_entries_.begin();
        entry != captured_entries_.end(); ++entry) {
     if (entry->source.id == source.id)
       entry_list->push_back(*entry);
   }
 }
 
-size_t CapturingNetLog::GetSize() const {
+size_t CapturingNetLogObserver::GetSize() const {
   base::AutoLock lock(lock_);
   return captured_entries_.size();
 }
 
-void CapturingNetLog::Clear() {
+void CapturingNetLogObserver::Clear() {
   base::AutoLock lock(lock_);
   captured_entries_.clear();
 }
 
-void CapturingNetLog::SetLogLevel(NetLog::LogLevel log_level) {
-  base::AutoLock lock(lock_);
-  log_level_ = log_level;
-}
-
-void CapturingNetLog::OnAddEntry(const net::NetLog::Entry& entry) {
+void CapturingNetLogObserver::OnAddEntry(const net::NetLog::Entry& entry) {
   // Only BoundNetLogs without a NetLog should have an invalid source.
   CHECK(entry.source().IsValid());
 
   // Using Dictionaries instead of Values makes checking values a little
   // simpler.
   DictionaryValue* param_dict = NULL;
   Value* param_value = entry.ParametersToValue();
   if (param_value && !param_value->GetAsDictionary(&param_dict))
     delete param_value;
 
   // Only need to acquire the lock when accessing class variables.
   base::AutoLock lock(lock_);
   captured_entries_.push_back(
       CapturedEntry(entry.type(),
                     base::TimeTicks::Now(),
                     entry.source(),
                     entry.phase(),
                     scoped_ptr<DictionaryValue>(param_dict)));
 }
 
-uint32 CapturingNetLog::NextID() {
-  return base::subtle::NoBarrier_AtomicIncrement(&last_id_, 1);
+CapturingNetLog::CapturingNetLog() {
+  AddThreadSafeObserver(&capturing_net_log_observer_, LOG_ALL_BUT_BYTES);
 }
 
-NetLog::LogLevel CapturingNetLog::GetLogLevel() const {
-  base::AutoLock lock(lock_);
-  return log_level_;
+CapturingNetLog::~CapturingNetLog() {
+  RemoveThreadSafeObserver(&capturing_net_log_observer_);
 }
 
-void CapturingNetLog::AddThreadSafeObserver(
-    NetLog::ThreadSafeObserver* observer,
-    NetLog::LogLevel log_level) {
-  NOTIMPLEMENTED() << "Not currently used by net unit tests.";
+void CapturingNetLog::SetLogLevel(NetLog::LogLevel log_level) {
+  SetObserverLogLevel(&capturing_net_log_observer_, log_level);
 }
 
-void CapturingNetLog::SetObserverLogLevel(ThreadSafeObserver* observer,
-                                          LogLevel log_level) {
-  NOTIMPLEMENTED() << "Not currently used by net unit tests.";
+void CapturingNetLog::GetEntries(
+    CapturingNetLogObserver::CapturedEntryList* entry_list) const {
+  capturing_net_log_observer_.GetEntries(entry_list);
 }
 
-void CapturingNetLog::RemoveThreadSafeObserver(
-    NetLog::ThreadSafeObserver* observer) {
-  NOTIMPLEMENTED() << "Not currently used by net unit tests.";
+size_t CapturingNetLog::GetSize() const {
+  return capturing_net_log_observer_.GetSize();
 }
 
 CapturingBoundNetLog::CapturingBoundNetLog()
-    : net_log_(BoundNetLog::Make(&capturing_net_log_,
-                                 net::NetLog::SOURCE_NONE)) {
+    : bound_net_log_(BoundNetLog::Make(&net_log_,
+                                       net::NetLog::SOURCE_NONE)) {
 }
 
 CapturingBoundNetLog::~CapturingBoundNetLog() {}
 
 void CapturingBoundNetLog::GetEntries(
-    CapturingNetLog::CapturedEntryList* entry_list) const {
-  capturing_net_log_.GetEntries(entry_list);
+    CapturingNetLogObserver::CapturedEntryList* entry_list) const {
+  net_log_.observer().GetEntries(entry_list);
 }
 
 void CapturingBoundNetLog::GetEntriesForSource(
     NetLog::Source source,
-    CapturingNetLog::CapturedEntryList* entry_list) const {
-  capturing_net_log_.GetEntriesForSource(source, entry_list);
+    CapturingNetLogObserver::CapturedEntryList* entry_list) const {
+  net_log_.observer().GetEntriesForSource(source, entry_list);
 }
 
 size_t CapturingBoundNetLog::GetSize() const {
-  return capturing_net_log_.GetSize();
+  return net_log_.observer().GetSize();
 }
 
 void CapturingBoundNetLog::Clear() {
-  capturing_net_log_.Clear();
+  net_log_.observer().Clear();
 }
 
 void CapturingBoundNetLog::SetLogLevel(NetLog::LogLevel log_level) {
-  capturing_net_log_.SetLogLevel(log_level);
+  net_log_.SetLogLevel(log_level);
 }
 
 }  // namespace net