OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "ppapi/proxy/ppb_flash_tcp_socket_proxy.h" | 5 #include "ppapi/proxy/ppb_flash_tcp_socket_proxy.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <cstring> | 8 #include <cstring> |
9 #include <map> | 9 #include <map> |
10 | 10 |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
42 virtual ~AbortCallbackTask() {} | 42 virtual ~AbortCallbackTask() {} |
43 virtual void Run() { | 43 virtual void Run() { |
44 if (callback_.func) | 44 if (callback_.func) |
45 PP_RunCompletionCallback(&callback_, PP_ERROR_ABORTED); | 45 PP_RunCompletionCallback(&callback_, PP_ERROR_ABORTED); |
46 } | 46 } |
47 | 47 |
48 private: | 48 private: |
49 PP_CompletionCallback callback_; | 49 PP_CompletionCallback callback_; |
50 }; | 50 }; |
51 | 51 |
52 InterfaceProxy* CreateFlashTCPSocketProxy(Dispatcher* dispatcher, | 52 InterfaceProxy* CreateFlashTCPSocketProxy(Dispatcher* dispatcher) { |
53 const void* target_interface) { | 53 return new PPB_Flash_TCPSocket_Proxy(dispatcher); |
54 return new PPB_Flash_TCPSocket_Proxy(dispatcher, target_interface); | |
55 } | 54 } |
56 | 55 |
57 } // namespace | 56 } // namespace |
58 | 57 |
59 class FlashTCPSocket : public PPB_Flash_TCPSocket_API, | 58 class FlashTCPSocket : public PPB_Flash_TCPSocket_API, |
60 public Resource { | 59 public Resource { |
61 public: | 60 public: |
62 FlashTCPSocket(const HostResource& resource, uint32 socket_id); | 61 FlashTCPSocket(const HostResource& resource, uint32 socket_id); |
63 virtual ~FlashTCPSocket(); | 62 virtual ~FlashTCPSocket(); |
64 | 63 |
(...skipping 317 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
382 PP_CompletionCallback* callback) { | 381 PP_CompletionCallback* callback) { |
383 DCHECK(callback); | 382 DCHECK(callback); |
384 | 383 |
385 if (callback->func) { | 384 if (callback->func) { |
386 MessageLoop::current()->PostTask(FROM_HERE, | 385 MessageLoop::current()->PostTask(FROM_HERE, |
387 new AbortCallbackTask(*callback)); | 386 new AbortCallbackTask(*callback)); |
388 *callback = PP_BlockUntilComplete(); | 387 *callback = PP_BlockUntilComplete(); |
389 } | 388 } |
390 } | 389 } |
391 | 390 |
392 PPB_Flash_TCPSocket_Proxy::PPB_Flash_TCPSocket_Proxy( | 391 PPB_Flash_TCPSocket_Proxy::PPB_Flash_TCPSocket_Proxy(Dispatcher* dispatcher) |
393 Dispatcher* dispatcher, | 392 : InterfaceProxy(dispatcher) { |
394 const void* target_interface) | |
395 : InterfaceProxy(dispatcher, target_interface) { | |
396 } | 393 } |
397 | 394 |
398 PPB_Flash_TCPSocket_Proxy::~PPB_Flash_TCPSocket_Proxy() { | 395 PPB_Flash_TCPSocket_Proxy::~PPB_Flash_TCPSocket_Proxy() { |
399 } | 396 } |
400 | 397 |
401 // static | 398 // static |
402 const InterfaceProxy::Info* PPB_Flash_TCPSocket_Proxy::GetInfo() { | 399 const InterfaceProxy::Info* PPB_Flash_TCPSocket_Proxy::GetInfo() { |
403 static const Info info = { | 400 static const Info info = { |
404 thunk::GetPPB_Flash_TCPSocket_Thunk(), | 401 thunk::GetPPB_Flash_TCPSocket_Thunk(), |
405 PPB_FLASH_TCPSOCKET_INTERFACE, | 402 PPB_FLASH_TCPSOCKET_INTERFACE, |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
493 return; | 490 return; |
494 } | 491 } |
495 IDToSocketMap::iterator iter = g_id_to_socket->find(socket_id); | 492 IDToSocketMap::iterator iter = g_id_to_socket->find(socket_id); |
496 if (iter == g_id_to_socket->end()) | 493 if (iter == g_id_to_socket->end()) |
497 return; | 494 return; |
498 iter->second->OnWriteCompleted(succeeded, bytes_written); | 495 iter->second->OnWriteCompleted(succeeded, bytes_written); |
499 } | 496 } |
500 | 497 |
501 } // namespace proxy | 498 } // namespace proxy |
502 } // namespace ppapi | 499 } // namespace ppapi |
OLD | NEW |