PPAPI: Make blocking completion callbacks work.

ppapi/shared_impl/private/ppb_tcp_server_socket_shared.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 "ppapi/shared_impl/private/ppb_tcp_server_socket_shared.h"
 
 #include <cstddef>
 
 #include "base/logging.h"
 #include "ppapi/c/pp_errors.h"
@@ skipping 16 matching lines @@
 }
 
 PPB_TCPServerSocket_Shared::~PPB_TCPServerSocket_Shared() {
 }
 
 thunk::PPB_TCPServerSocket_Private_API*
 PPB_TCPServerSocket_Shared::AsPPB_TCPServerSocket_Private_API() {
   return this;
 }
 
-int32_t PPB_TCPServerSocket_Shared::Listen(const PP_NetAddress_Private* addr,
-                                           int32_t backlog,
-                                           PP_CompletionCallback callback) {
+int32_t PPB_TCPServerSocket_Shared::Listen(
+    const PP_NetAddress_Private* addr,
+    int32_t backlog,
+    scoped_refptr<TrackedCallback> callback) {
   if (!addr)
     return PP_ERROR_BADARGUMENT;
-  if (!callback.func)
-    return PP_ERROR_BLOCKS_MAIN_THREAD;
   if (state_ != BEFORE_LISTENING)
     return PP_ERROR_FAILED;
   if (TrackedCallback::IsPending(listen_callback_))
     return PP_ERROR_INPROGRESS;  // Can only have one pending request.
 
-  listen_callback_ = new TrackedCallback(this, callback);
+  listen_callback_ = callback;
   // Send the request, the browser will call us back via ListenACK
   SendListen(*addr, backlog);
   return PP_OK_COMPLETIONPENDING;
 }
 
-int32_t PPB_TCPServerSocket_Shared::Accept(PP_Resource* tcp_socket,
-                                           PP_CompletionCallback callback) {
+int32_t PPB_TCPServerSocket_Shared::Accept(
+    PP_Resource* tcp_socket,
+    scoped_refptr<TrackedCallback> callback) {
   if (!tcp_socket)
     return PP_ERROR_BADARGUMENT;
-  if (!callback.func)
-    return PP_ERROR_BLOCKS_MAIN_THREAD;
 
   if (state_ != LISTENING)
     return PP_ERROR_FAILED;
   if (TrackedCallback::IsPending(accept_callback_))
     return PP_ERROR_INPROGRESS;
 
   tcp_socket_buffer_ = tcp_socket;
-  accept_callback_ = new TrackedCallback(this, callback);
+  accept_callback_ = callback;
 
   SendAccept();
   return PP_OK_COMPLETIONPENDING;
 }
 
 void PPB_TCPServerSocket_Shared::StopListening() {
   if (state_ == CLOSED)
     return;
 
   state_ = CLOSED;
@@ skipping 18 matching lines @@
 
   if (status == PP_OK) {
     socket_id_ = socket_id;
     state_ = LISTENING;
   }
 
   TrackedCallback::ClearAndRun(&listen_callback_, status);
 }
 
 }  // namespace ppapi