diff options
author | Allan Stephens <Allan.Stephens@windriver.com> | 2010-12-31 13:59:32 -0500 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2011-01-01 16:57:56 -0500 |
commit | 0e65967e33be61e5f67727edd4ea829b47676fc0 (patch) | |
tree | 1135d631e0cb88af3f8b060b8c32a130315542d8 /net/tipc | |
parent | 25860c3bd5bd1db236d4fd5826d76127d677dc28 (diff) |
tipc: cleanup various cosmetic whitespace issues
Cleans up TIPC's source code to eliminate deviations from generally
accepted coding conventions relating to leading/trailing white space
and white space around commas, braces, cases, and sizeof.
These changes are purely cosmetic and do not alter the operation of TIPC
in any way.
Signed-off-by: Allan Stephens <Allan.Stephens@windriver.com>
Signed-off-by: Paul Gortmaker <paul.gortmaker@windriver.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/tipc')
-rw-r--r-- | net/tipc/Kconfig | 2 | ||||
-rw-r--r-- | net/tipc/bcast.c | 2 | ||||
-rw-r--r-- | net/tipc/config.c | 3 | ||||
-rw-r--r-- | net/tipc/discover.c | 2 | ||||
-rw-r--r-- | net/tipc/eth_media.c | 5 | ||||
-rw-r--r-- | net/tipc/link.c | 31 | ||||
-rw-r--r-- | net/tipc/link.h | 4 | ||||
-rw-r--r-- | net/tipc/msg.c | 56 | ||||
-rw-r--r-- | net/tipc/msg.h | 8 | ||||
-rw-r--r-- | net/tipc/name_table.c | 14 | ||||
-rw-r--r-- | net/tipc/name_table.h | 2 | ||||
-rw-r--r-- | net/tipc/node.c | 2 | ||||
-rw-r--r-- | net/tipc/port.c | 15 | ||||
-rw-r--r-- | net/tipc/port.h | 2 | ||||
-rw-r--r-- | net/tipc/ref.c | 6 | ||||
-rw-r--r-- | net/tipc/socket.c | 24 | ||||
-rw-r--r-- | net/tipc/subscr.c | 2 |
17 files changed, 86 insertions, 94 deletions
diff --git a/net/tipc/Kconfig b/net/tipc/Kconfig index 0e7ce30fd567..0436927369f3 100644 --- a/net/tipc/Kconfig +++ b/net/tipc/Kconfig | |||
@@ -50,7 +50,7 @@ config TIPC_PORTS | |||
50 | Specifies how many ports can be supported by a node. | 50 | Specifies how many ports can be supported by a node. |
51 | Can range from 127 to 65535 ports; default is 8191. | 51 | Can range from 127 to 65535 ports; default is 8191. |
52 | 52 | ||
53 | Setting this to a smaller value saves some memory, | 53 | Setting this to a smaller value saves some memory, |
54 | setting it to higher allows for more ports. | 54 | setting it to higher allows for more ports. |
55 | 55 | ||
56 | config TIPC_LOG | 56 | config TIPC_LOG |
diff --git a/net/tipc/bcast.c b/net/tipc/bcast.c index c0f3b096e7f5..9de32564984a 100644 --- a/net/tipc/bcast.c +++ b/net/tipc/bcast.c | |||
@@ -428,7 +428,7 @@ void tipc_bclink_recv_pkt(struct sk_buff *buf) | |||
428 | static int rx_count = 0; | 428 | static int rx_count = 0; |
429 | #endif | 429 | #endif |
430 | struct tipc_msg *msg = buf_msg(buf); | 430 | struct tipc_msg *msg = buf_msg(buf); |
431 | struct tipc_node* node = tipc_node_find(msg_prevnode(msg)); | 431 | struct tipc_node *node = tipc_node_find(msg_prevnode(msg)); |
432 | u32 next_in; | 432 | u32 next_in; |
433 | u32 seqno; | 433 | u32 seqno; |
434 | struct sk_buff *deferred; | 434 | struct sk_buff *deferred; |
diff --git a/net/tipc/config.c b/net/tipc/config.c index 6c67132f8652..e16750dcf3c1 100644 --- a/net/tipc/config.c +++ b/net/tipc/config.c | |||
@@ -322,8 +322,7 @@ struct sk_buff *tipc_cfg_do_cmd(u32 orig_node, u16 cmd, const void *request_area | |||
322 | } else if (!tipc_remote_management) { | 322 | } else if (!tipc_remote_management) { |
323 | rep_tlv_buf = tipc_cfg_reply_error_string(TIPC_CFG_NO_REMOTE); | 323 | rep_tlv_buf = tipc_cfg_reply_error_string(TIPC_CFG_NO_REMOTE); |
324 | goto exit; | 324 | goto exit; |
325 | } | 325 | } else if (cmd >= 0x4000) { |
326 | else if (cmd >= 0x4000) { | ||
327 | u32 domain = 0; | 326 | u32 domain = 0; |
328 | 327 | ||
329 | if ((tipc_nametbl_translate(TIPC_ZM_SRV, 0, &domain) == 0) || | 328 | if ((tipc_nametbl_translate(TIPC_ZM_SRV, 0, &domain) == 0) || |
diff --git a/net/tipc/discover.c b/net/tipc/discover.c index be28f5adc770..fa026bd91a68 100644 --- a/net/tipc/discover.c +++ b/net/tipc/discover.c | |||
@@ -130,7 +130,7 @@ void tipc_disc_recv_msg(struct sk_buff *buf, struct bearer *b_ptr) | |||
130 | u32 net_id = msg_bc_netid(msg); | 130 | u32 net_id = msg_bc_netid(msg); |
131 | u32 type = msg_type(msg); | 131 | u32 type = msg_type(msg); |
132 | 132 | ||
133 | msg_get_media_addr(msg,&media_addr); | 133 | msg_get_media_addr(msg, &media_addr); |
134 | buf_discard(buf); | 134 | buf_discard(buf); |
135 | 135 | ||
136 | if (net_id != tipc_net_id) | 136 | if (net_id != tipc_net_id) |
diff --git a/net/tipc/eth_media.c b/net/tipc/eth_media.c index 101d9cb6a559..5dfe66357794 100644 --- a/net/tipc/eth_media.c +++ b/net/tipc/eth_media.c | |||
@@ -144,7 +144,7 @@ static int enable_bearer(struct tipc_bearer *tb_ptr) | |||
144 | 144 | ||
145 | /* Find device with specified name */ | 145 | /* Find device with specified name */ |
146 | 146 | ||
147 | for_each_netdev(&init_net, pdev){ | 147 | for_each_netdev(&init_net, pdev) { |
148 | if (!strncmp(pdev->name, driver_name, IFNAMSIZ)) { | 148 | if (!strncmp(pdev->name, driver_name, IFNAMSIZ)) { |
149 | dev = pdev; | 149 | dev = pdev; |
150 | break; | 150 | break; |
@@ -155,7 +155,8 @@ static int enable_bearer(struct tipc_bearer *tb_ptr) | |||
155 | 155 | ||
156 | /* Find Ethernet bearer for device (or create one) */ | 156 | /* Find Ethernet bearer for device (or create one) */ |
157 | 157 | ||
158 | for (;(eb_ptr != stop) && eb_ptr->dev && (eb_ptr->dev != dev); eb_ptr++); | 158 | while ((eb_ptr != stop) && eb_ptr->dev && (eb_ptr->dev != dev)) |
159 | eb_ptr++; | ||
159 | if (eb_ptr == stop) | 160 | if (eb_ptr == stop) |
160 | return -EDQUOT; | 161 | return -EDQUOT; |
161 | if (!eb_ptr->dev) { | 162 | if (!eb_ptr->dev) { |
diff --git a/net/tipc/link.c b/net/tipc/link.c index 647f2ecfde50..ef203a1581cd 100644 --- a/net/tipc/link.c +++ b/net/tipc/link.c | |||
@@ -977,8 +977,7 @@ static int link_send_buf_fast(struct link *l_ptr, struct sk_buff *buf, | |||
977 | l_ptr->next_out = buf; | 977 | l_ptr->next_out = buf; |
978 | return res; | 978 | return res; |
979 | } | 979 | } |
980 | } | 980 | } else |
981 | else | ||
982 | *used_max_pkt = l_ptr->max_pkt; | 981 | *used_max_pkt = l_ptr->max_pkt; |
983 | } | 982 | } |
984 | return tipc_link_send_buf(l_ptr, buf); /* All other cases */ | 983 | return tipc_link_send_buf(l_ptr, buf); /* All other cases */ |
@@ -1132,10 +1131,10 @@ static int link_send_sections_long(struct port *sender, | |||
1132 | struct tipc_node *node; | 1131 | struct tipc_node *node; |
1133 | struct tipc_msg *hdr = &sender->publ.phdr; | 1132 | struct tipc_msg *hdr = &sender->publ.phdr; |
1134 | u32 dsz = msg_data_sz(hdr); | 1133 | u32 dsz = msg_data_sz(hdr); |
1135 | u32 max_pkt,fragm_sz,rest; | 1134 | u32 max_pkt, fragm_sz, rest; |
1136 | struct tipc_msg fragm_hdr; | 1135 | struct tipc_msg fragm_hdr; |
1137 | struct sk_buff *buf,*buf_chain,*prev; | 1136 | struct sk_buff *buf, *buf_chain, *prev; |
1138 | u32 fragm_crs,fragm_rest,hsz,sect_rest; | 1137 | u32 fragm_crs, fragm_rest, hsz, sect_rest; |
1139 | const unchar *sect_crs; | 1138 | const unchar *sect_crs; |
1140 | int curr_sect; | 1139 | int curr_sect; |
1141 | u32 fragm_no; | 1140 | u32 fragm_no; |
@@ -1212,7 +1211,7 @@ error: | |||
1212 | /* Initiate new fragment: */ | 1211 | /* Initiate new fragment: */ |
1213 | if (rest <= fragm_sz) { | 1212 | if (rest <= fragm_sz) { |
1214 | fragm_sz = rest; | 1213 | fragm_sz = rest; |
1215 | msg_set_type(&fragm_hdr,LAST_FRAGMENT); | 1214 | msg_set_type(&fragm_hdr, LAST_FRAGMENT); |
1216 | } else { | 1215 | } else { |
1217 | msg_set_type(&fragm_hdr, FRAGMENT); | 1216 | msg_set_type(&fragm_hdr, FRAGMENT); |
1218 | } | 1217 | } |
@@ -1229,8 +1228,7 @@ error: | |||
1229 | fragm_crs = INT_H_SIZE; | 1228 | fragm_crs = INT_H_SIZE; |
1230 | fragm_rest = fragm_sz; | 1229 | fragm_rest = fragm_sz; |
1231 | } | 1230 | } |
1232 | } | 1231 | } while (rest > 0); |
1233 | while (rest > 0); | ||
1234 | 1232 | ||
1235 | /* | 1233 | /* |
1236 | * Now we have a buffer chain. Select a link and check | 1234 | * Now we have a buffer chain. Select a link and check |
@@ -1333,7 +1331,7 @@ u32 tipc_link_push_packet(struct link *l_ptr) | |||
1333 | buf = l_ptr->proto_msg_queue; | 1331 | buf = l_ptr->proto_msg_queue; |
1334 | if (buf) { | 1332 | if (buf) { |
1335 | msg_set_ack(buf_msg(buf), mod(l_ptr->next_in_no - 1)); | 1333 | msg_set_ack(buf_msg(buf), mod(l_ptr->next_in_no - 1)); |
1336 | msg_set_bcast_ack(buf_msg(buf),l_ptr->owner->bclink.last_in); | 1334 | msg_set_bcast_ack(buf_msg(buf), l_ptr->owner->bclink.last_in); |
1337 | if (tipc_bearer_send(l_ptr->b_ptr, buf, &l_ptr->media_addr)) { | 1335 | if (tipc_bearer_send(l_ptr->b_ptr, buf, &l_ptr->media_addr)) { |
1338 | l_ptr->unacked_window = 0; | 1336 | l_ptr->unacked_window = 0; |
1339 | buf_discard(buf); | 1337 | buf_discard(buf); |
@@ -1847,8 +1845,7 @@ u32 tipc_link_defer_pkt(struct sk_buff **head, | |||
1847 | } | 1845 | } |
1848 | prev = crs; | 1846 | prev = crs; |
1849 | crs = crs->next; | 1847 | crs = crs->next; |
1850 | } | 1848 | } while (crs); |
1851 | while (crs); | ||
1852 | 1849 | ||
1853 | /* Message is a duplicate of an existing message */ | 1850 | /* Message is a duplicate of an existing message */ |
1854 | 1851 | ||
@@ -2215,11 +2212,11 @@ void tipc_link_changeover(struct link *l_ptr) | |||
2215 | 2212 | ||
2216 | if ((msg_user(msg) == MSG_BUNDLER) && split_bundles) { | 2213 | if ((msg_user(msg) == MSG_BUNDLER) && split_bundles) { |
2217 | struct tipc_msg *m = msg_get_wrapped(msg); | 2214 | struct tipc_msg *m = msg_get_wrapped(msg); |
2218 | unchar* pos = (unchar*)m; | 2215 | unchar *pos = (unchar *)m; |
2219 | 2216 | ||
2220 | msgcount = msg_msgcnt(msg); | 2217 | msgcount = msg_msgcnt(msg); |
2221 | while (msgcount--) { | 2218 | while (msgcount--) { |
2222 | msg_set_seqno(m,msg_seqno(msg)); | 2219 | msg_set_seqno(m, msg_seqno(msg)); |
2223 | tipc_link_tunnel(l_ptr, &tunnel_hdr, m, | 2220 | tipc_link_tunnel(l_ptr, &tunnel_hdr, m, |
2224 | msg_link_selector(m)); | 2221 | msg_link_selector(m)); |
2225 | pos += align(msg_size(m)); | 2222 | pos += align(msg_size(m)); |
@@ -2321,7 +2318,7 @@ static int link_recv_changeover_msg(struct link **l_ptr, | |||
2321 | if (msg_typ == DUPLICATE_MSG) { | 2318 | if (msg_typ == DUPLICATE_MSG) { |
2322 | if (less(msg_seqno(msg), mod(dest_link->next_in_no))) | 2319 | if (less(msg_seqno(msg), mod(dest_link->next_in_no))) |
2323 | goto exit; | 2320 | goto exit; |
2324 | *buf = buf_extract(tunnel_buf,INT_H_SIZE); | 2321 | *buf = buf_extract(tunnel_buf, INT_H_SIZE); |
2325 | if (*buf == NULL) { | 2322 | if (*buf == NULL) { |
2326 | warn("Link changeover error, duplicate msg dropped\n"); | 2323 | warn("Link changeover error, duplicate msg dropped\n"); |
2327 | goto exit; | 2324 | goto exit; |
@@ -2552,8 +2549,8 @@ int tipc_link_recv_fragment(struct sk_buff **pending, struct sk_buff **fb, | |||
2552 | /* Prepare buffer for subsequent fragments. */ | 2549 | /* Prepare buffer for subsequent fragments. */ |
2553 | 2550 | ||
2554 | set_long_msg_seqno(pbuf, long_msg_seq_no); | 2551 | set_long_msg_seqno(pbuf, long_msg_seq_no); |
2555 | set_fragm_size(pbuf,fragm_sz); | 2552 | set_fragm_size(pbuf, fragm_sz); |
2556 | set_expected_frags(pbuf,exp_fragm_cnt - 1); | 2553 | set_expected_frags(pbuf, exp_fragm_cnt - 1); |
2557 | } else { | 2554 | } else { |
2558 | warn("Link unable to reassemble fragmented message\n"); | 2555 | warn("Link unable to reassemble fragmented message\n"); |
2559 | } | 2556 | } |
@@ -2580,7 +2577,7 @@ int tipc_link_recv_fragment(struct sk_buff **pending, struct sk_buff **fb, | |||
2580 | *m = buf_msg(pbuf); | 2577 | *m = buf_msg(pbuf); |
2581 | return 1; | 2578 | return 1; |
2582 | } | 2579 | } |
2583 | set_expected_frags(pbuf,exp_frags); | 2580 | set_expected_frags(pbuf, exp_frags); |
2584 | return 0; | 2581 | return 0; |
2585 | } | 2582 | } |
2586 | buf_discard(fbuf); | 2583 | buf_discard(fbuf); |
diff --git a/net/tipc/link.h b/net/tipc/link.h index eca19c247b79..70967e637027 100644 --- a/net/tipc/link.h +++ b/net/tipc/link.h | |||
@@ -229,8 +229,8 @@ struct sk_buff *tipc_link_cmd_reset_stats(const void *req_tlv_area, int req_tlv_ | |||
229 | void tipc_link_reset(struct link *l_ptr); | 229 | void tipc_link_reset(struct link *l_ptr); |
230 | int tipc_link_send(struct sk_buff *buf, u32 dest, u32 selector); | 230 | int tipc_link_send(struct sk_buff *buf, u32 dest, u32 selector); |
231 | int tipc_link_send_buf(struct link *l_ptr, struct sk_buff *buf); | 231 | int tipc_link_send_buf(struct link *l_ptr, struct sk_buff *buf); |
232 | u32 tipc_link_get_max_pkt(u32 dest,u32 selector); | 232 | u32 tipc_link_get_max_pkt(u32 dest, u32 selector); |
233 | int tipc_link_send_sections_fast(struct port* sender, | 233 | int tipc_link_send_sections_fast(struct port *sender, |
234 | struct iovec const *msg_sect, | 234 | struct iovec const *msg_sect, |
235 | const u32 num_sect, | 235 | const u32 num_sect, |
236 | u32 destnode); | 236 | u32 destnode); |
diff --git a/net/tipc/msg.c b/net/tipc/msg.c index 2571ffb4d350..e81d43a8ea3d 100644 --- a/net/tipc/msg.c +++ b/net/tipc/msg.c | |||
@@ -91,7 +91,7 @@ int tipc_msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect) | |||
91 | 91 | ||
92 | int tipc_msg_build(struct tipc_msg *hdr, | 92 | int tipc_msg_build(struct tipc_msg *hdr, |
93 | struct iovec const *msg_sect, u32 num_sect, | 93 | struct iovec const *msg_sect, u32 num_sect, |
94 | int max_size, int usrmem, struct sk_buff** buf) | 94 | int max_size, int usrmem, struct sk_buff **buf) |
95 | { | 95 | { |
96 | int dsz, sz, hsz, pos, res, cnt; | 96 | int dsz, sz, hsz, pos, res, cnt; |
97 | 97 | ||
@@ -161,10 +161,10 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
161 | tipc_printf(buf, "LAST:"); | 161 | tipc_printf(buf, "LAST:"); |
162 | break; | 162 | break; |
163 | default: | 163 | default: |
164 | tipc_printf(buf, "UNKNOWN:%x",msg_type(msg)); | 164 | tipc_printf(buf, "UNKNOWN:%x", msg_type(msg)); |
165 | 165 | ||
166 | } | 166 | } |
167 | tipc_printf(buf, "NO(%u/%u):",msg_long_msgno(msg), | 167 | tipc_printf(buf, "NO(%u/%u):", msg_long_msgno(msg), |
168 | msg_fragm_no(msg)); | 168 | msg_fragm_no(msg)); |
169 | break; | 169 | break; |
170 | case TIPC_LOW_IMPORTANCE: | 170 | case TIPC_LOW_IMPORTANCE: |
@@ -190,7 +190,7 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
190 | tipc_printf(buf, "DIR:"); | 190 | tipc_printf(buf, "DIR:"); |
191 | break; | 191 | break; |
192 | default: | 192 | default: |
193 | tipc_printf(buf, "UNKNOWN TYPE %u",msg_type(msg)); | 193 | tipc_printf(buf, "UNKNOWN TYPE %u", msg_type(msg)); |
194 | } | 194 | } |
195 | if (msg_routed(msg) && !msg_non_seq(msg)) | 195 | if (msg_routed(msg) && !msg_non_seq(msg)) |
196 | tipc_printf(buf, "ROUT:"); | 196 | tipc_printf(buf, "ROUT:"); |
@@ -208,7 +208,7 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
208 | tipc_printf(buf, "WDRW:"); | 208 | tipc_printf(buf, "WDRW:"); |
209 | break; | 209 | break; |
210 | default: | 210 | default: |
211 | tipc_printf(buf, "UNKNOWN:%x",msg_type(msg)); | 211 | tipc_printf(buf, "UNKNOWN:%x", msg_type(msg)); |
212 | } | 212 | } |
213 | if (msg_routed(msg)) | 213 | if (msg_routed(msg)) |
214 | tipc_printf(buf, "ROUT:"); | 214 | tipc_printf(buf, "ROUT:"); |
@@ -227,39 +227,39 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
227 | break; | 227 | break; |
228 | case CONN_ACK: | 228 | case CONN_ACK: |
229 | tipc_printf(buf, "CONN_ACK:"); | 229 | tipc_printf(buf, "CONN_ACK:"); |
230 | tipc_printf(buf, "ACK(%u):",msg_msgcnt(msg)); | 230 | tipc_printf(buf, "ACK(%u):", msg_msgcnt(msg)); |
231 | break; | 231 | break; |
232 | default: | 232 | default: |
233 | tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg)); | 233 | tipc_printf(buf, "UNKNOWN TYPE:%x", msg_type(msg)); |
234 | } | 234 | } |
235 | if (msg_routed(msg)) | 235 | if (msg_routed(msg)) |
236 | tipc_printf(buf, "ROUT:"); | 236 | tipc_printf(buf, "ROUT:"); |
237 | if (msg_reroute_cnt(msg)) | 237 | if (msg_reroute_cnt(msg)) |
238 | tipc_printf(buf, "REROUTED(%u):",msg_reroute_cnt(msg)); | 238 | tipc_printf(buf, "REROUTED(%u):", msg_reroute_cnt(msg)); |
239 | break; | 239 | break; |
240 | case LINK_PROTOCOL: | 240 | case LINK_PROTOCOL: |
241 | tipc_printf(buf, "PROT:TIM(%u):",msg_timestamp(msg)); | 241 | tipc_printf(buf, "PROT:TIM(%u):", msg_timestamp(msg)); |
242 | switch (msg_type(msg)) { | 242 | switch (msg_type(msg)) { |
243 | case STATE_MSG: | 243 | case STATE_MSG: |
244 | tipc_printf(buf, "STATE:"); | 244 | tipc_printf(buf, "STATE:"); |
245 | tipc_printf(buf, "%s:",msg_probe(msg) ? "PRB" :""); | 245 | tipc_printf(buf, "%s:", msg_probe(msg) ? "PRB" : ""); |
246 | tipc_printf(buf, "NXS(%u):",msg_next_sent(msg)); | 246 | tipc_printf(buf, "NXS(%u):", msg_next_sent(msg)); |
247 | tipc_printf(buf, "GAP(%u):",msg_seq_gap(msg)); | 247 | tipc_printf(buf, "GAP(%u):", msg_seq_gap(msg)); |
248 | tipc_printf(buf, "LSTBC(%u):",msg_last_bcast(msg)); | 248 | tipc_printf(buf, "LSTBC(%u):", msg_last_bcast(msg)); |
249 | break; | 249 | break; |
250 | case RESET_MSG: | 250 | case RESET_MSG: |
251 | tipc_printf(buf, "RESET:"); | 251 | tipc_printf(buf, "RESET:"); |
252 | if (msg_size(msg) != msg_hdr_sz(msg)) | 252 | if (msg_size(msg) != msg_hdr_sz(msg)) |
253 | tipc_printf(buf, "BEAR:%s:",msg_data(msg)); | 253 | tipc_printf(buf, "BEAR:%s:", msg_data(msg)); |
254 | break; | 254 | break; |
255 | case ACTIVATE_MSG: | 255 | case ACTIVATE_MSG: |
256 | tipc_printf(buf, "ACTIVATE:"); | 256 | tipc_printf(buf, "ACTIVATE:"); |
257 | break; | 257 | break; |
258 | default: | 258 | default: |
259 | tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg)); | 259 | tipc_printf(buf, "UNKNOWN TYPE:%x", msg_type(msg)); |
260 | } | 260 | } |
261 | tipc_printf(buf, "PLANE(%c):",msg_net_plane(msg)); | 261 | tipc_printf(buf, "PLANE(%c):", msg_net_plane(msg)); |
262 | tipc_printf(buf, "SESS(%u):",msg_session(msg)); | 262 | tipc_printf(buf, "SESS(%u):", msg_session(msg)); |
263 | break; | 263 | break; |
264 | case CHANGEOVER_PROTOCOL: | 264 | case CHANGEOVER_PROTOCOL: |
265 | tipc_printf(buf, "TUNL:"); | 265 | tipc_printf(buf, "TUNL:"); |
@@ -269,10 +269,10 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
269 | break; | 269 | break; |
270 | case ORIGINAL_MSG: | 270 | case ORIGINAL_MSG: |
271 | tipc_printf(buf, "ORIG:"); | 271 | tipc_printf(buf, "ORIG:"); |
272 | tipc_printf(buf, "EXP(%u)",msg_msgcnt(msg)); | 272 | tipc_printf(buf, "EXP(%u)", msg_msgcnt(msg)); |
273 | break; | 273 | break; |
274 | default: | 274 | default: |
275 | tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg)); | 275 | tipc_printf(buf, "UNKNOWN TYPE:%x", msg_type(msg)); |
276 | } | 276 | } |
277 | break; | 277 | break; |
278 | case ROUTE_DISTRIBUTOR: | 278 | case ROUTE_DISTRIBUTOR: |
@@ -280,26 +280,26 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
280 | switch (msg_type(msg)) { | 280 | switch (msg_type(msg)) { |
281 | case EXT_ROUTING_TABLE: | 281 | case EXT_ROUTING_TABLE: |
282 | tipc_printf(buf, "EXT_TBL:"); | 282 | tipc_printf(buf, "EXT_TBL:"); |
283 | tipc_printf(buf, "TO:%x:",msg_remote_node(msg)); | 283 | tipc_printf(buf, "TO:%x:", msg_remote_node(msg)); |
284 | break; | 284 | break; |
285 | case LOCAL_ROUTING_TABLE: | 285 | case LOCAL_ROUTING_TABLE: |
286 | tipc_printf(buf, "LOCAL_TBL:"); | 286 | tipc_printf(buf, "LOCAL_TBL:"); |
287 | tipc_printf(buf, "TO:%x:",msg_remote_node(msg)); | 287 | tipc_printf(buf, "TO:%x:", msg_remote_node(msg)); |
288 | break; | 288 | break; |
289 | case SLAVE_ROUTING_TABLE: | 289 | case SLAVE_ROUTING_TABLE: |
290 | tipc_printf(buf, "DP_TBL:"); | 290 | tipc_printf(buf, "DP_TBL:"); |
291 | tipc_printf(buf, "TO:%x:",msg_remote_node(msg)); | 291 | tipc_printf(buf, "TO:%x:", msg_remote_node(msg)); |
292 | break; | 292 | break; |
293 | case ROUTE_ADDITION: | 293 | case ROUTE_ADDITION: |
294 | tipc_printf(buf, "ADD:"); | 294 | tipc_printf(buf, "ADD:"); |
295 | tipc_printf(buf, "TO:%x:",msg_remote_node(msg)); | 295 | tipc_printf(buf, "TO:%x:", msg_remote_node(msg)); |
296 | break; | 296 | break; |
297 | case ROUTE_REMOVAL: | 297 | case ROUTE_REMOVAL: |
298 | tipc_printf(buf, "REMOVE:"); | 298 | tipc_printf(buf, "REMOVE:"); |
299 | tipc_printf(buf, "TO:%x:",msg_remote_node(msg)); | 299 | tipc_printf(buf, "TO:%x:", msg_remote_node(msg)); |
300 | break; | 300 | break; |
301 | default: | 301 | default: |
302 | tipc_printf(buf, "UNKNOWN TYPE:%x",msg_type(msg)); | 302 | tipc_printf(buf, "UNKNOWN TYPE:%x", msg_type(msg)); |
303 | } | 303 | } |
304 | break; | 304 | break; |
305 | case LINK_CONFIG: | 305 | case LINK_CONFIG: |
@@ -312,7 +312,7 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
312 | tipc_printf(buf, "DSC_RESP:"); | 312 | tipc_printf(buf, "DSC_RESP:"); |
313 | break; | 313 | break; |
314 | default: | 314 | default: |
315 | tipc_printf(buf, "UNKNOWN TYPE:%x:",msg_type(msg)); | 315 | tipc_printf(buf, "UNKNOWN TYPE:%x:", msg_type(msg)); |
316 | break; | 316 | break; |
317 | } | 317 | } |
318 | break; | 318 | break; |
@@ -393,8 +393,8 @@ void tipc_msg_dbg(struct print_buf *buf, struct tipc_msg *msg, const char *str) | |||
393 | } | 393 | } |
394 | 394 | ||
395 | if (msg_user(msg) == LINK_CONFIG) { | 395 | if (msg_user(msg) == LINK_CONFIG) { |
396 | u32* raw = (u32*)msg; | 396 | u32 *raw = (u32 *)msg; |
397 | struct tipc_media_addr* orig = (struct tipc_media_addr*)&raw[5]; | 397 | struct tipc_media_addr *orig = (struct tipc_media_addr *)&raw[5]; |
398 | tipc_printf(buf, ":REQL(%u):", msg_req_links(msg)); | 398 | tipc_printf(buf, ":REQL(%u):", msg_req_links(msg)); |
399 | tipc_printf(buf, ":DDOM(%x):", msg_dest_domain(msg)); | 399 | tipc_printf(buf, ":DDOM(%x):", msg_dest_domain(msg)); |
400 | tipc_printf(buf, ":NETID(%u):", msg_bc_netid(msg)); | 400 | tipc_printf(buf, ":NETID(%u):", msg_bc_netid(msg)); |
diff --git a/net/tipc/msg.h b/net/tipc/msg.h index 68b65ef3e74b..92c4c4fd7b3f 100644 --- a/net/tipc/msg.h +++ b/net/tipc/msg.h | |||
@@ -174,7 +174,7 @@ static inline u32 msg_hdr_sz(struct tipc_msg *m) | |||
174 | return msg_bits(m, 0, 21, 0xf) << 2; | 174 | return msg_bits(m, 0, 21, 0xf) << 2; |
175 | } | 175 | } |
176 | 176 | ||
177 | static inline void msg_set_hdr_sz(struct tipc_msg *m,u32 n) | 177 | static inline void msg_set_hdr_sz(struct tipc_msg *m, u32 n) |
178 | { | 178 | { |
179 | msg_set_bits(m, 0, 21, 0xf, n>>2); | 179 | msg_set_bits(m, 0, 21, 0xf, n>>2); |
180 | } | 180 | } |
@@ -425,7 +425,7 @@ static inline u32 msg_routed(struct tipc_msg *m) | |||
425 | { | 425 | { |
426 | if (likely(msg_short(m))) | 426 | if (likely(msg_short(m))) |
427 | return 0; | 427 | return 0; |
428 | return(msg_destnode(m) ^ msg_orignode(m)) >> 11; | 428 | return (msg_destnode(m) ^ msg_orignode(m)) >> 11; |
429 | } | 429 | } |
430 | 430 | ||
431 | static inline u32 msg_nametype(struct tipc_msg *m) | 431 | static inline u32 msg_nametype(struct tipc_msg *m) |
@@ -863,7 +863,7 @@ void tipc_msg_init(struct tipc_msg *m, u32 user, u32 type, | |||
863 | int tipc_msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect); | 863 | int tipc_msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect); |
864 | int tipc_msg_build(struct tipc_msg *hdr, | 864 | int tipc_msg_build(struct tipc_msg *hdr, |
865 | struct iovec const *msg_sect, u32 num_sect, | 865 | struct iovec const *msg_sect, u32 num_sect, |
866 | int max_size, int usrmem, struct sk_buff** buf); | 866 | int max_size, int usrmem, struct sk_buff **buf); |
867 | 867 | ||
868 | static inline void msg_set_media_addr(struct tipc_msg *m, struct tipc_media_addr *a) | 868 | static inline void msg_set_media_addr(struct tipc_msg *m, struct tipc_media_addr *a) |
869 | { | 869 | { |
@@ -872,7 +872,7 @@ static inline void msg_set_media_addr(struct tipc_msg *m, struct tipc_media_addr | |||
872 | 872 | ||
873 | static inline void msg_get_media_addr(struct tipc_msg *m, struct tipc_media_addr *a) | 873 | static inline void msg_get_media_addr(struct tipc_msg *m, struct tipc_media_addr *a) |
874 | { | 874 | { |
875 | memcpy(a, &((int*)m)[5], sizeof(*a)); | 875 | memcpy(a, &((int *)m)[5], sizeof(*a)); |
876 | } | 876 | } |
877 | 877 | ||
878 | #endif | 878 | #endif |
diff --git a/net/tipc/name_table.c b/net/tipc/name_table.c index ddc2ad4c2d32..46b2f31f96a1 100644 --- a/net/tipc/name_table.c +++ b/net/tipc/name_table.c | |||
@@ -296,8 +296,8 @@ static struct publication *tipc_nameseq_insert_publ(struct name_seq *nseq, | |||
296 | 296 | ||
297 | sseq = &nseq->sseqs[inspos]; | 297 | sseq = &nseq->sseqs[inspos]; |
298 | freesseq = &nseq->sseqs[nseq->first_free]; | 298 | freesseq = &nseq->sseqs[nseq->first_free]; |
299 | memmove(sseq + 1, sseq, (freesseq - sseq) * sizeof (*sseq)); | 299 | memmove(sseq + 1, sseq, (freesseq - sseq) * sizeof(*sseq)); |
300 | memset(sseq, 0, sizeof (*sseq)); | 300 | memset(sseq, 0, sizeof(*sseq)); |
301 | nseq->first_free++; | 301 | nseq->first_free++; |
302 | sseq->lower = lower; | 302 | sseq->lower = lower; |
303 | sseq->upper = upper; | 303 | sseq->upper = upper; |
@@ -471,7 +471,7 @@ end_node: | |||
471 | 471 | ||
472 | if (!sseq->zone_list) { | 472 | if (!sseq->zone_list) { |
473 | free = &nseq->sseqs[nseq->first_free--]; | 473 | free = &nseq->sseqs[nseq->first_free--]; |
474 | memmove(sseq, sseq + 1, (free - (sseq + 1)) * sizeof (*sseq)); | 474 | memmove(sseq, sseq + 1, (free - (sseq + 1)) * sizeof(*sseq)); |
475 | removed_subseq = 1; | 475 | removed_subseq = 1; |
476 | } | 476 | } |
477 | 477 | ||
@@ -507,7 +507,7 @@ static void tipc_nameseq_subscribe(struct name_seq *nseq, struct subscription *s | |||
507 | 507 | ||
508 | while (sseq != &nseq->sseqs[nseq->first_free]) { | 508 | while (sseq != &nseq->sseqs[nseq->first_free]) { |
509 | struct publication *zl = sseq->zone_list; | 509 | struct publication *zl = sseq->zone_list; |
510 | if (zl && tipc_subscr_overlap(s,sseq->lower,sseq->upper)) { | 510 | if (zl && tipc_subscr_overlap(s, sseq->lower, sseq->upper)) { |
511 | struct publication *crs = zl; | 511 | struct publication *crs = zl; |
512 | int must_report = 1; | 512 | int must_report = 1; |
513 | 513 | ||
@@ -798,7 +798,7 @@ void tipc_nametbl_subscribe(struct subscription *s) | |||
798 | if (!seq) { | 798 | if (!seq) { |
799 | seq = tipc_nameseq_create(type, &table.types[hash(type)]); | 799 | seq = tipc_nameseq_create(type, &table.types[hash(type)]); |
800 | } | 800 | } |
801 | if (seq){ | 801 | if (seq) { |
802 | spin_lock_bh(&seq->lock); | 802 | spin_lock_bh(&seq->lock); |
803 | tipc_nameseq_subscribe(seq, s); | 803 | tipc_nameseq_subscribe(seq, s); |
804 | spin_unlock_bh(&seq->lock); | 804 | spin_unlock_bh(&seq->lock); |
@@ -819,7 +819,7 @@ void tipc_nametbl_unsubscribe(struct subscription *s) | |||
819 | 819 | ||
820 | write_lock_bh(&tipc_nametbl_lock); | 820 | write_lock_bh(&tipc_nametbl_lock); |
821 | seq = nametbl_find_seq(s->seq.type); | 821 | seq = nametbl_find_seq(s->seq.type); |
822 | if (seq != NULL){ | 822 | if (seq != NULL) { |
823 | spin_lock_bh(&seq->lock); | 823 | spin_lock_bh(&seq->lock); |
824 | list_del_init(&s->nameseq_list); | 824 | list_del_init(&s->nameseq_list); |
825 | spin_unlock_bh(&seq->lock); | 825 | spin_unlock_bh(&seq->lock); |
@@ -852,7 +852,7 @@ static void subseq_list(struct sub_seq *sseq, struct print_buf *buf, u32 depth, | |||
852 | } | 852 | } |
853 | 853 | ||
854 | do { | 854 | do { |
855 | sprintf (portIdStr, "<%u.%u.%u:%u>", | 855 | sprintf(portIdStr, "<%u.%u.%u:%u>", |
856 | tipc_zone(publ->node), tipc_cluster(publ->node), | 856 | tipc_zone(publ->node), tipc_cluster(publ->node), |
857 | tipc_node(publ->node), publ->ref); | 857 | tipc_node(publ->node), publ->ref); |
858 | tipc_printf(buf, "%-26s ", portIdStr); | 858 | tipc_printf(buf, "%-26s ", portIdStr); |
diff --git a/net/tipc/name_table.h b/net/tipc/name_table.h index 139882d4ed00..d228bd682655 100644 --- a/net/tipc/name_table.h +++ b/net/tipc/name_table.h | |||
@@ -46,7 +46,7 @@ struct port_list; | |||
46 | * TIPC name types reserved for internal TIPC use (both current and planned) | 46 | * TIPC name types reserved for internal TIPC use (both current and planned) |
47 | */ | 47 | */ |
48 | 48 | ||
49 | #define TIPC_ZM_SRV 3 /* zone master service name type */ | 49 | #define TIPC_ZM_SRV 3 /* zone master service name type */ |
50 | 50 | ||
51 | 51 | ||
52 | /** | 52 | /** |
diff --git a/net/tipc/node.c b/net/tipc/node.c index 126d774883dd..2ed162f91a08 100644 --- a/net/tipc/node.c +++ b/net/tipc/node.c | |||
@@ -334,7 +334,7 @@ static void node_lost_contact(struct tipc_node *n_ptr) | |||
334 | /* Clean up broadcast reception remains */ | 334 | /* Clean up broadcast reception remains */ |
335 | n_ptr->bclink.gap_after = n_ptr->bclink.gap_to = 0; | 335 | n_ptr->bclink.gap_after = n_ptr->bclink.gap_to = 0; |
336 | while (n_ptr->bclink.deferred_head) { | 336 | while (n_ptr->bclink.deferred_head) { |
337 | struct sk_buff* buf = n_ptr->bclink.deferred_head; | 337 | struct sk_buff *buf = n_ptr->bclink.deferred_head; |
338 | n_ptr->bclink.deferred_head = buf->next; | 338 | n_ptr->bclink.deferred_head = buf->next; |
339 | buf_discard(buf); | 339 | buf_discard(buf); |
340 | } | 340 | } |
diff --git a/net/tipc/port.c b/net/tipc/port.c index db14b7e0afdc..78fcb75bb082 100644 --- a/net/tipc/port.c +++ b/net/tipc/port.c | |||
@@ -54,8 +54,8 @@ static DEFINE_SPINLOCK(queue_lock); | |||
54 | 54 | ||
55 | static LIST_HEAD(ports); | 55 | static LIST_HEAD(ports); |
56 | static void port_handle_node_down(unsigned long ref); | 56 | static void port_handle_node_down(unsigned long ref); |
57 | static struct sk_buff* port_build_self_abort_msg(struct port *,u32 err); | 57 | static struct sk_buff *port_build_self_abort_msg(struct port *, u32 err); |
58 | static struct sk_buff* port_build_peer_abort_msg(struct port *,u32 err); | 58 | static struct sk_buff *port_build_peer_abort_msg(struct port *, u32 err); |
59 | static void port_timeout(unsigned long ref); | 59 | static void port_timeout(unsigned long ref); |
60 | 60 | ||
61 | 61 | ||
@@ -155,7 +155,7 @@ int tipc_multicast(u32 ref, struct tipc_name_seq const *seq, | |||
155 | 155 | ||
156 | void tipc_port_recv_mcast(struct sk_buff *buf, struct port_list *dp) | 156 | void tipc_port_recv_mcast(struct sk_buff *buf, struct port_list *dp) |
157 | { | 157 | { |
158 | struct tipc_msg* msg; | 158 | struct tipc_msg *msg; |
159 | struct port_list dports = {0, NULL, }; | 159 | struct port_list dports = {0, NULL, }; |
160 | struct port_list *item = dp; | 160 | struct port_list *item = dp; |
161 | int cnt = 0; | 161 | int cnt = 0; |
@@ -193,7 +193,7 @@ void tipc_port_recv_mcast(struct sk_buff *buf, struct port_list *dp) | |||
193 | if ((index == 0) && (cnt != 0)) { | 193 | if ((index == 0) && (cnt != 0)) { |
194 | item = item->next; | 194 | item = item->next; |
195 | } | 195 | } |
196 | msg_set_destport(buf_msg(b),item->ports[index]); | 196 | msg_set_destport(buf_msg(b), item->ports[index]); |
197 | tipc_port_recv_msg(b); | 197 | tipc_port_recv_msg(b); |
198 | } | 198 | } |
199 | } | 199 | } |
@@ -484,7 +484,7 @@ static void port_timeout(unsigned long ref) | |||
484 | static void port_handle_node_down(unsigned long ref) | 484 | static void port_handle_node_down(unsigned long ref) |
485 | { | 485 | { |
486 | struct port *p_ptr = tipc_port_lock(ref); | 486 | struct port *p_ptr = tipc_port_lock(ref); |
487 | struct sk_buff* buf = NULL; | 487 | struct sk_buff *buf = NULL; |
488 | 488 | ||
489 | if (!p_ptr) | 489 | if (!p_ptr) |
490 | return; | 490 | return; |
@@ -620,8 +620,7 @@ static void port_print(struct port *p_ptr, struct print_buf *buf, int full_id) | |||
620 | tipc_printf(buf, " via {%u,%u}", | 620 | tipc_printf(buf, " via {%u,%u}", |
621 | p_ptr->publ.conn_type, | 621 | p_ptr->publ.conn_type, |
622 | p_ptr->publ.conn_instance); | 622 | p_ptr->publ.conn_instance); |
623 | } | 623 | } else if (p_ptr->publ.published) { |
624 | else if (p_ptr->publ.published) { | ||
625 | tipc_printf(buf, " bound to"); | 624 | tipc_printf(buf, " bound to"); |
626 | list_for_each_entry(publ, &p_ptr->publications, pport_list) { | 625 | list_for_each_entry(publ, &p_ptr->publications, pport_list) { |
627 | if (publ->lower == publ->upper) | 626 | if (publ->lower == publ->upper) |
@@ -1099,7 +1098,7 @@ int tipc_connect2port(u32 ref, struct tipc_portid const *peer) | |||
1099 | p_ptr->publ.connected = 1; | 1098 | p_ptr->publ.connected = 1; |
1100 | k_start_timer(&p_ptr->timer, p_ptr->probing_interval); | 1099 | k_start_timer(&p_ptr->timer, p_ptr->probing_interval); |
1101 | 1100 | ||
1102 | tipc_nodesub_subscribe(&p_ptr->subscription,peer->node, | 1101 | tipc_nodesub_subscribe(&p_ptr->subscription, peer->node, |
1103 | (void *)(unsigned long)ref, | 1102 | (void *)(unsigned long)ref, |
1104 | (net_ev_handler)port_handle_node_down); | 1103 | (net_ev_handler)port_handle_node_down); |
1105 | res = 0; | 1104 | res = 0; |
diff --git a/net/tipc/port.h b/net/tipc/port.h index a9c528799f2f..8e84b989949c 100644 --- a/net/tipc/port.h +++ b/net/tipc/port.h | |||
@@ -258,7 +258,7 @@ static inline void tipc_port_unlock(struct port *p_ptr) | |||
258 | spin_unlock_bh(p_ptr->publ.lock); | 258 | spin_unlock_bh(p_ptr->publ.lock); |
259 | } | 259 | } |
260 | 260 | ||
261 | static inline struct port* tipc_port_deref(u32 ref) | 261 | static inline struct port *tipc_port_deref(u32 ref) |
262 | { | 262 | { |
263 | return (struct port *)tipc_ref_deref(ref); | 263 | return (struct port *)tipc_ref_deref(ref); |
264 | } | 264 | } |
diff --git a/net/tipc/ref.c b/net/tipc/ref.c index ab8ad32d8c20..3974529a66e7 100644 --- a/net/tipc/ref.c +++ b/net/tipc/ref.c | |||
@@ -178,14 +178,12 @@ u32 tipc_ref_acquire(void *object, spinlock_t **lock) | |||
178 | next_plus_upper = entry->ref; | 178 | next_plus_upper = entry->ref; |
179 | tipc_ref_table.first_free = next_plus_upper & index_mask; | 179 | tipc_ref_table.first_free = next_plus_upper & index_mask; |
180 | ref = (next_plus_upper & ~index_mask) + index; | 180 | ref = (next_plus_upper & ~index_mask) + index; |
181 | } | 181 | } else if (tipc_ref_table.init_point < tipc_ref_table.capacity) { |
182 | else if (tipc_ref_table.init_point < tipc_ref_table.capacity) { | ||
183 | index = tipc_ref_table.init_point++; | 182 | index = tipc_ref_table.init_point++; |
184 | entry = &(tipc_ref_table.entries[index]); | 183 | entry = &(tipc_ref_table.entries[index]); |
185 | spin_lock_init(&entry->lock); | 184 | spin_lock_init(&entry->lock); |
186 | ref = tipc_ref_table.start_mask + index; | 185 | ref = tipc_ref_table.start_mask + index; |
187 | } | 186 | } else { |
188 | else { | ||
189 | ref = 0; | 187 | ref = 0; |
190 | } | 188 | } |
191 | write_unlock_bh(&ref_table_lock); | 189 | write_unlock_bh(&ref_table_lock); |
diff --git a/net/tipc/socket.c b/net/tipc/socket.c index 1a2eb23c6223..e9fc5df79eb0 100644 --- a/net/tipc/socket.c +++ b/net/tipc/socket.c | |||
@@ -375,7 +375,7 @@ static int bind(struct socket *sock, struct sockaddr *uaddr, int uaddr_len) | |||
375 | * | 375 | * |
376 | * NOTE: This routine doesn't need to take the socket lock since it only | 376 | * NOTE: This routine doesn't need to take the socket lock since it only |
377 | * accesses socket information that is unchanging (or which changes in | 377 | * accesses socket information that is unchanging (or which changes in |
378 | * a completely predictable manner). | 378 | * a completely predictable manner). |
379 | */ | 379 | */ |
380 | 380 | ||
381 | static int get_name(struct socket *sock, struct sockaddr *uaddr, | 381 | static int get_name(struct socket *sock, struct sockaddr *uaddr, |
@@ -570,14 +570,12 @@ static int send_msg(struct kiocb *iocb, struct socket *sock, | |||
570 | dest->addr.name.domain, | 570 | dest->addr.name.domain, |
571 | m->msg_iovlen, | 571 | m->msg_iovlen, |
572 | m->msg_iov); | 572 | m->msg_iov); |
573 | } | 573 | } else if (dest->addrtype == TIPC_ADDR_ID) { |
574 | else if (dest->addrtype == TIPC_ADDR_ID) { | ||
575 | res = tipc_send2port(tport->ref, | 574 | res = tipc_send2port(tport->ref, |
576 | &dest->addr.id, | 575 | &dest->addr.id, |
577 | m->msg_iovlen, | 576 | m->msg_iovlen, |
578 | m->msg_iov); | 577 | m->msg_iov); |
579 | } | 578 | } else if (dest->addrtype == TIPC_ADDR_MCAST) { |
580 | else if (dest->addrtype == TIPC_ADDR_MCAST) { | ||
581 | if (needs_conn) { | 579 | if (needs_conn) { |
582 | res = -EOPNOTSUPP; | 580 | res = -EOPNOTSUPP; |
583 | break; | 581 | break; |
@@ -812,8 +810,8 @@ static void set_orig_addr(struct msghdr *m, struct tipc_msg *msg) | |||
812 | addr->addrtype = TIPC_ADDR_ID; | 810 | addr->addrtype = TIPC_ADDR_ID; |
813 | addr->addr.id.ref = msg_origport(msg); | 811 | addr->addr.id.ref = msg_origport(msg); |
814 | addr->addr.id.node = msg_orignode(msg); | 812 | addr->addr.id.node = msg_orignode(msg); |
815 | addr->addr.name.domain = 0; /* could leave uninitialized */ | 813 | addr->addr.name.domain = 0; /* could leave uninitialized */ |
816 | addr->scope = 0; /* could leave uninitialized */ | 814 | addr->scope = 0; /* could leave uninitialized */ |
817 | m->msg_namelen = sizeof(struct sockaddr_tipc); | 815 | m->msg_namelen = sizeof(struct sockaddr_tipc); |
818 | } | 816 | } |
819 | } | 817 | } |
@@ -1743,10 +1741,10 @@ static int getsockopt(struct socket *sock, | |||
1743 | value = jiffies_to_msecs(tipc_sk(sk)->conn_timeout); | 1741 | value = jiffies_to_msecs(tipc_sk(sk)->conn_timeout); |
1744 | /* no need to set "res", since already 0 at this point */ | 1742 | /* no need to set "res", since already 0 at this point */ |
1745 | break; | 1743 | break; |
1746 | case TIPC_NODE_RECVQ_DEPTH: | 1744 | case TIPC_NODE_RECVQ_DEPTH: |
1747 | value = (u32)atomic_read(&tipc_queue_size); | 1745 | value = (u32)atomic_read(&tipc_queue_size); |
1748 | break; | 1746 | break; |
1749 | case TIPC_SOCK_RECVQ_DEPTH: | 1747 | case TIPC_SOCK_RECVQ_DEPTH: |
1750 | value = skb_queue_len(&sk->sk_receive_queue); | 1748 | value = skb_queue_len(&sk->sk_receive_queue); |
1751 | break; | 1749 | break; |
1752 | default: | 1750 | default: |
@@ -1772,7 +1770,7 @@ static int getsockopt(struct socket *sock, | |||
1772 | */ | 1770 | */ |
1773 | 1771 | ||
1774 | static const struct proto_ops msg_ops = { | 1772 | static const struct proto_ops msg_ops = { |
1775 | .owner = THIS_MODULE, | 1773 | .owner = THIS_MODULE, |
1776 | .family = AF_TIPC, | 1774 | .family = AF_TIPC, |
1777 | .release = release, | 1775 | .release = release, |
1778 | .bind = bind, | 1776 | .bind = bind, |
@@ -1793,7 +1791,7 @@ static const struct proto_ops msg_ops = { | |||
1793 | }; | 1791 | }; |
1794 | 1792 | ||
1795 | static const struct proto_ops packet_ops = { | 1793 | static const struct proto_ops packet_ops = { |
1796 | .owner = THIS_MODULE, | 1794 | .owner = THIS_MODULE, |
1797 | .family = AF_TIPC, | 1795 | .family = AF_TIPC, |
1798 | .release = release, | 1796 | .release = release, |
1799 | .bind = bind, | 1797 | .bind = bind, |
@@ -1814,7 +1812,7 @@ static const struct proto_ops packet_ops = { | |||
1814 | }; | 1812 | }; |
1815 | 1813 | ||
1816 | static const struct proto_ops stream_ops = { | 1814 | static const struct proto_ops stream_ops = { |
1817 | .owner = THIS_MODULE, | 1815 | .owner = THIS_MODULE, |
1818 | .family = AF_TIPC, | 1816 | .family = AF_TIPC, |
1819 | .release = release, | 1817 | .release = release, |
1820 | .bind = bind, | 1818 | .bind = bind, |
@@ -1835,7 +1833,7 @@ static const struct proto_ops stream_ops = { | |||
1835 | }; | 1833 | }; |
1836 | 1834 | ||
1837 | static const struct net_proto_family tipc_family_ops = { | 1835 | static const struct net_proto_family tipc_family_ops = { |
1838 | .owner = THIS_MODULE, | 1836 | .owner = THIS_MODULE, |
1839 | .family = AF_TIPC, | 1837 | .family = AF_TIPC, |
1840 | .create = tipc_create | 1838 | .create = tipc_create |
1841 | }; | 1839 | }; |
diff --git a/net/tipc/subscr.c b/net/tipc/subscr.c index 510271152165..acc30e1833c9 100644 --- a/net/tipc/subscr.c +++ b/net/tipc/subscr.c | |||
@@ -538,7 +538,7 @@ int tipc_subscr_start(void) | |||
538 | struct tipc_name_seq seq = {TIPC_TOP_SRV, TIPC_TOP_SRV, TIPC_TOP_SRV}; | 538 | struct tipc_name_seq seq = {TIPC_TOP_SRV, TIPC_TOP_SRV, TIPC_TOP_SRV}; |
539 | int res; | 539 | int res; |
540 | 540 | ||
541 | memset(&topsrv, 0, sizeof (topsrv)); | 541 | memset(&topsrv, 0, sizeof(topsrv)); |
542 | spin_lock_init(&topsrv.lock); | 542 | spin_lock_init(&topsrv.lock); |
543 | INIT_LIST_HEAD(&topsrv.subscriber_list); | 543 | INIT_LIST_HEAD(&topsrv.subscriber_list); |
544 | 544 | ||