Blame view
net/tipc/port.h
10.2 KB
b97bf3fd8 [TIPC] Initial merge |
1 2 |
/* * net/tipc/port.h: Include file for TIPC port code |
c43072852 [NET] TIPC: Fix w... |
3 |
* |
05646c911 [TIPC]: Optimize ... |
4 |
* Copyright (c) 1994-2007, Ericsson AB |
23dd4cce3 tipc: Combine por... |
5 |
* Copyright (c) 2004-2007, 2010-2011, Wind River Systems |
b97bf3fd8 [TIPC] Initial merge |
6 7 |
* All rights reserved. * |
9ea1fd3c1 [TIPC] License he... |
8 |
* Redistribution and use in source and binary forms, with or without |
b97bf3fd8 [TIPC] Initial merge |
9 10 |
* modification, are permitted provided that the following conditions are met: * |
9ea1fd3c1 [TIPC] License he... |
11 12 13 14 15 16 17 18 |
* 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. Neither the names of the copyright holders nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. |
b97bf3fd8 [TIPC] Initial merge |
19 |
* |
9ea1fd3c1 [TIPC] License he... |
20 21 22 23 24 25 26 27 28 29 30 31 32 33 |
* Alternatively, this software may be distributed under the terms of the * GNU General Public License ("GPL") version 2 as published by the Free * Software Foundation. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE |
b97bf3fd8 [TIPC] Initial merge |
34 35 36 37 38 |
* POSSIBILITY OF SUCH DAMAGE. */ #ifndef _TIPC_PORT_H #define _TIPC_PORT_H |
b97bf3fd8 [TIPC] Initial merge |
39 40 41 |
#include "ref.h" #include "net.h" #include "msg.h" |
b97bf3fd8 [TIPC] Initial merge |
42 |
#include "node_subscr.h" |
d265fef6d tipc: Remove obso... |
43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 |
#define TIPC_FLOW_CONTROL_WIN 512 typedef void (*tipc_msg_err_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size, int reason, struct tipc_portid const *attmpt_destid); typedef void (*tipc_named_msg_err_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size, int reason, struct tipc_name_seq const *attmpt_dest); typedef void (*tipc_conn_shutdown_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size, int reason); typedef void (*tipc_msg_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size, unsigned int importance, struct tipc_portid const *origin); typedef void (*tipc_named_msg_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size, unsigned int importance, struct tipc_portid const *orig, struct tipc_name_seq const *dest); typedef void (*tipc_conn_msg_event) (void *usr_handle, u32 portref, struct sk_buff **buf, unsigned char const *data, unsigned int size); typedef void (*tipc_continue_event) (void *usr_handle, u32 portref); |
b97bf3fd8 [TIPC] Initial merge |
75 76 |
/** * struct user_port - TIPC user port (used with native API) |
b97bf3fd8 [TIPC] Initial merge |
77 78 79 |
* @usr_handle: user-specified field * @ref: object reference to associated TIPC port * <various callback routines> |
b97bf3fd8 [TIPC] Initial merge |
80 |
*/ |
c43072852 [NET] TIPC: Fix w... |
81 |
|
b97bf3fd8 [TIPC] Initial merge |
82 |
struct user_port { |
c43072852 [NET] TIPC: Fix w... |
83 |
void *usr_handle; |
b97bf3fd8 [TIPC] Initial merge |
84 |
u32 ref; |
c43072852 [NET] TIPC: Fix w... |
85 86 87 88 89 90 |
tipc_msg_err_event err_cb; tipc_named_msg_err_event named_err_cb; tipc_conn_shutdown_event conn_err_cb; tipc_msg_event msg_cb; tipc_named_msg_event named_msg_cb; tipc_conn_msg_event conn_msg_cb; |
b97bf3fd8 [TIPC] Initial merge |
91 |
tipc_continue_event continue_event_cb; |
b97bf3fd8 [TIPC] Initial merge |
92 93 94 |
}; /** |
23dd4cce3 tipc: Combine por... |
95 |
* struct tipc_port - TIPC port structure |
d265fef6d tipc: Remove obso... |
96 97 98 99 100 101 102 103 104 105 106 |
* @usr_handle: pointer to additional user-defined information about port * @lock: pointer to spinlock for controlling access to port * @connected: non-zero if port is currently connected to a peer port * @conn_type: TIPC type used when connection was established * @conn_instance: TIPC instance used when connection was established * @conn_unacked: number of unacknowledged messages received from peer port * @published: non-zero if port has one or more associated names * @congested: non-zero if cannot send because of link or port congestion * @max_pkt: maximum packet size "hint" used when building messages sent by port * @ref: unique reference to port in TIPC object registry * @phdr: preformatted message header used when sending messages |
b97bf3fd8 [TIPC] Initial merge |
107 108 109 110 111 |
* @port_list: adjacent ports in TIPC's global list of ports * @dispatcher: ptr to routine which handles received messages * @wakeup: ptr to routine to call when port is no longer congested * @user_port: ptr to user port associated with port (if any) * @wait_list: adjacent ports in list of ports waiting on link congestion |
b97bf3fd8 [TIPC] Initial merge |
112 |
* @waiting_pkts: |
cb7ce9144 tipc: Fix port co... |
113 114 |
* @sent: # of non-empty messages sent by port * @acked: # of non-empty message acknowledgements from connected port's peer |
b97bf3fd8 [TIPC] Initial merge |
115 116 |
* @publications: list of publications for port * @pub_count: total # of publications port has made during its lifetime |
b97bf3fd8 [TIPC] Initial merge |
117 118 |
* @probing_state: * @probing_interval: |
b97bf3fd8 [TIPC] Initial merge |
119 120 121 |
* @timer_ref: * @subscription: "node down" subscription used to terminate failed connections */ |
23dd4cce3 tipc: Combine por... |
122 123 124 125 126 127 128 129 130 131 132 133 |
struct tipc_port { void *usr_handle; spinlock_t *lock; int connected; u32 conn_type; u32 conn_instance; u32 conn_unacked; int published; u32 congested; u32 max_pkt; u32 ref; struct tipc_msg phdr; |
b97bf3fd8 [TIPC] Initial merge |
134 135 136 137 138 |
struct list_head port_list; u32 (*dispatcher)(struct tipc_port *, struct sk_buff *); void (*wakeup)(struct tipc_port *); struct user_port *user_port; struct list_head wait_list; |
b97bf3fd8 [TIPC] Initial merge |
139 140 141 142 143 |
u32 waiting_pkts; u32 sent; u32 acked; struct list_head publications; u32 pub_count; |
b97bf3fd8 [TIPC] Initial merge |
144 145 |
u32 probing_state; u32 probing_interval; |
b97bf3fd8 [TIPC] Initial merge |
146 |
struct timer_list timer; |
6c00055a8 tipc: Don't use s... |
147 |
struct tipc_node_subscr subscription; |
b97bf3fd8 [TIPC] Initial merge |
148 |
}; |
4323add67 [TIPC] Avoid poll... |
149 |
extern spinlock_t tipc_port_list_lock; |
4584310b4 tipc: rename stru... |
150 |
struct tipc_port_list; |
b97bf3fd8 [TIPC] Initial merge |
151 |
|
d265fef6d tipc: Remove obso... |
152 153 154 155 156 157 158 159 160 161 162 163 |
/* * TIPC port manipulation routines */ struct tipc_port *tipc_createport_raw(void *usr_handle, u32 (*dispatcher)(struct tipc_port *, struct sk_buff *), void (*wakeup)(struct tipc_port *), const u32 importance); int tipc_reject_msg(struct sk_buff *buf, u32 err); int tipc_send_buf_fast(struct sk_buff *buf, u32 destnode); void tipc_acknowledge(u32 port_ref, u32 ack); |
b0c1e928c tipc: Remove user... |
164 |
int tipc_createport(void *usr_handle, |
d265fef6d tipc: Remove obso... |
165 166 167 168 169 170 171 172 |
unsigned int importance, tipc_msg_err_event error_cb, tipc_named_msg_err_event named_error_cb, tipc_conn_shutdown_event conn_error_cb, tipc_msg_event msg_cb, tipc_named_msg_event named_msg_cb, tipc_conn_msg_event conn_msg_cb, tipc_continue_event continue_event_cb, u32 *portref); int tipc_deleteport(u32 portref); |
d265fef6d tipc: Remove obso... |
173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 |
int tipc_portimportance(u32 portref, unsigned int *importance); int tipc_set_portimportance(u32 portref, unsigned int importance); int tipc_portunreliable(u32 portref, unsigned int *isunreliable); int tipc_set_portunreliable(u32 portref, unsigned int isunreliable); int tipc_portunreturnable(u32 portref, unsigned int *isunreturnable); int tipc_set_portunreturnable(u32 portref, unsigned int isunreturnable); int tipc_publish(u32 portref, unsigned int scope, struct tipc_name_seq const *name_seq); int tipc_withdraw(u32 portref, unsigned int scope, struct tipc_name_seq const *name_seq); int tipc_connect2port(u32 portref, struct tipc_portid const *port); int tipc_disconnect(u32 portref); int tipc_shutdown(u32 ref); /* * The following routines require that the port be locked on entry */ int tipc_disconnect_port(struct tipc_port *tp_ptr); /* * TIPC messaging routines */ |
268969046 tipc: Avoid recom... |
202 203 |
int tipc_send(u32 portref, unsigned int num_sect, struct iovec const *msg_sect, unsigned int total_len); |
d265fef6d tipc: Remove obso... |
204 205 |
int tipc_send2name(u32 portref, struct tipc_name const *name, u32 domain, |
268969046 tipc: Avoid recom... |
206 207 |
unsigned int num_sect, struct iovec const *msg_sect, unsigned int total_len); |
d265fef6d tipc: Remove obso... |
208 209 |
int tipc_send2port(u32 portref, struct tipc_portid const *dest, |
268969046 tipc: Avoid recom... |
210 211 |
unsigned int num_sect, struct iovec const *msg_sect, unsigned int total_len); |
d265fef6d tipc: Remove obso... |
212 213 214 |
int tipc_send_buf2port(u32 portref, struct tipc_portid const *dest, struct sk_buff *buf, unsigned int dsz); |
38f232eae tipc: Remove unus... |
215 |
int tipc_multicast(u32 portref, struct tipc_name_seq const *seq, |
268969046 tipc: Avoid recom... |
216 217 |
unsigned int section_count, struct iovec const *msg, unsigned int total_len); |
d265fef6d tipc: Remove obso... |
218 |
|
23dd4cce3 tipc: Combine por... |
219 |
int tipc_port_reject_sections(struct tipc_port *p_ptr, struct tipc_msg *hdr, |
4323add67 [TIPC] Avoid poll... |
220 |
struct iovec const *msg_sect, u32 num_sect, |
268969046 tipc: Avoid recom... |
221 |
unsigned int total_len, int err); |
4323add67 [TIPC] Avoid poll... |
222 |
struct sk_buff *tipc_port_get_ports(void); |
4323add67 [TIPC] Avoid poll... |
223 |
void tipc_port_recv_proto_msg(struct sk_buff *buf); |
4584310b4 tipc: rename stru... |
224 |
void tipc_port_recv_mcast(struct sk_buff *buf, struct tipc_port_list *dp); |
4323add67 [TIPC] Avoid poll... |
225 |
void tipc_port_reinit(void); |
b97bf3fd8 [TIPC] Initial merge |
226 227 |
/** |
4323add67 [TIPC] Avoid poll... |
228 |
* tipc_port_lock - lock port instance referred to and return its pointer |
b97bf3fd8 [TIPC] Initial merge |
229 |
*/ |
23dd4cce3 tipc: Combine por... |
230 |
static inline struct tipc_port *tipc_port_lock(u32 ref) |
b97bf3fd8 [TIPC] Initial merge |
231 |
{ |
23dd4cce3 tipc: Combine por... |
232 |
return (struct tipc_port *)tipc_ref_lock(ref); |
b97bf3fd8 [TIPC] Initial merge |
233 |
} |
c43072852 [NET] TIPC: Fix w... |
234 |
/** |
4323add67 [TIPC] Avoid poll... |
235 |
* tipc_port_unlock - unlock a port instance |
c43072852 [NET] TIPC: Fix w... |
236 |
* |
4323add67 [TIPC] Avoid poll... |
237 |
* Can use pointer instead of tipc_ref_unlock() since port is already locked. |
b97bf3fd8 [TIPC] Initial merge |
238 |
*/ |
23dd4cce3 tipc: Combine por... |
239 |
static inline void tipc_port_unlock(struct tipc_port *p_ptr) |
b97bf3fd8 [TIPC] Initial merge |
240 |
{ |
23dd4cce3 tipc: Combine por... |
241 |
spin_unlock_bh(p_ptr->lock); |
b97bf3fd8 [TIPC] Initial merge |
242 |
} |
23dd4cce3 tipc: Combine por... |
243 |
static inline struct tipc_port *tipc_port_deref(u32 ref) |
b97bf3fd8 [TIPC] Initial merge |
244 |
{ |
23dd4cce3 tipc: Combine por... |
245 |
return (struct tipc_port *)tipc_ref_deref(ref); |
b97bf3fd8 [TIPC] Initial merge |
246 |
} |
23dd4cce3 tipc: Combine por... |
247 |
static inline u32 tipc_peer_port(struct tipc_port *p_ptr) |
b97bf3fd8 [TIPC] Initial merge |
248 |
{ |
23dd4cce3 tipc: Combine por... |
249 |
return msg_destport(&p_ptr->phdr); |
b97bf3fd8 [TIPC] Initial merge |
250 |
} |
23dd4cce3 tipc: Combine por... |
251 |
static inline u32 tipc_peer_node(struct tipc_port *p_ptr) |
b97bf3fd8 [TIPC] Initial merge |
252 |
{ |
23dd4cce3 tipc: Combine por... |
253 |
return msg_destnode(&p_ptr->phdr); |
b97bf3fd8 [TIPC] Initial merge |
254 |
} |
23dd4cce3 tipc: Combine por... |
255 |
static inline int tipc_port_congested(struct tipc_port *p_ptr) |
b97bf3fd8 [TIPC] Initial merge |
256 |
{ |
a02cec215 net: return opera... |
257 |
return (p_ptr->sent - p_ptr->acked) >= (TIPC_FLOW_CONTROL_WIN * 2); |
b97bf3fd8 [TIPC] Initial merge |
258 |
} |
c43072852 [NET] TIPC: Fix w... |
259 |
/** |
4323add67 [TIPC] Avoid poll... |
260 |
* tipc_port_recv_msg - receive message from lower layer and deliver to port user |
b97bf3fd8 [TIPC] Initial merge |
261 |
*/ |
4323add67 [TIPC] Avoid poll... |
262 |
static inline int tipc_port_recv_msg(struct sk_buff *buf) |
b97bf3fd8 [TIPC] Initial merge |
263 |
{ |
23dd4cce3 tipc: Combine por... |
264 |
struct tipc_port *p_ptr; |
b97bf3fd8 [TIPC] Initial merge |
265 266 267 268 |
struct tipc_msg *msg = buf_msg(buf); u32 destport = msg_destport(msg); u32 dsz = msg_data_sz(msg); u32 err; |
c43072852 [NET] TIPC: Fix w... |
269 |
|
b97bf3fd8 [TIPC] Initial merge |
270 271 |
/* forward unresolved named message */ if (unlikely(!destport)) { |
4323add67 [TIPC] Avoid poll... |
272 |
tipc_net_route_msg(buf); |
b97bf3fd8 [TIPC] Initial merge |
273 274 275 276 |
return dsz; } /* validate destination & pass to port, otherwise reject message */ |
4323add67 [TIPC] Avoid poll... |
277 |
p_ptr = tipc_port_lock(destport); |
b97bf3fd8 [TIPC] Initial merge |
278 |
if (likely(p_ptr)) { |
23dd4cce3 tipc: Combine por... |
279 |
if (likely(p_ptr->connected)) { |
4323add67 [TIPC] Avoid poll... |
280 281 |
if ((unlikely(msg_origport(msg) != tipc_peer_port(p_ptr))) || (unlikely(msg_orignode(msg) != tipc_peer_node(p_ptr))) || |
b97bf3fd8 [TIPC] Initial merge |
282 283 |
(unlikely(!msg_connected(msg)))) { err = TIPC_ERR_NO_PORT; |
4323add67 [TIPC] Avoid poll... |
284 |
tipc_port_unlock(p_ptr); |
b97bf3fd8 [TIPC] Initial merge |
285 286 287 |
goto reject; } } |
23dd4cce3 tipc: Combine por... |
288 |
err = p_ptr->dispatcher(p_ptr, buf); |
4323add67 [TIPC] Avoid poll... |
289 |
tipc_port_unlock(p_ptr); |
b97bf3fd8 [TIPC] Initial merge |
290 291 292 293 294 295 |
if (likely(!err)) return dsz; } else { err = TIPC_ERR_NO_PORT; } reject: |
b97bf3fd8 [TIPC] Initial merge |
296 297 298 299 |
return tipc_reject_msg(buf, err); } #endif |