Commit 12bae479 authored by Allan Stephens's avatar Allan Stephens Committed by David S. Miller

tipc: Eliminate obsolete native API forwarding routines

Moves the content of each native API message forwarding routine
into the sole routine that calls it, since the forwarding routines
no longer be called in isolation. Also removes code in each routine
that altered the outgoing message's importance level since this is
now no longer possible.

The previous function mapping (parent function, and child API) was
as follows:

   tipc_send2name
       \--tipc_forward2name

   tipc_send2port
       \--tipc_forward2port

   tipc_send_buf2port
       \--tipc_forward_buf2port

After this commit, the children don't exist and their functionality
is completely in the respective parent.
Signed-off-by: default avatarAllan Stephens <Allan.Stephens@windriver.com>
Signed-off-by: default avatarPaul Gortmaker <paul.gortmaker@windriver.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent 471450f7
...@@ -1265,16 +1265,11 @@ int tipc_send(u32 ref, unsigned int num_sect, struct iovec const *msg_sect) ...@@ -1265,16 +1265,11 @@ int tipc_send(u32 ref, unsigned int num_sect, struct iovec const *msg_sect)
} }
/** /**
* tipc_forward2name - forward message sections to port name * tipc_send2name - send message sections to port name
*/ */
static int tipc_forward2name(u32 ref, int tipc_send2name(u32 ref, struct tipc_name const *name, unsigned int domain,
struct tipc_name const *name, unsigned int num_sect, struct iovec const *msg_sect)
u32 domain,
u32 num_sect,
struct iovec const *msg_sect,
struct tipc_portid const *orig,
unsigned int importance)
{ {
struct port *p_ptr; struct port *p_ptr;
struct tipc_msg *msg; struct tipc_msg *msg;
...@@ -1288,14 +1283,12 @@ static int tipc_forward2name(u32 ref, ...@@ -1288,14 +1283,12 @@ static int tipc_forward2name(u32 ref,
msg = &p_ptr->publ.phdr; msg = &p_ptr->publ.phdr;
msg_set_type(msg, TIPC_NAMED_MSG); msg_set_type(msg, TIPC_NAMED_MSG);
msg_set_orignode(msg, orig->node); msg_set_orignode(msg, tipc_own_addr);
msg_set_origport(msg, orig->ref); msg_set_origport(msg, 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, tipc_addr_scope(domain)); msg_set_lookup_scope(msg, tipc_addr_scope(domain));
if (importance <= TIPC_CRITICAL_IMPORTANCE)
msg_set_importance(msg,importance);
destport = tipc_nametbl_translate(name->type, name->instance, &destnode); destport = tipc_nametbl_translate(name->type, name->instance, &destnode);
msg_set_destnode(msg, destnode); msg_set_destnode(msg, destnode);
msg_set_destport(msg, destport); msg_set_destport(msg, destport);
...@@ -1319,33 +1312,11 @@ static int tipc_forward2name(u32 ref, ...@@ -1319,33 +1312,11 @@ static int tipc_forward2name(u32 ref,
} }
/** /**
* tipc_send2name - send message sections to port name * tipc_send2port - send message sections to port identity
*/
int tipc_send2name(u32 ref,
struct tipc_name const *name,
unsigned int domain,
unsigned int num_sect,
struct iovec const *msg_sect)
{
struct tipc_portid orig;
orig.ref = ref;
orig.node = tipc_own_addr;
return tipc_forward2name(ref, name, domain, num_sect, msg_sect, &orig,
TIPC_PORT_IMPORTANCE);
}
/**
* tipc_forward2port - forward message sections to port identity
*/ */
static int tipc_forward2port(u32 ref, int tipc_send2port(u32 ref, struct tipc_portid const *dest,
struct tipc_portid const *dest, unsigned int num_sect, struct iovec const *msg_sect)
unsigned int num_sect,
struct iovec const *msg_sect,
struct tipc_portid const *orig,
unsigned int importance)
{ {
struct port *p_ptr; struct port *p_ptr;
struct tipc_msg *msg; struct tipc_msg *msg;
...@@ -1357,13 +1328,11 @@ static int tipc_forward2port(u32 ref, ...@@ -1357,13 +1328,11 @@ static int tipc_forward2port(u32 ref,
msg = &p_ptr->publ.phdr; msg = &p_ptr->publ.phdr;
msg_set_type(msg, TIPC_DIRECT_MSG); msg_set_type(msg, TIPC_DIRECT_MSG);
msg_set_orignode(msg, orig->node); msg_set_orignode(msg, tipc_own_addr);
msg_set_origport(msg, orig->ref); msg_set_origport(msg, ref);
msg_set_destnode(msg, dest->node); msg_set_destnode(msg, dest->node);
msg_set_destport(msg, dest->ref); msg_set_destport(msg, dest->ref);
msg_set_hdr_sz(msg, DIR_MSG_H_SIZE); msg_set_hdr_sz(msg, DIR_MSG_H_SIZE);
if (importance <= TIPC_CRITICAL_IMPORTANCE)
msg_set_importance(msg, importance);
p_ptr->sent++; p_ptr->sent++;
if (dest->node == tipc_own_addr) if (dest->node == tipc_own_addr)
return tipc_port_recv_sections(p_ptr, num_sect, msg_sect); return tipc_port_recv_sections(p_ptr, num_sect, msg_sect);
...@@ -1378,31 +1347,11 @@ static int tipc_forward2port(u32 ref, ...@@ -1378,31 +1347,11 @@ static int tipc_forward2port(u32 ref,
} }
/** /**
* tipc_send2port - send message sections to port identity * tipc_send_buf2port - send message buffer to port identity
*/ */
int tipc_send2port(u32 ref, int tipc_send_buf2port(u32 ref, struct tipc_portid const *dest,
struct tipc_portid const *dest, struct sk_buff *buf, unsigned int dsz)
unsigned int num_sect,
struct iovec const *msg_sect)
{
struct tipc_portid orig;
orig.ref = ref;
orig.node = tipc_own_addr;
return tipc_forward2port(ref, dest, num_sect, msg_sect, &orig,
TIPC_PORT_IMPORTANCE);
}
/**
* tipc_forward_buf2port - forward message buffer to port identity
*/
static int tipc_forward_buf2port(u32 ref,
struct tipc_portid const *dest,
struct sk_buff *buf,
unsigned int dsz,
struct tipc_portid const *orig,
unsigned int importance)
{ {
struct port *p_ptr; struct port *p_ptr;
struct tipc_msg *msg; struct tipc_msg *msg;
...@@ -1414,13 +1363,11 @@ static int tipc_forward_buf2port(u32 ref, ...@@ -1414,13 +1363,11 @@ static int tipc_forward_buf2port(u32 ref,
msg = &p_ptr->publ.phdr; msg = &p_ptr->publ.phdr;
msg_set_type(msg, TIPC_DIRECT_MSG); msg_set_type(msg, TIPC_DIRECT_MSG);
msg_set_orignode(msg, orig->node); msg_set_orignode(msg, tipc_own_addr);
msg_set_origport(msg, orig->ref); msg_set_origport(msg, ref);
msg_set_destnode(msg, dest->node); msg_set_destnode(msg, dest->node);
msg_set_destport(msg, dest->ref); msg_set_destport(msg, dest->ref);
msg_set_hdr_sz(msg, DIR_MSG_H_SIZE); msg_set_hdr_sz(msg, DIR_MSG_H_SIZE);
if (importance <= TIPC_CRITICAL_IMPORTANCE)
msg_set_importance(msg, importance);
msg_set_size(msg, DIR_MSG_H_SIZE + dsz); msg_set_size(msg, DIR_MSG_H_SIZE + dsz);
if (skb_cow(buf, DIR_MSG_H_SIZE)) if (skb_cow(buf, DIR_MSG_H_SIZE))
return -ENOMEM; return -ENOMEM;
...@@ -1439,20 +1386,3 @@ static int tipc_forward_buf2port(u32 ref, ...@@ -1439,20 +1386,3 @@ static int tipc_forward_buf2port(u32 ref,
return -ELINKCONG; return -ELINKCONG;
} }
/**
* tipc_send_buf2port - send message buffer to port identity
*/
int tipc_send_buf2port(u32 ref,
struct tipc_portid const *dest,
struct sk_buff *buf,
unsigned int dsz)
{
struct tipc_portid orig;
orig.ref = ref;
orig.node = tipc_own_addr;
return tipc_forward_buf2port(ref, dest, buf, dsz, &orig,
TIPC_PORT_IMPORTANCE);
}
...@@ -222,8 +222,6 @@ int tipc_disconnect_port(struct tipc_port *tp_ptr); ...@@ -222,8 +222,6 @@ int tipc_disconnect_port(struct tipc_port *tp_ptr);
/* /*
* TIPC messaging routines * TIPC messaging routines
*/ */
#define TIPC_PORT_IMPORTANCE 100 /* send using current port setting */
int tipc_send(u32 portref, unsigned int num_sect, struct iovec const *msg_sect); int tipc_send(u32 portref, unsigned int num_sect, struct iovec const *msg_sect);
int tipc_send2name(u32 portref, struct tipc_name const *name, u32 domain, int tipc_send2name(u32 portref, struct tipc_name const *name, u32 domain,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment