diff options
Diffstat (limited to 'net/irda/iriap.c')
-rw-r--r-- | net/irda/iriap.c | 1089 |
1 files changed, 1089 insertions, 0 deletions
diff --git a/net/irda/iriap.c b/net/irda/iriap.c new file mode 100644 index 000000000000..b8bb78af8b8a --- /dev/null +++ b/net/irda/iriap.c | |||
@@ -0,0 +1,1089 @@ | |||
1 | /********************************************************************* | ||
2 | * | ||
3 | * Filename: iriap.c | ||
4 | * Version: 0.8 | ||
5 | * Description: Information Access Protocol (IAP) | ||
6 | * Status: Experimental. | ||
7 | * Author: Dag Brattli <dagb@cs.uit.no> | ||
8 | * Created at: Thu Aug 21 00:02:07 1997 | ||
9 | * Modified at: Sat Dec 25 16:42:42 1999 | ||
10 | * Modified by: Dag Brattli <dagb@cs.uit.no> | ||
11 | * | ||
12 | * Copyright (c) 1998-1999 Dag Brattli <dagb@cs.uit.no>, | ||
13 | * All Rights Reserved. | ||
14 | * Copyright (c) 2000-2003 Jean Tourrilhes <jt@hpl.hp.com> | ||
15 | * | ||
16 | * This program is free software; you can redistribute it and/or | ||
17 | * modify it under the terms of the GNU General Public License as | ||
18 | * published by the Free Software Foundation; either version 2 of | ||
19 | * the License, or (at your option) any later version. | ||
20 | * | ||
21 | * Neither Dag Brattli nor University of Tromsų admit liability nor | ||
22 | * provide warranty for any of this software. This material is | ||
23 | * provided "AS-IS" and at no charge. | ||
24 | * | ||
25 | ********************************************************************/ | ||
26 | |||
27 | #include <linux/config.h> | ||
28 | #include <linux/module.h> | ||
29 | #include <linux/types.h> | ||
30 | #include <linux/skbuff.h> | ||
31 | #include <linux/string.h> | ||
32 | #include <linux/init.h> | ||
33 | #include <linux/seq_file.h> | ||
34 | |||
35 | #include <asm/byteorder.h> | ||
36 | #include <asm/unaligned.h> | ||
37 | |||
38 | #include <net/irda/irda.h> | ||
39 | #include <net/irda/irttp.h> | ||
40 | #include <net/irda/irlmp.h> | ||
41 | #include <net/irda/irias_object.h> | ||
42 | #include <net/irda/iriap_event.h> | ||
43 | #include <net/irda/iriap.h> | ||
44 | |||
45 | #ifdef CONFIG_IRDA_DEBUG | ||
46 | /* FIXME: This one should go in irlmp.c */ | ||
47 | static const char *ias_charset_types[] = { | ||
48 | "CS_ASCII", | ||
49 | "CS_ISO_8859_1", | ||
50 | "CS_ISO_8859_2", | ||
51 | "CS_ISO_8859_3", | ||
52 | "CS_ISO_8859_4", | ||
53 | "CS_ISO_8859_5", | ||
54 | "CS_ISO_8859_6", | ||
55 | "CS_ISO_8859_7", | ||
56 | "CS_ISO_8859_8", | ||
57 | "CS_ISO_8859_9", | ||
58 | "CS_UNICODE" | ||
59 | }; | ||
60 | #endif /* CONFIG_IRDA_DEBUG */ | ||
61 | |||
62 | static hashbin_t *iriap = NULL; | ||
63 | static void *service_handle; | ||
64 | |||
65 | static void __iriap_close(struct iriap_cb *self); | ||
66 | static int iriap_register_lsap(struct iriap_cb *self, __u8 slsap_sel, int mode); | ||
67 | static void iriap_disconnect_indication(void *instance, void *sap, | ||
68 | LM_REASON reason, struct sk_buff *skb); | ||
69 | static void iriap_connect_indication(void *instance, void *sap, | ||
70 | struct qos_info *qos, __u32 max_sdu_size, | ||
71 | __u8 max_header_size, | ||
72 | struct sk_buff *skb); | ||
73 | static void iriap_connect_confirm(void *instance, void *sap, | ||
74 | struct qos_info *qos, | ||
75 | __u32 max_sdu_size, __u8 max_header_size, | ||
76 | struct sk_buff *skb); | ||
77 | static int iriap_data_indication(void *instance, void *sap, | ||
78 | struct sk_buff *skb); | ||
79 | |||
80 | static void iriap_watchdog_timer_expired(void *data); | ||
81 | |||
82 | static inline void iriap_start_watchdog_timer(struct iriap_cb *self, | ||
83 | int timeout) | ||
84 | { | ||
85 | irda_start_timer(&self->watchdog_timer, timeout, self, | ||
86 | iriap_watchdog_timer_expired); | ||
87 | } | ||
88 | |||
89 | /* | ||
90 | * Function iriap_init (void) | ||
91 | * | ||
92 | * Initializes the IrIAP layer, called by the module initialization code | ||
93 | * in irmod.c | ||
94 | */ | ||
95 | int __init iriap_init(void) | ||
96 | { | ||
97 | struct ias_object *obj; | ||
98 | struct iriap_cb *server; | ||
99 | __u8 oct_seq[6]; | ||
100 | __u16 hints; | ||
101 | |||
102 | /* Allocate master array */ | ||
103 | iriap = hashbin_new(HB_LOCK); | ||
104 | if (!iriap) | ||
105 | return -ENOMEM; | ||
106 | |||
107 | /* Object repository - defined in irias_object.c */ | ||
108 | irias_objects = hashbin_new(HB_LOCK); | ||
109 | if (!irias_objects) { | ||
110 | IRDA_WARNING("%s: Can't allocate irias_objects hashbin!\n", | ||
111 | __FUNCTION__); | ||
112 | hashbin_delete(iriap, NULL); | ||
113 | return -ENOMEM; | ||
114 | } | ||
115 | |||
116 | /* | ||
117 | * Register some default services for IrLMP | ||
118 | */ | ||
119 | hints = irlmp_service_to_hint(S_COMPUTER); | ||
120 | service_handle = irlmp_register_service(hints); | ||
121 | |||
122 | /* Register the Device object with LM-IAS */ | ||
123 | obj = irias_new_object("Device", IAS_DEVICE_ID); | ||
124 | irias_add_string_attrib(obj, "DeviceName", "Linux", IAS_KERNEL_ATTR); | ||
125 | |||
126 | oct_seq[0] = 0x01; /* Version 1 */ | ||
127 | oct_seq[1] = 0x00; /* IAS support bits */ | ||
128 | oct_seq[2] = 0x00; /* LM-MUX support bits */ | ||
129 | #ifdef CONFIG_IRDA_ULTRA | ||
130 | oct_seq[2] |= 0x04; /* Connectionless Data support */ | ||
131 | #endif | ||
132 | irias_add_octseq_attrib(obj, "IrLMPSupport", oct_seq, 3, | ||
133 | IAS_KERNEL_ATTR); | ||
134 | irias_insert_object(obj); | ||
135 | |||
136 | /* | ||
137 | * Register server support with IrLMP so we can accept incoming | ||
138 | * connections | ||
139 | */ | ||
140 | server = iriap_open(LSAP_IAS, IAS_SERVER, NULL, NULL); | ||
141 | if (!server) { | ||
142 | IRDA_DEBUG(0, "%s(), unable to open server\n", __FUNCTION__); | ||
143 | return -1; | ||
144 | } | ||
145 | iriap_register_lsap(server, LSAP_IAS, IAS_SERVER); | ||
146 | |||
147 | return 0; | ||
148 | } | ||
149 | |||
150 | /* | ||
151 | * Function iriap_cleanup (void) | ||
152 | * | ||
153 | * Initializes the IrIAP layer, called by the module cleanup code in | ||
154 | * irmod.c | ||
155 | */ | ||
156 | void __exit iriap_cleanup(void) | ||
157 | { | ||
158 | irlmp_unregister_service(service_handle); | ||
159 | |||
160 | hashbin_delete(iriap, (FREE_FUNC) __iriap_close); | ||
161 | hashbin_delete(irias_objects, (FREE_FUNC) __irias_delete_object); | ||
162 | } | ||
163 | |||
164 | /* | ||
165 | * Function iriap_open (void) | ||
166 | * | ||
167 | * Opens an instance of the IrIAP layer, and registers with IrLMP | ||
168 | */ | ||
169 | struct iriap_cb *iriap_open(__u8 slsap_sel, int mode, void *priv, | ||
170 | CONFIRM_CALLBACK callback) | ||
171 | { | ||
172 | struct iriap_cb *self; | ||
173 | |||
174 | IRDA_DEBUG(2, "%s()\n", __FUNCTION__); | ||
175 | |||
176 | self = kmalloc(sizeof(struct iriap_cb), GFP_ATOMIC); | ||
177 | if (!self) { | ||
178 | IRDA_WARNING("%s: Unable to kmalloc!\n", __FUNCTION__); | ||
179 | return NULL; | ||
180 | } | ||
181 | |||
182 | /* | ||
183 | * Initialize instance | ||
184 | */ | ||
185 | memset(self, 0, sizeof(struct iriap_cb)); | ||
186 | |||
187 | self->magic = IAS_MAGIC; | ||
188 | self->mode = mode; | ||
189 | if (mode == IAS_CLIENT) | ||
190 | iriap_register_lsap(self, slsap_sel, mode); | ||
191 | |||
192 | self->confirm = callback; | ||
193 | self->priv = priv; | ||
194 | |||
195 | /* iriap_getvaluebyclass_request() will construct packets before | ||
196 | * we connect, so this must have a sane value... Jean II */ | ||
197 | self->max_header_size = LMP_MAX_HEADER; | ||
198 | |||
199 | init_timer(&self->watchdog_timer); | ||
200 | |||
201 | hashbin_insert(iriap, (irda_queue_t *) self, (long) self, NULL); | ||
202 | |||
203 | /* Initialize state machines */ | ||
204 | iriap_next_client_state(self, S_DISCONNECT); | ||
205 | iriap_next_call_state(self, S_MAKE_CALL); | ||
206 | iriap_next_server_state(self, R_DISCONNECT); | ||
207 | iriap_next_r_connect_state(self, R_WAITING); | ||
208 | |||
209 | return self; | ||
210 | } | ||
211 | EXPORT_SYMBOL(iriap_open); | ||
212 | |||
213 | /* | ||
214 | * Function __iriap_close (self) | ||
215 | * | ||
216 | * Removes (deallocates) the IrIAP instance | ||
217 | * | ||
218 | */ | ||
219 | static void __iriap_close(struct iriap_cb *self) | ||
220 | { | ||
221 | IRDA_DEBUG(4, "%s()\n", __FUNCTION__); | ||
222 | |||
223 | IRDA_ASSERT(self != NULL, return;); | ||
224 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
225 | |||
226 | del_timer(&self->watchdog_timer); | ||
227 | |||
228 | if (self->request_skb) | ||
229 | dev_kfree_skb(self->request_skb); | ||
230 | |||
231 | self->magic = 0; | ||
232 | |||
233 | kfree(self); | ||
234 | } | ||
235 | |||
236 | /* | ||
237 | * Function iriap_close (void) | ||
238 | * | ||
239 | * Closes IrIAP and deregisters with IrLMP | ||
240 | */ | ||
241 | void iriap_close(struct iriap_cb *self) | ||
242 | { | ||
243 | struct iriap_cb *entry; | ||
244 | |||
245 | IRDA_DEBUG(2, "%s()\n", __FUNCTION__); | ||
246 | |||
247 | IRDA_ASSERT(self != NULL, return;); | ||
248 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
249 | |||
250 | if (self->lsap) { | ||
251 | irlmp_close_lsap(self->lsap); | ||
252 | self->lsap = NULL; | ||
253 | } | ||
254 | |||
255 | entry = (struct iriap_cb *) hashbin_remove(iriap, (long) self, NULL); | ||
256 | IRDA_ASSERT(entry == self, return;); | ||
257 | |||
258 | __iriap_close(self); | ||
259 | } | ||
260 | EXPORT_SYMBOL(iriap_close); | ||
261 | |||
262 | static int iriap_register_lsap(struct iriap_cb *self, __u8 slsap_sel, int mode) | ||
263 | { | ||
264 | notify_t notify; | ||
265 | |||
266 | IRDA_DEBUG(2, "%s()\n", __FUNCTION__); | ||
267 | |||
268 | irda_notify_init(¬ify); | ||
269 | notify.connect_confirm = iriap_connect_confirm; | ||
270 | notify.connect_indication = iriap_connect_indication; | ||
271 | notify.disconnect_indication = iriap_disconnect_indication; | ||
272 | notify.data_indication = iriap_data_indication; | ||
273 | notify.instance = self; | ||
274 | if (mode == IAS_CLIENT) | ||
275 | strcpy(notify.name, "IrIAS cli"); | ||
276 | else | ||
277 | strcpy(notify.name, "IrIAS srv"); | ||
278 | |||
279 | self->lsap = irlmp_open_lsap(slsap_sel, ¬ify, 0); | ||
280 | if (self->lsap == NULL) { | ||
281 | IRDA_ERROR("%s: Unable to allocated LSAP!\n", __FUNCTION__); | ||
282 | return -1; | ||
283 | } | ||
284 | self->slsap_sel = self->lsap->slsap_sel; | ||
285 | |||
286 | return 0; | ||
287 | } | ||
288 | |||
289 | /* | ||
290 | * Function iriap_disconnect_indication (handle, reason) | ||
291 | * | ||
292 | * Got disconnect, so clean up everything associated with this connection | ||
293 | * | ||
294 | */ | ||
295 | static void iriap_disconnect_indication(void *instance, void *sap, | ||
296 | LM_REASON reason, | ||
297 | struct sk_buff *skb) | ||
298 | { | ||
299 | struct iriap_cb *self; | ||
300 | |||
301 | IRDA_DEBUG(4, "%s(), reason=%s\n", __FUNCTION__, irlmp_reasons[reason]); | ||
302 | |||
303 | self = (struct iriap_cb *) instance; | ||
304 | |||
305 | IRDA_ASSERT(self != NULL, return;); | ||
306 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
307 | |||
308 | IRDA_ASSERT(iriap != NULL, return;); | ||
309 | |||
310 | del_timer(&self->watchdog_timer); | ||
311 | |||
312 | /* Not needed */ | ||
313 | if (skb) | ||
314 | dev_kfree_skb(skb); | ||
315 | |||
316 | if (self->mode == IAS_CLIENT) { | ||
317 | IRDA_DEBUG(4, "%s(), disconnect as client\n", __FUNCTION__); | ||
318 | |||
319 | |||
320 | iriap_do_client_event(self, IAP_LM_DISCONNECT_INDICATION, | ||
321 | NULL); | ||
322 | /* | ||
323 | * Inform service user that the request failed by sending | ||
324 | * it a NULL value. Warning, the client might close us, so | ||
325 | * remember no to use self anymore after calling confirm | ||
326 | */ | ||
327 | if (self->confirm) | ||
328 | self->confirm(IAS_DISCONNECT, 0, NULL, self->priv); | ||
329 | } else { | ||
330 | IRDA_DEBUG(4, "%s(), disconnect as server\n", __FUNCTION__); | ||
331 | iriap_do_server_event(self, IAP_LM_DISCONNECT_INDICATION, | ||
332 | NULL); | ||
333 | iriap_close(self); | ||
334 | } | ||
335 | } | ||
336 | |||
337 | /* | ||
338 | * Function iriap_disconnect_request (handle) | ||
339 | */ | ||
340 | static void iriap_disconnect_request(struct iriap_cb *self) | ||
341 | { | ||
342 | struct sk_buff *tx_skb; | ||
343 | |||
344 | IRDA_DEBUG(4, "%s()\n", __FUNCTION__); | ||
345 | |||
346 | IRDA_ASSERT(self != NULL, return;); | ||
347 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
348 | |||
349 | tx_skb = dev_alloc_skb(64); | ||
350 | if (tx_skb == NULL) { | ||
351 | IRDA_DEBUG(0, "%s(), Could not allocate an sk_buff of length %d\n", | ||
352 | __FUNCTION__, 64); | ||
353 | return; | ||
354 | } | ||
355 | |||
356 | /* | ||
357 | * Reserve space for MUX control and LAP header | ||
358 | */ | ||
359 | skb_reserve(tx_skb, LMP_MAX_HEADER); | ||
360 | |||
361 | irlmp_disconnect_request(self->lsap, tx_skb); | ||
362 | } | ||
363 | |||
364 | /* | ||
365 | * Function iriap_getvaluebyclass (addr, name, attr) | ||
366 | * | ||
367 | * Retreive all values from attribute in all objects with given class | ||
368 | * name | ||
369 | */ | ||
370 | int iriap_getvaluebyclass_request(struct iriap_cb *self, | ||
371 | __u32 saddr, __u32 daddr, | ||
372 | char *name, char *attr) | ||
373 | { | ||
374 | struct sk_buff *tx_skb; | ||
375 | int name_len, attr_len, skb_len; | ||
376 | __u8 *frame; | ||
377 | |||
378 | IRDA_ASSERT(self != NULL, return -1;); | ||
379 | IRDA_ASSERT(self->magic == IAS_MAGIC, return -1;); | ||
380 | |||
381 | /* Client must supply the destination device address */ | ||
382 | if (!daddr) | ||
383 | return -1; | ||
384 | |||
385 | self->daddr = daddr; | ||
386 | self->saddr = saddr; | ||
387 | |||
388 | /* | ||
389 | * Save operation, so we know what the later indication is about | ||
390 | */ | ||
391 | self->operation = GET_VALUE_BY_CLASS; | ||
392 | |||
393 | /* Give ourselves 10 secs to finish this operation */ | ||
394 | iriap_start_watchdog_timer(self, 10*HZ); | ||
395 | |||
396 | name_len = strlen(name); /* Up to IAS_MAX_CLASSNAME = 60 */ | ||
397 | attr_len = strlen(attr); /* Up to IAS_MAX_ATTRIBNAME = 60 */ | ||
398 | |||
399 | skb_len = self->max_header_size+2+name_len+1+attr_len+4; | ||
400 | tx_skb = dev_alloc_skb(skb_len); | ||
401 | if (!tx_skb) | ||
402 | return -ENOMEM; | ||
403 | |||
404 | /* Reserve space for MUX and LAP header */ | ||
405 | skb_reserve(tx_skb, self->max_header_size); | ||
406 | skb_put(tx_skb, 3+name_len+attr_len); | ||
407 | frame = tx_skb->data; | ||
408 | |||
409 | /* Build frame */ | ||
410 | frame[0] = IAP_LST | GET_VALUE_BY_CLASS; | ||
411 | frame[1] = name_len; /* Insert length of name */ | ||
412 | memcpy(frame+2, name, name_len); /* Insert name */ | ||
413 | frame[2+name_len] = attr_len; /* Insert length of attr */ | ||
414 | memcpy(frame+3+name_len, attr, attr_len); /* Insert attr */ | ||
415 | |||
416 | iriap_do_client_event(self, IAP_CALL_REQUEST_GVBC, tx_skb); | ||
417 | |||
418 | /* Drop reference count - see state_s_disconnect(). */ | ||
419 | dev_kfree_skb(tx_skb); | ||
420 | |||
421 | return 0; | ||
422 | } | ||
423 | EXPORT_SYMBOL(iriap_getvaluebyclass_request); | ||
424 | |||
425 | /* | ||
426 | * Function iriap_getvaluebyclass_confirm (self, skb) | ||
427 | * | ||
428 | * Got result from GetValueByClass command. Parse it and return result | ||
429 | * to service user. | ||
430 | * | ||
431 | */ | ||
432 | static void iriap_getvaluebyclass_confirm(struct iriap_cb *self, | ||
433 | struct sk_buff *skb) | ||
434 | { | ||
435 | struct ias_value *value; | ||
436 | int charset; | ||
437 | __u32 value_len; | ||
438 | __u32 tmp_cpu32; | ||
439 | __u16 obj_id; | ||
440 | __u16 len; | ||
441 | __u8 type; | ||
442 | __u8 *fp; | ||
443 | int n; | ||
444 | |||
445 | IRDA_ASSERT(self != NULL, return;); | ||
446 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
447 | IRDA_ASSERT(skb != NULL, return;); | ||
448 | |||
449 | /* Initialize variables */ | ||
450 | fp = skb->data; | ||
451 | n = 2; | ||
452 | |||
453 | /* Get length, MSB first */ | ||
454 | len = be16_to_cpu(get_unaligned((__u16 *)(fp+n))); n += 2; | ||
455 | |||
456 | IRDA_DEBUG(4, "%s(), len=%d\n", __FUNCTION__, len); | ||
457 | |||
458 | /* Get object ID, MSB first */ | ||
459 | obj_id = be16_to_cpu(get_unaligned((__u16 *)(fp+n))); n += 2; | ||
460 | |||
461 | type = fp[n++]; | ||
462 | IRDA_DEBUG(4, "%s(), Value type = %d\n", __FUNCTION__, type); | ||
463 | |||
464 | switch (type) { | ||
465 | case IAS_INTEGER: | ||
466 | memcpy(&tmp_cpu32, fp+n, 4); n += 4; | ||
467 | be32_to_cpus(&tmp_cpu32); | ||
468 | value = irias_new_integer_value(tmp_cpu32); | ||
469 | |||
470 | /* Legal values restricted to 0x01-0x6f, page 15 irttp */ | ||
471 | IRDA_DEBUG(4, "%s(), lsap=%d\n", __FUNCTION__, value->t.integer); | ||
472 | break; | ||
473 | case IAS_STRING: | ||
474 | charset = fp[n++]; | ||
475 | |||
476 | switch (charset) { | ||
477 | case CS_ASCII: | ||
478 | break; | ||
479 | /* case CS_ISO_8859_1: */ | ||
480 | /* case CS_ISO_8859_2: */ | ||
481 | /* case CS_ISO_8859_3: */ | ||
482 | /* case CS_ISO_8859_4: */ | ||
483 | /* case CS_ISO_8859_5: */ | ||
484 | /* case CS_ISO_8859_6: */ | ||
485 | /* case CS_ISO_8859_7: */ | ||
486 | /* case CS_ISO_8859_8: */ | ||
487 | /* case CS_ISO_8859_9: */ | ||
488 | /* case CS_UNICODE: */ | ||
489 | default: | ||
490 | IRDA_DEBUG(0, "%s(), charset %s, not supported\n", | ||
491 | __FUNCTION__, ias_charset_types[charset]); | ||
492 | |||
493 | /* Aborting, close connection! */ | ||
494 | iriap_disconnect_request(self); | ||
495 | return; | ||
496 | /* break; */ | ||
497 | } | ||
498 | value_len = fp[n++]; | ||
499 | IRDA_DEBUG(4, "%s(), strlen=%d\n", __FUNCTION__, value_len); | ||
500 | |||
501 | /* Make sure the string is null-terminated */ | ||
502 | fp[n+value_len] = 0x00; | ||
503 | IRDA_DEBUG(4, "Got string %s\n", fp+n); | ||
504 | |||
505 | /* Will truncate to IAS_MAX_STRING bytes */ | ||
506 | value = irias_new_string_value(fp+n); | ||
507 | break; | ||
508 | case IAS_OCT_SEQ: | ||
509 | value_len = be16_to_cpu(get_unaligned((__u16 *)(fp+n))); | ||
510 | n += 2; | ||
511 | |||
512 | /* Will truncate to IAS_MAX_OCTET_STRING bytes */ | ||
513 | value = irias_new_octseq_value(fp+n, value_len); | ||
514 | break; | ||
515 | default: | ||
516 | value = irias_new_missing_value(); | ||
517 | break; | ||
518 | } | ||
519 | |||
520 | /* Finished, close connection! */ | ||
521 | iriap_disconnect_request(self); | ||
522 | |||
523 | /* Warning, the client might close us, so remember no to use self | ||
524 | * anymore after calling confirm | ||
525 | */ | ||
526 | if (self->confirm) | ||
527 | self->confirm(IAS_SUCCESS, obj_id, value, self->priv); | ||
528 | else { | ||
529 | IRDA_DEBUG(0, "%s(), missing handler!\n", __FUNCTION__); | ||
530 | irias_delete_value(value); | ||
531 | } | ||
532 | } | ||
533 | |||
534 | /* | ||
535 | * Function iriap_getvaluebyclass_response () | ||
536 | * | ||
537 | * Send answer back to remote LM-IAS | ||
538 | * | ||
539 | */ | ||
540 | static void iriap_getvaluebyclass_response(struct iriap_cb *self, | ||
541 | __u16 obj_id, | ||
542 | __u8 ret_code, | ||
543 | struct ias_value *value) | ||
544 | { | ||
545 | struct sk_buff *tx_skb; | ||
546 | int n; | ||
547 | __u32 tmp_be32, tmp_be16; | ||
548 | __u8 *fp; | ||
549 | |||
550 | IRDA_DEBUG(4, "%s()\n", __FUNCTION__); | ||
551 | |||
552 | IRDA_ASSERT(self != NULL, return;); | ||
553 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
554 | IRDA_ASSERT(value != NULL, return;); | ||
555 | IRDA_ASSERT(value->len <= 1024, return;); | ||
556 | |||
557 | /* Initialize variables */ | ||
558 | n = 0; | ||
559 | |||
560 | /* | ||
561 | * We must adjust the size of the response after the length of the | ||
562 | * value. We add 32 bytes because of the 6 bytes for the frame and | ||
563 | * max 5 bytes for the value coding. | ||
564 | */ | ||
565 | tx_skb = dev_alloc_skb(value->len + self->max_header_size + 32); | ||
566 | if (!tx_skb) | ||
567 | return; | ||
568 | |||
569 | /* Reserve space for MUX and LAP header */ | ||
570 | skb_reserve(tx_skb, self->max_header_size); | ||
571 | skb_put(tx_skb, 6); | ||
572 | |||
573 | fp = tx_skb->data; | ||
574 | |||
575 | /* Build frame */ | ||
576 | fp[n++] = GET_VALUE_BY_CLASS | IAP_LST; | ||
577 | fp[n++] = ret_code; | ||
578 | |||
579 | /* Insert list length (MSB first) */ | ||
580 | tmp_be16 = __constant_htons(0x0001); | ||
581 | memcpy(fp+n, &tmp_be16, 2); n += 2; | ||
582 | |||
583 | /* Insert object identifier ( MSB first) */ | ||
584 | tmp_be16 = cpu_to_be16(obj_id); | ||
585 | memcpy(fp+n, &tmp_be16, 2); n += 2; | ||
586 | |||
587 | switch (value->type) { | ||
588 | case IAS_STRING: | ||
589 | skb_put(tx_skb, 3 + value->len); | ||
590 | fp[n++] = value->type; | ||
591 | fp[n++] = 0; /* ASCII */ | ||
592 | fp[n++] = (__u8) value->len; | ||
593 | memcpy(fp+n, value->t.string, value->len); n+=value->len; | ||
594 | break; | ||
595 | case IAS_INTEGER: | ||
596 | skb_put(tx_skb, 5); | ||
597 | fp[n++] = value->type; | ||
598 | |||
599 | tmp_be32 = cpu_to_be32(value->t.integer); | ||
600 | memcpy(fp+n, &tmp_be32, 4); n += 4; | ||
601 | break; | ||
602 | case IAS_OCT_SEQ: | ||
603 | skb_put(tx_skb, 3 + value->len); | ||
604 | fp[n++] = value->type; | ||
605 | |||
606 | tmp_be16 = cpu_to_be16(value->len); | ||
607 | memcpy(fp+n, &tmp_be16, 2); n += 2; | ||
608 | memcpy(fp+n, value->t.oct_seq, value->len); n+=value->len; | ||
609 | break; | ||
610 | case IAS_MISSING: | ||
611 | IRDA_DEBUG( 3, "%s: sending IAS_MISSING\n", __FUNCTION__); | ||
612 | skb_put(tx_skb, 1); | ||
613 | fp[n++] = value->type; | ||
614 | break; | ||
615 | default: | ||
616 | IRDA_DEBUG(0, "%s(), type not implemented!\n", __FUNCTION__); | ||
617 | break; | ||
618 | } | ||
619 | iriap_do_r_connect_event(self, IAP_CALL_RESPONSE, tx_skb); | ||
620 | |||
621 | /* Drop reference count - see state_r_execute(). */ | ||
622 | dev_kfree_skb(tx_skb); | ||
623 | } | ||
624 | |||
625 | /* | ||
626 | * Function iriap_getvaluebyclass_indication (self, skb) | ||
627 | * | ||
628 | * getvaluebyclass is requested from peer LM-IAS | ||
629 | * | ||
630 | */ | ||
631 | static void iriap_getvaluebyclass_indication(struct iriap_cb *self, | ||
632 | struct sk_buff *skb) | ||
633 | { | ||
634 | struct ias_object *obj; | ||
635 | struct ias_attrib *attrib; | ||
636 | int name_len; | ||
637 | int attr_len; | ||
638 | char name[IAS_MAX_CLASSNAME + 1]; /* 60 bytes */ | ||
639 | char attr[IAS_MAX_ATTRIBNAME + 1]; /* 60 bytes */ | ||
640 | __u8 *fp; | ||
641 | int n; | ||
642 | |||
643 | IRDA_DEBUG(4, "%s()\n", __FUNCTION__); | ||
644 | |||
645 | IRDA_ASSERT(self != NULL, return;); | ||
646 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
647 | IRDA_ASSERT(skb != NULL, return;); | ||
648 | |||
649 | fp = skb->data; | ||
650 | n = 1; | ||
651 | |||
652 | name_len = fp[n++]; | ||
653 | memcpy(name, fp+n, name_len); n+=name_len; | ||
654 | name[name_len] = '\0'; | ||
655 | |||
656 | attr_len = fp[n++]; | ||
657 | memcpy(attr, fp+n, attr_len); n+=attr_len; | ||
658 | attr[attr_len] = '\0'; | ||
659 | |||
660 | IRDA_DEBUG(4, "LM-IAS: Looking up %s: %s\n", name, attr); | ||
661 | obj = irias_find_object(name); | ||
662 | |||
663 | if (obj == NULL) { | ||
664 | IRDA_DEBUG(2, "LM-IAS: Object %s not found\n", name); | ||
665 | iriap_getvaluebyclass_response(self, 0x1235, IAS_CLASS_UNKNOWN, | ||
666 | &irias_missing); | ||
667 | return; | ||
668 | } | ||
669 | IRDA_DEBUG(4, "LM-IAS: found %s, id=%d\n", obj->name, obj->id); | ||
670 | |||
671 | attrib = irias_find_attrib(obj, attr); | ||
672 | if (attrib == NULL) { | ||
673 | IRDA_DEBUG(2, "LM-IAS: Attribute %s not found\n", attr); | ||
674 | iriap_getvaluebyclass_response(self, obj->id, | ||
675 | IAS_ATTRIB_UNKNOWN, | ||
676 | &irias_missing); | ||
677 | return; | ||
678 | } | ||
679 | |||
680 | /* We have a match; send the value. */ | ||
681 | iriap_getvaluebyclass_response(self, obj->id, IAS_SUCCESS, | ||
682 | attrib->value); | ||
683 | |||
684 | return; | ||
685 | } | ||
686 | |||
687 | /* | ||
688 | * Function iriap_send_ack (void) | ||
689 | * | ||
690 | * Currently not used | ||
691 | * | ||
692 | */ | ||
693 | void iriap_send_ack(struct iriap_cb *self) | ||
694 | { | ||
695 | struct sk_buff *tx_skb; | ||
696 | __u8 *frame; | ||
697 | |||
698 | IRDA_DEBUG(2, "%s()\n", __FUNCTION__); | ||
699 | |||
700 | IRDA_ASSERT(self != NULL, return;); | ||
701 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
702 | |||
703 | tx_skb = dev_alloc_skb(64); | ||
704 | if (!tx_skb) | ||
705 | return; | ||
706 | |||
707 | /* Reserve space for MUX and LAP header */ | ||
708 | skb_reserve(tx_skb, self->max_header_size); | ||
709 | skb_put(tx_skb, 1); | ||
710 | frame = tx_skb->data; | ||
711 | |||
712 | /* Build frame */ | ||
713 | frame[0] = IAP_LST | IAP_ACK | self->operation; | ||
714 | |||
715 | irlmp_data_request(self->lsap, tx_skb); | ||
716 | } | ||
717 | |||
718 | void iriap_connect_request(struct iriap_cb *self) | ||
719 | { | ||
720 | int ret; | ||
721 | |||
722 | IRDA_ASSERT(self != NULL, return;); | ||
723 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
724 | |||
725 | ret = irlmp_connect_request(self->lsap, LSAP_IAS, | ||
726 | self->saddr, self->daddr, | ||
727 | NULL, NULL); | ||
728 | if (ret < 0) { | ||
729 | IRDA_DEBUG(0, "%s(), connect failed!\n", __FUNCTION__); | ||
730 | self->confirm(IAS_DISCONNECT, 0, NULL, self->priv); | ||
731 | } | ||
732 | } | ||
733 | |||
734 | /* | ||
735 | * Function iriap_connect_confirm (handle, skb) | ||
736 | * | ||
737 | * LSAP connection confirmed! | ||
738 | * | ||
739 | */ | ||
740 | static void iriap_connect_confirm(void *instance, void *sap, | ||
741 | struct qos_info *qos, __u32 max_seg_size, | ||
742 | __u8 max_header_size, | ||
743 | struct sk_buff *skb) | ||
744 | { | ||
745 | struct iriap_cb *self; | ||
746 | |||
747 | self = (struct iriap_cb *) instance; | ||
748 | |||
749 | IRDA_ASSERT(self != NULL, return;); | ||
750 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
751 | IRDA_ASSERT(skb != NULL, return;); | ||
752 | |||
753 | self->max_data_size = max_seg_size; | ||
754 | self->max_header_size = max_header_size; | ||
755 | |||
756 | del_timer(&self->watchdog_timer); | ||
757 | |||
758 | iriap_do_client_event(self, IAP_LM_CONNECT_CONFIRM, skb); | ||
759 | |||
760 | /* Drop reference count - see state_s_make_call(). */ | ||
761 | dev_kfree_skb(skb); | ||
762 | } | ||
763 | |||
764 | /* | ||
765 | * Function iriap_connect_indication ( handle, skb) | ||
766 | * | ||
767 | * Remote LM-IAS is requesting connection | ||
768 | * | ||
769 | */ | ||
770 | static void iriap_connect_indication(void *instance, void *sap, | ||
771 | struct qos_info *qos, __u32 max_seg_size, | ||
772 | __u8 max_header_size, | ||
773 | struct sk_buff *skb) | ||
774 | { | ||
775 | struct iriap_cb *self, *new; | ||
776 | |||
777 | IRDA_DEBUG(1, "%s()\n", __FUNCTION__); | ||
778 | |||
779 | self = (struct iriap_cb *) instance; | ||
780 | |||
781 | IRDA_ASSERT(skb != NULL, return;); | ||
782 | IRDA_ASSERT(self != NULL, goto out;); | ||
783 | IRDA_ASSERT(self->magic == IAS_MAGIC, goto out;); | ||
784 | |||
785 | /* Start new server */ | ||
786 | new = iriap_open(LSAP_IAS, IAS_SERVER, NULL, NULL); | ||
787 | if (!new) { | ||
788 | IRDA_DEBUG(0, "%s(), open failed\n", __FUNCTION__); | ||
789 | goto out; | ||
790 | } | ||
791 | |||
792 | /* Now attach up the new "socket" */ | ||
793 | new->lsap = irlmp_dup(self->lsap, new); | ||
794 | if (!new->lsap) { | ||
795 | IRDA_DEBUG(0, "%s(), dup failed!\n", __FUNCTION__); | ||
796 | goto out; | ||
797 | } | ||
798 | |||
799 | new->max_data_size = max_seg_size; | ||
800 | new->max_header_size = max_header_size; | ||
801 | |||
802 | /* Clean up the original one to keep it in listen state */ | ||
803 | irlmp_listen(self->lsap); | ||
804 | |||
805 | iriap_do_server_event(new, IAP_LM_CONNECT_INDICATION, skb); | ||
806 | |||
807 | out: | ||
808 | /* Drop reference count - see state_r_disconnect(). */ | ||
809 | dev_kfree_skb(skb); | ||
810 | } | ||
811 | |||
812 | /* | ||
813 | * Function iriap_data_indication (handle, skb) | ||
814 | * | ||
815 | * Receives data from connection identified by handle from IrLMP | ||
816 | * | ||
817 | */ | ||
818 | static int iriap_data_indication(void *instance, void *sap, | ||
819 | struct sk_buff *skb) | ||
820 | { | ||
821 | struct iriap_cb *self; | ||
822 | __u8 *frame; | ||
823 | __u8 opcode; | ||
824 | |||
825 | IRDA_DEBUG(3, "%s()\n", __FUNCTION__); | ||
826 | |||
827 | self = (struct iriap_cb *) instance; | ||
828 | |||
829 | IRDA_ASSERT(skb != NULL, return 0;); | ||
830 | IRDA_ASSERT(self != NULL, goto out;); | ||
831 | IRDA_ASSERT(self->magic == IAS_MAGIC, goto out;); | ||
832 | |||
833 | frame = skb->data; | ||
834 | |||
835 | if (self->mode == IAS_SERVER) { | ||
836 | /* Call server */ | ||
837 | IRDA_DEBUG(4, "%s(), Calling server!\n", __FUNCTION__); | ||
838 | iriap_do_r_connect_event(self, IAP_RECV_F_LST, skb); | ||
839 | goto out; | ||
840 | } | ||
841 | opcode = frame[0]; | ||
842 | if (~opcode & IAP_LST) { | ||
843 | IRDA_WARNING("%s:, IrIAS multiframe commands or " | ||
844 | "results is not implemented yet!\n", | ||
845 | __FUNCTION__); | ||
846 | goto out; | ||
847 | } | ||
848 | |||
849 | /* Check for ack frames since they don't contain any data */ | ||
850 | if (opcode & IAP_ACK) { | ||
851 | IRDA_DEBUG(0, "%s() Got ack frame!\n", __FUNCTION__); | ||
852 | goto out; | ||
853 | } | ||
854 | |||
855 | opcode &= ~IAP_LST; /* Mask away LST bit */ | ||
856 | |||
857 | switch (opcode) { | ||
858 | case GET_INFO_BASE: | ||
859 | IRDA_DEBUG(0, "IrLMP GetInfoBaseDetails not implemented!\n"); | ||
860 | break; | ||
861 | case GET_VALUE_BY_CLASS: | ||
862 | iriap_do_call_event(self, IAP_RECV_F_LST, NULL); | ||
863 | |||
864 | switch (frame[1]) { | ||
865 | case IAS_SUCCESS: | ||
866 | iriap_getvaluebyclass_confirm(self, skb); | ||
867 | break; | ||
868 | case IAS_CLASS_UNKNOWN: | ||
869 | IRDA_DEBUG(1, "%s(), No such class!\n", __FUNCTION__); | ||
870 | /* Finished, close connection! */ | ||
871 | iriap_disconnect_request(self); | ||
872 | |||
873 | /* | ||
874 | * Warning, the client might close us, so remember | ||
875 | * no to use self anymore after calling confirm | ||
876 | */ | ||
877 | if (self->confirm) | ||
878 | self->confirm(IAS_CLASS_UNKNOWN, 0, NULL, | ||
879 | self->priv); | ||
880 | break; | ||
881 | case IAS_ATTRIB_UNKNOWN: | ||
882 | IRDA_DEBUG(1, "%s(), No such attribute!\n", __FUNCTION__); | ||
883 | /* Finished, close connection! */ | ||
884 | iriap_disconnect_request(self); | ||
885 | |||
886 | /* | ||
887 | * Warning, the client might close us, so remember | ||
888 | * no to use self anymore after calling confirm | ||
889 | */ | ||
890 | if (self->confirm) | ||
891 | self->confirm(IAS_ATTRIB_UNKNOWN, 0, NULL, | ||
892 | self->priv); | ||
893 | break; | ||
894 | } | ||
895 | break; | ||
896 | default: | ||
897 | IRDA_DEBUG(0, "%s(), Unknown op-code: %02x\n", __FUNCTION__, | ||
898 | opcode); | ||
899 | break; | ||
900 | } | ||
901 | |||
902 | out: | ||
903 | /* Cleanup - sub-calls will have done skb_get() as needed. */ | ||
904 | dev_kfree_skb(skb); | ||
905 | return 0; | ||
906 | } | ||
907 | |||
908 | /* | ||
909 | * Function iriap_call_indication (self, skb) | ||
910 | * | ||
911 | * Received call to server from peer LM-IAS | ||
912 | * | ||
913 | */ | ||
914 | void iriap_call_indication(struct iriap_cb *self, struct sk_buff *skb) | ||
915 | { | ||
916 | __u8 *fp; | ||
917 | __u8 opcode; | ||
918 | |||
919 | IRDA_DEBUG(4, "%s()\n", __FUNCTION__); | ||
920 | |||
921 | IRDA_ASSERT(self != NULL, return;); | ||
922 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
923 | IRDA_ASSERT(skb != NULL, return;); | ||
924 | |||
925 | fp = skb->data; | ||
926 | |||
927 | opcode = fp[0]; | ||
928 | if (~opcode & 0x80) { | ||
929 | IRDA_WARNING("%s: IrIAS multiframe commands or results" | ||
930 | "is not implemented yet!\n", __FUNCTION__); | ||
931 | return; | ||
932 | } | ||
933 | opcode &= 0x7f; /* Mask away LST bit */ | ||
934 | |||
935 | switch (opcode) { | ||
936 | case GET_INFO_BASE: | ||
937 | IRDA_WARNING("%s: GetInfoBaseDetails not implemented yet!\n", | ||
938 | __FUNCTION__); | ||
939 | break; | ||
940 | case GET_VALUE_BY_CLASS: | ||
941 | iriap_getvaluebyclass_indication(self, skb); | ||
942 | break; | ||
943 | } | ||
944 | /* skb will be cleaned up in iriap_data_indication */ | ||
945 | } | ||
946 | |||
947 | /* | ||
948 | * Function iriap_watchdog_timer_expired (data) | ||
949 | * | ||
950 | * Query has taken too long time, so abort | ||
951 | * | ||
952 | */ | ||
953 | static void iriap_watchdog_timer_expired(void *data) | ||
954 | { | ||
955 | struct iriap_cb *self = (struct iriap_cb *) data; | ||
956 | |||
957 | IRDA_ASSERT(self != NULL, return;); | ||
958 | IRDA_ASSERT(self->magic == IAS_MAGIC, return;); | ||
959 | |||
960 | /* iriap_close(self); */ | ||
961 | } | ||
962 | |||
963 | #ifdef CONFIG_PROC_FS | ||
964 | |||
965 | static const char *ias_value_types[] = { | ||
966 | "IAS_MISSING", | ||
967 | "IAS_INTEGER", | ||
968 | "IAS_OCT_SEQ", | ||
969 | "IAS_STRING" | ||
970 | }; | ||
971 | |||
972 | static inline struct ias_object *irias_seq_idx(loff_t pos) | ||
973 | { | ||
974 | struct ias_object *obj; | ||
975 | |||
976 | for (obj = (struct ias_object *) hashbin_get_first(irias_objects); | ||
977 | obj; obj = (struct ias_object *) hashbin_get_next(irias_objects)) { | ||
978 | if (pos-- == 0) | ||
979 | break; | ||
980 | } | ||
981 | |||
982 | return obj; | ||
983 | } | ||
984 | |||
985 | static void *irias_seq_start(struct seq_file *seq, loff_t *pos) | ||
986 | { | ||
987 | spin_lock_irq(&irias_objects->hb_spinlock); | ||
988 | |||
989 | return *pos ? irias_seq_idx(*pos - 1) : SEQ_START_TOKEN; | ||
990 | } | ||
991 | |||
992 | static void *irias_seq_next(struct seq_file *seq, void *v, loff_t *pos) | ||
993 | { | ||
994 | ++*pos; | ||
995 | |||
996 | return (v == SEQ_START_TOKEN) | ||
997 | ? (void *) hashbin_get_first(irias_objects) | ||
998 | : (void *) hashbin_get_next(irias_objects); | ||
999 | } | ||
1000 | |||
1001 | static void irias_seq_stop(struct seq_file *seq, void *v) | ||
1002 | { | ||
1003 | spin_unlock_irq(&irias_objects->hb_spinlock); | ||
1004 | } | ||
1005 | |||
1006 | static int irias_seq_show(struct seq_file *seq, void *v) | ||
1007 | { | ||
1008 | if (v == SEQ_START_TOKEN) | ||
1009 | seq_puts(seq, "LM-IAS Objects:\n"); | ||
1010 | else { | ||
1011 | struct ias_object *obj = v; | ||
1012 | struct ias_attrib *attrib; | ||
1013 | |||
1014 | IRDA_ASSERT(obj->magic == IAS_OBJECT_MAGIC, return -EINVAL;); | ||
1015 | |||
1016 | seq_printf(seq, "name: %s, id=%d\n", | ||
1017 | obj->name, obj->id); | ||
1018 | |||
1019 | /* Careful for priority inversions here ! | ||
1020 | * All other uses of attrib spinlock are independent of | ||
1021 | * the object spinlock, so we are safe. Jean II */ | ||
1022 | spin_lock(&obj->attribs->hb_spinlock); | ||
1023 | |||
1024 | /* List all attributes for this object */ | ||
1025 | for (attrib = (struct ias_attrib *) hashbin_get_first(obj->attribs); | ||
1026 | attrib != NULL; | ||
1027 | attrib = (struct ias_attrib *) hashbin_get_next(obj->attribs)) { | ||
1028 | |||
1029 | IRDA_ASSERT(attrib->magic == IAS_ATTRIB_MAGIC, | ||
1030 | goto outloop; ); | ||
1031 | |||
1032 | seq_printf(seq, " - Attribute name: \"%s\", ", | ||
1033 | attrib->name); | ||
1034 | seq_printf(seq, "value[%s]: ", | ||
1035 | ias_value_types[attrib->value->type]); | ||
1036 | |||
1037 | switch (attrib->value->type) { | ||
1038 | case IAS_INTEGER: | ||
1039 | seq_printf(seq, "%d\n", | ||
1040 | attrib->value->t.integer); | ||
1041 | break; | ||
1042 | case IAS_STRING: | ||
1043 | seq_printf(seq, "\"%s\"\n", | ||
1044 | attrib->value->t.string); | ||
1045 | break; | ||
1046 | case IAS_OCT_SEQ: | ||
1047 | seq_printf(seq, "octet sequence (%d bytes)\n", | ||
1048 | attrib->value->len); | ||
1049 | break; | ||
1050 | case IAS_MISSING: | ||
1051 | seq_puts(seq, "missing\n"); | ||
1052 | break; | ||
1053 | default: | ||
1054 | seq_printf(seq, "type %d?\n", | ||
1055 | attrib->value->type); | ||
1056 | } | ||
1057 | seq_putc(seq, '\n'); | ||
1058 | |||
1059 | } | ||
1060 | IRDA_ASSERT_LABEL(outloop:) | ||
1061 | spin_unlock(&obj->attribs->hb_spinlock); | ||
1062 | } | ||
1063 | |||
1064 | return 0; | ||
1065 | } | ||
1066 | |||
1067 | static struct seq_operations irias_seq_ops = { | ||
1068 | .start = irias_seq_start, | ||
1069 | .next = irias_seq_next, | ||
1070 | .stop = irias_seq_stop, | ||
1071 | .show = irias_seq_show, | ||
1072 | }; | ||
1073 | |||
1074 | static int irias_seq_open(struct inode *inode, struct file *file) | ||
1075 | { | ||
1076 | IRDA_ASSERT( irias_objects != NULL, return -EINVAL;); | ||
1077 | |||
1078 | return seq_open(file, &irias_seq_ops); | ||
1079 | } | ||
1080 | |||
1081 | struct file_operations irias_seq_fops = { | ||
1082 | .owner = THIS_MODULE, | ||
1083 | .open = irias_seq_open, | ||
1084 | .read = seq_read, | ||
1085 | .llseek = seq_lseek, | ||
1086 | .release = seq_release, | ||
1087 | }; | ||
1088 | |||
1089 | #endif /* PROC_FS */ | ||