rx: Remove multi_End_Ignore
[openafs.git] / src / rx / rx_multi.h
1 /*
2  * Copyright 2000, International Business Machines Corporation and others.
3  * All Rights Reserved.
4  *
5  * This software has been released under the terms of the IBM Public
6  * License.  For details, see the LICENSE file in the top-level source
7  * directory or online at http://www.openafs.org/dl/license10.html
8  */
9
10 #ifndef _RX_MULTI_
11 #define _RX_MULTI_
12
13 struct multi_handle {
14     int nConns;
15     struct rx_call **calls;
16     short *ready;
17     short nReady;               /* XXX UNALIGNED */
18     short *nextReady;
19     short *firstNotReady;
20 #ifdef RX_ENABLE_LOCKS
21     afs_kmutex_t lock;
22     afs_kcondvar_t cv;
23 #endif                          /* RX_ENABLE_LOCKS */
24 };
25
26 #define multi_Rx(conns, nConns) \
27     do {\
28         struct multi_handle *multi_h;\
29         int multi_i;\
30         int multi_i0;\
31         afs_int32 multi_error;\
32         struct rx_call *multi_call;\
33         multi_h = multi_Init(conns, nConns);\
34         for (multi_i0 = multi_i = 0; ; multi_i = multi_i0 )
35
36 #define multi_Body(startProc, endProc)\
37         if (multi_h->nextReady == multi_h->firstNotReady && multi_i < multi_h->nConns) {\
38             multi_call = multi_h->calls[multi_i];\
39             if (multi_call) {\
40                 startProc;\
41                 rx_FlushWrite(multi_call);\
42             }\
43             multi_i0++;  /* THIS is the loop variable!! */\
44             continue;\
45         }\
46         if ((multi_i = multi_Select(multi_h)) < 0) break;\
47         multi_call = multi_h->calls[multi_i];\
48         multi_error = rx_EndCall(multi_call, endProc);\
49         multi_h->calls[multi_i] = (struct rx_call *) 0
50
51 #define multi_Abort break
52
53 #define multi_End\
54         multi_Finalize(multi_h);\
55     } while (0)
56
57 #endif /* _RX_MULTI_     End of rx_multi.h */