Lines Matching refs:it
31 for (ConnectedList::iterator it = active_.begin(); it != active_.end();
32 ++it) {
33 delete it->second;
35 for (ConnectedList::iterator it = cached_.begin(); it != cached_.end();
36 ++it) {
37 delete it->second;
44 for (ConnectedList::iterator it = cached_.begin(); it != cached_.end();
45 ++it) {
46 if (remote == it->first) {
47 it->second->SignalEvent.disconnect(this);
49 active_.push_front(*it);
50 cached_.erase(it);
67 for (ConnectedList::iterator it = active_.begin(); it != active_.end();
68 ++it) {
69 if (stream == it->second) {
70 LOG_F(LS_VERBOSE) << "(" << it->first << ")";
74 pool_->ReturnConnectedStream(it->second);
79 cached_.push_front(*it);
81 active_.erase(it);
94 for (ConnectedList::iterator it = cached_.begin(); it != cached_.end();
95 ++it) {
96 if (stream == it->second) {
97 LOG_F(LS_VERBOSE) << "(" << it->first << ")";
98 // We don't cache closed streams, so return it.
99 it->second->SignalEvent.disconnect(this);
101 pool_->ReturnConnectedStream(it->second);
102 cached_.erase(it);
203 // Until the socket is reused, monitor it to determine if it closes.
213 // we may get a writable notification for it, which we should ignore.
219 // If the peer sent data, we can't process it, so drop the connection.
220 // If the socket has closed, clean it up.
221 // In either case, we'll reconnect it the next time it is used.
243 for (StreamList::iterator it = recycle_bin_.begin();
244 it != recycle_bin_.end(); ++it) {
245 delete *it;
