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) { |
