Lines Matching refs:getRequest
322 TIrGetRequest *getRequest;
325 for (getRequest = (TIrGetRequest*)iter->FirstItem();
326 iter->More(); getRequest = (TIrGetRequest*)iter->NextItem()) {
327 //for (getRequest = OSDynamicCast(TIrGetRequest, (OSObject *)iter->FirstItem());
328 // iter->More(); getRequest = OSDynamicCast(TIrGetRequest, (OSObject *)iter->NextItem())) {
329 XTRACE(kLogResetGetRequest, 0, getRequest);
332 this->CleanupPendingGetRequestsAndReplies( getRequest->fLSAPConn, errCancel);
961 TIrGetRequest* getRequest = (TIrGetRequest*)GetCurrentEvent();
975 if (DataDelivered(getRequest, header, headerLength, replyBuffer)) {
985 XTRACE(kLogAddingGetRequest1, 0, getRequest);
986 XTRACE(kLogAddingGetRequest2, 0, getRequest->fLSAPConn);
987 fPendingGetRequests->InsertLast(getRequest);
988 XTRACE(kLogAddingGetRequest3, fPendingGetRequests->Count(), getRequest->fLSAPConn->GetMyLSAPId());
1047 for (TIrGetRequest* getRequest = (TIrGetRequest*)iter->FirstItem();
1048 iter->More(); getRequest = (TIrGetRequest*)iter->NextItem()) {
1049 if (getRequest->fLSAPConn == lsapConn) {
1051 fPendingGetRequests->Remove(getRequest); // get this req off the list
1053 getRequest->fEvent = kIrGetDataReplyEvent;
1054 getRequest->fResult = returnCode;
1055 lsapConn->EnqueueEvent(getRequest);
1108 for (TIrGetRequest* getRequest = (TIrGetRequest*)iter->FirstItem();
1109 iter->More(); getRequest = (TIrGetRequest*)iter->NextItem()) {
1110 XTRACE(kLogDemuxCheckingGets2, 0, getRequest);
1112 if (DataDelivered(getRequest, header, headerLength, inputBuffer)) {
1113 fPendingGetRequests->Remove(getRequest);
1114 XTRACE(kDemuxGetPendingEvent, 0, getRequest);
1248 Boolean TIrLAPConn::DataDelivered(TIrGetRequest* getRequest, TLMPDUHeader& header, ULong headerLength, CBufferSegment* dataBuffer)
1250 if (getRequest->fLSAPConn->YourData(header, false /*justChecking*/)) {
1254 if (getRequest->fData && (dataLength > 0)) {
1255 //if (getRequest->fLength < dataLength) { // jdg
1257 // getRequest->fLength, dataLength);
1259 XASSERT(getRequest->fLength >= dataLength);
1260 getRequest->fData->Seek(getRequest->fOffset, kPosBeg);
1261 written = getRequest->fData->Putn(dataBuffer->GetBufferPtr() + headerLength, dataLength);
1266 getRequest->fEvent = kIrGetDataReplyEvent;
1267 getRequest->fResult = noErr;
1268 getRequest->fLength = written;
1269 getRequest->fCtrlOpCode = header.fOpCode;
1270 getRequest->fCtrlInfo = header.fInfo;
1273 check(getRequest->fLSAPConn);
1274 getRequest->fLSAPConn->EnqueueEvent(getRequest);