66     LOG_ALWAYS_FATAL_IF(mConnections.mIncoming.size() != 0,  in ~RpcSession()
252         LOG_ALWAYS_FATAL_IF(!mConnections.mThreads.empty(), "Shutdown failed");  in shutdownAndWait()
324     while (mShutdownCount < session->mConnections.mMaxIncoming) {  in waitForShutdown()
328                   session->mConnections.mIncoming.size(), mShutdownCount.load(),  in waitForShutdown()
329                   session->mConnections.mMaxIncoming);  in waitForShutdown()
339         mConnections.mThreads[thread.get_id()] = std::move(thread);  in preJoinThreadOwnership()
449         auto it = session->mConnections.mThreads.find(rpc_this_thread::get_id());  in join()
450         LOG_ALWAYS_FATAL_IF(it == session->mConnections.mThreads.end());  in join()
452         session->mConnections.mThreads.erase(it);  in join()
515         mConnections = {};  in setupClient()
770         mConnections.mOutgoing.push_back(connection);  in addOutgoingConnection()
808     if (mConnections.mIncoming.size() >= mMaxIncomingThreads) {  in assignIncomingConnectionToThisThread()
810               mConnections.mIncoming.size(), mMaxIncomingThreads);  in assignIncomingConnectionToThisThread()
818     if (mConnections.mIncoming.size() < mConnections.mMaxIncoming) {  in assignIncomingConnectionToThisThread()
826     mConnections.mIncoming.push_back(session);  in assignIncomingConnectionToThisThread()
827     mConnections.mMaxIncoming = mConnections.mIncoming.size();  in assignIncomingConnectionToThisThread()
835                 std::find(mConnections.mIncoming.begin(), mConnections.mIncoming.end(), connection);  in removeIncomingConnection()
836         it != mConnections.mIncoming.end()) {  in removeIncomingConnection()
837         mConnections.mIncoming.erase(it);  in removeIncomingConnection()
838         if (mConnections.mIncoming.size() == 0) {  in removeIncomingConnection()
853     if (mConnections.mWaitingThreads > 0) {  in clearConnectionTid()
872     session->mConnections.mWaitingThreads++;  in find()
880         findConnection(tid, &exclusive, &available, session->mConnections.mOutgoing,  in find()
881                        session->mConnections.mOutgoingOffset);  in find()
894             session->mConnections.mOutgoingOffset = (session->mConnections.mOutgoingOffset + 1) %  in find()
895                     session->mConnections.mOutgoing.size();  in find()
903                            session->mConnections.mIncoming, 0 /* index hint */);  in find()
932         if (session->mConnections.mOutgoing.size() == 0) {  in find()
936                   static_cast<int>(use), session->mConnections.mIncoming.size(),  in find()
948                        session->mConnections.mOutgoing.size(),  in find()
949                        session->mConnections.mIncoming.size());  in find()
952     session->mConnections.mWaitingThreads--;  in find()
1004     if (hasActiveConnection(mConnections.mIncoming)) {  in hasActiveRequests()
1007     if (hasActiveConnection(mConnections.mOutgoing)) {  in hasActiveRequests()
1010     return mConnections.mWaitingThreads != 0;  in hasActiveRequests()