Set up the infrastructure for Extension event metrics.

extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.cc

 // Copyright 2014 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 "extensions/browser/api/sockets_tcp/tcp_socket_event_dispatcher.h"
 
 #include "base/lazy_instance.h"
 #include "extensions/browser/api/socket/tcp_socket.h"
 #include "extensions/browser/event_router.h"
 #include "extensions/browser/extension_system.h"
@@ skipping 113 matching lines @@
     bytes_read = net::ERR_CONNECTION_CLOSED;
   }
 
   if (bytes_read > 0) {
     // Dispatch "onReceive" event.
     sockets_tcp::ReceiveInfo receive_info;
     receive_info.socket_id = params.socket_id;
     receive_info.data.assign(io_buffer->data(), io_buffer->data() + bytes_read);
     scoped_ptr<base::ListValue> args =
         sockets_tcp::OnReceive::Create(receive_info);
-    scoped_ptr<Event> event(
-        new Event(sockets_tcp::OnReceive::kEventName, args.Pass()));
+    scoped_ptr<Event> event(new Event(
+        events::UNKNOWN, sockets_tcp::OnReceive::kEventName, args.Pass()));
     PostEvent(params, event.Pass());
 
     // Post a task to delay the read until the socket is available, as
     // calling StartReceive at this point would error with ERR_IO_PENDING.
     BrowserThread::PostTask(
         params.thread_id,
         FROM_HERE,
         base::Bind(&TCPSocketEventDispatcher::StartRead, params));
   } else if (bytes_read == net::ERR_IO_PENDING) {
     // This happens when resuming a socket which already had an
     // active "read" callback.
   } else {
     // Dispatch "onReceiveError" event but don't start another read to avoid
     // potential infinite reads if we have a persistent network error.
     sockets_tcp::ReceiveErrorInfo receive_error_info;
     receive_error_info.socket_id = params.socket_id;
     receive_error_info.result_code = bytes_read;
     scoped_ptr<base::ListValue> args =
         sockets_tcp::OnReceiveError::Create(receive_error_info);
-    scoped_ptr<Event> event(
-        new Event(sockets_tcp::OnReceiveError::kEventName, args.Pass()));
+    scoped_ptr<Event> event(new Event(
+        events::UNKNOWN, sockets_tcp::OnReceiveError::kEventName, args.Pass()));
     PostEvent(params, event.Pass());
 
     // Since we got an error, the socket is now "paused" until the application
     // "resumes" it.
     ResumableTCPSocket* socket =
         params.sockets->Get(params.extension_id, params.socket_id);
     if (socket) {
       socket->set_paused(true);
     }
   }
@@ skipping 23 matching lines @@
   if (!extensions::ExtensionsBrowserClient::Get()->IsValidContext(context))
     return;
 
   EventRouter* event_router = EventRouter::Get(context);
   if (event_router)
     event_router->DispatchEventToExtension(extension_id, event.Pass());
 }
 
 }  // namespace core_api
 }  // namespace extensions