tipc: add tipc_ prefix to fcns targeted for un-inlining

These functions have enough code in them such that they
seem like sensible targets for un-inlining.  Prior to doing
that, this adds the tipc_ prefix to the functions, so that
in the event of a panic dump or similar, the subsystem from
which the functions come from is immediately clear.

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>
This commit is contained in:
Allan Stephens 2010-05-11 14:30:12 +00:00 committed by David S. Miller
parent 01fee256a6
commit c68ca7b720
13 changed files with 55 additions and 55 deletions

View File

@ -67,7 +67,7 @@ static inline int may_route(u32 addr)
return(addr ^ tipc_own_addr) >> 11; return(addr ^ tipc_own_addr) >> 11;
} }
static inline int in_scope(u32 domain, u32 addr) static inline int tipc_in_scope(u32 domain, u32 addr)
{ {
if (!domain || (domain == addr)) if (!domain || (domain == addr))
return 1; return 1;
@ -79,10 +79,10 @@ static inline int in_scope(u32 domain, u32 addr)
} }
/** /**
* addr_scope - convert message lookup domain to equivalent 2-bit scope value * tipc_addr_scope - convert message lookup domain to a 2-bit scope value
*/ */
static inline int addr_scope(u32 domain) static inline int tipc_addr_scope(u32 domain)
{ {
if (likely(!domain)) if (likely(!domain))
return TIPC_ZONE_SCOPE; return TIPC_ZONE_SCOPE;
@ -110,7 +110,7 @@ static inline int addr_domain(int sc)
return tipc_addr(tipc_zone(tipc_own_addr), 0, 0); return tipc_addr(tipc_zone(tipc_own_addr), 0, 0);
} }
static inline char *addr_string_fill(char *string, u32 addr) static inline char *tipc_addr_string_fill(char *string, u32 addr)
{ {
snprintf(string, 16, "<%u.%u.%u>", snprintf(string, 16, "<%u.%u.%u>",
tipc_zone(addr), tipc_cluster(addr), tipc_node(addr)); tipc_zone(addr), tipc_cluster(addr), tipc_node(addr));

View File

@ -275,7 +275,7 @@ static void bclink_send_nack(struct tipc_node *n_ptr)
buf = buf_acquire(INT_H_SIZE); buf = buf_acquire(INT_H_SIZE);
if (buf) { if (buf) {
msg = buf_msg(buf); msg = buf_msg(buf);
msg_init(msg, BCAST_PROTOCOL, STATE_MSG, tipc_msg_init(msg, BCAST_PROTOCOL, STATE_MSG,
INT_H_SIZE, n_ptr->addr); INT_H_SIZE, n_ptr->addr);
msg_set_mc_netid(msg, tipc_net_id); msg_set_mc_netid(msg, tipc_net_id);
msg_set_bcast_ack(msg, mod(n_ptr->bclink.last_in)); msg_set_bcast_ack(msg, mod(n_ptr->bclink.last_in));

View File

@ -74,7 +74,7 @@ extern const char tipc_bclink_name[];
/** /**
* nmap_add - add a node to a node map * tipc_nmap_add - add a node to a node map
*/ */
static inline void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node) static inline void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node)
@ -90,7 +90,7 @@ static inline void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node)
} }
/** /**
* nmap_remove - remove a node from a node map * tipc_nmap_remove - remove a node from a node map
*/ */
static inline void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node) static inline void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node)
@ -106,7 +106,7 @@ static inline void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node)
} }
/** /**
* nmap_equal - test for equality of node maps * tipc_nmap_equal - test for equality of node maps
*/ */
static inline int tipc_nmap_equal(struct tipc_node_map *nm_a, struct tipc_node_map *nm_b) static inline int tipc_nmap_equal(struct tipc_node_map *nm_a, struct tipc_node_map *nm_b)
@ -115,7 +115,7 @@ static inline int tipc_nmap_equal(struct tipc_node_map *nm_a, struct tipc_node_m
} }
/** /**
* nmap_diff - find differences between node maps * tipc_nmap_diff - find differences between node maps
* @nm_a: input node map A * @nm_a: input node map A
* @nm_b: input node map B * @nm_b: input node map B
* @nm_diff: output node map A-B (i.e. nodes of A that are not in B) * @nm_diff: output node map A-B (i.e. nodes of A that are not in B)
@ -143,7 +143,7 @@ static inline void tipc_nmap_diff(struct tipc_node_map *nm_a, struct tipc_node_m
} }
/** /**
* port_list_add - add a port to a port list, ensuring no duplicates * tipc_port_list_add - add a port to a port list, ensuring no duplicates
*/ */
static inline void tipc_port_list_add(struct port_list *pl_ptr, u32 port) static inline void tipc_port_list_add(struct port_list *pl_ptr, u32 port)
@ -176,7 +176,7 @@ static inline void tipc_port_list_add(struct port_list *pl_ptr, u32 port)
} }
/** /**
* port_list_free - free dynamically created entries in port_list chain * tipc_port_list_free - free dynamically created entries in port_list chain
* *
* Note: First item is on stack, so it doesn't need to be released * Note: First item is on stack, so it doesn't need to be released
*/ */

