Rev 4324 | Rev 4542 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed
Rev 4324 | Rev 4475 | ||
---|---|---|---|
Line 41... | Line 41... | ||
41 | #include <atomic.h> |
41 | #include <atomic.h> |
42 | #include <bool.h> |
42 | #include <bool.h> |
43 | 43 | ||
44 | typedef ipc_callid_t aid_t; |
44 | typedef ipc_callid_t aid_t; |
45 | typedef void (*async_client_conn_t)(ipc_callid_t callid, ipc_call_t *call); |
45 | typedef void (*async_client_conn_t)(ipc_callid_t callid, ipc_call_t *call); |
- | 46 | typedef void (*async_pending_t)(void); |
|
- | 47 | ||
- | 48 | extern atomic_t async_futex; |
|
46 | 49 | ||
47 | static inline void async_manager(void) |
50 | static inline void async_manager(void) |
48 | { |
51 | { |
49 | fibril_switch(FIBRIL_TO_MANAGER); |
52 | fibril_switch(FIBRIL_TO_MANAGER); |
50 | } |
53 | } |
51 | 54 | ||
52 | ipc_callid_t async_get_call_timeout(ipc_call_t *call, suseconds_t usecs); |
55 | extern ipc_callid_t async_get_call_timeout(ipc_call_t *call, suseconds_t usecs); |
- | 56 | ||
53 | static inline ipc_callid_t async_get_call(ipc_call_t *data) |
57 | static inline ipc_callid_t async_get_call(ipc_call_t *data) |
54 | { |
58 | { |
55 | return async_get_call_timeout(data, 0); |
59 | return async_get_call_timeout(data, 0); |
56 | } |
60 | } |
57 | 61 | ||
Line 84... | Line 88... | ||
84 | ipc_call_t *dataptr); |
88 | ipc_call_t *dataptr); |
85 | extern void async_wait_for(aid_t amsgid, ipcarg_t *result); |
89 | extern void async_wait_for(aid_t amsgid, ipcarg_t *result); |
86 | extern int async_wait_timeout(aid_t amsgid, ipcarg_t *retval, |
90 | extern int async_wait_timeout(aid_t amsgid, ipcarg_t *retval, |
87 | suseconds_t timeout); |
91 | suseconds_t timeout); |
88 | 92 | ||
89 | fid_t async_new_connection(ipcarg_t in_phone_hash, ipc_callid_t callid, |
93 | extern fid_t async_new_connection(ipcarg_t in_phone_hash, ipc_callid_t callid, |
90 | ipc_call_t *call, void (*cthread)(ipc_callid_t, ipc_call_t *)); |
94 | ipc_call_t *call, void (*cthread)(ipc_callid_t, ipc_call_t *)); |
91 | void async_usleep(suseconds_t timeout); |
95 | extern void async_usleep(suseconds_t timeout); |
92 | void async_create_manager(void); |
96 | extern void async_create_manager(void); |
93 | void async_destroy_manager(void); |
97 | extern void async_destroy_manager(void); |
94 | int _async_init(void); |
98 | extern int _async_init(void); |
95 | 99 | ||
96 | extern void async_set_client_connection(async_client_conn_t conn); |
100 | extern void async_set_client_connection(async_client_conn_t conn); |
97 | extern void async_set_interrupt_received(async_client_conn_t conn); |
101 | extern void async_set_interrupt_received(async_client_conn_t conn); |
- | 102 | extern void async_set_pending(async_pending_t pend); |
|
98 | 103 | ||
99 | /* Wrappers for simple communication */ |
104 | /* Wrappers for simple communication */ |
100 | #define async_msg_0(phone, method) \ |
105 | #define async_msg_0(phone, method) \ |
101 | ipc_call_async_0((phone), (method), NULL, NULL, true) |
106 | ipc_call_async_0((phone), (method), NULL, NULL, true) |
102 | #define async_msg_1(phone, method, arg1) \ |
107 | #define async_msg_1(phone, method, arg1) \ |
Line 251... | Line 256... | ||
251 | static inline void async_serialize_end(void) |
256 | static inline void async_serialize_end(void) |
252 | { |
257 | { |
253 | fibril_dec_sercount(); |
258 | fibril_dec_sercount(); |
254 | } |
259 | } |
255 | 260 | ||
256 | extern atomic_t async_futex; |
- | |
257 | - | ||
258 | #endif |
261 | #endif |
259 | 262 | ||
260 | /** @} |
263 | /** @} |
261 | */ |
264 | */ |