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 #ifdef  KERNEL
  14 #include "../rx/rx.h"
  15 #else /* KERNEL */
  16 # include "rx.h"
  17 #endif /* KERNEL */
  18
  19 struct multi_handle {
  20     int nConns;
  21     struct rx_call **calls;
  22     short *ready;
  23     short nReady;        /* XXX UNALIGNED */
  24     short *nextReady;
  25     short *firstNotReady;
  26 #ifdef RX_ENABLE_LOCKS
  27     afs_kmutex_t lock;
  28     afs_kcondvar_t cv;
  29 #endif /* RX_ENABLE_LOCKS */
  30 };
  31
  32 #define multi_Rx(conns, nConns) \
  33     do {\
  34         register struct multi_handle *multi_h;\
  35         register int multi_i;\
  36         register struct rx_call *multi_call;\
  37         multi_h = multi_Init(conns, nConns);\
  38         for (multi_i = 0; multi_i < nConns; multi_i++)
  39
  40 #define multi_Body(startProc, endProc)\
  41         multi_call = multi_h->calls[multi_i];\
  42         startProc;\
  43         rx_FlushWrite(multi_call);\
  44         }\
  45         while ((multi_i = multi_Select(multi_h)) >= 0) {\
  46             register afs_int32 multi_error;\
  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 /* Ignore remaining multi RPC's */
  58 #define multi_End_Ignore\
  59         multi_Finalize_Ignore(multi_h);\
  60     } while (0)
  61
  62 #endif /* _RX_MULTI_     End of rx_multi.h */