source: mainline/uspace/app/trace/ipcp.c@ 7e752b2

lfn serial ticket/834-toolchain-update topic/msim-upgrade topic/simplify-dev-export
Last change on this file since 7e752b2 was 7e752b2, checked in by Martin Decky <martin@…>, 15 years ago
  • correct printf() formatting strings and corresponding arguments
  • minor cstyle changes and other small fixes
  • Property mode set to 100644
File size: 8.8 KB
RevLine 
[9a1b20c]1/*
2 * Copyright (c) 2008 Jiri Svoboda
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29/** @addtogroup trace
30 * @{
31 */
32/** @file
33 */
34
35#include <stdio.h>
36#include <stdlib.h>
[d9c8c81]37#include <adt/hash_table.h>
[1ccafee]38#include <sys/typefmt.h>
[9a1b20c]39
40#include "ipc_desc.h"
41#include "proto.h"
[1643855]42#include "trace.h"
[9a1b20c]43#include "ipcp.h"
44
45#define IPCP_CALLID_SYNC 0
46
47typedef struct {
[a5c3f73]48 ipcarg_t phone_hash;
[9a1b20c]49 ipc_call_t question;
[abf3564]50 oper_t *oper;
[9a1b20c]51
[a5c3f73]52 ipc_callid_t call_hash;
[9a1b20c]53
54 link_t link;
55} pending_call_t;
56
57typedef struct {
58 int server;
59 proto_t *proto;
60} connection_t;
61
62#define MAX_PHONE 64
63connection_t connections[MAX_PHONE];
64int have_conn[MAX_PHONE];
65
66#define PCALL_TABLE_CHAINS 32
67hash_table_t pending_calls;
68
[8c125ad]69/*
70 * Pseudo-protocols
71 */
72proto_t *proto_system; /**< Protocol describing system IPC methods. */
73proto_t *proto_unknown; /**< Protocol with no known methods. */
74
[9a1b20c]75static hash_index_t pending_call_hash(unsigned long key[]);
76static int pending_call_compare(unsigned long key[], hash_count_t keys,
77 link_t *item);
78static void pending_call_remove_callback(link_t *item);
79
80hash_table_operations_t pending_call_ops = {
81 .hash = pending_call_hash,
82 .compare = pending_call_compare,
83 .remove_callback = pending_call_remove_callback
84};
85
86
87static hash_index_t pending_call_hash(unsigned long key[])
88{
89// printf("pending_call_hash\n");
90 return key[0] % PCALL_TABLE_CHAINS;
91}
92
93static int pending_call_compare(unsigned long key[], hash_count_t keys,
94 link_t *item)
95{
96 pending_call_t *hs;
97
98// printf("pending_call_compare\n");
99 hs = hash_table_get_instance(item, pending_call_t, link);
100
[a5c3f73]101 // FIXME: this will fail if sizeof(long) < sizeof(void *).
[9a1b20c]102 return key[0] == hs->call_hash;
103}
104
105static void pending_call_remove_callback(link_t *item)
106{
107// printf("pending_call_remove_callback\n");
108}
109
110
111void ipcp_connection_set(int phone, int server, proto_t *proto)
112{
113 if (phone <0 || phone >= MAX_PHONE) return;
114 connections[phone].server = server;
115 connections[phone].proto = proto;
116 have_conn[phone] = 1;
117}
118
119void ipcp_connection_clear(int phone)
120{
121 have_conn[phone] = 0;
122 connections[phone].server = 0;
123 connections[phone].proto = NULL;
124}
125
126static void ipc_m_print(proto_t *proto, ipcarg_t method)
127{
128 oper_t *oper;
129
[8c125ad]130 /* Try system methods first */
131 oper = proto_get_oper(proto_system, method);
[9a1b20c]132
[8c125ad]133 if (oper == NULL && proto != NULL) {
134 /* Not a system method, try the user protocol. */
135 oper = proto_get_oper(proto, method);
[9a1b20c]136 }
137
[8c125ad]138 if (oper != NULL) {
[7e752b2]139 printf("%s (%" PRIun ")", oper->name, method);
[8c125ad]140 return;
[9a1b20c]141 }
142
[7e752b2]143 printf("%" PRIun, method);
[9a1b20c]144}
145
146void ipcp_init(void)
147{
[8c125ad]148 ipc_m_desc_t *desc;
149 oper_t *oper;
150
[abf3564]151 val_type_t arg_def[OPER_MAX_ARGS] = {
152 V_INTEGER,
153 V_INTEGER,
154 V_INTEGER,
155 V_INTEGER,
156 V_INTEGER
157 };
158
[8c125ad]159 /*
160 * Create a pseudo-protocol 'unknown' that has no known methods.
161 */
162 proto_unknown = proto_new("unknown");
163
164 /*
165 * Create a pseudo-protocol 'system' defining names of system IPC
166 * methods.
167 */
168 proto_system = proto_new("system");
169
170 desc = ipc_methods;
171 while (desc->number != 0) {
[abf3564]172 oper = oper_new(desc->name, OPER_MAX_ARGS, arg_def, V_INTEGER,
173 OPER_MAX_ARGS, arg_def);
[8c125ad]174 proto_add_oper(proto_system, desc->number, oper);
175
176 ++desc;
177 }
178
[9a1b20c]179 hash_table_create(&pending_calls, PCALL_TABLE_CHAINS, 1, &pending_call_ops);
180}
181
182void ipcp_cleanup(void)
183{
[8c125ad]184 proto_delete(proto_system);
[9a1b20c]185 hash_table_destroy(&pending_calls);
186}
187
188void ipcp_call_out(int phone, ipc_call_t *call, ipc_callid_t hash)
189{
190 pending_call_t *pcall;
191 proto_t *proto;
192 unsigned long key[1];
[1643855]193 oper_t *oper;
[abf3564]194 ipcarg_t *args;
195 int i;
[9a1b20c]196
197 if (have_conn[phone]) proto = connections[phone].proto;
198 else proto = NULL;
199
[abf3564]200 args = call->args;
201
[1643855]202 if ((display_mask & DM_IPC) != 0) {
[7e752b2]203 printf("Call ID: %p, phone: %d, proto: %s, method: ",
204 (void *) hash, phone,
205 (proto ? proto->name : "n/a"));
[1643855]206 ipc_m_print(proto, IPC_GET_METHOD(*call));
[7e752b2]207 printf(" args: (%" PRIun ", %" PRIun ", %" PRIun ", "
208 "%" PRIun ", %" PRIun ")\n",
209 args[1], args[2], args[3], args[4], args[5]);
[1643855]210 }
211
212
213 if ((display_mask & DM_USER) != 0) {
214
215 if (proto != NULL) {
216 oper = proto_get_oper(proto, IPC_GET_METHOD(*call));
217 } else {
218 oper = NULL;
219 }
220
221 if (oper != NULL) {
222
223 printf("%s(%d).%s", (proto ? proto->name : "n/a"),
224 phone, (oper ? oper->name : "unknown"));
225
[abf3564]226 putchar('(');
227 for (i = 1; i <= oper->argc; ++i) {
228 if (i > 1) printf(", ");
229 val_print(args[i], oper->arg_type[i - 1]);
230 }
231 putchar(')');
232
233 if (oper->rv_type == V_VOID && oper->respc == 0) {
234 /*
235 * No response data (typically the task will
236 * not be interested in the response).
237 * We will not display response.
238 */
239 putchar('.');
240 }
241
242 putchar('\n');
[1643855]243 }
[abf3564]244 } else {
245 oper = NULL;
[1643855]246 }
[9a1b20c]247
248 /* Store call in hash table for response matching */
249
250 pcall = malloc(sizeof(pending_call_t));
251 pcall->phone_hash = phone;
252 pcall->question = *call;
253 pcall->call_hash = hash;
[abf3564]254 pcall->oper = oper;
[9a1b20c]255
256 key[0] = hash;
257
258 hash_table_insert(&pending_calls, key, &pcall->link);
259}
260
[1643855]261static void parse_answer(ipc_callid_t hash, pending_call_t *pcall,
262 ipc_call_t *answer)
[9a1b20c]263{
[a5c3f73]264 ipcarg_t phone;
[9a1b20c]265 ipcarg_t method;
266 ipcarg_t service;
[a5c3f73]267 ipcarg_t retval;
[9a1b20c]268 proto_t *proto;
269 int cphone;
270
[abf3564]271 ipcarg_t *resp;
272 oper_t *oper;
273 int i;
274
[9a1b20c]275// printf("parse_answer\n");
276
277 phone = pcall->phone_hash;
278 method = IPC_GET_METHOD(pcall->question);
279 retval = IPC_GET_RETVAL(*answer);
[1643855]280
[abf3564]281 resp = answer->args;
282
[1643855]283 if ((display_mask & DM_IPC) != 0) {
[7e752b2]284 printf("Response to %p: retval=%" PRIdn ", args = (%" PRIun ", "
285 "%" PRIun ", %" PRIun ", %" PRIun ", %" PRIun ")\n",
286 (void *) hash, retval, IPC_GET_ARG1(*answer),
[1ccafee]287 IPC_GET_ARG2(*answer), IPC_GET_ARG3(*answer),
288 IPC_GET_ARG4(*answer), IPC_GET_ARG5(*answer));
[1643855]289 }
290
291 if ((display_mask & DM_USER) != 0) {
[abf3564]292 oper = pcall->oper;
293
[2e3355a]294 if (oper != NULL && (oper->rv_type != V_VOID || oper->respc > 0)) {
[abf3564]295 printf("->");
296
297 if (oper->rv_type != V_VOID) {
298 putchar(' ');
299 val_print(retval, oper->rv_type);
300 }
301
302 if (oper->respc > 0) {
303 putchar(' ');
304 putchar('(');
305 for (i = 1; i <= oper->respc; ++i) {
306 if (i > 1) printf(", ");
307 val_print(resp[i], oper->resp_type[i - 1]);
308 }
309 putchar(')');
310 }
311
312 putchar('\n');
313 }
[1643855]314 }
[9a1b20c]315
316 if (phone == 0 && method == IPC_M_CONNECT_ME_TO && retval == 0) {
317 /* Connected to a service (through NS) */
318 service = IPC_GET_ARG1(pcall->question);
319 proto = proto_get_by_srv(service);
[8c125ad]320 if (proto == NULL) proto = proto_unknown;
[9a1b20c]321
322 cphone = IPC_GET_ARG5(*answer);
[1643855]323 if ((display_mask & DM_SYSTEM) != 0) {
324 printf("Registering connection (phone %d, protocol: %s)\n", cphone,
325 proto->name);
326 }
[9a1b20c]327 ipcp_connection_set(cphone, 0, proto);
328 }
329}
330
331void ipcp_call_in(ipc_call_t *call, ipc_callid_t hash)
332{
333 link_t *item;
334 pending_call_t *pcall;
335 unsigned long key[1];
336
337// printf("ipcp_call_in()\n");
338
339 if ((hash & IPC_CALLID_ANSWERED) == 0 && hash != IPCP_CALLID_SYNC) {
340 /* Not a response */
[1643855]341 if ((display_mask & DM_IPC) != 0) {
[7e752b2]342 printf("Not a response (hash %p)\n", (void *) hash);
[1643855]343 }
[9a1b20c]344 return;
345 }
346
347 hash = hash & ~IPC_CALLID_ANSWERED;
348 key[0] = hash;
349
350 item = hash_table_find(&pending_calls, key);
351 if (item == NULL) return; // No matching question found
[1643855]352
353 /*
354 * Response matched to question.
355 */
[9a1b20c]356
357 pcall = hash_table_get_instance(item, pending_call_t, link);
358 hash_table_remove(&pending_calls, key, 1);
359
[1643855]360 parse_answer(hash, pcall, call);
[9a1b20c]361 free(pcall);
362}
363
364void ipcp_call_sync(int phone, ipc_call_t *call, ipc_call_t *answer)
365{
366 ipcp_call_out(phone, call, IPCP_CALLID_SYNC);
367 ipcp_call_in(answer, IPCP_CALLID_SYNC);
368}
369
370void ipcp_hangup(int phone, int rc)
371{
[1643855]372 if ((display_mask & DM_SYSTEM) != 0) {
373 printf("Hang phone %d up -> %d\n", phone, rc);
374 ipcp_connection_clear(phone);
375 }
[9a1b20c]376}
377
378/** @}
379 */
Note: See TracBrowser for help on using the repository browser.