Subversion Repositories HelenOS

Rev

Rev 4420 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 4420 Rev 4537
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 
 */