Commit | Line | Data |
---|---|---|
1da177e4 LT |
1 | /* transport.h: Rx transport management |
2 | * | |
3 | * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved. | |
4 | * Written by David Howells (dhowells@redhat.com) | |
5 | * | |
6 | * This program is free software; you can redistribute it and/or | |
7 | * modify it under the terms of the GNU General Public License | |
8 | * as published by the Free Software Foundation; either version | |
9 | * 2 of the License, or (at your option) any later version. | |
10 | */ | |
11 | ||
12 | #ifndef _LINUX_RXRPC_TRANSPORT_H | |
13 | #define _LINUX_RXRPC_TRANSPORT_H | |
14 | ||
15 | #include <rxrpc/types.h> | |
16 | #include <rxrpc/krxiod.h> | |
17 | #include <rxrpc/rxrpc.h> | |
18 | #include <linux/skbuff.h> | |
19 | #include <linux/rwsem.h> | |
20 | ||
21 | typedef int (*rxrpc_newcall_fnx_t)(struct rxrpc_call *call); | |
22 | ||
23 | extern wait_queue_head_t rxrpc_krxiod_wq; | |
24 | ||
25 | /*****************************************************************************/ | |
26 | /* | |
27 | * Rx operation specification | |
28 | * - tables of these must be sorted by op ID so that they can be binary-chop searched | |
29 | */ | |
30 | struct rxrpc_operation | |
31 | { | |
32 | unsigned id; /* operation ID */ | |
33 | size_t asize; /* minimum size of argument block */ | |
34 | const char *name; /* name of operation */ | |
35 | void *user; /* initial user data */ | |
36 | }; | |
37 | ||
38 | /*****************************************************************************/ | |
39 | /* | |
40 | * Rx transport service record | |
41 | */ | |
42 | struct rxrpc_service | |
43 | { | |
44 | struct list_head link; /* link in services list on transport */ | |
45 | struct module *owner; /* owner module */ | |
46 | rxrpc_newcall_fnx_t new_call; /* new call handler function */ | |
47 | const char *name; /* name of service */ | |
48 | unsigned short service_id; /* Rx service ID */ | |
49 | rxrpc_call_attn_func_t attn_func; /* call requires attention callback */ | |
50 | rxrpc_call_error_func_t error_func; /* call error callback */ | |
51 | rxrpc_call_aemap_func_t aemap_func; /* abort -> errno mapping callback */ | |
52 | ||
53 | const struct rxrpc_operation *ops_begin; /* beginning of operations table */ | |
54 | const struct rxrpc_operation *ops_end; /* end of operations table */ | |
55 | }; | |
56 | ||
57 | /*****************************************************************************/ | |
58 | /* | |
59 | * Rx transport endpoint record | |
60 | */ | |
61 | struct rxrpc_transport | |
62 | { | |
63 | atomic_t usage; | |
64 | struct socket *socket; /* my UDP socket */ | |
65 | struct list_head services; /* services listening on this socket */ | |
66 | struct list_head link; /* link in transport list */ | |
67 | struct list_head proc_link; /* link in transport proc list */ | |
68 | struct list_head krxiodq_link; /* krxiod attention queue link */ | |
69 | spinlock_t lock; /* access lock */ | |
70 | struct list_head peer_active; /* active peers connected to over this socket */ | |
71 | struct list_head peer_graveyard; /* inactive peer list */ | |
72 | spinlock_t peer_gylock; /* peer graveyard lock */ | |
73 | wait_queue_head_t peer_gy_waitq; /* wait queue hit when peer graveyard is empty */ | |
74 | rwlock_t peer_lock; /* peer list access lock */ | |
75 | atomic_t peer_count; /* number of peers */ | |
76 | struct rxrpc_peer_ops *peer_ops; /* default peer operations */ | |
77 | unsigned short port; /* port upon which listening */ | |
78 | volatile char error_rcvd; /* T if received ICMP error outstanding */ | |
79 | }; | |
80 | ||
81 | extern int rxrpc_create_transport(unsigned short port, | |
82 | struct rxrpc_transport **_trans); | |
83 | ||
84 | static inline void rxrpc_get_transport(struct rxrpc_transport *trans) | |
85 | { | |
86 | BUG_ON(atomic_read(&trans->usage) <= 0); | |
87 | atomic_inc(&trans->usage); | |
88 | //printk("rxrpc_get_transport(%p{u=%d})\n", | |
89 | // trans, atomic_read(&trans->usage)); | |
90 | } | |
91 | ||
92 | extern void rxrpc_put_transport(struct rxrpc_transport *trans); | |
93 | ||
94 | extern int rxrpc_add_service(struct rxrpc_transport *trans, | |
95 | struct rxrpc_service *srv); | |
96 | ||
97 | extern void rxrpc_del_service(struct rxrpc_transport *trans, | |
98 | struct rxrpc_service *srv); | |
99 | ||
100 | extern void rxrpc_trans_receive_packet(struct rxrpc_transport *trans); | |
101 | ||
102 | extern int rxrpc_trans_immediate_abort(struct rxrpc_transport *trans, | |
103 | struct rxrpc_message *msg, | |
104 | int error); | |
105 | ||
106 | #endif /* _LINUX_RXRPC_TRANSPORT_H */ |