Subversion Repositories HelenOS

Rev

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

Rev 4327 Rev 4581
Line 42... Line 42...
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 
 
 46 
 
- 
 
 47 
extern atomic_t async_futex;
- 
 
 48 
 
47 
static inline void async_manager(void)
 49 
static inline void async_manager(void)
48 
{
 50 
{
49 
    fibril_switch(FIBRIL_TO_MANAGER);
 51 
    fibril_switch(FIBRIL_TO_MANAGER);
50 
}
 52 
}
51 
 
 53 
 
52 
ipc_callid_t async_get_call_timeout(ipc_call_t *call, suseconds_t usecs);
 54 
extern ipc_callid_t async_get_call_timeout(ipc_call_t *call, suseconds_t usecs);
- 
 
 55 
 
53 
static inline ipc_callid_t async_get_call(ipc_call_t *data)
 56 
static inline ipc_callid_t async_get_call(ipc_call_t *data)
54 
{
 57 
{
55 
    return async_get_call_timeout(data, 0);
 58 
    return async_get_call_timeout(data, 0);
56 
}
 59 
}
57 
 
 60 
 
Line 84... Line 87...
84 
    ipc_call_t *dataptr);
 87 
    ipc_call_t *dataptr);
85 
extern void async_wait_for(aid_t amsgid, ipcarg_t *result);
 88 
extern void async_wait_for(aid_t amsgid, ipcarg_t *result);
86 
extern int async_wait_timeout(aid_t amsgid, ipcarg_t *retval,
 89 
extern int async_wait_timeout(aid_t amsgid, ipcarg_t *retval,
87 
    suseconds_t timeout);
 90 
    suseconds_t timeout);
88 
 
 91 
 
89 
fid_t async_new_connection(ipcarg_t in_phone_hash, ipc_callid_t callid,
 92 
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 *));
 93 
    ipc_call_t *call, void (*cthread)(ipc_callid_t, ipc_call_t *));
91 
void async_usleep(suseconds_t timeout);
 94 
extern void async_usleep(suseconds_t timeout);
92 
void async_create_manager(void);
 95 
extern void async_create_manager(void);
93 
void async_destroy_manager(void);
 96 
extern void async_destroy_manager(void);
94 
int _async_init(void);
 97 
extern int _async_init(void);
95 
 
 98 
 
96 
extern void async_set_client_connection(async_client_conn_t conn);
 99 
extern void async_set_client_connection(async_client_conn_t conn);
97 
extern void async_set_interrupt_received(async_client_conn_t conn);
 100 
extern void async_set_interrupt_received(async_client_conn_t conn);
98 
 
 101 
 
99 
/* Wrappers for simple communication */
 102 
/* Wrappers for simple communication */
Line 251... Line 254...
251 
static inline void async_serialize_end(void)
 254 
static inline void async_serialize_end(void)
252 
{
 255 
{
253 
    fibril_dec_sercount();
 256 
    fibril_dec_sercount();
254 
}
 257 
}
255 
 
 258 
 
256 
extern atomic_t async_futex;
 - 
 
257 
 
 - 
 
258 
#endif
 259 
#endif
259 
 
 260 
 
260 
/** @}
 261 
/** @}
261 
 */
 262 
 */