View File

@ -493,7 +493,7 @@ int tipc_enable_bearer(const char *name, u32 bcast_scope, u32 priority)
return -EINVAL; return -EINVAL;
} }
if (!tipc_addr_domain_valid(bcast_scope) || if (!tipc_addr_domain_valid(bcast_scope) ||
!in_scope(bcast_scope, tipc_own_addr)) { !tipc_in_scope(bcast_scope, tipc_own_addr)) {
warn("Bearer <%s> rejected, illegal broadcast scope\n", name); warn("Bearer <%s> rejected, illegal broadcast scope\n", name);
return -EINVAL; return -EINVAL;
} }
@ -571,7 +571,7 @@ restart:
spin_lock_init(&b_ptr->publ.lock); spin_lock_init(&b_ptr->publ.lock);
write_unlock_bh(&tipc_net_lock); write_unlock_bh(&tipc_net_lock);
info("Enabled bearer <%s>, discovery domain %s, priority %u\n", info("Enabled bearer <%s>, discovery domain %s, priority %u\n",
name, addr_string_fill(addr_string, bcast_scope), priority); name, tipc_addr_string_fill(addr_string, bcast_scope), priority);
return 0; return 0;
failed: failed:
write_unlock_bh(&tipc_net_lock); write_unlock_bh(&tipc_net_lock);

View File

@ -238,7 +238,7 @@ static struct sk_buff *tipc_cltr_prepare_routing_msg(u32 data_size, u32 dest)
if (buf) { if (buf) {
msg = buf_msg(buf); msg = buf_msg(buf);
memset((char *)msg, 0, size); memset((char *)msg, 0, size);
msg_init(msg, ROUTE_DISTRIBUTOR, 0, INT_H_SIZE, dest); tipc_msg_init(msg, ROUTE_DISTRIBUTOR, 0, INT_H_SIZE, dest);
} }
return buf; return buf;
} }

View File

