| Index: ppapi/shared_impl/private/udp_socket_private_impl.h
|
| diff --git a/ppapi/shared_impl/private/udp_socket_private_impl.h b/ppapi/shared_impl/private/udp_socket_private_impl.h
|
| index e8e3cb20e401045ff6a09b01ccc10d899beaed26..e48e11b2703005d461736b09a3836403aacd4458 100644
|
| --- a/ppapi/shared_impl/private/udp_socket_private_impl.h
|
| +++ b/ppapi/shared_impl/private/udp_socket_private_impl.h
|
| @@ -5,6 +5,7 @@
|
| #ifndef PPAPI_SHARED_IMPL_PRIVATE_UDP_SOCKET_PRIVATE_IMPL_H_
|
| #define PPAPI_SHARED_IMPL_PRIVATE_UDP_SOCKET_PRIVATE_IMPL_H_
|
|
|
| +#include <queue>
|
| #include <string>
|
|
|
| #include "base/compiler_specific.h"
|
| @@ -73,6 +74,20 @@ class PPAPI_SHARED_EXPORT UDPSocketPrivateImpl
|
| virtual void SendClose() = 0;
|
|
|
| protected:
|
| + struct RecvFromRequest {
|
| + RecvFromRequest(scoped_refptr<TrackedCallback> callback,
|
| + char* buffer,
|
| + int32_t num_bytes)
|
| + : callback(callback),
|
| + buffer(buffer),
|
| + num_bytes(num_bytes) {
|
| + }
|
| +
|
| + scoped_refptr<TrackedCallback> callback;
|
| + char* buffer;
|
| + int32_t num_bytes;
|
| + };
|
| +
|
| void Init(uint32 socket_id);
|
| void PostAbortIfNecessary(scoped_refptr<TrackedCallback>* callback);
|
|
|
| @@ -82,11 +97,8 @@ class PPAPI_SHARED_EXPORT UDPSocketPrivateImpl
|
| bool closed_;
|
|
|
| scoped_refptr<TrackedCallback> bind_callback_;
|
| - scoped_refptr<TrackedCallback> recvfrom_callback_;
|
| - scoped_refptr<TrackedCallback> sendto_callback_;
|
| -
|
| - char* read_buffer_;
|
| - int32_t bytes_to_read_;
|
| + std::queue<RecvFromRequest> recvfrom_requests_;
|
| + std::queue<scoped_refptr<TrackedCallback> > sendto_callbacks_;
|
|
|
| PP_NetAddress_Private recvfrom_addr_;
|
| PP_NetAddress_Private bound_addr_;
|
|
|