aboutsummaryrefslogtreecommitdiffstats
path: root/net/tipc/subscr.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/tipc/subscr.c')
-rw-r--r--net/tipc/subscr.c22
1 files changed, 11 insertions, 11 deletions
diff --git a/net/tipc/subscr.c b/net/tipc/subscr.c
index 5bcd1f6e103c..8c49566da8f3 100644
--- a/net/tipc/subscr.c
+++ b/net/tipc/subscr.c
@@ -40,14 +40,14 @@
40#include "subscr.h" 40#include "subscr.h"
41 41
42/** 42/**
43 * struct subscriber - TIPC network topology subscriber 43 * struct tipc_subscriber - TIPC network topology subscriber
44 * @port_ref: object reference to server port connecting to subscriber 44 * @port_ref: object reference to server port connecting to subscriber
45 * @lock: pointer to spinlock controlling access to subscriber's server port 45 * @lock: pointer to spinlock controlling access to subscriber's server port
46 * @subscriber_list: adjacent subscribers in top. server's list of subscribers 46 * @subscriber_list: adjacent subscribers in top. server's list of subscribers
47 * @subscription_list: list of subscription objects for this subscriber 47 * @subscription_list: list of subscription objects for this subscriber
48 */ 48 */
49 49
50struct subscriber { 50struct tipc_subscriber {
51 u32 port_ref; 51 u32 port_ref;
52 spinlock_t *lock; 52 spinlock_t *lock;
53 struct list_head subscriber_list; 53 struct list_head subscriber_list;
@@ -224,7 +224,7 @@ static void subscr_del(struct tipc_subscription *sub)
224 * simply wait for it to be released, then claim it.) 224 * simply wait for it to be released, then claim it.)
225 */ 225 */
226 226
227static void subscr_terminate(struct subscriber *subscriber) 227static void subscr_terminate(struct tipc_subscriber *subscriber)
228{ 228{
229 u32 port_ref; 229 u32 port_ref;
230 struct tipc_subscription *sub; 230 struct tipc_subscription *sub;
@@ -278,7 +278,7 @@ static void subscr_terminate(struct subscriber *subscriber)
278 */ 278 */
279 279
280static void subscr_cancel(struct tipc_subscr *s, 280static void subscr_cancel(struct tipc_subscr *s,
281 struct subscriber *subscriber) 281 struct tipc_subscriber *subscriber)
282{ 282{
283 struct tipc_subscription *sub; 283 struct tipc_subscription *sub;
284 struct tipc_subscription *sub_temp; 284 struct tipc_subscription *sub_temp;
@@ -315,7 +315,7 @@ static void subscr_cancel(struct tipc_subscr *s,
315 */ 315 */
316 316
317static struct tipc_subscription *subscr_subscribe(struct tipc_subscr *s, 317static struct tipc_subscription *subscr_subscribe(struct tipc_subscr *s,
318 struct subscriber *subscriber) 318 struct tipc_subscriber *subscriber)
319{ 319{
320 struct tipc_subscription *sub; 320 struct tipc_subscription *sub;
321 int swap; 321 int swap;
@@ -393,7 +393,7 @@ static void subscr_conn_shutdown_event(void *usr_handle,
393 unsigned int size, 393 unsigned int size,
394 int reason) 394 int reason)
395{ 395{
396 struct subscriber *subscriber = usr_handle; 396 struct tipc_subscriber *subscriber = usr_handle;
397 spinlock_t *subscriber_lock; 397 spinlock_t *subscriber_lock;
398 398
399 if (tipc_port_lock(port_ref) == NULL) 399 if (tipc_port_lock(port_ref) == NULL)
@@ -416,7 +416,7 @@ static void subscr_conn_msg_event(void *usr_handle,
416 const unchar *data, 416 const unchar *data,
417 u32 size) 417 u32 size)
418{ 418{
419 struct subscriber *subscriber = usr_handle; 419 struct tipc_subscriber *subscriber = usr_handle;
420 spinlock_t *subscriber_lock; 420 spinlock_t *subscriber_lock;
421 struct tipc_subscription *sub; 421 struct tipc_subscription *sub;
422 422
@@ -471,12 +471,12 @@ static void subscr_named_msg_event(void *usr_handle,
471 struct tipc_portid const *orig, 471 struct tipc_portid const *orig,
472 struct tipc_name_seq const *dest) 472 struct tipc_name_seq const *dest)
473{ 473{
474 struct subscriber *subscriber; 474 struct tipc_subscriber *subscriber;
475 u32 server_port_ref; 475 u32 server_port_ref;
476 476
477 /* Create subscriber object */ 477 /* Create subscriber object */
478 478
479 subscriber = kzalloc(sizeof(struct subscriber), GFP_ATOMIC); 479 subscriber = kzalloc(sizeof(struct tipc_subscriber), GFP_ATOMIC);
480 if (subscriber == NULL) { 480 if (subscriber == NULL) {
481 warn("Subscriber rejected, no memory\n"); 481 warn("Subscriber rejected, no memory\n");
482 return; 482 return;
@@ -568,8 +568,8 @@ failed:
568 568
569void tipc_subscr_stop(void) 569void tipc_subscr_stop(void)
570{ 570{
571 struct subscriber *subscriber; 571 struct tipc_subscriber *subscriber;
572 struct subscriber *subscriber_temp; 572 struct tipc_subscriber *subscriber_temp;
573 spinlock_t *subscriber_lock; 573 spinlock_t *subscriber_lock;
574 574
575 if (topsrv.setup_port) { 575 if (topsrv.setup_port) {