@ -120,7 +120,7 @@ static struct sk_buff *tipc_disc_init_msg(u32 type,
if (buf) { if (buf) {
msg = buf_msg(buf); msg = buf_msg(buf);
msg_init(msg, LINK_CONFIG, type, DSC_H_SIZE, dest_domain); tipc_msg_init(msg, LINK_CONFIG, type, DSC_H_SIZE, dest_domain);
msg_set_non_seq(msg, 1); msg_set_non_seq(msg, 1);
msg_set_req_links(msg, req_links); msg_set_req_links(msg, req_links);
msg_set_dest_domain(msg, dest_domain); msg_set_dest_domain(msg, dest_domain);
@ -144,7 +144,7 @@ static void disc_dupl_alert(struct bearer *b_ptr, u32 node_addr,
char media_addr_str[64]; char media_addr_str[64];
struct print_buf pb; struct print_buf pb;
addr_string_fill(node_addr_str, node_addr); tipc_addr_string_fill(node_addr_str, node_addr);
tipc_printbuf_init(&pb, media_addr_str, sizeof(media_addr_str)); tipc_printbuf_init(&pb, media_addr_str, sizeof(media_addr_str));
tipc_media_addr_printf(&pb, media_addr); tipc_media_addr_printf(&pb, media_addr);
tipc_printbuf_validate(&pb); tipc_printbuf_validate(&pb);
@ -183,7 +183,7 @@ void tipc_disc_recv_msg(struct sk_buff *buf, struct bearer *b_ptr)
disc_dupl_alert(b_ptr, tipc_own_addr, &media_addr); disc_dupl_alert(b_ptr, tipc_own_addr, &media_addr);
return; return;
} }
if (!in_scope(dest, tipc_own_addr)) if (!tipc_in_scope(dest, tipc_own_addr))
return; return;
if (is_slave(tipc_own_addr) && is_slave(orig)) if (is_slave(tipc_own_addr) && is_slave(orig))
return; return;

View File

@ -433,7 +433,7 @@ struct link *tipc_link_create(struct bearer *b_ptr, const u32 peer,
l_ptr->pmsg = (struct tipc_msg *)&l_ptr->proto_msg; l_ptr->pmsg = (struct tipc_msg *)&l_ptr->proto_msg;
msg = l_ptr->pmsg; msg = l_ptr->pmsg;
msg_init(msg, LINK_PROTOCOL, RESET_MSG, INT_H_SIZE, l_ptr->addr); tipc_msg_init(msg, LINK_PROTOCOL, RESET_MSG, INT_H_SIZE, l_ptr->addr);
msg_set_size(msg, sizeof(l_ptr->proto_msg)); msg_set_size(msg, sizeof(l_ptr->proto_msg));
msg_set_session(msg, (tipc_random & 0xffff)); msg_set_session(msg, (tipc_random & 0xffff));
msg_set_bearer_id(msg, b_ptr->identity); msg_set_bearer_id(msg, b_ptr->identity);
@ -1025,7 +1025,7 @@ int tipc_link_send_buf(struct link *l_ptr, struct sk_buff *buf)
u32 size = msg_size(msg); u32 size = msg_size(msg);
u32 dsz = msg_data_sz(msg); u32 dsz = msg_data_sz(msg);
u32 queue_size = l_ptr->out_queue_size; u32 queue_size = l_ptr->out_queue_size;
u32 imp = msg_tot_importance(msg); u32 imp = tipc_msg_tot_importance(msg);
u32 queue_limit = l_ptr->queue_limit[imp]; u32 queue_limit = l_ptr->queue_limit[imp];
u32 max_packet = l_ptr->max_pkt; u32 max_packet = l_ptr->max_pkt;
@ -1090,7 +1090,7 @@ int tipc_link_send_buf(struct link *l_ptr, struct sk_buff *buf)
struct tipc_msg bundler_hdr; struct tipc_msg bundler_hdr;
if (bundler) { if (bundler) {
msg_init(&bundler_hdr, MSG_BUNDLER, OPEN_MSG, tipc_msg_init(&bundler_hdr, MSG_BUNDLER, OPEN_MSG,
INT_H_SIZE, l_ptr->addr); INT_H_SIZE, l_ptr->addr);
skb_copy_to_linear_data(bundler, &bundler_hdr, skb_copy_to_linear_data(bundler, &bundler_hdr,
INT_H_SIZE); INT_H_SIZE);
@ -1243,7 +1243,7 @@ again:
* (Must not hold any locks while building message.) * (Must not hold any locks while building message.)
*/ */
res = msg_build(hdr, msg_sect, num_sect, sender->publ.max_pkt, res = tipc_msg_build(hdr, msg_sect, num_sect, sender->publ.max_pkt,
!sender->user_port, &buf); !sender->user_port, &buf);
read_lock_bh(&tipc_net_lock); read_lock_bh(&tipc_net_lock);
@ -1354,7 +1354,7 @@ again:
/* Prepare reusable fragment header: */ /* Prepare reusable fragment header: */
msg_dbg(hdr, ">FRAGMENTING>"); msg_dbg(hdr, ">FRAGMENTING>");
msg_init(&fragm_hdr, MSG_FRAGMENTER, FIRST_FRAGMENT, tipc_msg_init(&fragm_hdr, MSG_FRAGMENTER, FIRST_FRAGMENT,
INT_H_SIZE, msg_destnode(hdr)); INT_H_SIZE, msg_destnode(hdr));
msg_set_link_selector(&fragm_hdr, sender->publ.ref); msg_set_link_selector(&fragm_hdr, sender->publ.ref);
msg_set_size(&fragm_hdr, max_pkt); msg_set_size(&fragm_hdr, max_pkt);
@ -1613,7 +1613,7 @@ static void link_reset_all(unsigned long addr)
tipc_node_lock(n_ptr); tipc_node_lock(n_ptr);
warn("Resetting all links to %s\n", warn("Resetting all links to %s\n",
addr_string_fill(addr_string, n_ptr->addr)); tipc_addr_string_fill(addr_string, n_ptr->addr));
for (i = 0; i < MAX_BEARERS; i++) { for (i = 0; i < MAX_BEARERS; i++) {
if (n_ptr->links[i]) { if (n_ptr->links[i]) {
@ -1655,7 +1655,7 @@ static void link_retransmit_failure(struct link *l_ptr, struct sk_buff *buf)
n_ptr = l_ptr->owner->next; n_ptr = l_ptr->owner->next;
tipc_node_lock(n_ptr); tipc_node_lock(n_ptr);
addr_string_fill(addr_string, n_ptr->addr); tipc_addr_string_fill(addr_string, n_ptr->addr);
tipc_printf(TIPC_OUTPUT, "Multicast link info for %s\n", addr_string); tipc_printf(TIPC_OUTPUT, "Multicast link info for %s\n", addr_string);
tipc_printf(TIPC_OUTPUT, "Supported: %d, ", n_ptr->bclink.supported); tipc_printf(TIPC_OUTPUT, "Supported: %d, ", n_ptr->bclink.supported);
tipc_printf(TIPC_OUTPUT, "Acked: %u\n", n_ptr->bclink.acked); tipc_printf(TIPC_OUTPUT, "Acked: %u\n", n_ptr->bclink.acked);
@ -2398,7 +2398,7 @@ void tipc_link_changeover(struct link *l_ptr)
return; return;
} }
msg_init(&tunnel_hdr, CHANGEOVER_PROTOCOL, tipc_msg_init(&tunnel_hdr, CHANGEOVER_PROTOCOL,
ORIGINAL_MSG, INT_H_SIZE, l_ptr->addr); ORIGINAL_MSG, INT_H_SIZE, l_ptr->addr);
msg_set_bearer_id(&tunnel_hdr, l_ptr->peer_bearer_id); msg_set_bearer_id(&tunnel_hdr, l_ptr->peer_bearer_id);
msg_set_msgcnt(&tunnel_hdr, msgcount); msg_set_msgcnt(&tunnel_hdr, msgcount);
@ -2453,7 +2453,7 @@ void tipc_link_send_duplicate(struct link *l_ptr, struct link *tunnel)
struct sk_buff *iter; struct sk_buff *iter;
struct tipc_msg tunnel_hdr; struct tipc_msg tunnel_hdr;
msg_init(&tunnel_hdr, CHANGEOVER_PROTOCOL, tipc_msg_init(&tunnel_hdr, CHANGEOVER_PROTOCOL,
DUPLICATE_MSG, INT_H_SIZE, l_ptr->addr); DUPLICATE_MSG, INT_H_SIZE, l_ptr->addr);
msg_set_msgcnt(&tunnel_hdr, l_ptr->out_queue_size); msg_set_msgcnt(&tunnel_hdr, l_ptr->out_queue_size);
msg_set_bearer_id(&tunnel_hdr, l_ptr->peer_bearer_id); msg_set_bearer_id(&tunnel_hdr, l_ptr->peer_bearer_id);
@ -2659,7 +2659,7 @@ int tipc_link_send_long_buf(struct link *l_ptr, struct sk_buff *buf)
/* Prepare reusable fragment header: */ /* Prepare reusable fragment header: */
msg_init(&fragm_hdr, MSG_FRAGMENTER, FIRST_FRAGMENT, tipc_msg_init(&fragm_hdr, MSG_FRAGMENTER, FIRST_FRAGMENT,
INT_H_SIZE, destaddr); INT_H_SIZE, destaddr);
msg_set_link_selector(&fragm_hdr, msg_link_selector(inmsg)); msg_set_link_selector(&fragm_hdr, msg_link_selector(inmsg));
msg_set_long_msgno(&fragm_hdr, mod(l_ptr->long_msg_seq_no++)); msg_set_long_msgno(&fragm_hdr, mod(l_ptr->long_msg_seq_no++));

View File

@ -708,7 +708,7 @@ static inline void msg_set_dataoctet(struct tipc_msg *m, u32 pos)
#define DSC_REQ_MSG 0 #define DSC_REQ_MSG 0
#define DSC_RESP_MSG 1 #define DSC_RESP_MSG 1
static inline u32 msg_tot_importance(struct tipc_msg *m) static inline u32 tipc_msg_tot_importance(struct tipc_msg *m)
{ {
if (likely(msg_isdata(m))) { if (likely(msg_isdata(m))) {
if (likely(msg_orignode(m) == tipc_own_addr)) if (likely(msg_orignode(m) == tipc_own_addr))
@ -722,7 +722,7 @@ static inline u32 msg_tot_importance(struct tipc_msg *m)
} }
static inline void msg_init(struct tipc_msg *m, u32 user, u32 type, static inline void tipc_msg_init(struct tipc_msg *m, u32 user, u32 type,
u32 hsize, u32 destnode) u32 hsize, u32 destnode)
{ {
memset(m, 0, hsize); memset(m, 0, hsize);
@ -739,10 +739,10 @@ static inline void msg_init(struct tipc_msg *m, u32 user, u32 type,
} }
/** /**
* msg_calc_data_size - determine total data size for message * tipc_msg_calc_data_size - determine total data size for message
*/ */
static inline int msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect) static inline int tipc_msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect)
{ {
int dsz = 0; int dsz = 0;
int i; int i;
@ -753,20 +753,20 @@ static inline int msg_calc_data_size(struct iovec const *msg_sect, u32 num_sect)
} }
/** /**
* msg_build - create message using specified header and data * tipc_msg_build - create message using specified header and data
* *
* Note: Caller must not hold any locks in case copy_from_user() is interrupted! * Note: Caller must not hold any locks in case copy_from_user() is interrupted!
* *
* Returns message data size or errno * Returns message data size or errno
*/ */
static inline int msg_build(struct tipc_msg *hdr, static inline int tipc_msg_build(struct tipc_msg *hdr,
struct iovec const *msg_sect, u32 num_sect, struct iovec const *msg_sect, u32 num_sect,
int max_size, int usrmem, struct sk_buff** buf) int max_size, int usrmem, struct sk_buff** buf)
{ {
int dsz, sz, hsz, pos, res, cnt; int dsz, sz, hsz, pos, res, cnt;
dsz = msg_calc_data_size(msg_sect, num_sect); dsz = tipc_msg_calc_data_size(msg_sect, num_sect);
if (unlikely(dsz > TIPC_MAX_USER_MSG_SIZE)) { if (unlikely(dsz > TIPC_MAX_USER_MSG_SIZE)) {
*buf = NULL; *buf = NULL;
return -EINVAL; return -EINVAL;

View File

@ -103,7 +103,7 @@ static struct sk_buff *named_prepare_buf(u32 type, u32 size, u32 dest)
if (buf != NULL) { if (buf != NULL) {
msg = buf_msg(buf); msg = buf_msg(buf);
msg_init(msg, NAME_DISTRIBUTOR, type, LONG_H_SIZE, dest); tipc_msg_init(msg, NAME_DISTRIBUTOR, type, LONG_H_SIZE, dest);
msg_set_size(msg, LONG_H_SIZE + size); msg_set_size(msg, LONG_H_SIZE + size);
} }
return buf; return buf;

View File

@ -627,7 +627,7 @@ u32 tipc_nametbl_translate(u32 type, u32 instance, u32 *destnode)
struct name_seq *seq; struct name_seq *seq;
u32 ref; u32 ref;
if (!in_scope(*destnode, tipc_own_addr)) if (!tipc_in_scope(*destnode, tipc_own_addr))
return 0; return 0;
read_lock_bh(&tipc_nametbl_lock); read_lock_bh(&tipc_nametbl_lock);

View File

@ -219,7 +219,7 @@ void tipc_net_route_msg(struct sk_buff *buf)
/* Handle message for this node */ /* Handle message for this node */
dnode = msg_short(msg) ? tipc_own_addr : msg_destnode(msg); dnode = msg_short(msg) ? tipc_own_addr : msg_destnode(msg);
if (in_scope(dnode, tipc_own_addr)) { if (tipc_in_scope(dnode, tipc_own_addr)) {
if (msg_isdata(msg)) { if (msg_isdata(msg)) {
if (msg_mcast(msg)) if (msg_mcast(msg))
tipc_port_recv_mcast(buf, NULL); tipc_port_recv_mcast(buf, NULL);
@ -277,7 +277,7 @@ int tipc_net_start(u32 addr)
info("Started in network mode\n"); info("Started in network mode\n");
info("Own node address %s, network identity %u\n", info("Own node address %s, network identity %u\n",
addr_string_fill(addr_string, tipc_own_addr), tipc_net_id); tipc_addr_string_fill(addr_string, tipc_own_addr), tipc_net_id);
return 0; return 0;
} }

View File

@ -268,7 +268,7 @@ struct tipc_node *tipc_node_attach_link(struct link *l_ptr)
if (n_ptr->link_cnt >= 2) { if (n_ptr->link_cnt >= 2) {
err("Attempt to create third link to %s\n", err("Attempt to create third link to %s\n",
addr_string_fill(addr_string, n_ptr->addr)); tipc_addr_string_fill(addr_string, n_ptr->addr));
return NULL; return NULL;
} }
@ -280,7 +280,7 @@ struct tipc_node *tipc_node_attach_link(struct link *l_ptr)
} }
err("Attempt to establish second link on <%s> to %s\n", err("Attempt to establish second link on <%s> to %s\n",
l_ptr->b_ptr->publ.name, l_ptr->b_ptr->publ.name,
addr_string_fill(addr_string, l_ptr->addr)); tipc_addr_string_fill(addr_string, l_ptr->addr));
} }
return NULL; return NULL;
} }
@ -439,7 +439,7 @@ static void node_lost_contact(struct tipc_node *n_ptr)
return; return;
info("Lost contact with %s\n", info("Lost contact with %s\n",
addr_string_fill(addr_string, n_ptr->addr)); tipc_addr_string_fill(addr_string, n_ptr->addr));
/* Abort link changeover */ /* Abort link changeover */
for (i = 0; i < MAX_BEARERS; i++) { for (i = 0; i < MAX_BEARERS; i++) {
@ -602,7 +602,7 @@ u32 tipc_available_nodes(const u32 domain)
read_lock_bh(&tipc_net_lock); read_lock_bh(&tipc_net_lock);
for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) { for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) {
if (!in_scope(domain, n_ptr->addr)) if (!tipc_in_scope(domain, n_ptr->addr))
continue; continue;
if (tipc_node_is_up(n_ptr)) if (tipc_node_is_up(n_ptr))
cnt++; cnt++;
@ -651,7 +651,7 @@ struct sk_buff *tipc_node_get_nodes(const void *req_tlv_area, int req_tlv_space)
/* Add TLVs for all nodes in scope */ /* Add TLVs for all nodes in scope */
for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) { for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) {
if (!in_scope(domain, n_ptr->addr)) if (!tipc_in_scope(domain, n_ptr->addr))
continue; continue;
node_info.addr = htonl(n_ptr->addr); node_info.addr = htonl(n_ptr->addr);
node_info.up = htonl(tipc_node_is_up(n_ptr)); node_info.up = htonl(tipc_node_is_up(n_ptr));
@ -711,7 +711,7 @@ struct sk_buff *tipc_node_get_links(const void *req_tlv_area, int req_tlv_space)
for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) { for (n_ptr = tipc_nodes; n_ptr; n_ptr = n_ptr->next) {
u32 i; u32 i;
if (!in_scope(domain, n_ptr->addr)) if (!tipc_in_scope(domain, n_ptr->addr))
continue; continue;
tipc_node_lock(n_ptr); tipc_node_lock(n_ptr);
for (i = 0; i < MAX_BEARERS; i++) { for (i = 0; i < MAX_BEARERS; i++) {

View File

@ -116,7 +116,7 @@ int tipc_multicast(u32 ref, struct tipc_name_seq const *seq, u32 domain,
msg_set_namelower(hdr, seq->lower); msg_set_namelower(hdr, seq->lower);
msg_set_nameupper(hdr, seq->upper); msg_set_nameupper(hdr, seq->upper);
msg_set_hdr_sz(hdr, MCAST_H_SIZE); msg_set_hdr_sz(hdr, MCAST_H_SIZE);
res = msg_build(hdr, msg_sect, num_sect, MAX_MSG_SIZE, res = tipc_msg_build(hdr, msg_sect, num_sect, MAX_MSG_SIZE,
!oport->user_port, &buf); !oport->user_port, &buf);
if (unlikely(!buf)) if (unlikely(!buf))
return res; return res;
@ -241,7 +241,7 @@ struct tipc_port *tipc_createport_raw(void *usr_handle,
p_ptr->publ.max_pkt = MAX_PKT_DEFAULT; p_ptr->publ.max_pkt = MAX_PKT_DEFAULT;
p_ptr->publ.ref = ref; p_ptr->publ.ref = ref;
msg = &p_ptr->publ.phdr; msg = &p_ptr->publ.phdr;
msg_init(msg, importance, TIPC_NAMED_MSG, LONG_H_SIZE, 0); tipc_msg_init(msg, importance, TIPC_NAMED_MSG, LONG_H_SIZE, 0);
msg_set_origport(msg, ref); msg_set_origport(msg, ref);
p_ptr->last_in_seqno = 41; p_ptr->last_in_seqno = 41;
p_ptr->sent = 1; p_ptr->sent = 1;
@ -395,7 +395,7 @@ static struct sk_buff *port_build_proto_msg(u32 destport, u32 destnode,
buf = buf_acquire(LONG_H_SIZE); buf = buf_acquire(LONG_H_SIZE);
if (buf) { if (buf) {
msg = buf_msg(buf); msg = buf_msg(buf);
msg_init(msg, usr, type, LONG_H_SIZE, destnode); tipc_msg_init(msg, usr, type, LONG_H_SIZE, destnode);
msg_set_errcode(msg, err); msg_set_errcode(msg, err);
msg_set_destport(msg, destport); msg_set_destport(msg, destport);
msg_set_origport(msg, origport); msg_set_origport(msg, origport);
@ -439,7 +439,7 @@ int tipc_reject_msg(struct sk_buff *buf, u32 err)
return data_sz; return data_sz;
} }
rmsg = buf_msg(rbuf); rmsg = buf_msg(rbuf);
msg_init(rmsg, imp, msg_type(msg), hdr_sz, msg_orignode(msg)); tipc_msg_init(rmsg, imp, msg_type(msg), hdr_sz, msg_orignode(msg));
msg_set_errcode(rmsg, err); msg_set_errcode(rmsg, err);
msg_set_destport(rmsg, msg_origport(msg)); msg_set_destport(rmsg, msg_origport(msg));
msg_set_origport(rmsg, msg_destport(msg)); msg_set_origport(rmsg, msg_destport(msg));
@ -480,7 +480,7 @@ int tipc_port_reject_sections(struct port *p_ptr, struct tipc_msg *hdr,
struct sk_buff *buf; struct sk_buff *buf;
int res; int res;
res = msg_build(hdr, msg_sect, num_sect, MAX_MSG_SIZE, res = tipc_msg_build(hdr, msg_sect, num_sect, MAX_MSG_SIZE,
!p_ptr->user_port, &buf); !p_ptr->user_port, &buf);
if (!buf) if (!buf)
return res; return res;
@ -1343,7 +1343,7 @@ int tipc_port_recv_sections(struct port *sender, unsigned int num_sect,
struct sk_buff *buf; struct sk_buff *buf;
int res; int res;
res = msg_build(&sender->publ.phdr, msg_sect, num_sect, res = tipc_msg_build(&sender->publ.phdr, msg_sect, num_sect,
MAX_MSG_SIZE, !sender->user_port, &buf); MAX_MSG_SIZE, !sender->user_port, &buf);
if (likely(buf)) if (likely(buf))
tipc_port_recv_msg(buf); tipc_port_recv_msg(buf);
@ -1383,7 +1383,7 @@ int tipc_send(u32 ref, unsigned int num_sect, struct iovec const *msg_sect)
if (port_unreliable(p_ptr)) { if (port_unreliable(p_ptr)) {
p_ptr->publ.congested = 0; p_ptr->publ.congested = 0;
/* Just calculate msg length and return */ /* Just calculate msg length and return */
return msg_calc_data_size(msg_sect, num_sect); return tipc_msg_calc_data_size(msg_sect, num_sect);
} }
return -ELINKCONG; return -ELINKCONG;
} }
@ -1466,7 +1466,7 @@ int tipc_forward2name(u32 ref,
msg_set_hdr_sz(msg, LONG_H_SIZE); msg_set_hdr_sz(msg, LONG_H_SIZE);
msg_set_nametype(msg, name->type); msg_set_nametype(msg, name->type);
msg_set_nameinst(msg, name->instance); msg_set_nameinst(msg, name->instance);
msg_set_lookup_scope(msg, addr_scope(domain)); msg_set_lookup_scope(msg, tipc_addr_scope(domain));
if (importance <= TIPC_CRITICAL_IMPORTANCE) if (importance <= TIPC_CRITICAL_IMPORTANCE)
msg_set_importance(msg,importance); msg_set_importance(msg,importance);
destport = tipc_nametbl_translate(name->type, name->instance, &destnode); destport = tipc_nametbl_translate(name->type, name->instance, &destnode);
@ -1483,7 +1483,7 @@ int tipc_forward2name(u32 ref,
return res; return res;
if (port_unreliable(p_ptr)) { if (port_unreliable(p_ptr)) {
/* Just calculate msg length and return */ /* Just calculate msg length and return */
return msg_calc_data_size(msg_sect, num_sect); return tipc_msg_calc_data_size(msg_sect, num_sect);
} }
return -ELINKCONG; return -ELINKCONG;
} }
@ -1539,7 +1539,7 @@ int tipc_forward_buf2name(u32 ref,
msg_set_origport(msg, orig->ref); msg_set_origport(msg, orig->ref);
msg_set_nametype(msg, name->type); msg_set_nametype(msg, name->type);
msg_set_nameinst(msg, name->instance); msg_set_nameinst(msg, name->instance);
msg_set_lookup_scope(msg, addr_scope(domain)); msg_set_lookup_scope(msg, tipc_addr_scope(domain));
msg_set_hdr_sz(msg, LONG_H_SIZE); msg_set_hdr_sz(msg, LONG_H_SIZE);
msg_set_size(msg, LONG_H_SIZE + dsz); msg_set_size(msg, LONG_H_SIZE + dsz);
destport = tipc_nametbl_translate(name->type, name->instance, &destnode); destport = tipc_nametbl_translate(name->type, name->instance, &destnode);
@ -1619,7 +1619,7 @@ int tipc_forward2port(u32 ref,
return res; return res;
if (port_unreliable(p_ptr)) { if (port_unreliable(p_ptr)) {
/* Just calculate msg length and return */ /* Just calculate msg length and return */
return msg_calc_data_size(msg_sect, num_sect); return tipc_msg_calc_data_size(msg_sect, num_sect);
} }
return -ELINKCONG; return -ELINKCONG;
} }