4  * Copyright (c) 2000-2017, Ericsson AB
5  * Copyright (c) 2005-2007, 2010-2013, Wind River Systems
41 static void tipc_sub_send_event(struct tipc_subscription *sub,  in tipc_sub_send_event()  argument
43 				u32 event, u32 port, u32 node)  in tipc_sub_send_event()  argument
45 	struct tipc_event *evt = &sub->evt;  in tipc_sub_send_event()
47 	if (sub->inactive)  in tipc_sub_send_event()
53 	tipc_evt_write(evt, port.node, node);  in tipc_sub_send_event()
54 	tipc_topsrv_queue_evt(sub->net, sub->conid, event, evt);  in tipc_sub_send_event()
58  * tipc_sub_check_overlap - test for subscription overlap with the
66 	if (found_lower < seq->lower)  in tipc_sub_check_overlap()
67 		found_lower = seq->lower;  in tipc_sub_check_overlap()
68 	if (found_upper > seq->upper)  in tipc_sub_check_overlap()
69 		found_upper = seq->upper;  in tipc_sub_check_overlap()
75 void tipc_sub_report_overlap(struct tipc_subscription *sub,  in tipc_sub_report_overlap()  argument
77 			     u32 event, u32 port, u32 node,  in tipc_sub_report_overlap()  argument
80 	struct tipc_subscr *s = &sub->evt.s;  in tipc_sub_report_overlap()
97 	spin_lock(&sub->lock);  in tipc_sub_report_overlap()
98 	tipc_sub_send_event(sub, found_lower, found_upper,  in tipc_sub_report_overlap()
99 			    event, port, node);  in tipc_sub_report_overlap()
100 	spin_unlock(&sub->lock);  in tipc_sub_report_overlap()
105 	struct tipc_subscription *sub = from_timer(sub, t, timer);  in tipc_sub_timeout()  local
106 	struct tipc_subscr *s = &sub->evt.s;  in tipc_sub_timeout()
108 	spin_lock(&sub->lock);  in tipc_sub_timeout()
109 	tipc_sub_send_event(sub, s->seq.lower, s->seq.upper,  in tipc_sub_timeout()
111 	sub->inactive = true;  in tipc_sub_timeout()
112 	spin_unlock(&sub->lock);  in tipc_sub_timeout()
122 	kref_put(&subscription->kref, tipc_sub_kref_release);  in tipc_sub_put()
127 	kref_get(&subscription->kref);  in tipc_sub_get()
135 	struct tipc_subscription *sub;  in tipc_sub_subscribe()  local
143 	sub = kmalloc(sizeof(*sub), GFP_ATOMIC);  in tipc_sub_subscribe()
144 	if (!sub) {  in tipc_sub_subscribe()
148 	INIT_LIST_HEAD(&sub->service_list);  in tipc_sub_subscribe()
149 	INIT_LIST_HEAD(&sub->sub_list);  in tipc_sub_subscribe()
150 	sub->net = net;  in tipc_sub_subscribe()
151 	sub->conid = conid;  in tipc_sub_subscribe()
152 	sub->inactive = false;  in tipc_sub_subscribe()
153 	memcpy(&sub->evt.s, s, sizeof(*s));  in tipc_sub_subscribe()
154 	spin_lock_init(&sub->lock);  in tipc_sub_subscribe()
155 	kref_init(&sub->kref);  in tipc_sub_subscribe()
156 	if (!tipc_nametbl_subscribe(sub)) {  in tipc_sub_subscribe()
157 		kfree(sub);  in tipc_sub_subscribe()
160 	timer_setup(&sub->timer, tipc_sub_timeout, 0);  in tipc_sub_subscribe()
161 	timeout = tipc_sub_read(&sub->evt.s, timeout);  in tipc_sub_subscribe()
163 		mod_timer(&sub->timer, jiffies + msecs_to_jiffies(timeout));  in tipc_sub_subscribe()
164 	return sub;  in tipc_sub_subscribe()
167 void tipc_sub_unsubscribe(struct tipc_subscription *sub)  in tipc_sub_unsubscribe()  argument
169 	tipc_nametbl_unsubscribe(sub);  in tipc_sub_unsubscribe()
170 	if (sub->evt.s.timeout != TIPC_WAIT_FOREVER)  in tipc_sub_unsubscribe()
171 		del_timer_sync(&sub->timer);  in tipc_sub_unsubscribe()
172 	list_del(&sub->sub_list);  in tipc_sub_unsubscribe()
173 	tipc_sub_put(sub);  in tipc_sub_unsubscribe()