Subversion Repositories HelenOS

Rev

Rev 2568 | Rev 4002 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 2568 Rev 2621
Line 37... Line 37...
37 
 
 37 
 
38 
#include <ipc/ipc.h>
 38 
#include <ipc/ipc.h>
39 
#include <fibril.h>
 39 
#include <fibril.h>
40 
#include <sys/time.h>
 40 
#include <sys/time.h>
41 
#include <atomic.h>
 41 
#include <atomic.h>
- 
 
 42 
#include <bool.h>
42 
 
 43 
 
43 
typedef ipc_callid_t aid_t;
 44 
typedef ipc_callid_t aid_t;
44 
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);
45 
 
 46 
 
46 
static inline void async_manager(void)
 47 
static inline void async_manager(void)
Line 52... Line 53...
52 
static inline ipc_callid_t async_get_call(ipc_call_t *data)
 53 
static inline ipc_callid_t async_get_call(ipc_call_t *data)
53 
{
 54 
{
54 
    return async_get_call_timeout(data, 0);
 55 
    return async_get_call_timeout(data, 0);
55 
}
 56 
}
56 
 
 57 
 
57 
aid_t async_send_2(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2,
 - 
 
58 
    ipc_call_t *dataptr);
 - 
 
59 
aid_t async_send_3(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2,
 - 
 
60 
    ipcarg_t arg3, ipc_call_t *dataptr);
 - 
 
61 
void async_wait_for(aid_t amsgid, ipcarg_t *result);
 - 
 
62 
int async_wait_timeout(aid_t amsgid, ipcarg_t *retval, suseconds_t timeout);
 - 
 
63 
 
 58 
/*
64 
/** Pseudo-synchronous message sending
 59 
 * User-friendly wrappers for async_send_fast() and async_send_slow(). The
65 
 *
 - 
 
- 
 
 60 
 * macros are in the form async_send_m(), where m denotes the number of payload
66 
 * Send message through IPC, wait in the event loop, until it is received
 61 
 * arguments.  Each macros chooses between the fast and the slow version based
67 
 *
 62 
 * on m.
68 
 * @return Return code of message
 - 
 
69 
 */
 63 
 */
70 
static inline ipcarg_t async_req_2(int phoneid, ipcarg_t method, ipcarg_t arg1,
 - 
 
71 
    ipcarg_t arg2, ipcarg_t *r1, ipcarg_t *r2)
 - 
 
72 
{
 - 
 
73 
    ipc_call_t result;
 - 
 
74 
    ipcarg_t rc;
 - 
 
75 
 
 - 
 
76 
    aid_t eid = async_send_2(phoneid, method, arg1, arg2, &result);
 - 
 
77 
    async_wait_for(eid, &rc);
 - 
 
78 
    if (r1)
 - 
 
79 
        *r1 = IPC_GET_ARG1(result);
 - 
 
80 
    if (r2)
 - 
 
81 
        *r2 = IPC_GET_ARG2(result);
 - 
 
82 
    return rc;
 - 
 
83 
}
 - 
 
84 
#define async_req(phoneid, method, arg1, r1) \
 - 
 
85 
    async_req_2(phoneid, method, arg1, 0, r1, 0)
 - 
 
86 
 
 - 
 
87 
static inline ipcarg_t async_req_3(int phoneid, ipcarg_t method, ipcarg_t arg1,
 - 
 
88 
    ipcarg_t arg2, ipcarg_t arg3, ipcarg_t *r1, ipcarg_t *r2, ipcarg_t *r3)
 - 
 
89 
{
 - 
 
90 
    ipc_call_t result;
 - 
 
91 
    ipcarg_t rc;
 - 
 
92 
 
 - 
 
93 
    aid_t eid = async_send_3(phoneid, method, arg1, arg2, arg3, &result);
 - 
 
94 
    async_wait_for(eid, &rc);
 - 
 
95 
    if (r1)
 - 
 
96 
        *r1 = IPC_GET_ARG1(result);
 - 
 
97 
    if (r2)
 - 
 
98 
        *r2 = IPC_GET_ARG2(result);
 - 
 
99 
    if (r3)
 - 
 
100 
        *r3 = IPC_GET_ARG3(result);
 - 
 
101 
    return rc;
 - 
 
102 
}
 - 
 
103 
 
 64 
 
- 
 
 65 
#define async_send_0(phoneid, method, dataptr) \
- 
 
 66 
    async_send_fast((phoneid), (method), 0, 0, 0, 0, (dataptr))
- 
 
 67 
#define async_send_1(phoneid, method, arg1, dataptr) \
- 
 
 68 
    async_send_fast((phoneid), (method), (arg1), 0, 0, 0, (dataptr))
- 
 
 69 
