Lines Matching refs:remote
42 const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
43 LOG_F(LS_VERBOSE) << "(" << remote << ")"; in RequestConnectedStream()
46 if (remote == it->first) { in RequestConnectedStream()
57 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
59 active_.push_front(ConnectedStream(remote, stream)); in RequestConnectedStream()
120 NewSocketPool::RequestConnectedStream(const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
122 factory_->CreateAsyncSocket(remote.family(), SOCK_STREAM); in RequestConnectedStream()
128 if ((socket->Connect(remote) != 0) && !socket->IsBlocking()) { in RequestConnectedStream()
158 ReuseSocketPool::RequestConnectedStream(const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
163 int family = remote.family(); in RequestConnectedStream()
165 if (remote.IsUnresolvedIP()) { in RequestConnectedStream()
177 if ((stream_->GetState() == SS_OPEN) && (remote == remote_)) { in RequestConnectedStream()
180 remote_ = remote; in RequestConnectedStream()
250 const SocketAddress& remote, int* err) { in RequestConnectedStream() argument
251 if (StreamInterface* stream = pool_->RequestConnectedStream(remote, err)) { in RequestConnectedStream()
259 << " to " << remote; in RequestConnectedStream()