diff options
Diffstat (limited to 'net/tipc/subscr.c')
-rw-r--r-- | net/tipc/subscr.c | 22 |
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 | ||
50 | struct subscriber { | 50 | struct 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 | ||
227 | static void subscr_terminate(struct subscriber *subscriber) | 227 | static 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 | ||
280 | static void subscr_cancel(struct tipc_subscr *s, | 280 | static 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 | ||
317 | static struct tipc_subscription *subscr_subscribe(struct tipc_subscr *s, | 317 | static 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 | ||
569 | void tipc_subscr_stop(void) | 569 | void 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) { |