Lines Matching refs:SocketReader
460 class SocketReader : public MessageLoopForIO::Watcher {
462 SocketReader(ProcessSingleton::LinuxWatcher* parent,
473 this, &SocketReader::OnTimerExpiry);
476 virtual ~SocketReader() {
483 // SocketReader only watches for accept (read) events.
488 // message and removing this SocketReader.
516 base::OneShotTimer<SocketReader> timer_;
518 DISALLOW_COPY_AND_ASSIGN(SocketReader);
536 SocketReader *reader);
557 // Removes and deletes the SocketReader.
558 void RemoveSocketReader(SocketReader* reader);
569 std::set<SocketReader*> readers_;
586 SocketReader* reader = new SocketReader(this,
603 SocketReader* reader) {
659 void ProcessSingleton::LinuxWatcher::RemoveSocketReader(SocketReader* reader) {
666 // ProcessSingleton::LinuxWatcher::SocketReader
669 void ProcessSingleton::LinuxWatcher::SocketReader::OnFileCanReadWithoutBlocking(
710 // Stop the expiration timer to prevent this SocketReader object from being
729 // LinuxWatcher::HandleMessage() is in charge of destroying this SocketReader
730 // object by invoking SocketReader::FinishWithACK().
733 void ProcessSingleton::LinuxWatcher::SocketReader::FinishWithACK(
