86 	ConnectionQueueItem* cqi = new ConnectionQueueItem(aUser, download, hubHint);  in getCQI()  local
89 		downloads.push_back(cqi);  in getCQI()
92 		uploads.push_back(cqi);  in getCQI()
95 	fire(ConnectionManagerListener::Added(), cqi);  in getCQI()
96 	return cqi;  in getCQI()
99 void ConnectionManager::putCQI(ConnectionQueueItem* cqi) {  in putCQI()  argument
100 	fire(ConnectionManagerListener::Removed(), cqi);  in putCQI()
101 	if(cqi->getDownload()) {  in putCQI()
102 		dcassert(find(downloads.begin(), downloads.end(), cqi) != downloads.end());  in putCQI()
103 		downloads.erase(remove(downloads.begin(), downloads.end(), cqi), downloads.end());  in putCQI()
105 		dcassert(find(uploads.begin(), uploads.end(), cqi) != uploads.end());  in putCQI()
106 		uploads.erase(remove(uploads.begin(), uploads.end(), cqi), uploads.end());  in putCQI()
108 	delete cqi;  in putCQI()
141 			ConnectionQueueItem* cqi = *i;  in on()  local
143 			if(cqi->getState() != ConnectionQueueItem::ACTIVE) {  in on()
144 				if(!cqi->getUser()->isOnline()) {  in on()
146 					removed.push_back(cqi);  in on()
150 				if(cqi->getUser()->isSet(User::PASSIVE) && !ClientManager::getInstance()->isActive()) {  in on()
151 					passiveUsers.push_back(cqi->getUser());  in on()
152 					removed.push_back(cqi);  in on()
156 …		if(cqi->getLastAttempt() == 0 || (((cqi->getLastAttempt() + 60*1000) < aTick) && !attemptDone)) {  in on()
157 					cqi->setLastAttempt(aTick);  in on()
159 					QueueItem::Priority prio = QueueManager::getInstance()->hasDownload(cqi->getUser());  in on()
162 						removed.push_back(cqi);  in on()
168 					if(cqi->getState() == ConnectionQueueItem::WAITING) {  in on()
170 							cqi->setState(ConnectionQueueItem::CONNECTING);  in on()
171 							ClientManager::getInstance()->connect(cqi->getUser(), cqi->getToken(), cqi->getHubHint());  in on()
172 							fire(ConnectionManagerListener::StatusChanged(), cqi);  in on()
175 							cqi->setState(ConnectionQueueItem::NO_DOWNLOAD_SLOTS);  in on()
176 							fire(ConnectionManagerListener::Failed(), cqi, _("All download slots taken"));  in on()
178 					} else if(cqi->getState() == ConnectionQueueItem::NO_DOWNLOAD_SLOTS && startDown) {  in on()
179 						cqi->setState(ConnectionQueueItem::WAITING);  in on()
181 …} else if(((cqi->getLastAttempt() + 50*1000) < aTick) && (cqi->getState() == ConnectionQueueItem::…  in on()
182 					fire(ConnectionManagerListener::Failed(), cqi, _("Connection timeout"));  in on()
183 					cqi->setState(ConnectionQueueItem::WAITING);  in on()
457 			ConnectionQueueItem* cqi = *i;  in on()  local
458 …if((cqi->getState() == ConnectionQueueItem::CONNECTING || cqi->getState() == ConnectionQueueItem::…  in on()
459 				aSource->setUser(cqi->getUser());  in on()
557 			ConnectionQueueItem* cqi = *i;  in addDownloadConnection()  local
558 …if(cqi->getState() == ConnectionQueueItem::WAITING || cqi->getState() == ConnectionQueueItem::CONN…  in addDownloadConnection()
559 				cqi->setState(ConnectionQueueItem::ACTIVE);  in addDownloadConnection()
562 				fire(ConnectionManagerListener::Connected(), cqi);  in addDownloadConnection()
586 			ConnectionQueueItem* cqi = getCQI(uc->getUser(), false, Util::emptyString);  in addUploadConnection()  local
588 			cqi->setState(ConnectionQueueItem::ACTIVE);  in addUploadConnection()
591 			fire(ConnectionManagerListener::Connected(), cqi);  in addUploadConnection()
698 			ConnectionQueueItem* cqi = *i;  in on()  local
699 			cqi->setState(ConnectionQueueItem::WAITING);  in on()
700 			cqi->setLastAttempt(GET_TICK());  in on()
701 			fire(ConnectionManagerListener::Failed(), cqi, aError);  in on()
705 			ConnectionQueueItem* cqi = *i;  in on()  local
706 			putCQI(cqi);  in on()