Changes in uspace/lib/c/include/async.h [8869f7b:8e80d3f] in mainline
- File:
-
- 1 edited
-
uspace/lib/c/include/async.h (modified) (10 diffs)
Legend:
- Unmodified
- Added
- Removed
-
uspace/lib/c/include/async.h
r8869f7b r8e80d3f 41 41 42 42 #include <ipc/common.h> 43 #include <async_sess.h> 43 44 #include <fibril.h> 44 #include <fibril_synch.h>45 45 #include <sys/time.h> 46 46 #include <atomic.h> … … 55 55 typedef void (*async_client_conn_t)(ipc_callid_t, ipc_call_t *); 56 56 57 /** Exchange management style58 *59 */60 typedef enum {61 /** No explicit exchange management62 *63 * Suitable for protocols which use a single64 * IPC message per exchange only.65 *66 */67 EXCHANGE_ATOMIC = 0,68 69 /** Exchange management via phone cloning70 *71 * Suitable for servers which support client72 * data tracking by task hashes and do not73 * mind cloned phones.74 *75 */76 EXCHANGE_PARALLEL,77 78 /** Exchange management via mutual exclusion79 *80 * Suitable for any kind of client/server communication,81 * but can limit parallelism.82 *83 */84 EXCHANGE_SERIALIZE85 } exch_mgmt_t;86 87 /** Session data */88 typedef struct {89 /** List of inactive exchanges */90 link_t exch_list;91 92 /** Exchange management style */93 exch_mgmt_t mgmt;94 95 /** Session identification */96 int phone;97 98 /** First clone connection argument */99 sysarg_t arg1;100 101 /** Second clone connection argument */102 sysarg_t arg2;103 104 /** Third clone connection argument */105 sysarg_t arg3;106 107 /** Exchange mutex */108 fibril_mutex_t mutex;109 110 /** Number of opened exchanges */111 atomic_t refcnt;112 } async_sess_t;113 114 /** Exchange data */115 typedef struct {116 /** Link into list of inactive exchanges */117 link_t sess_link;118 119 /** Link into global list of inactive exchanges */120 link_t global_link;121 122 /** Session pointer */123 async_sess_t *sess;124 125 /** Exchange identification */126 int phone;127 } async_exch_t;128 129 57 extern atomic_t threads_in_ipc_wait; 130 58 … … 140 68 * User-friendly wrappers for async_send_fast() and async_send_slow(). The 141 69 * macros are in the form async_send_m(), where m denotes the number of payload 142 * arguments. Each macros chooses between the fast and the slow version based70 * arguments. Each macros chooses between the fast and the slow version based 143 71 * on m. 144 72 */ 145 73 146 #define async_send_0(exch, method, dataptr) \ 147 async_send_fast(exch, method, 0, 0, 0, 0, dataptr) 148 #define async_send_1(exch, method, arg1, dataptr) \ 149 async_send_fast(exch, method, arg1, 0, 0, 0, dataptr) 150 #define async_send_2(exch, method, arg1, arg2, dataptr) \ 151 async_send_fast(exch, method, arg1, arg2, 0, 0, dataptr) 152 #define async_send_3(exch, method, arg1, arg2, arg3, dataptr) \ 153 async_send_fast(exch, method, arg1, arg2, arg3, 0, dataptr) 154 #define async_send_4(exch, method, arg1, arg2, arg3, arg4, dataptr) \ 155 async_send_fast(exch, method, arg1, arg2, arg3, arg4, dataptr) 156 #define async_send_5(exch, method, arg1, arg2, arg3, arg4, arg5, dataptr) \ 157 async_send_slow(exch, method, arg1, arg2, arg3, arg4, arg5, dataptr) 158 159 extern aid_t async_send_fast(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, 74 #define async_send_0(phoneid, method, dataptr) \ 75 async_send_fast((phoneid), (method), 0, 0, 0, 0, (dataptr)) 76 #define async_send_1(phoneid, method, arg1, dataptr) \ 77 async_send_fast((phoneid), (method), (arg1), 0, 0, 0, (dataptr)) 78 #define async_send_2(phoneid, method, arg1, arg2, dataptr) \ 79 async_send_fast((phoneid), (method), (arg1), (arg2), 0, 0, (dataptr)) 80 #define async_send_3(phoneid, method, arg1, arg2, arg3, dataptr) \ 81 async_send_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (dataptr)) 82 #define async_send_4(phoneid, method, arg1, arg2, arg3, arg4, dataptr) \ 83 async_send_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 84 (dataptr)) 85 #define async_send_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, dataptr) \ 86 async_send_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 87 (arg5), (dataptr)) 88 89 extern aid_t async_send_fast(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 90 sysarg_t, ipc_call_t *); 91 extern aid_t async_send_slow(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 160 92 sysarg_t, sysarg_t, ipc_call_t *); 161 extern aid_t async_send_slow(async_exch_t *, sysarg_t, sysarg_t, sysarg_t,162 sysarg_t, sysarg_t, sysarg_t, ipc_call_t *);163 164 93 extern void async_wait_for(aid_t, sysarg_t *); 165 94 extern int async_wait_timeout(aid_t, sysarg_t *, suseconds_t); 166 95 167 96 extern fid_t async_new_connection(sysarg_t, sysarg_t, ipc_callid_t, 168 ipc_call_t *, async_client_conn_t); 169 97 ipc_call_t *, void (*)(ipc_callid_t, ipc_call_t *)); 170 98 extern void async_usleep(suseconds_t); 171 99 extern void async_create_manager(void); … … 174 102 extern void async_set_client_data_constructor(async_client_data_ctor_t); 175 103 extern void async_set_client_data_destructor(async_client_data_dtor_t); 176 extern void *async_get_client_data(void); 104 105 extern void *async_client_data_get(void); 177 106 178 107 extern void async_set_client_connection(async_client_conn_t); … … 183 112 */ 184 113 185 extern void async_msg_0(async_exch_t *, sysarg_t); 186 extern void async_msg_1(async_exch_t *, sysarg_t, sysarg_t); 187 extern void async_msg_2(async_exch_t *, sysarg_t, sysarg_t, sysarg_t); 188 extern void async_msg_3(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, sysarg_t); 189 extern void async_msg_4(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 114 extern void async_msg_0(int, sysarg_t); 115 extern void async_msg_1(int, sysarg_t, sysarg_t); 116 extern void async_msg_2(int, sysarg_t, sysarg_t, sysarg_t); 117 extern void async_msg_3(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t); 118 extern void async_msg_4(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, sysarg_t); 119 extern void async_msg_5(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 190 120 sysarg_t); 191 extern void async_msg_5(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, sysarg_t,192 sysarg_t, sysarg_t);193 121 194 122 /* … … 210 138 */ 211 139 212 extern int async_forward_fast(ipc_callid_t, async_exch_t *, sysarg_t, sysarg_t,213 sysarg_t,unsigned int);214 extern int async_forward_slow(ipc_callid_t, async_exch_t *, sysarg_t, sysarg_t,215 sysarg_t, sysarg_t, sysarg_t, sysarg_t,unsigned int);140 extern int async_forward_fast(ipc_callid_t, int, sysarg_t, sysarg_t, sysarg_t, 141 unsigned int); 142 extern int async_forward_slow(ipc_callid_t, int, sysarg_t, sysarg_t, sysarg_t, 143 sysarg_t, sysarg_t, sysarg_t, unsigned int); 216 144 217 145 /* … … 222 150 */ 223 151 224 #define async_req_0_0(exch, method) \ 225 async_req_fast(exch, method, 0, 0, 0, 0, NULL, NULL, NULL, NULL, NULL) 226 #define async_req_0_1(exch, method, r1) \ 227 async_req_fast(exch, method, 0, 0, 0, 0, r1, NULL, NULL, NULL, NULL) 228 #define async_req_0_2(exch, method, r1, r2) \ 229 async_req_fast(exch, method, 0, 0, 0, 0, r1, r2, NULL, NULL, NULL) 230 #define async_req_0_3(exch, method, r1, r2, r3) \ 231 async_req_fast(exch, method, 0, 0, 0, 0, r1, r2, r3, NULL, NULL) 232 #define async_req_0_4(exch, method, r1, r2, r3, r4) \ 233 async_req_fast(exch, method, 0, 0, 0, 0, r1, r2, r3, r4, NULL) 234 #define async_req_0_5(exch, method, r1, r2, r3, r4, r5) \ 235 async_req_fast(exch, method, 0, 0, 0, 0, r1, r2, r3, r4, r5) 236 237 #define async_req_1_0(exch, method, arg1) \ 238 async_req_fast(exch, method, arg1, 0, 0, 0, NULL, NULL, NULL, NULL, \ 239 NULL) 240 #define async_req_1_1(exch, method, arg1, rc1) \ 241 async_req_fast(exch, method, arg1, 0, 0, 0, rc1, NULL, NULL, NULL, \ 242 NULL) 243 #define async_req_1_2(exch, method, arg1, rc1, rc2) \ 244 async_req_fast(exch, method, arg1, 0, 0, 0, rc1, rc2, NULL, NULL, \ 245 NULL) 246 #define async_req_1_3(exch, method, arg1, rc1, rc2, rc3) \ 247 async_req_fast(exch, method, arg1, 0, 0, 0, rc1, rc2, rc3, NULL, \ 248 NULL) 249 #define async_req_1_4(exch, method, arg1, rc1, rc2, rc3, rc4) \ 250 async_req_fast(exch, method, arg1, 0, 0, 0, rc1, rc2, rc3, rc4, \ 251 NULL) 252 #define async_req_1_5(exch, method, arg1, rc1, rc2, rc3, rc4, rc5) \ 253 async_req_fast(exch, method, arg1, 0, 0, 0, rc1, rc2, rc3, rc4, \ 254 rc5) 255 256 #define async_req_2_0(exch, method, arg1, arg2) \ 257 async_req_fast(exch, method, arg1, arg2, 0, 0, NULL, NULL, NULL, \ 152 #define async_req_0_0(phoneid, method) \ 153 async_req_fast((phoneid), (method), 0, 0, 0, 0, NULL, NULL, NULL, NULL, \ 154 NULL) 155 #define async_req_0_1(phoneid, method, r1) \ 156 async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), NULL, NULL, NULL, \ 157 NULL) 158 #define async_req_0_2(phoneid, method, r1, r2) \ 159 async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), NULL, NULL, \ 160 NULL) 161 #define async_req_0_3(phoneid, method, r1, r2, r3) \ 162 async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), NULL, \ 163 NULL) 164 #define async_req_0_4(phoneid, method, r1, r2, r3, r4) \ 165 async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), (r4), \ 166 NULL) 167 #define async_req_0_5(phoneid, method, r1, r2, r3, r4, r5) \ 168 async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), (r4), \ 169 (r5)) 170 #define async_req_1_0(phoneid, method, arg1) \ 171 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, NULL, NULL, NULL, \ 258 172 NULL, NULL) 259 #define async_req_ 2_1(exch, method, arg1, arg2, rc1) \260 async_req_fast( exch, method, arg1, arg2, 0, 0, rc1, NULL, NULL, \173 #define async_req_1_1(phoneid, method, arg1, rc1) \ 174 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), NULL, NULL, \ 261 175 NULL, NULL) 262 #define async_req_2_2(exch, method, arg1, arg2, rc1, rc2) \ 263 async_req_fast(exch, method, arg1, arg2, 0, 0, rc1, rc2, NULL, NULL, \ 264 NULL) 265 #define async_req_2_3(exch, method, arg1, arg2, rc1, rc2, rc3) \ 266 async_req_fast(exch, method, arg1, arg2, 0, 0, rc1, rc2, rc3, NULL, \ 267 NULL) 268 #define async_req_2_4(exch, method, arg1, arg2, rc1, rc2, rc3, rc4) \ 269 async_req_fast(exch, method, arg1, arg2, 0, 0, rc1, rc2, rc3, rc4, \ 270 NULL) 271 #define async_req_2_5(exch, method, arg1, arg2, rc1, rc2, rc3, rc4, rc5) \ 272 async_req_fast(exch, method, arg1, arg2, 0, 0, rc1, rc2, rc3, rc4, \ 273 rc5) 274 275 #define async_req_3_0(exch, method, arg1, arg2, arg3) \ 276 async_req_fast(exch, method, arg1, arg2, arg3, 0, NULL, NULL, NULL, \ 176 #define async_req_1_2(phoneid, method, arg1, rc1, rc2) \ 177 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), NULL, \ 277 178 NULL, NULL) 278 #define async_req_ 3_1(exch, method, arg1, arg2, arg3, rc1) \279 async_req_fast( exch, method, arg1, arg2, arg3, 0, rc1, NULL, NULL, \179 #define async_req_1_3(phoneid, method, arg1, rc1, rc2, rc3) \ 180 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \ 280 181 NULL, NULL) 281 #define async_req_3_2(exch, method, arg1, arg2, arg3, rc1, rc2) \ 282 async_req_fast(exch, method, arg1, arg2, arg3, 0, rc1, rc2, NULL, \ 283 NULL, NULL) 284 #define async_req_3_3(exch, method, arg1, arg2, arg3, rc1, rc2, rc3) \ 285 async_req_fast(exch, method, arg1, arg2, arg3, 0, rc1, rc2, rc3, \ 286 NULL, NULL) 287 #define async_req_3_4(exch, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4) \ 288 async_req_fast(exch, method, arg1, arg2, arg3, 0, rc1, rc2, rc3, \ 289 rc4, NULL) 290 #define async_req_3_5(exch, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4, \ 182 #define async_req_1_4(phoneid, method, arg1, rc1, rc2, rc3, rc4) \ 183 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \ 184 (rc4), NULL) 185 #define async_req_1_5(phoneid, method, arg1, rc1, rc2, rc3, rc4, rc5) \ 186 async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \ 187 (rc4), (rc5)) 188 #define async_req_2_0(phoneid, method, arg1, arg2) \ 189 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, NULL, NULL, \ 190 NULL, NULL, NULL) 191 #define async_req_2_1(phoneid, method, arg1, arg2, rc1) \ 192 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), NULL, \ 193 NULL, NULL, NULL) 194 #define async_req_2_2(phoneid, method, arg1, arg2, rc1, rc2) \ 195 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \ 196 NULL, NULL, NULL) 197 #define async_req_2_3(phoneid, method, arg1, arg2, rc1, rc2, rc3) \ 198 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \ 199 (rc3), NULL, NULL) 200 #define async_req_2_4(phoneid, method, arg1, arg2, rc1, rc2, rc3, rc4) \ 201 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \ 202 (rc3), (rc4), NULL) 203 #define async_req_2_5(phoneid, method, arg1, arg2, rc1, rc2, rc3, rc4, rc5) \ 204 async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \ 205 (rc3), (rc4), (rc5)) 206 #define async_req_3_0(phoneid, method, arg1, arg2, arg3) \ 207 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, NULL, NULL, \ 208 NULL, NULL, NULL) 209 #define async_req_3_1(phoneid, method, arg1, arg2, arg3, rc1) \ 210 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \ 211 NULL, NULL, NULL, NULL) 212 #define async_req_3_2(phoneid, method, arg1, arg2, arg3, rc1, rc2) \ 213 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \ 214 (rc2), NULL, NULL, NULL) 215 #define async_req_3_3(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3) \ 216 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \ 217 (rc2), (rc3), NULL, NULL) 218 #define async_req_3_4(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4) \ 219 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \ 220 (rc2), (rc3), (rc4), NULL) 221 #define async_req_3_5(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4, \ 291 222 rc5) \ 292 async_req_fast(exch, method, arg1, arg2, arg3, 0, rc1, rc2, rc3, \ 293 rc4, rc5) 294 295 #define async_req_4_0(exch, method, arg1, arg2, arg3, arg4) \ 296 async_req_fast(exch, method, arg1, arg2, arg3, arg4, NULL, NULL, \ 297 NULL, NULL, NULL) 298 #define async_req_4_1(exch, method, arg1, arg2, arg3, arg4, rc1) \ 299 async_req_fast(exch, method, arg1, arg2, arg3, arg4, rc1, NULL, \ 300 NULL, NULL, NULL) 301 #define async_req_4_2(exch, method, arg1, arg2, arg3, arg4, rc1, rc2) \ 302 async_req_fast(exch, method, arg1, arg2, arg3, arg4, rc1, rc2, NULL, \ 303 NULL, NULL) 304 #define async_req_4_3(exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3) \ 305 async_req_fast(exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \ 306 NULL, NULL) 307 #define async_req_4_4(exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \ 223 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \ 224 (rc2), (rc3), (rc4), (rc5)) 225 #define async_req_4_0(phoneid, method, arg1, arg2, arg3, arg4) \ 226 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), NULL, \ 227 NULL, NULL, NULL, NULL) 228 #define async_req_4_1(phoneid, method, arg1, arg2, arg3, arg4, rc1) \ 229 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \ 230 NULL, NULL, NULL, NULL) 231 #define async_req_4_2(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2) \ 232 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \ 233 (rc2), NULL, NULL, NULL) 234 #define async_req_4_3(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3) \ 235 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \ 236 (rc2), (rc3), NULL, NULL) 237 #define async_req_4_4(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \ 308 238 rc4) \ 309 async_req_fast( exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \310 rc4, NULL)311 #define async_req_4_5( exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \239 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 240 (rc1), (rc2), (rc3), (rc4), NULL) 241 #define async_req_4_5(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \ 312 242 rc4, rc5) \ 313 async_req_fast(exch, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \ 314 rc4, rc5) 315 316 #define async_req_5_0(exch, method, arg1, arg2, arg3, arg4, arg5) \ 317 async_req_slow(exch, method, arg1, arg2, arg3, arg4, arg5, NULL, \ 318 NULL, NULL, NULL, NULL) 319 #define async_req_5_1(exch, method, arg1, arg2, arg3, arg4, arg5, rc1) \ 320 async_req_slow(exch, method, arg1, arg2, arg3, arg4, arg5, rc1, \ 321 NULL, NULL, NULL, NULL) 322 #define async_req_5_2(exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2) \ 323 async_req_slow(exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 324 NULL, NULL, NULL) 325 #define async_req_5_3(exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 243 async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 244 (rc1), (rc2), (rc3), (rc4), (rc5)) 245 #define async_req_5_0(phoneid, method, arg1, arg2, arg3, arg4, arg5) \ 246 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 247 (arg5), NULL, NULL, NULL, NULL, NULL) 248 #define async_req_5_1(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1) \ 249 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 250 (arg5), (rc1), NULL, NULL, NULL, NULL) 251 #define async_req_5_2(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2) \ 252 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 253 (arg5), (rc1), (rc2), NULL, NULL, NULL) 254 #define async_req_5_3(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 326 255 rc3) \ 327 async_req_slow( exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \328 rc3, NULL, NULL)329 #define async_req_5_4( exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \256 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 257 (arg5), (rc1), (rc2), (rc3), NULL, NULL) 258 #define async_req_5_4(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 330 259 rc3, rc4) \ 331 async_req_slow( exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \332 rc3, rc4, NULL)333 #define async_req_5_5( exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \260 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 261 (arg5), (rc1), (rc2), (rc3), (rc4), NULL) 262 #define async_req_5_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 334 263 rc3, rc4, rc5) \ 335 async_req_slow(exch, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \ 336 rc3, rc4, rc5) 337 338 extern sysarg_t async_req_fast(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, 264 async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \ 265 (arg5), (rc1), (rc2), (rc3), (rc4), (rc5)) 266 267 extern sysarg_t async_req_fast(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 268 sysarg_t, sysarg_t *, sysarg_t *, sysarg_t *, sysarg_t *, sysarg_t *); 269 extern sysarg_t async_req_slow(int, sysarg_t, sysarg_t, sysarg_t, sysarg_t, 339 270 sysarg_t, sysarg_t, sysarg_t *, sysarg_t *, sysarg_t *, sysarg_t *, 340 271 sysarg_t *); 341 extern sysarg_t async_req_slow(async_exch_t *, sysarg_t, sysarg_t, sysarg_t, 342 sysarg_t, sysarg_t, sysarg_t, sysarg_t *, sysarg_t *, sysarg_t *, 343 sysarg_t *, sysarg_t *); 344 345 extern async_sess_t *async_connect_me(exch_mgmt_t, async_exch_t *); 346 extern async_sess_t *async_connect_me_to(exch_mgmt_t, async_exch_t *, sysarg_t, 347 sysarg_t, sysarg_t); 348 extern async_sess_t *async_connect_me_to_blocking(exch_mgmt_t, async_exch_t *, 349 sysarg_t, sysarg_t, sysarg_t);350 extern async_sess_t *async_connect_kbox(task_id_t); 351 352 extern int async_connect_to_me( async_exch_t *, sysarg_t, sysarg_t, sysarg_t,272 273 static inline void async_serialize_start(void) 274 { 275 fibril_inc_sercount(); 276 } 277 278 static inline void async_serialize_end(void) 279 { 280 fibril_dec_sercount(); 281 } 282 283 extern int async_connect_to_me(int, sysarg_t, sysarg_t, sysarg_t, 353 284 async_client_conn_t); 354 355 extern int async_hangup(async_sess_t *); 285 extern int async_connect_me_to(int, sysarg_t, sysarg_t, sysarg_t); 286 extern int async_connect_me_to_blocking(int, sysarg_t, sysarg_t, sysarg_t); 287 extern int async_connect_kbox(task_id_t); 288 extern int async_hangup(int); 356 289 extern void async_poke(void); 357 290 358 extern async_exch_t *async_exchange_begin(async_sess_t *);359 extern void async_exchange_end(async_exch_t *);360 361 291 /* 362 292 * User-friendly wrappers for async_share_in_start(). 363 293 */ 364 294 365 #define async_share_in_start_0_0(exch, dst, size) \ 366 async_share_in_start(exch, dst, size, 0, NULL) 367 #define async_share_in_start_0_1(exch, dst, size, flags) \ 368 async_share_in_start(exch, dst, size, 0, flags) 369 #define async_share_in_start_1_0(exch, dst, size, arg) \ 370 async_share_in_start(exch, dst, size, arg, NULL) 371 #define async_share_in_start_1_1(exch, dst, size, arg, flags) \ 372 async_share_in_start(exch, dst, size, arg, flags) 373 374 extern int async_share_in_start(async_exch_t *, void *, size_t, sysarg_t, 375 unsigned int *); 295 #define async_share_in_start_0_0(phoneid, dst, size) \ 296 async_share_in_start((phoneid), (dst), (size), 0, NULL) 297 #define async_share_in_start_0_1(phoneid, dst, size, flags) \ 298 async_share_in_start((phoneid), (dst), (size), 0, (flags)) 299 #define async_share_in_start_1_0(phoneid, dst, size, arg) \ 300 async_share_in_start((phoneid), (dst), (size), (arg), NULL) 301 #define async_share_in_start_1_1(phoneid, dst, size, arg, flags) \ 302 async_share_in_start((phoneid), (dst), (size), (arg), (flags)) 303 304 extern int async_share_in_start(int, void *, size_t, sysarg_t, unsigned int *); 376 305 extern bool async_share_in_receive(ipc_callid_t *, size_t *); 377 306 extern int async_share_in_finalize(ipc_callid_t, void *, unsigned int); 378 307 379 extern int async_share_out_start( async_exch_t *, void *, unsigned int);308 extern int async_share_out_start(int, void *, unsigned int); 380 309 extern bool async_share_out_receive(ipc_callid_t *, size_t *, unsigned int *); 381 310 extern int async_share_out_finalize(ipc_callid_t, void *); … … 385 314 */ 386 315 387 #define async_data_read_forward_0_0(exch, method, answer) \ 388 async_data_read_forward_fast(exch, method, 0, 0, 0, 0, NULL) 389 #define async_data_read_forward_0_1(exch, method, answer) \ 390 async_data_read_forward_fast(exch, method, 0, 0, 0, 0, answer) 391 #define async_data_read_forward_1_0(exch, method, arg1, answer) \ 392 async_data_read_forward_fast(exch, method, arg1, 0, 0, 0, NULL) 393 #define async_data_read_forward_1_1(exch, method, arg1, answer) \ 394 async_data_read_forward_fast(exch, method, arg1, 0, 0, 0, answer) 395 #define async_data_read_forward_2_0(exch, method, arg1, arg2, answer) \ 396 async_data_read_forward_fast(exch, method, arg1, arg2, 0, 0, NULL) 397 #define async_data_read_forward_2_1(exch, method, arg1, arg2, answer) \ 398 async_data_read_forward_fast(exch, method, arg1, arg2, 0, 0, answer) 399 #define async_data_read_forward_3_0(exch, method, arg1, arg2, arg3, answer) \ 400 async_data_read_forward_fast(exch, method, arg1, arg2, arg3, 0, NULL) 401 #define async_data_read_forward_3_1(exch, method, arg1, arg2, arg3, answer) \ 402 async_data_read_forward_fast(exch, method, arg1, arg2, arg3, 0, \ 403 answer) 404 #define async_data_read_forward_4_0(exch, method, arg1, arg2, arg3, arg4, \ 405 answer) \ 406 async_data_read_forward_fast(exch, method, arg1, arg2, arg3, arg4, \ 407 NULL) 408 #define async_data_read_forward_4_1(exch, method, arg1, arg2, arg3, arg4, \ 409 answer) \ 410 async_data_read_forward_fast(exch, method, arg1, arg2, arg3, arg4, \ 411 answer) 412 413 extern aid_t async_data_read(async_exch_t *, void *, size_t, ipc_call_t *); 414 extern int async_data_read_start(async_exch_t *, void *, size_t); 316 #define async_data_read_forward_0_0(phoneid, method, answer) \ 317 async_data_read_forward_fast((phoneid), (method), 0, 0, 0, 0, NULL) 318 #define async_data_read_forward_0_1(phoneid, method, answer) \ 319 async_data_read_forward_fast((phoneid), (method), 0, 0, 0, 0, (answer)) 320 #define async_data_read_forward_1_0(phoneid, method, arg1, answer) \ 321 async_data_read_forward_fast((phoneid), (method), (arg1), 0, 0, 0, NULL) 322 #define async_data_read_forward_1_1(phoneid, method, arg1, answer) \ 323 async_data_read_forward_fast((phoneid), (method), (arg1), 0, 0, 0, (answer)) 324 #define async_data_read_forward_2_0(phoneid, method, arg1, arg2, answer) \ 325 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), 0, 0, NULL) 326 #define async_data_read_forward_2_1(phoneid, method, arg1, arg2, answer) \ 327 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), 0, 0, \ 328 (answer)) 329 #define async_data_read_forward_3_0(phoneid, method, arg1, arg2, arg3, answer) \ 330 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, \ 331 NULL) 332 #define async_data_read_forward_3_1(phoneid, method, arg1, arg2, arg3, answer) \ 333 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, \ 334 (answer)) 335 #define async_data_read_forward_4_0(phoneid, method, arg1, arg2, arg3, arg4, answer) \ 336 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 337 (arg4), NULL) 338 #define async_data_read_forward_4_1(phoneid, method, arg1, arg2, arg3, arg4, answer) \ 339 async_data_read_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 340 (arg4), (answer)) 341 342 #define async_data_read_start(p, buf, len) \ 343 async_data_read_start_generic((p), (buf), (len), IPC_XF_NONE) 344 345 extern int async_data_read_start_generic(int, void *, size_t, int); 415 346 extern bool async_data_read_receive(ipc_callid_t *, size_t *); 416 347 extern int async_data_read_finalize(ipc_callid_t, const void *, size_t); 417 348 418 extern int async_data_read_forward_fast( async_exch_t *, sysarg_t, sysarg_t,419 sysarg_t, sysarg_t, sysarg_t,ipc_call_t *);349 extern int async_data_read_forward_fast(int, sysarg_t, sysarg_t, sysarg_t, 350 sysarg_t, sysarg_t, ipc_call_t *); 420 351 421 352 /* … … 423 354 */ 424 355 425 #define async_data_write_forward_0_0(exch, method, answer) \ 426 async_data_write_forward_fast(exch, method, 0, 0, 0, 0, NULL) 427 #define async_data_write_forward_0_1(exch, method, answer) \ 428 async_data_write_forward_fast(exch, method, 0, 0, 0, 0, answer) 429 #define async_data_write_forward_1_0(exch, method, arg1, answer) \ 430 async_data_write_forward_fast(exch, method, arg1, 0, 0, 0, NULL) 431 #define async_data_write_forward_1_1(exch, method, arg1, answer) \ 432 async_data_write_forward_fast(exch, method, arg1, 0, 0, 0, answer) 433 #define async_data_write_forward_2_0(exch, method, arg1, arg2, answer) \ 434 async_data_write_forward_fast(exch, method, arg1, arg2, 0, 0, NULL) 435 #define async_data_write_forward_2_1(exch, method, arg1, arg2, answer) \ 436 async_data_write_forward_fast(exch, method, arg1, arg2, 0, 0, answer) 437 #define async_data_write_forward_3_0(exch, method, arg1, arg2, arg3, answer) \ 438 async_data_write_forward_fast(exch, method, arg1, arg2, arg3, 0, \ 439 NULL) 440 #define async_data_write_forward_3_1(exch, method, arg1, arg2, arg3, answer) \ 441 async_data_write_forward_fast(exch, method, arg1, arg2, arg3, 0, \ 442 answer) 443 #define async_data_write_forward_4_0(exch, method, arg1, arg2, arg3, arg4, \ 444 answer) \ 445 async_data_write_forward_fast(exch, method, arg1, arg2, arg3, arg4, \ 446 NULL) 447 #define async_data_write_forward_4_1(exch, method, arg1, arg2, arg3, arg4, \ 448 answer) \ 449 async_data_write_forward_fast(exch, method, arg1, arg2, arg3, arg4, \ 450 answer) 451 452 extern int async_data_write_start(async_exch_t *, const void *, size_t); 356 #define async_data_write_forward_0_0(phoneid, method, answer) \ 357 async_data_write_forward_fast((phoneid), (method), 0, 0, 0, 0, NULL) 358 #define async_data_write_forward_0_1(phoneid, method, answer) \ 359 async_data_write_forward_fast((phoneid), (method), 0, 0, 0, 0, (answer)) 360 #define async_data_write_forward_1_0(phoneid, method, arg1, answer) \ 361 async_data_write_forward_fast((phoneid), (method), (arg1), 0, 0, 0, NULL) 362 #define async_data_write_forward_1_1(phoneid, method, arg1, answer) \ 363 async_data_write_forward_fast((phoneid), (method), (arg1), 0, 0, 0, \ 364 (answer)) 365 #define async_data_write_forward_2_0(phoneid, method, arg1, arg2, answer) \ 366 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), 0, 0, \ 367 NULL) 368 #define async_data_write_forward_2_1(phoneid, method, arg1, arg2, answer) \ 369 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), 0, 0, \ 370 (answer)) 371 #define async_data_write_forward_3_0(phoneid, method, arg1, arg2, arg3, answer) \ 372 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 373 0, NULL) 374 #define async_data_write_forward_3_1(phoneid, method, arg1, arg2, arg3, answer) \ 375 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 376 0, (answer)) 377 #define async_data_write_forward_4_0(phoneid, method, arg1, arg2, arg3, arg4, answer) \ 378 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 379 (arg4), NULL) 380 #define async_data_write_forward_4_1(phoneid, method, arg1, arg2, arg3, arg4, answer) \ 381 async_data_write_forward_fast((phoneid), (method), (arg1), (arg2), (arg3), \ 382 (arg4), (answer)) 383 384 #define async_data_write_start(p, buf, len) \ 385 async_data_write_start_generic((p), (buf), (len), IPC_XF_NONE) 386 387 extern int async_data_write_start_generic(int, const void *, size_t, int); 453 388 extern bool async_data_write_receive(ipc_callid_t *, size_t *); 454 389 extern int async_data_write_finalize(ipc_callid_t, void *, size_t); … … 458 393 extern void async_data_write_void(sysarg_t); 459 394 460 extern int async_data_write_forward_fast(async_exch_t *, sysarg_t, sysarg_t, 461 sysarg_t, sysarg_t, sysarg_t, ipc_call_t *); 462 463 extern int async_exchange_clone(async_exch_t *, async_exch_t *); 464 extern async_sess_t *async_clone_receive(exch_mgmt_t); 465 extern async_sess_t *async_callback_receive(exch_mgmt_t); 466 extern async_sess_t *async_callback_receive_start(exch_mgmt_t, ipc_call_t *); 395 extern int async_data_write_forward_fast(int, sysarg_t, sysarg_t, sysarg_t, 396 sysarg_t, sysarg_t, ipc_call_t *); 467 397 468 398 #endif
Note:
See TracChangeset
for help on using the changeset viewer.
