Lines Matching refs:it
168 ChannelMap::iterator it = _openChannels.begin(); local
169 for (; it != _openChannels.end(); it++) {
170 if (it->second->GetSocket() == s) {
171 return it->second;
175 ChannelMap::iterator it = _openChannels.find(s); local
176 if (it != _openChannels.end()) {
177 return it->second;
210 ChannelMap::iterator it = _openChannels.begin(); local
212 for (; it != _openChannels.end(); it++) {
213 ATNetworkTool::CloseSocket(it->second->GetSocket());
214 delete it->second;
222 PortMap::iterator it = _openPorts.begin(); local
224 for (; it != _openPorts.end(); it++) {
225 if (it->second.size() > 0) {
226 ATNetworkTool::CloseSocket(it->second[0]->GetListeningSocket());
228 PortForwardRequestList::iterator it2 = it->second.begin();
229 for (; it2 != it->second.end(); it2++) {
279 PortMap::iterator it = _openPorts.find(port); local
280 if (it != _openPorts.end()) {
281 if (it->second.size() > 0) {
282 socket = it->second[0]->GetListeningSocket();
283 PortForwardRequestList::iterator it2 = it->second.begin();
285 for (; it2 != it->second.end(); it2++) {
421 PortMap::iterator it = _openPorts.find(port); local
422 if (it != _openPorts.end()) {
423 PortForwardRequestList::iterator it2 = it->second.begin();
425 for (; it2 != it->second.end(); it2++) {
497 PortMap::iterator it = _openPorts.begin(); local
499 for (; it != _openPorts.end(); it++) {
500 if (it->second.size() > 0) {
501 SOCKET serverSocket = it->second[0]->GetListeningSocket();
513 ChannelMap::iterator it = _openChannels.begin(); local
515 for (; it != _openChannels.end(); it++) {
516 if ((it->second->GetStatus() == Channel::OPEN) &&
517 (it->second->GetTxWindow() > 0)) {
518 SOCKET socket = it->second->GetSocket();
563 PortMap::iterator it = _openPorts.begin(); local
565 for (; it != _openPorts.end(); it++) {
566 if (it->second.size() > 0) {
567 SOCKET serverSocket = it->second[0]->GetListeningSocket();
570 PRINT("Connection requested on port %d\n", it->first);
571 _acceptConnection(serverSocket, it->first);
673 ChannelMap::iterator it = _openChannels.begin(); local
674 for (; it != _openChannels.end(); it++) {
675 if (it->second == cx) {
679 if (it != _openChannels.end()) {
680 _openChannels.erase(it);
705 PortMap::iterator it = _openPorts.find(p->GetPort()); local
706 if (it == _openPorts.end()) {
711 PortForwardRequestList::iterator it2 = it->second.begin();
712 for (; it2 != it->second.end(); it2++) {
723 it->second.erase(it2);
725 if (it->second.size() == 0) {
737 _openPorts.erase(it);
936 ChannelMap::iterator it = _openChannels.find(chOpenSuccMsg->RecipientChannel); local
937 if (it != _openChannels.end()) {
938 it->second->SetStatus(Channel::OPEN);
939 it->second->SetRecipientChannel(chOpenSuccMsg->SenderChannel);
940 it->second->AddBytesTxWindow(chOpenSuccMsg->InitialWindow);
986 ChannelMap::iterator it = _openChannels.find(channelWindowMessage->RecipientChannel); local
987 if (it != _openChannels.end()) {
988 it->second->AddBytesTxWindow(channelWindowMessage->BytesToAdd);
1158 PortMap::iterator it = _openPorts.find(tcpFwdCnclMsg->Port); local
1159 if (it == _openPorts.end()) {
1166 PortForwardRequestList::iterator it2 = it->second.begin();
1167 for (; it2 != it->second.end(); it2++) {
1293 ChannelMap::iterator it = _openChannels.find(chFailMsg->RecipientChannel); local
1294 if (it != _openChannels.end()) {
1295 clPFwdReq = _closeMChannel(it->second);
1296 _openChannels.erase(it);
1310 ChannelMap::iterator it = _openChannels.find(chClMsg->RecipientChannel); local
1311 if (it != _openChannels.end()) {
1312 Channel *c = it->second;
1330 _openChannels.erase(it);
1343 ChannelMap::iterator it = _openChannels.find(chDMsg->RecipientChannel); local
1344 if (it == _openChannels.end()) {
1348 if ((it->second->GetStatus() != Channel::OPEN) &&
1349 (it->second->GetStatus() != Channel::WAITING_CLOSE)) {
1353 if (it->second->GetRxWindow() < chDMsg->DataLength) {
1358 int count = _send(it->second->GetSocket(), (char *)chDMsg->Data,
1362 it->second->GetSocket());
1366 clPFwdReq = _closeMChannel(it->second);
1367 _openChannels.erase(it);
1373 _lme.ChannelWindowAdjust(it->second->GetRecipientChannel(), chDMsg->DataLength);
1457 for (PortMap::iterator it = _openPorts.begin(); it != _openPorts.end(); it++) { local
1458 for (PortForwardRequestList::iterator it2 = it->second.begin();
1459 it2 != it->second.end(); it2++) {
1550 std::list<std::string>::const_iterator it = _AMTDNSSuffixes.begin(); local
1551 for (; it != _AMTDNSSuffixes.end(); it++) {
1552 if (_compareDNSSuffix(*it, dnsSuffix)) {