#define async_send_2(phoneid, method, arg1, arg2, dataptr) \
- 
 
 70 
    async_send_fast((phoneid), (method), (arg1), (arg2), 0, 0, (dataptr))
- 
 
 71 
#define async_send_3(phoneid, method, arg1, arg2, arg3, dataptr) \
- 
 
 72 
    async_send_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (dataptr))
- 
 
 73 
#define async_send_4(phoneid, method, arg1, arg2, arg3, arg4, dataptr) \
- 
 
 74 
    async_send_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 75 
        (dataptr))
- 
 
 76 
#define async_send_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, dataptr) \
- 
 
 77 
    async_send_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 78 
        (arg5), (dataptr))
- 
 
 79 
 
- 
 
 80 
extern aid_t async_send_fast(int phoneid, ipcarg_t method, ipcarg_t arg1,
- 
 
 81 
    ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipc_call_t *dataptr);
- 
 
 82 
extern aid_t async_send_slow(int phoneid, ipcarg_t method, ipcarg_t arg1,
- 
 
 83 
    ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipcarg_t arg5,
- 
 
 84 
    ipc_call_t *dataptr);
- 
 
 85 
extern void async_wait_for(aid_t amsgid, ipcarg_t *result);
- 
 
 86 
extern int async_wait_timeout(aid_t amsgid, ipcarg_t *retval,
- 
 
 87 
    suseconds_t timeout);
104 
 
 88 
 
105 
fid_t async_new_connection(ipcarg_t in_phone_hash,ipc_callid_t callid,
 89 
fid_t async_new_connection(ipcarg_t in_phone_hash,ipc_callid_t callid,
106 
    ipc_call_t *call, void (*cthread)(ipc_callid_t,ipc_call_t *));
 90 
    ipc_call_t *call, void (*cthread)(ipc_callid_t,ipc_call_t *));
107 
void async_usleep(suseconds_t timeout);
 91 
void async_usleep(suseconds_t timeout);
108 
void async_create_manager(void);
 92 
void async_create_manager(void);
109 
void async_destroy_manager(void);
 93 
void async_destroy_manager(void);
110 
void async_set_client_connection(async_client_conn_t conn);
 - 
 
111 
void async_set_interrupt_received(async_client_conn_t conn);
 - 
 
112 
int _async_init(void);
 94 
int _async_init(void);
113 
 
 95 
 
- 
 
 96 
extern void async_set_client_connection(async_client_conn_t conn);
- 
 
 97 
extern void async_set_interrupt_received(async_client_conn_t conn);
114 
 
 98 
 
115 
/* Primitve functions for IPC communication */
 99 
/* Wrappers for simple communication */
- 
 
 100 
#define async_msg_0(phone, method) \
- 
 
 101 
    ipc_call_async_0((phone), (method), NULL, NULL, !in_interrupt_handler())
- 
 
 102 
#define async_msg_1(phone, method, arg1) \
- 
 
 103 
    ipc_call_async_1((phone), (method), (arg1), NULL, NULL, \
- 
 
 104 
        !in_interrupt_handler())
- 
 
 105 
#define async_msg_2(phone, method, arg1, arg2) \
- 
 
 106 
    ipc_call_async_2((phone), (method), (arg1), (arg2), NULL, NULL, \
- 
 
 107 
        !in_interrupt_handler())
- 
 
 108 
#define async_msg_3(phone, method, arg1, arg2, arg3) \
- 
 
 109 
    ipc_call_async_3((phone), (method), (arg1), (arg2), (arg3), NULL, NULL, \
- 
 
 110 
        !in_interrupt_handler())
116 
void async_msg_3(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2,
 111 
#define async_msg_4(phone, method, arg1, arg2, arg3, arg4) \
- 
 
 112 
    ipc_call_async_4((phone), (method), (arg1), (arg2), (arg3), (arg4), NULL, \
- 
 
 113 
        NULL, !in_interrupt_handler())
- 
 
 114 
#define async_msg_5(phone, method, arg1, arg2, arg3, arg4, arg5) \
- 
 
 115 
    ipc_call_async_5((phone), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 116 
        (arg5), NULL, NULL, !in_interrupt_handler())
- 
 
 117 
 
- 
 
 118 
/*
- 
 
 119 
 * User-friendly wrappers for async_req_fast() and async_req_slow(). The macros
- 
 
 120 
 * are in the form async_req_m_n(), where m is the number of payload arguments
- 
 
 121 
 * and n is the number of return arguments. The macros decidce between the fast
- 
 
 122 
 * and slow verion based on m.
- 
 
 123 
 */
- 
 
 124 
#define async_req_0_0(phoneid, method) \
- 
 
 125 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, NULL, NULL, NULL, NULL, \
- 
 
 126 
    NULL)
