Lines Matching refs:cqi
82 ConnectionQueueItem* cqi = new ConnectionQueueItem(aUser, download); in getCQI() local
85 downloads.push_back(cqi); in getCQI()
88 uploads.push_back(cqi); in getCQI()
91 fire(ConnectionManagerListener::Added(), cqi); in getCQI()
92 return cqi; in getCQI()
95 void ConnectionManager::putCQI(ConnectionQueueItem* cqi) { in putCQI() argument
96 fire(ConnectionManagerListener::Removed(), cqi); in putCQI()
97 if(cqi->getDownload()) { in putCQI()
98 dcassert(find(downloads.begin(), downloads.end(), cqi) != downloads.end()); in putCQI()
99 downloads.erase(remove(downloads.begin(), downloads.end(), cqi), downloads.end()); in putCQI()
101 dcassert(find(uploads.begin(), uploads.end(), cqi) != uploads.end()); in putCQI()
102 uploads.erase(remove(uploads.begin(), uploads.end(), cqi), uploads.end()); in putCQI()
104 delete cqi; in putCQI()
137 ConnectionQueueItem* cqi = *i; in on() local
139 if(cqi->getState() != ConnectionQueueItem::ACTIVE) { in on()
140 if(!cqi->getUser().user->isOnline()) { in on()
142 removed.push_back(cqi); in on()
146 … if(cqi->getUser().user->isSet(User::PASSIVE) && !ClientManager::getInstance()->isActive()) { in on()
147 passiveUsers.push_back(cqi->getUser()); in on()
148 removed.push_back(cqi); in on()
152 if(cqi->getErrors() == -1 && cqi->getLastAttempt() != 0) { in on()
157 if(cqi->getLastAttempt() == 0 || (!attemptDone && in on()
158 cqi->getLastAttempt() + 60 * 1000 * max(1, cqi->getErrors()) < aTick)) in on()
160 cqi->setLastAttempt(aTick); in on()
162 … QueueItem::Priority prio = QueueManager::getInstance()->hasDownload(cqi->getUser()); in on()
165 removed.push_back(cqi); in on()
171 if(cqi->getState() == ConnectionQueueItem::WAITING) { in on()
173 cqi->setState(ConnectionQueueItem::CONNECTING); in on()
174 ClientManager::getInstance()->connect(cqi->getUser(), cqi->getToken()); in on()
175 fire(ConnectionManagerListener::StatusChanged(), cqi); in on()
178 cqi->setState(ConnectionQueueItem::NO_DOWNLOAD_SLOTS); in on()
179 … fire(ConnectionManagerListener::Failed(), cqi, _("All download slots taken")); in on()
181 … } else if(cqi->getState() == ConnectionQueueItem::NO_DOWNLOAD_SLOTS && startDown) { in on()
182 cqi->setState(ConnectionQueueItem::WAITING); in on()
184 …} else if(cqi->getState() == ConnectionQueueItem::CONNECTING && cqi->getLastAttempt() + 50 * 1000 … in on()
185 cqi->setErrors(cqi->getErrors() + 1); in on()
186 fire(ConnectionManagerListener::Failed(), cqi, _("Connection timeout")); in on()
187 cqi->setState(ConnectionQueueItem::WAITING); in on()
486 ConnectionQueueItem* cqi = *i; in on() local
487 cqi->setErrors(0); in on()
488 …if((cqi->getState() == ConnectionQueueItem::CONNECTING || cqi->getState() == ConnectionQueueItem::… in on()
489 cqi->getUser().user->getCID() == cid) in on()
491 aSource->setUser(cqi->getUser()); in on()
587 ConnectionQueueItem* cqi = *i; in addDownloadConnection() local
588 …if(cqi->getState() == ConnectionQueueItem::WAITING || cqi->getState() == ConnectionQueueItem::CONN… in addDownloadConnection()
589 cqi->setState(ConnectionQueueItem::ACTIVE); in addDownloadConnection()
592 fire(ConnectionManagerListener::Connected(), cqi); in addDownloadConnection()
616 ConnectionQueueItem* cqi = getCQI(uc->getHintedUser(), false); in addUploadConnection() local
618 cqi->setState(ConnectionQueueItem::ACTIVE); in addUploadConnection()
621 fire(ConnectionManagerListener::Connected(), cqi); in addUploadConnection()
765 ConnectionQueueItem* cqi = *i; in failed() local
766 cqi->setState(ConnectionQueueItem::WAITING); in failed()
767 cqi->setLastAttempt(GET_TICK()); in failed()
768 cqi->setErrors(protocolError ? -1 : (cqi->getErrors() + 1)); in failed()
769 fire(ConnectionManagerListener::Failed(), cqi, aError); in failed()
773 ConnectionQueueItem* cqi = *i; in failed() local
774 putCQI(cqi); in failed()