Searched refs:sendObject (Results 1 – 2 of 2) sorted by relevance
146 sendObject->SetSrmWait(false); in HandlePutData()150 if (sendObject->IsSrmEnable() && !sendObject->IsSrmWait()) { in HandlePutData()153 } else if (sendObject->IsDone()) { in HandlePutData()187 if (!sendObject) { in ProcessSendPutWithSrm()190 sendObject->SetSrmSending(); in ProcessSendPutWithSrm()191 if (sendObject->IsBusy()) { in ProcessSendPutWithSrm()197 if (!sendObject->IsDone()) { in ProcessSendPutWithSrm()210 if (sendObject->IsDone()) { in ProcessSendPutWithSrm()350 if (!sendObject) { in HandleTransportDataBusy()353 bool oldBusy = sendObject->IsBusy(); in HandleTransportDataBusy()[all …]
134 auto &sendObject = session.GetSendObject(); in HandleTransportDataBusy() local135 if (!sendObject) { in HandleTransportDataBusy()138 bool oldBusy = sendObject->IsBusy(); in HandleTransportDataBusy()140 sendObject->SetBusy(newBusy); in HandleTransportDataBusy()151 auto &sendObject = session.GetSendObject(); in HandleGetRequest() local152 if (!sendObject) { in HandleGetRequest()157 if (sendObject->IsSrmEnable()) { in HandleGetRequest()160 sendObject->SetSrmWait(false); in HandleGetRequest()164 if (sendObject->IsSrmEnable() && !sendObject->IsSrmWait()) { in HandleGetRequest()172 if (sendObject->IsSrmSending()) { in HandleGetRequest()[all …]