- 
 
 127 
#define async_req_0_1(phoneid, method, r1) \
- 
 
 128 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), NULL, NULL, NULL, \
- 
 
 129 
    NULL)
- 
 
 130 
#define async_req_0_2(phoneid, method, r1, r2) \
- 
 
 131 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), NULL, NULL, \
- 
 
 132 
    NULL)
- 
 
 133 
#define async_req_0_3(phoneid, method, r1, r2, r3) \
- 
 
 134 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), NULL, \
- 
 
 135 
    NULL)
- 
 
 136 
#define async_req_0_4(phoneid, method, r1, r2, r3, r4) \
- 
 
 137 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), (r4), \
- 
 
 138 
    NULL)
- 
 
 139 
#define async_req_0_5(phoneid, method, r1, r2, r3, r4, r5) \
- 
 
 140 
    async_req_fast((phoneid), (method), 0, 0, 0, 0, (r1), (r2), (r3), (r4), \
- 
 
 141 
    (r5))
- 
 
 142 
#define async_req_1_0(phoneid, method, arg1) \
- 
 
 143 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, NULL, NULL, NULL, \
- 
 
 144 
    NULL, NULL)
- 
 
 145 
#define async_req_1_1(phoneid, method, arg1, rc1) \
- 
 
 146 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), NULL, NULL, \
- 
 
 147 
    NULL, NULL)
- 
 
 148 
#define async_req_1_2(phoneid, method, arg1, rc1, rc2) \
- 
 
 149 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), NULL, \
- 
 
 150 
    NULL, NULL)
- 
 
 151 
#define async_req_1_3(phoneid, method, arg1, rc1, rc2, rc3) \
- 
 
 152 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \
- 
 
 153 
    NULL, NULL)
- 
 
 154 
#define async_req_1_4(phoneid, method, arg1, rc1, rc2, rc3, rc4) \
- 
 
 155 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \
- 
 
 156 
    (rc4), NULL)
- 
 
 157 
#define async_req_1_5(phoneid, method, arg1, rc1, rc2, rc3, rc4, rc5) \
- 
 
 158 
    async_req_fast((phoneid), (method), (arg1), 0, 0, 0, (rc1), (rc2), (rc3), \
- 
 
 159 
    (rc4), (rc5))
- 
 
 160 
#define async_req_2_0(phoneid, method, arg1, arg2) \
- 
 
 161 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, NULL, NULL, \
- 
 
 162 
    NULL, NULL, NULL)
- 
 
 163 
#define async_req_2_1(phoneid, method, arg1, arg2, rc1) \
- 
 
 164 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), NULL, \
- 
 
 165 
    NULL, NULL, NULL)
- 
 
 166 
#define async_req_2_2(phoneid, method, arg1, arg2, rc1, rc2) \
- 
 
 167 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \
- 
 
 168 
    NULL, NULL, NULL)
- 
 
 169 
#define async_req_2_3(phoneid, method, arg1, arg2, rc1, rc2, rc3) \
- 
 
 170 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \
- 
 
 171 
    (rc3), NULL, NULL)
- 
 
 172 
#define async_req_2_4(phoneid, method, arg1, arg2, rc1, rc2, rc3, rc4) \
- 
 
 173 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \
- 
 
 174 
    (rc3), (rc4), NULL)
- 
 
 175 
#define async_req_2_5(phoneid, method, arg1, arg2, rc1, rc2, rc3, rc4, rc5) \
- 
 
 176 
    async_req_fast((phoneid), (method), (arg1), (arg2), 0, 0, (rc1), (rc2), \
- 
 
 177 
    (rc3), (rc4), (rc5))
- 
 
 178 
#define async_req_3_0(phoneid, method, arg1, arg2, arg3) \
- 
 
 179 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, NULL, NULL, \
- 
 
 180 
    NULL, NULL, NULL)
- 
 
 181 
#define async_req_3_1(phoneid, method, arg1, arg2, arg3, rc1) \
- 
 
 182 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \
- 
 
 183 
    NULL, NULL, NULL, NULL)
- 
 
 184 
#define async_req_3_2(phoneid, method, arg1, arg2, arg3, rc1, rc2) \
- 
 
 185 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \
- 
 
 186 
    (rc2), NULL, NULL, NULL)
- 
 
 187 
#define async_req_3_3(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3) \
- 
 
 188 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \
- 
 
 189 
    (rc2), (rc3), NULL, NULL)
- 
 
 190 
#define async_req_3_4(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4) \
- 
 
 191 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \
- 
 
 192 
    (rc2), (rc3), (rc4), NULL)
- 
 
 193 
#define async_req_3_5(phoneid, method, arg1, arg2, arg3, rc1, rc2, rc3, rc4, \
- 
 
 194 
    rc5) \
