emitter_           39 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc       emitter_(new EventEmitter),
emitter_           46 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc   emitter_->RaiseEvents_Locked(POLLOUT);
emitter_           79 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc EventEmitter* TtyNode::GetEventEmitter() { return emitter_.get(); }
emitter_          148 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc     emitter_->ClearEvents_Locked(POLLIN);
emitter_          167 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc   AUTO_LOCK(emitter_->GetLock())
emitter_          227 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc       emitter_->RaiseEvents_Locked(POLLIN);
emitter_          267 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc         AUTO_LOCK(emitter_->GetLock())
emitter_          268 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc         emitter_->RaiseEvents_Locked(POLLERR);
emitter_          269 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.cc         emitter_->ClearEvents_Locked(POLLERR);
emitter_           44 native_client_sdk/src/libraries/nacl_io/devfs/tty_node.h   ScopedEventEmitter emitter_;
emitter_           71 native_client_sdk/src/libraries/nacl_io/event_listener.cc       emitter_(emitter),
emitter_           90 native_client_sdk/src/libraries/nacl_io/event_listener.cc   emitter_->RegisterListener_Locked(this, events);
emitter_           91 native_client_sdk/src/libraries/nacl_io/event_listener.cc   while ((emitter_->GetEventStatus() & events) == 0) {
emitter_           95 native_client_sdk/src/libraries/nacl_io/event_listener.cc                                            emitter_->GetLock().mutex(),
emitter_           99 native_client_sdk/src/libraries/nacl_io/event_listener.cc                                       emitter_->GetLock().mutex());
emitter_          102 native_client_sdk/src/libraries/nacl_io/event_listener.cc     if (emitter_->GetEventStatus() & POLLERR)
emitter_          107 native_client_sdk/src/libraries/nacl_io/event_listener.cc       emitter_->UnregisterListener_Locked(this);
emitter_          112 native_client_sdk/src/libraries/nacl_io/event_listener.cc   emitter_->UnregisterListener_Locked(this);
emitter_          134 native_client_sdk/src/libraries/nacl_io/event_listener.h   EventEmitter* emitter_;
emitter_           29 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc         emitter_(emitter),
emitter_           39 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   ScopedTcpEventEmitter emitter_;
emitter_           50 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_           60 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     size_t tx_data_avail = emitter_->BytesInOutputFIFO();
emitter_           66 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     emitter_->ReadOut_Locked(data_, capped_len);
emitter_           84 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          110 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          111 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* stream = static_cast<TcpNode*>(emitter_->stream());
emitter_          121 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     size_t rx_space_avail = emitter_->SpaceInInputFIFO();
emitter_          144 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          145 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* stream = static_cast<TcpNode*>(emitter_->stream());
emitter_          156 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     emitter_->WriteIn_Locked(data_, length_error);
emitter_          172 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          173 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* node = static_cast<TcpNode*>(emitter_->stream());
emitter_          197 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          198 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* node = static_cast<TcpNode*>(emitter_->stream());
emitter_          208 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     emitter_->SetAcceptedSocket_Locked(new_socket_);
emitter_          213 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   ScopedTcpEventEmitter emitter_;
emitter_          227 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          228 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* node = static_cast<TcpNode*>(emitter_->stream());
emitter_          247 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          248 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     TcpNode* node = static_cast<TcpNode*>(emitter_->stream());
emitter_          263 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   ScopedTcpEventEmitter emitter_;
emitter_          268 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc       emitter_(new TcpEventEmitter(kDefaultFifoSize, kDefaultFifoSize)),
emitter_          270 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->AttachStream(this);
emitter_          275 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc       emitter_(new TcpEventEmitter(kDefaultFifoSize, kDefaultFifoSize)),
emitter_          277 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->AttachStream(this);
emitter_          281 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->DetachStream();
emitter_          310 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc EventEmitter* TcpNode::GetEventEmitter() { return emitter_.get(); }
emitter_          314 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->SetError_Locked();
emitter_          359 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   StreamFs::Work* work = new TCPAcceptWork(stream(), emitter_);
emitter_          364 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   StreamFs::Work* work = new TCPConnectWork(stream(), emitter_);
emitter_          369 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   StreamFs::Work* work = new TcpRecvWork(emitter_);
emitter_          380 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   if (0 == emitter_->BytesInOutputFIFO())
emitter_          383 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   StreamFs::Work* work = new TcpSendWork(emitter_, ScopedSocketNode(this));
emitter_          403 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   int s = emitter_->GetAcceptedSocket_Locked();
emitter_          410 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->ClearEvents_Locked(POLLIN);
emitter_          485 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          486 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc     emitter_->SetError_Locked();
emitter_          498 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->ConnectDone_Locked();
emitter_          525 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   emitter_->SetListening_Locked();
emitter_          534 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   assert(emitter_.get());
emitter_          535 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   *out_len = emitter_->ReadIn_Locked((char*)buf, len);
emitter_          548 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   assert(emitter_.get());
emitter_          549 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   if (emitter_->GetError_Locked())
emitter_          551 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.cc   *out_len = emitter_->WriteOut_Locked((char*)buf, len);
emitter_           69 native_client_sdk/src/libraries/nacl_io/socket/tcp_node.h   ScopedTcpEventEmitter emitter_;
emitter_           28 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc         emitter_(emitter),
emitter_           38 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   ScopedUdpEventEmitter emitter_;
emitter_           49 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_           55 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     packet_ = emitter_->ReadTXPacket_Locked();
emitter_           75 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          104 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          105 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     UdpNode* stream = static_cast<UdpNode*>(emitter_->stream());
emitter_          130 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     AUTO_LOCK(emitter_->GetLock());
emitter_          131 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc     UdpNode* stream = static_cast<UdpNode*>(emitter_->stream());
emitter_          139 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc       emitter_->WriteRXPacket_Locked(packet);
emitter_          155 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   emitter_->AttachStream(this);
emitter_          159 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   emitter_->DetachStream();
emitter_          163 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc UdpEventEmitter* UdpNode::GetEventEmitter() { return emitter_.get(); }
emitter_          182 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   UdpRecvWork* work = new UdpRecvWork(emitter_);
emitter_          193 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   UdpSendWork* work = new UdpSendWork(emitter_, ScopedSocketNode(this));
emitter_          251 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   Packet* packet = emitter_->ReadRXPacket_Locked();
emitter_          295 native_client_sdk/src/libraries/nacl_io/socket/udp_node.cc   emitter_->WriteTXPacket_Locked(packet);
emitter_           49 native_client_sdk/src/libraries/nacl_io/socket/udp_node.h   ScopedUdpEventEmitter emitter_;
emitter_           93 native_client_sdk/src/tests/nacl_io_test/event_test.cc     EventListenerLock listener(&emitter_);
emitter_           98 native_client_sdk/src/tests/nacl_io_test/event_test.cc     emitter_.ClearEvents_Locked(POLLIN);
emitter_          105 native_client_sdk/src/tests/nacl_io_test/event_test.cc   EventEmitter emitter_;
emitter_          117 native_client_sdk/src/tests/nacl_io_test/event_test.cc     AUTO_LOCK(emitter_.GetLock());
emitter_          121 native_client_sdk/src/tests/nacl_io_test/event_test.cc       pthread_cond_wait(&multi_cond_, emitter_.GetLock().mutex());
emitter_          125 native_client_sdk/src/tests/nacl_io_test/event_test.cc     emitter_.RaiseEvents_Locked(POLLIN);
emitter_          135 native_client_sdk/src/tests/nacl_io_test/event_test.cc     AUTO_LOCK(emitter_.GetLock());
emitter_          136 native_client_sdk/src/tests/nacl_io_test/event_test.cc     emitter_.RaiseEvents_Locked(POLLIN);
emitter_          144 native_client_sdk/src/tests/nacl_io_test/event_test.cc     AUTO_LOCK(emitter_.GetLock());
emitter_          145 native_client_sdk/src/tests/nacl_io_test/event_test.cc     emitter_.RaiseEvents_Locked(POLLIN);