Skip to content

Commit

Permalink
tipc: convert allocations of global variables associated with bclink
Browse files Browse the repository at this point in the history
Convert allocations of global variables associated with bclink from
static way to dynamical way for the convenience of bclink instance
initialisation. Meanwhile, this also helps TIPC support name space
in the future easily.

Signed-off-by: Ying Xue <ying.xue@windriver.com>
Reviewed-by: Erik Hugne <erik.hugne@ericsson.com>
Reviewed-by: Jon Maloy <jon.maloy@ericsson.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
  • Loading branch information
Ying Xue authored and David S. Miller committed May 5, 2014
1 parent d69afc9 commit eb8b00f
Show file tree
Hide file tree
Showing 5 changed files with 32 additions and 15 deletions.
28 changes: 19 additions & 9 deletions net/tipc/bcast.c
Original file line number Diff line number Diff line change
Expand Up @@ -100,12 +100,9 @@ struct tipc_bclink {
struct tipc_node *retransmit_to;
};

static struct tipc_bcbearer bcast_bearer;
static struct tipc_bclink bcast_link;

static struct tipc_bcbearer *bcbearer = &bcast_bearer;
static struct tipc_bclink *bclink = &bcast_link;
static struct tipc_link *bcl = &bcast_link.link;
static struct tipc_bcbearer *bcbearer;
static struct tipc_bclink *bclink;
static struct tipc_link *bcl;

const char tipc_bclink_name[] = "broadcast-link";

Expand Down Expand Up @@ -788,8 +785,19 @@ int tipc_bclink_set_queue_limits(u32 limit)
return 0;
}

void tipc_bclink_init(void)
int tipc_bclink_init(void)
{
bcbearer = kzalloc(sizeof(*bcbearer), GFP_ATOMIC);
if (!bcbearer)
return -ENOMEM;

bclink = kzalloc(sizeof(*bclink), GFP_ATOMIC);
if (!bclink) {
kfree(bcbearer);
return -ENOMEM;
}

bcl = &bclink->link;
bcbearer->bearer.media = &bcbearer->media;
bcbearer->media.send_msg = tipc_bcbearer_send;
sprintf(bcbearer->media.name, "tipc-broadcast");
Expand All @@ -805,6 +813,7 @@ void tipc_bclink_init(void)
rcu_assign_pointer(bearer_list[MAX_BEARERS], &bcbearer->bearer);
bcl->state = WORKING_WORKING;
strlcpy(bcl->name, tipc_bclink_name, TIPC_MAX_LINK_NAME);
return 0;
}

void tipc_bclink_stop(void)
Expand All @@ -814,8 +823,9 @@ void tipc_bclink_stop(void)
tipc_bclink_unlock();

RCU_INIT_POINTER(bearer_list[BCBEARER], NULL);
memset(bclink, 0, sizeof(*bclink));
memset(bcbearer, 0, sizeof(*bcbearer));
synchronize_net();
kfree(bcbearer);
kfree(bclink);
}

/**
Expand Down
2 changes: 1 addition & 1 deletion net/tipc/bcast.h
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ static inline int tipc_nmap_equal(struct tipc_node_map *nm_a,
void tipc_port_list_add(struct tipc_port_list *pl_ptr, u32 port);
void tipc_port_list_free(struct tipc_port_list *pl_ptr);

void tipc_bclink_init(void);
int tipc_bclink_init(void);
void tipc_bclink_stop(void);
void tipc_bclink_add_node(u32 addr);
void tipc_bclink_remove_node(u32 addr);
Expand Down
6 changes: 4 additions & 2 deletions net/tipc/config.c
Original file line number Diff line number Diff line change
Expand Up @@ -177,8 +177,10 @@ static struct sk_buff *cfg_set_own_addr(void)
if (tipc_own_addr)
return tipc_cfg_reply_error_string(TIPC_CFG_NOT_SUPPORTED
" (cannot change node address once assigned)");
tipc_net_start(addr);
return tipc_cfg_reply_none();
if (!tipc_net_start(addr))
return tipc_cfg_reply_none();

return tipc_cfg_reply_error_string("cannot change to network mode");
}

static struct sk_buff *cfg_set_max_ports(void)
Expand Down
9 changes: 7 additions & 2 deletions net/tipc/net.c
Original file line number Diff line number Diff line change
Expand Up @@ -164,20 +164,25 @@ void tipc_net_route_msg(struct sk_buff *buf)
tipc_link_xmit(buf, dnode, msg_link_selector(msg));
}

void tipc_net_start(u32 addr)
int tipc_net_start(u32 addr)
{
char addr_string[16];
int res;

tipc_own_addr = addr;
tipc_named_reinit();
tipc_port_reinit();
tipc_bclink_init();
res = tipc_bclink_init();
if (res)
return res;

tipc_nametbl_publish(TIPC_CFG_SRV, tipc_own_addr, tipc_own_addr,
TIPC_ZONE_SCOPE, 0, tipc_own_addr);

pr_info("Started in network mode\n");
pr_info("Own node address %s, network identity %u\n",
tipc_addr_string_fill(addr_string, tipc_own_addr), tipc_net_id);
return 0;
}

void tipc_net_stop(void)
Expand Down
2 changes: 1 addition & 1 deletion net/tipc/net.h
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@

void tipc_net_route_msg(struct sk_buff *buf);

void tipc_net_start(u32 addr);
int tipc_net_start(u32 addr);
void tipc_net_stop(void);

#endif

0 comments on commit eb8b00f

Please sign in to comment.