- 
 
 195 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), 0, (rc1), \
- 
 
 196 
        (rc2), (rc3), (rc4), (rc5))
- 
 
 197 
#define async_req_4_0(phoneid, method, arg1, arg2, arg3, arg4) \
- 
 
 198 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), NULL, \
- 
 
 199 
    NULL, NULL, NULL, NULL)
- 
 
 200 
#define async_req_4_1(phoneid, method, arg1, arg2, arg3, arg4, rc1) \
- 
 
 201 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \
- 
 
 202 
    NULL, NULL, NULL, NULL)
- 
 
 203 
#define async_req_4_2(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2) \
- 
 
 204 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \
- 
 
 205 
    (rc2), NULL, NULL, NULL)
- 
 
 206 
#define async_req_4_3(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3) \
- 
 
 207 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), (rc1), \
- 
 
 208 
    (rc2), (rc3), NULL, NULL)
- 
 
 209 
#define async_req_4_4(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \
- 
 
 210 
    rc4) \
- 
 
 211 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 212 
        (rc1), (rc2), (rc3), (rc4), NULL)
- 
 
 213 
#define async_req_4_5(phoneid, method, arg1, arg2, arg3, arg4, rc1, rc2, rc3, \
117 
    ipcarg_t arg3);
 214 
    rc4, rc5) \
- 
 
 215 
    async_req_fast((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 216 
        (rc1), (rc2), (rc3), (rc4), (rc5))
118 
void async_msg_2(int phoneid, ipcarg_t method, ipcarg_t arg1, ipcarg_t arg2);
 217 
#define async_req_5_0(phoneid, method, arg1, arg2, arg3, arg4, arg5) \
- 
 
 218 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 219 
        (arg5), NULL, NULL, NULL, NULL, NULL)
119 
#define async_msg(ph, m, a1) async_msg_2(ph, m, a1, 0)
 220 
#define async_req_5_1(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1) \
- 
 
 221 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 222 
    (arg5), (rc1), NULL, NULL, NULL, NULL)
- 
 
 223 
#define async_req_5_2(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2) \
- 
 
 224 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 225 
    (arg5), (rc1), (rc2), NULL, NULL, NULL)
- 
 
 226 
#define async_req_5_3(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \
- 
 
 227 
    rc3) \
- 
 
 228 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 229 
        (arg5), (rc1), (rc2), (rc3), NULL, NULL)
- 
 
 230 
#define async_req_5_4(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \
- 
 
 231 
    rc3, rc4) \
- 
 
 232 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 233 
        (arg5), (rc1), (rc2), (rc3), (rc4), NULL)
- 
 
 234 
#define async_req_5_5(phoneid, method, arg1, arg2, arg3, arg4, arg5, rc1, rc2, \
- 
 
 235 
    rc3, rc4, rc5) \
- 
 
 236 
    async_req_slow((phoneid), (method), (arg1), (arg2), (arg3), (arg4), \
- 
 
 237 
        (arg5), (rc1), (rc2), (rc3), (rc4), (rc5))
- 
 
 238 
 
- 
 
 239 
extern ipcarg_t async_req_fast(int phoneid, ipcarg_t method, ipcarg_t arg1,
- 
 
 240 
    ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipcarg_t *r1, ipcarg_t *r2,
- 
 
 241 
    ipcarg_t *r3, ipcarg_t *r4, ipcarg_t *r5);
- 
 
 242 
extern ipcarg_t async_req_slow(int phoneid, ipcarg_t method, ipcarg_t arg1,
- 
 
 243 
    ipcarg_t arg2, ipcarg_t arg3, ipcarg_t arg4, ipcarg_t arg5, ipcarg_t *r1,
- 
 
 244 
    ipcarg_t *r2, ipcarg_t *r3, ipcarg_t *r4, ipcarg_t *r5);
120 
 
 245 
 
121 
static inline void async_serialize_start(void)
 246 
static inline void async_serialize_start(void)
122 
{
 247 
{
123 
    fibril_inc_sercount();
 248 
    fibril_inc_sercount();
124 
}
 249 
}
Line 126... Line 251...
126 
static inline void async_serialize_end(void)
 251 
static inline void async_serialize_end(void)
127 
{
 252 
{
128 
    fibril_dec_sercount();
 253 
    fibril_dec_sercount();
129 
}
 254 
}
130 
 
 255 
 
- 
 
 256 
extern bool in_interrupt_handler(void);
- 
 
 257 
 
131 
extern atomic_t async_futex;
 258 
extern atomic_t async_futex;
- 
 
 259 
 
132 
#endif
 260 
#endif
133 
 
 261 
 
134 
/** @}
 262 
/** @}
135 
 */
 263 
 */