Rev 960 | Rev 999 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed
Rev 960 | Rev 966 | ||
---|---|---|---|
Line 27... | Line 27... | ||
27 | */ |
27 | */ |
28 | 28 | ||
29 | #include <ipc.h> |
29 | #include <ipc.h> |
30 | #include <libc.h> |
30 | #include <libc.h> |
31 | 31 | ||
32 | int ipc_call_sync(int phoneid, int arg1, int arg2, ipc_data_t *resdata) |
32 | int ipc_call_sync(int phoneid, sysarg_t method, sysarg_t arg1, |
- | 33 | sysarg_t *result) |
|
33 | { |
34 | { |
- | 35 | ipc_data_t resdata; |
|
- | 36 | int callres; |
|
- | 37 | ||
34 | return __SYSCALL4(SYS_IPC_CALL_SYNC, phoneid, arg1, arg2, |
38 | callres = __SYSCALL4(SYS_IPC_CALL_SYNC, phoneid, method, arg1, |
35 | (sysarg_t)resdata); |
39 | (sysarg_t)&resdata); |
- | 40 | if (callres) |
|
- | 41 | return callres; |
|
- | 42 | if (result) |
|
- | 43 | *result = IPC_GET_ARG1(resdata); |
|
- | 44 | return IPC_GET_RETVAL(resdata); |
|
36 | } |
45 | } |
37 | 46 | ||
38 | /* |
- | |
- | 47 | int ipc_call_sync_3(int phoneid, sysarg_t method, sysarg_t arg1, |
|
39 | int ipc_call_async() |
48 | sysarg_t arg2, sysarg_t arg3, |
- | 49 | sysarg_t *result1, sysarg_t *result2, sysarg_t *result3) |
|
40 | { |
50 | { |
- | 51 | ipc_data_t data; |
|
- | 52 | int callres; |
|
- | 53 | ||
- | 54 | IPC_SET_METHOD(data, method); |
|
- | 55 | IPC_SET_ARG1(data, arg1); |
|
- | 56 | IPC_SET_ARG2(data, arg2); |
|
- | 57 | IPC_SET_ARG3(data, arg3); |
|
- | 58 | ||
- | 59 | callres = __SYSCALL2(SYS_IPC_CALL_SYNC_MEDIUM, phoneid, (sysarg_t)&data); |
|
- | 60 | if (callres) |
|
- | 61 | return callres; |
|
- | 62 | ||
- | 63 | if (result1) |
|
- | 64 | *result1 = IPC_GET_ARG1(data); |
|
- | 65 | if (result2) |
|
- | 66 | *result2 = IPC_GET_ARG2(data); |
|
- | 67 | if (result3) |
|
- | 68 | *result3 = IPC_GET_ARG3(data); |
|
- | 69 | return IPC_GET_RETVAL(data); |
|
- | 70 | } |
|
- | 71 | ||
- | 72 | /** Send asynchronous message |
|
- | 73 | * |
|
- | 74 | * - if fatal error, call callback handler with proper error code |
|
- | 75 | * - if message cannot be temporarily sent, add to queue |
|
- | 76 | */ |
|
- | 77 | void ipc_call_async_2(int phoneid, sysarg_t method, sysarg_t arg1, |
|
- | 78 | sysarg_t arg2, |
|
- | 79 | ipc_async_callback_t callback) |
|
- | 80 | { |
|
- | 81 | ipc_callid_t callid; |
|
- | 82 | ipc_data_t data; /* Data storage for saving calls */ |
|
- | 83 | ||
- | 84 | callid = __SYSCALL4(SYS_IPC_CALL_ASYNC, phoneid, method, arg1, arg2); |
|
- | 85 | if (callid == IPC_CALLRET_FATAL) { |
|
- | 86 | /* Call asynchronous handler with error code */ |
|
- | 87 | IPC_SET_RETVAL(data, IPC_CALLRET_FATAL); |
|
- | 88 | callback(&data); |
|
- | 89 | return; |
|
- | 90 | } |
|
- | 91 | if (callid == IPC_CALLRET_TEMPORARY) { |
|
- | 92 | /* Add asynchronous call to queue of non-dispatched async calls */ |
|
- | 93 | IPC_SET_METHOD(data, method); |
|
- | 94 | IPC_SET_ARG1(data, arg1); |
|
- | 95 | IPC_SET_ARG2(data, arg2); |
|
- | 96 | ||
- | 97 | return; |
|
- | 98 | } |
|
- | 99 | /* Add callid to list of dispatched calls */ |
|
41 | |
100 | |
42 | } |
101 | } |
43 | 102 | ||
- | 103 | ||
- | 104 | /** Send answer to a received call */ |
|
- | 105 | void ipc_answer(ipc_callid_t callid, sysarg_t retval, sysarg_t arg1, |
|
44 | int ipc_answer() |
106 | sysarg_t arg2) |
45 | { |
107 | { |
- | 108 | __SYSCALL4(SYS_IPC_ANSWER, callid, retval, arg1, arg2); |
|
46 | } |
109 | } |
47 | */ |
110 | |
48 | 111 | ||
49 | /** Call syscall function sys_ipc_wait_for_call */ |
112 | /** Call syscall function sys_ipc_wait_for_call */ |
50 | static inline ipc_callid_t _ipc_wait_for_call(ipc_data_t *data, int flags) |
113 | static inline ipc_callid_t _ipc_wait_for_call(ipc_data_t *data, int flags) |
51 | { |
114 | { |
52 | return __SYSCALL2(SYS_IPC_WAIT, (sysarg_t)data, flags); |
115 | return __SYSCALL2(SYS_IPC_WAIT, (sysarg_t)data, flags); |
Line 58... | Line 121... | ||
58 | */ |
121 | */ |
59 | int ipc_wait_for_call(ipc_data_t *data, int flags) |
122 | int ipc_wait_for_call(ipc_data_t *data, int flags) |
60 | { |
123 | { |
61 | ipc_callid_t callid; |
124 | ipc_callid_t callid; |
62 | 125 | ||
- | 126 | do { |
|
- | 127 | /* Try to dispatch non-dispatched async calls */ |
|
63 | callid = _ipc_wait_for_call(data, flags); |
128 | callid = _ipc_wait_for_call(data, flags); |
- | 129 | if (callid & IPC_CALLID_ANSWERED) { |
|
64 | /* TODO: Handle async replies etc.. */ |
130 | /* TODO: Call async answer handler */ |
- | 131 | } |
|
- | 132 | } while (callid & IPC_CALLID_ANSWERED); |
|
65 | return callid; |
133 | return callid; |
66 | } |
134 | } |