Lines Matching defs:calls
19 RPCPendingCallsInit(struct RPCPendingCalls *calls)
21 SemaphorePoolInit(&calls->fPool);
23 calls->fFirst=NULL;
24 calls->fSem=create_sem(1,"RPCPendingCalls");
25 set_sem_owner (calls->fSem,B_SYSTEM_TEAM);
29 RPCPendingCallsDestroy(struct RPCPendingCalls *calls)
31 delete_sem(calls->fSem);
33 while (calls->fFirst)
35 struct PendingCall *next=calls->fFirst->next;
37 SemaphorePoolPut (&calls->fPool,calls->fFirst->sem);
38 PendingCallDestroy (calls->fFirst);
39 free (calls->fFirst);
41 calls->fFirst=next;
44 SemaphorePoolDestroy (&calls->fPool);
48 RPCPendingCallsAddPendingCall (struct RPCPendingCalls *calls,
54 call->sem=SemaphorePoolGet(&calls->fPool);
59 while (acquire_sem (calls->fSem)==B_INTERRUPTED);
61 call->next=calls->fFirst;
62 calls->fFirst=call;
64 while (release_sem (calls->fSem)==B_INTERRUPTED);
70 RPCPendingCallsFindAndRemovePendingCall (struct RPCPendingCalls *calls,
76 while (acquire_sem (calls->fSem)==B_INTERRUPTED);
78 current=calls->fFirst; // mmu_man
90 calls->fFirst=current->next;
94 while (release_sem (calls->fSem)==B_INTERRUPTED);
103 while (release_sem (calls->fSem)==B_INTERRUPTED);