netfs/client/ServerManager.cpp

49 		ExtendedServerInfo* serverInfo)
53 		  fServerInfo(serverInfo),
118 		error = fServerInfo->SetTo(&request->serverInfo);
197 		ExtendedServerInfo* serverInfo = it.Next().value;
198 		serverInfo->ReleaseReference();
216 	ExtendedServerInfo* serverInfo = fServerInfos->Get(address);
217 	if (!serverInfo
218 		|| (serverInfo->GetState() != STATE_READY
219 			&& serverInfo->GetState() != STATE_UPDATING)) {
222 	serverInfo->AcquireReference();
223 	return serverInfo;
237 	ExtendedServerInfo* serverInfo
239 	if (!serverInfo)
241 	serverInfo->SetState(STATE_ADDING);
242 	BReference<ExtendedServerInfo> serverInfoReference(serverInfo, true);
243 	status_t error = fServerInfos->Put(address, serverInfo);
246 	serverInfo->AcquireReference();
249 	ServerInfoTask task(this, NULL, serverInfo);
264 	ExtendedServerInfo* serverInfo = fServerInfos->Get(address);
265 	if (!serverInfo)
271 	if (serverInfo->GetState() == STATE_READY) {
272 		BReference<ExtendedServerInfo> _(serverInfo);
273 		_RemoveServer(serverInfo);
275 		fListener->ServerRemoved(serverInfo);
277 		serverInfo->SetState(STATE_REMOVING);
366 		ExtendedServerInfo* serverInfo
368 		if (!serverInfo)
370 		serverInfo->SetState(STATE_ADDING);
371 		BReference<ExtendedServerInfo> serverInfoReference(serverInfo, true);
375 			status_t error = fServerInfos->Put(netAddress, serverInfo);
378 			serverInfo->AcquireReference();
383 			serverInfo);
388 				fServerInfos->Remove(serverInfo->GetAddress());
389 				serverInfo->ReleaseReference();
454 ServerManager::_ServerAdded(ExtendedServerInfo* serverInfo)
457 	if (fServerInfos->Get(serverInfo->GetAddress()) == serverInfo) {
459 		if (serverInfo->GetState() == STATE_REMOVING) {
460 			_RemoveServer(serverInfo);
463 				fListener->ServerRemoved(serverInfo);
469 		serverInfo->SetState(STATE_READY);
472 			fListener->ServerAdded(serverInfo);
476 			"info.\n", serverInfo);
482 ServerManager::_ServerUpdated(ExtendedServerInfo* serverInfo)
485 	ExtendedServerInfo* oldInfo = fServerInfos->Get(serverInfo->GetAddress());
486 	if (serverInfo != oldInfo) {
500 		fServerInfos->Put(serverInfo->GetAddress(), serverInfo);
501 		serverInfo->AcquireReference();
502 		serverInfo->SetState(STATE_READY);
506 			fListener->ServerUpdated(oldInfo, serverInfo);
511 			"info.\n", serverInfo);
517 ServerManager::_AddingServerFailed(ExtendedServerInfo* serverInfo)
520 	if (fServerInfos->Get(serverInfo->GetAddress()) == serverInfo) {
521 		bool removing = (serverInfo->GetState() == STATE_REMOVING);
522 		fServerInfos->Remove(serverInfo->GetAddress());
523 		serverInfo->ReleaseReference();
524 		serverInfo->SetState(STATE_OBSOLETE);
530 			fListener->ServerRemoved(serverInfo);
534 			"server info.\n", serverInfo);
540 ServerManager::_UpdatingServerFailed(ExtendedServerInfo* serverInfo)
543 	ExtendedServerInfo* oldInfo = fServerInfos->Get(serverInfo->GetAddress());
544 	if (serverInfo != oldInfo) {
554 			serverInfo->SetState(STATE_OBSOLETE);
559 		serverInfo->SetState(STATE_OBSOLETE);
563 			"server info.\n", serverInfo);
571 ServerManager::_RemoveServer(ExtendedServerInfo* serverInfo)
573 	if (!serverInfo)
576 	ExtendedServerInfo* oldInfo = fServerInfos->Get(serverInfo->GetAddress());