86         if (mPipeRunnerDb.find(name) == mPipeRunnerDb.end()) {  in RegisterPipe()
90             mPipeRunnerDb.emplace(  in RegisterPipe()
94         if (!mPipeRunnerDb[name]->isAlive()) {  in RegisterPipe()
95             mPipeRunnerDb.erase(name);  in RegisterPipe()
99             mPipeRunnerDb.emplace(  in RegisterPipe()
109         mPipeRunnerDb.clear();  in ~PipeRegistry()
121         if (mPipeRunnerDb.find(name) == mPipeRunnerDb.end()) {  in getPipeHandle()
126             return mPipeRunnerDb[name]->isAlive() ? mPipeRunnerDb[name]->dupPipeHandle() : nullptr;  in getPipeHandle()
129         if (mPipeRunnerDb[name]->isAvailable()) {  in getPipeHandle()
130             if (mPipeRunnerDb[name]->isAlive()) {  in getPipeHandle()
131                 mPipeRunnerDb[name]->setClient(std::move(clientHandle));  in getPipeHandle()
132                 return mPipeRunnerDb[name]->dupPipeHandle();  in getPipeHandle()
134                 mPipeRunnerDb.erase(name);  in getPipeHandle()
146         if (mPipeRunnerDb.find(name) == mPipeRunnerDb.end()) {  in DeletePipeHandle()
149         mPipeRunnerDb.erase(name);  in DeletePipeHandle()
155     std::unordered_map<std::string, std::unique_ptr<PipeContext<T>>> mPipeRunnerDb;  variable
163     for (auto const& kv : mPipeRunnerDb) {  in getPipeList()