| Index: native_client_sdk/src/libraries/nacl_io/event_emitter_tcp.cc
|
| diff --git a/native_client_sdk/src/libraries/nacl_io/event_emitter_tcp.cc b/native_client_sdk/src/libraries/nacl_io/event_emitter_tcp.cc
|
| index 24d7cdd4ee5821a50fc5a45de01ddef072ed6c78..f031949019d23e59a9bbadb37cc8cc5a3d925092 100644
|
| --- a/native_client_sdk/src/libraries/nacl_io/event_emitter_tcp.cc
|
| +++ b/native_client_sdk/src/libraries/nacl_io/event_emitter_tcp.cc
|
| @@ -16,7 +16,6 @@ namespace nacl_io {
|
| EventEmitterTCP::EventEmitterTCP(size_t rsize, size_t wsize)
|
| : in_fifo_(std::max<size_t>(65536, rsize)),
|
| out_fifo_(std::max<size_t>(65536, wsize)) {
|
| - UpdateStatus_Locked();
|
| }
|
|
|
| uint32_t EventEmitterTCP::ReadIn_Locked(char* data, uint32_t len) {
|
| @@ -47,7 +46,21 @@ uint32_t EventEmitterTCP::WriteOut_Locked(const char* data, uint32_t len) {
|
| return count;
|
| }
|
|
|
| +void EventEmitterTCP::ConnectDone() {
|
| + RaiseEvents_Locked(POLLOUT);
|
| + UpdateStatus_Locked();
|
| +}
|
|
|
| -} // namespace nacl_io
|
| +void EventEmitterTCP::SetAcceptedSocket_Locked(PP_Resource socket) {
|
| + accepted_socket_ = socket;
|
| + RaiseEvents_Locked(POLLIN);
|
| +}
|
|
|
| +PP_Resource EventEmitterTCP::GetAcceptedSocket_Locked() {
|
| + int rtn = accepted_socket_;
|
| + accepted_socket_ = 0;
|
| + ClearEvents_Locked(POLLIN);
|
| + return rtn;
|
| +}
|
|
|
| +} // namespace nacl_io
|
|
|