67 if(mSocketInfos.empty()) {
71 if(mPmarkHandles.empty()) {
74 ss <<
"scitag.flow=" << mReq.mSciTag
86 <<
"&" <<
"pmark.appname=" << ((mTpcType ==
TPC::TpcType::Pull) ?
"http-put" :
"http-get");
88 auto pmark = mPmark->Begin(sockInfo.
client, mReq.resource.c_str(), ss.str().c_str(),
"http-tpc");
92 mPmarkHandles.emplace(sockInfo.
client.
addrInfo->
SockFD(),std::unique_ptr<XrdNetPMark::Handle>(pmark));
96 auto pmarkHandleItor = mPmarkHandles.begin();
97 while(!mSocketInfos.empty()) {
99 auto pmark = mPmark->Begin(*sockInfo.
client.
addrInfo, *(pmarkHandleItor->second),
nullptr);
106 mPmarkHandles.emplace(fd, std::unique_ptr<XrdNetPMark::Handle>(pmark));