/dports/devel/grpc/grpc-1.42.0/test/cpp/end2end/xds/ |
H A D | xds_server.cc | 100 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 D | xds_server.h | 330 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 D | event.c | 119 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 D | eXinsubscription_api.c | 238 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 D | eXcall_api.c | 660 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 D | sip_utils.c | 42 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 D | registrar_notify.c | 1515 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 D | registrar_notify.h | 61 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 D | host_document_info.hpp | 50 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 D | client_document_info.hpp | 56 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 D | local_document_info.hpp | 47 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 D | headers.h | 572 …_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 D | roster.c | 80 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 D | test_fetcher.py | 14 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 D | test_subscription_state.py | 6 from kafka.consumer.subscription_state import SubscriptionState
|
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/ |
H A D | __init__.py | 23 from kafka.consumer.subscription_state import ConsumerRebalanceListener
|
/dports/net/freeswitch/freeswitch-1.10.3.-release/libs/sofia-sip/libsofia-sip-ua/sip/ |
H A D | sip_event.c | 298 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 D | sip_event.c | 298 SIP_HEADER_CLASS(subscription_state, "Subscription-State", "", 300 subscription_state);
|
/dports/net-im/pidgin-sipe/pidgin-sipe-1.24.0/src/core/ |
H A D | sipe-subscriptions.c | 170 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 D | sipe-notify.c | 1608 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 D | belle_sip_headers_impl.c | 1568 …_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 D | xds_end2end_test.cc | 572 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 D | rostermodule.h | 161 virtual XmppSubscriptionState subscription_state() const = 0;
|
H A D | rostermoduleimpl.h | 121 virtual XmppSubscriptionState subscription_state() const;
|
/dports/editors/gobby/gobby-0.4.13/src/ |
H A D | documentlist.cpp | 28 Gobby::LocalDocumentInfo::subscription_state state = in can_subscribe()
|