Lines Matching defs:pRI
223 RequestInfo *pRI;
251 pRI = (RequestInfo *)calloc(1, sizeof(RequestInfo));
252 if (pRI == NULL) {
257 pRI->token = serial;
258 pRI->pCI = &(s_commands[request]);
259 pRI->socket_id = socket_id;
264 pRI->p_next = *pendingRequestsHook;
265 *pendingRequestsHook = pRI;
270 return pRI;
517 checkAndDequeueRequestInfoIfAck(struct RequestInfo *pRI, bool isAck) {
525 if (pRI == NULL) {
530 if (pRI->socket_id == RIL_SOCKET_2) {
535 if (pRI->socket_id == RIL_SOCKET_3) {
541 if (pRI->socket_id == RIL_SOCKET_4) {
553 if (pRI == *ppCur) {
556 if (pRI->wasAckSent == 1) {
557 RLOGD("Ack was already sent for %s", requestToString(pRI->pCI->requestNumber));
559 pRI->wasAckSent = 1;
575 RequestInfo *pRI;
581 pRI = (RequestInfo *)t;
583 if (!checkAndDequeueRequestInfoIfAck(pRI, true)) {
588 socket_id = pRI->socket_id;
594 appendPrintBuf("Ack [%04d]< %s", pRI->token, requestToString(pRI->pCI->requestNumber));
596 if (pRI->cancelled == 0) {
602 radio::acknowledgeRequest((int) socket_id, pRI->token);
610 RequestInfo *pRI;
615 pRI = (RequestInfo *)t;
617 if (!checkAndDequeueRequestInfoIfAck(pRI, false)) {
622 socket_id = pRI->socket_id;
627 if (pRI->local > 0) {
630 RLOGD("C[locl]< %s", requestToString(pRI->pCI->requestNumber));
632 free(pRI);
637 pRI->token, requestToString(pRI->pCI->requestNumber));
639 if (pRI->cancelled == 0) {
641 if (s_callbacks.version >= 13 && pRI->wasAckSent == 1) {
652 RLOGE ("Calling responseFunction() for token %d", pRI->token);
659 ret = pRI->pCI->responseFunction((int) socket_id,
660 responseType, pRI->token, e, response, responselen);
665 free(pRI);
