Home
last modified time | relevance | path

Searched refs:subscription_state (Results 1 – 25 of 35) sorted by relevance

12

/dports/devel/grpc/grpc-1.42.0/test/cpp/end2end/xds/
H A Dxds_server.cc100 SubscriptionState* subscription_state, in MaybeSubscribe() argument
104 if (subscription_state->update_queue != nullptr) return false; in MaybeSubscribe()
105 subscription_state->update_queue = update_queue; in MaybeSubscribe()
106 resource_state->subscriptions.emplace(subscription_state); in MaybeSubscribe()
109 &subscription_state); in MaybeSubscribe()
123 SubscriptionState& subscription_state = it->second; in ProcessUnsubscriptions() local
130 resource_type.c_str(), resource_name.c_str(), &subscription_state); in ProcessUnsubscriptions()
134 resource_state.subscriptions.erase(&subscription_state); in ProcessUnsubscriptions()
H A Dxds_server.h330 SubscriptionState& subscription_state = q.second; in StreamAggregatedResources() local
334 resource_state.subscriptions.erase(&subscription_state); in StreamAggregatedResources()
427 auto& subscription_state = subscription_name_map[resource_name]; in ProcessRequest() local
434 &subscription_state, &resource_state, in ProcessRequest()
610 SubscriptionState* subscription_state,
/dports/net/liblinphone/linphone-3.12.0/coreapi/
H A Devent.c119 if (lev->subscription_state!=state){ in linphone_event_set_state()
121 lev->subscription_state=state; in linphone_event_set_state()
178 lev->subscription_state = LinphoneSubscriptionIncomingReceived; in linphone_core_create_notify()
198 switch (lev->subscription_state){ in linphone_event_send_subscribe()
223 if (lev->subscription_state==LinphoneSubscriptionNone) in linphone_event_send_subscribe()
239 if (lev->subscription_state!=LinphoneSubscriptionIncomingReceived){ in linphone_event_accept_subscription()
252 if (lev->subscription_state!=LinphoneSubscriptionIncomingReceived){ in linphone_event_deny_subscription()
263 …if (lev->subscription_state!=LinphoneSubscriptionActive && lev->subscription_state!=LinphoneSubscr… in linphone_event_notify()
387 …if (lev->subscription_state == LinphoneSubscriptionError || lev->subscription_state == LinphoneSub… in linphone_event_terminate()
407 if (lev->subscription_state!=LinphoneSubscriptionNone){ in linphone_event_terminate()
[all …]
/dports/net/libexosip2/libexosip2-5.3.0/src/
H A DeXinsubscription_api.c238 char subscription_state[50]; in eXosip_insubscription_build_notify() local
267 osip_strncpy(subscription_state, "pending;expires=", 16); in eXosip_insubscription_build_notify()
270 osip_strncpy(subscription_state, "active;expires=", 15); in eXosip_insubscription_build_notify()
277 osip_strncpy(subscription_state, "terminated;reason=probation", 27); in eXosip_insubscription_build_notify()
280 osip_strncpy(subscription_state, "terminated;reason=rejected", 26); in eXosip_insubscription_build_notify()
283 osip_strncpy(subscription_state, "terminated;reason=timeout", 25); in eXosip_insubscription_build_notify()
286 osip_strncpy(subscription_state, "terminated;reason=giveup", 24); in eXosip_insubscription_build_notify()
289 osip_strncpy(subscription_state, "terminated;reason=noresource", 28); in eXosip_insubscription_build_notify()
292 osip_strncpy(subscription_state, "terminated;reason=noresource", 28); in eXosip_insubscription_build_notify()
295 osip_strncpy(subscription_state, "pending;expires=", 16); in eXosip_insubscription_build_notify()
[all …]
H A DeXcall_api.c660 char subscription_state[50]; in eXosip_call_build_notify() local
671 osip_strncpy(subscription_state, "pending;expires=", 16); in eXosip_call_build_notify()
674 osip_strncpy(subscription_state, "active;expires=", 15); in eXosip_call_build_notify()
681 osip_strncpy(subscription_state, "terminated;reason=deactivated", 29); in eXosip_call_build_notify()
684 osip_strncpy(subscription_state, "terminated;reason=probation", 27); in eXosip_call_build_notify()
687 osip_strncpy(subscription_state, "terminated;reason=rejected", 26); in eXosip_call_build_notify()
690 osip_strncpy(subscription_state, "terminated;reason=timeout", 25); in eXosip_call_build_notify()
693 osip_strncpy(subscription_state, "terminated;reason=giveup", 24); in eXosip_call_build_notify()
697 osip_strncpy(subscription_state, "terminated;reason=noresource", 29); in eXosip_call_build_notify()
700 tmp = subscription_state + strlen(subscription_state); in eXosip_call_build_notify()
[all …]
/dports/net/kamailio/kamailio-5.4.5/src/lib/cds/
H A Dsip_utils.c42 if (!m->subscription_state) { in is_terminating_notify()
46 if (parse_subscription_state(m->subscription_state) < 0) { in is_terminating_notify()
50 ss = (subscription_state_t*)m->subscription_state->parsed; in is_terminating_notify()
/dports/net/kamailio/kamailio-5.4.5/src/modules/ims_registrar_scscf/
H A Dregistrar_notify.c1515 subscription_state.len = 0; in create_notifications()
1516 if (subscription_state.s) { in create_notifications()
1520 subscription_state.len = strlen(subscription_state.s); in create_notifications()
1577 if (subscription_state.s) { in create_notifications()
2092 …if (n->subscription_state.len) h.len += subss_hdr1.len + subss_hdr2.len + n->subscription_state.le… in send_notification()
2111 if (n->subscription_state.len) { in send_notification()
2251 n->subscription_state.s = p; in new_notification()
2252 n->subscription_state.len = subscription_state.len; in new_notification()
2253 memcpy(p, subscription_state.s, subscription_state.len); in new_notification()
2254 p += subscription_state.len; in new_notification()
[all …]
H A Dregistrar_notify.h61 str subscription_state; /**< Subscription-state header value*/ member
154 reg_notification* new_notification(str subscription_state,
/dports/devel/obby/obby-0.4.8/inc/
H A Dhost_document_info.hpp50 typedef typename base_local_type::subscription_state subscription_state; typedef in obby::basic_host_document_info
89 virtual subscription_state get_subscription_state() const;
204 typename basic_host_document_info<Document, Selector>::subscription_state
H A Dclient_document_info.hpp56 typedef typename base_local_type::subscription_state subscription_state; typedef in obby::basic_client_document_info
117 virtual subscription_state get_subscription_state() const;
177 subscription_state m_subscription_state;
444 typename basic_client_document_info<Document, Selector>::subscription_state
H A Dlocal_document_info.hpp47 enum subscription_state { enum in obby::basic_local_document_info
99 virtual subscription_state get_subscription_state() const = 0;
/dports/net/belle-sip/belle-sip-1.6.3-0/include/belle-sip/
H A Dheaders.h572 …_subscription_state_t* belle_sip_header_subscription_state_parse (const char* subscription_state) ;
573 …n_state_t* belle_sip_header_subscription_state_create (const char* subscription_state,int expires);
575 …ader_subscription_state_get_state(const belle_sip_header_subscription_state_t* subscription_state);
576 …er_subscription_state_get_expires(const belle_sip_header_subscription_state_t* subscription_state);
577 …der_subscription_state_get_reason(const belle_sip_header_subscription_state_t* subscription_state);
578 …ubscription_state_get_retry_after(const belle_sip_header_subscription_state_t* subscription_state);
580 …ubscription_state_set_state(belle_sip_header_subscription_state_t* subscription_state,const char* …
581 …bscription_state_set_expires(belle_sip_header_subscription_state_t* subscription_state,int expire);
582 …bscription_state_set_reason(belle_sip_header_subscription_state_t* subscription_state, const char*…
583 …ption_state_set_retry_after(belle_sip_header_subscription_state_t* subscription_state, int retry_a…
/dports/net-im/freetalk/freetalk-4.1/src/
H A Droster.c80 subscription_state (LmMessageNode *item) in subscription_state() function
181 r_item->subscription = subscription_state (item); in roster_result_rcvd()
213 subscription = subscription_state (item); in roster_set_rcvd()
249 newi->subscription = subscription_state (item); in roster_set_rcvd()
/dports/net/py-kafka-python/kafka-python-1.4.5/test/
H A Dtest_fetcher.py14 from kafka.consumer.subscription_state import SubscriptionState
33 def subscription_state(): function
43 def fetcher(client, subscription_state, topic): argument
44 subscription_state.subscribe(topics=[topic])
46 subscription_state.assign_from_subscribed(assignment)
48 subscription_state.seek(tp, 0)
49 return Fetcher(client, subscription_state, Metrics())
H A Dtest_subscription_state.py6 from kafka.consumer.subscription_state import SubscriptionState
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/
H A D__init__.py23 from kafka.consumer.subscription_state import ConsumerRebalanceListener
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/sip/
H A Dsip_event.c298 SIP_HEADER_CLASS(subscription_state, "Subscription-State", "",
300 subscription_state);
/dports/net/sofia-sip/sofia-sip-1.13.4/libsofia-sip-ua/sip/
H A Dsip_event.c298 SIP_HEADER_CLASS(subscription_state, "Subscription-State", "",
300 subscription_state);
/dports/net-im/pidgin-sipe/pidgin-sipe-1.24.0/src/core/
H A Dsipe-subscriptions.c170 const gchar *subscription_state = sipmsg_find_header(msg, "subscription-state"); in process_subscribe_response() local
171 gboolean terminated = subscription_state && strstr(subscription_state, "terminated"); in process_subscribe_response()
H A Dsipe-notify.c1608 const gchar *subscription_state = sipmsg_find_header(msg, "subscription-state"); in process_incoming_notify() local
1610 …_INFO("process_incoming_notify: subscription_state: %s", subscription_state ? subscription_state :… in process_incoming_notify()
1630 } else if (!subscription_state || strstr(subscription_state, "active")) { in process_incoming_notify()
/dports/net/belle-sip/belle-sip-1.6.3-0/src/
H A Dbelle_sip_headers_impl.c1568 …_sip_header_subscription_state_destroy(belle_sip_header_subscription_state_t* subscription_state) { in belle_sip_header_subscription_state_destroy() argument
1569 DESTROY_STRING(subscription_state,state); in belle_sip_header_subscription_state_destroy()
1572 …elle_sip_header_subscription_state_clone(belle_sip_header_subscription_state_t* subscription_state, in belle_sip_header_subscription_state_clone() argument
1574 CLONE_STRING(belle_sip_header_subscription_state,state,subscription_state,orig) in belle_sip_header_subscription_state_clone()
1577 …_subscription_state_marshal(belle_sip_header_subscription_state_t* subscription_state, char* buff,… in belle_sip_header_subscription_state_marshal() argument
1578 …belle_sip_error_code error=belle_sip_header_marshal(BELLE_SIP_HEADER(subscription_state), buff, bu… in belle_sip_header_subscription_state_marshal()
1580 error=belle_sip_snprintf(buff,buff_size,offset,"%s",subscription_state->state); in belle_sip_header_subscription_state_marshal()
1582 …error=belle_sip_parameters_marshal(BELLE_SIP_PARAMETERS(subscription_state), buff, buff_size, offs… in belle_sip_header_subscription_state_marshal()
1593 …n_state_t* belle_sip_header_subscription_state_create (const char* subscription_state,int expires)… in GET_SET_INT_PARAM()
1595 belle_sip_header_subscription_state_set_state(sub_state,subscription_state); in GET_SET_INT_PARAM()
/dports/devel/grpc130/grpc-1.30.2/test/cpp/end2end/
H A Dxds_end2end_test.cc572 SubscriptionState& subscription_state = it->second; in StreamAggregatedResources() local
620 SubscriptionState& subscription_state = q.second; in StreamAggregatedResources() local
623 resource_state.subscriptions.erase(&subscription_state); in StreamAggregatedResources()
875 SubscriptionState* subscription_state, in MaybeSubscribe() argument
879 if (subscription_state->update_queue != nullptr) return; in MaybeSubscribe()
880 subscription_state->update_queue = update_queue; in MaybeSubscribe()
881 resource_state->subscriptions.emplace(subscription_state); in MaybeSubscribe()
884 &subscription_state); in MaybeSubscribe()
897 SubscriptionState& subscription_state = it->second; in ProcessUnsubscriptions() local
905 &subscription_state); in ProcessUnsubscriptions()
[all …]
/dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/xmpp/
H A Drostermodule.h161 virtual XmppSubscriptionState subscription_state() const = 0;
H A Drostermoduleimpl.h121 virtual XmppSubscriptionState subscription_state() const;
/dports/editors/gobby/gobby-0.4.13/src/
H A Ddocumentlist.cpp28 Gobby::LocalDocumentInfo::subscription_state state = in can_subscribe()

12