66 if(mSocketInfos.empty()) {
70 if(mPmarkHandles.empty()) {
73 ss <<
"scitag.flow=" << mReq.
mSciTag;
75 auto pmark = mPmark->
Begin(sockInfo.
client, mReq.
resource.c_str(), ss.str().c_str(),
"http-tpc");
79 mPmarkHandles.emplace(sockInfo.
client.
addrInfo->
SockFD(),std::unique_ptr<XrdNetPMark::Handle>(pmark));
83 auto pmarkHandleItor = mPmarkHandles.begin();
84 while(!mSocketInfos.empty()) {
93 mPmarkHandles.emplace(fd, std::unique_ptr<XrdNetPMark::Handle>(pmark));