Home | History | Annotate | Download | only in ServiceRegistration

Lines Matching refs:subscription

62 advertising_proxy_subscription_finalize(advertising_proxy_subscription_t *subscription)
64 if (subscription->local_instance != NULL) {
65 FAULT("subscription->local_instance is not NULL (%p)", subscription->local_instance);
67 if (subscription->push_instance != NULL) {
68 FAULT("subscription->push_instance is not NULL (%p)", subscription->push_instance);
70 if (subscription->service != NULL) {
71 FAULT("subscription->service is not NULL (%p)", subscription->service);
244 advertising_proxy_subscription_t *subscription = calloc(1, sizeof(*subscription));
245 if (subscription == NULL) {
248 RETAIN_HERE(subscription, advertising_proxy_subscription);
250 return subscription;
255 adv_instance_unsubscribe(adv_instance_state_t *instance, advertising_proxy_subscription_t *subscription)
262 if (instance->subscribers[i] == subscription) {
271 adv_service_unsubscribe(adv_service_state_t *service, advertising_proxy_subscription_t *subscription)
282 if (service->subscribers[i] == subscription) {
291 advertising_proxy_subscription_retain_(advertising_proxy_subscription_t *subscription, const char *file, int line)
293 RETAIN(subscription, advertising_proxy_subscription);
298 advertising_proxy_subscription_release_(advertising_proxy_subscription_t *subscription, const char *file, int line)
300 RELEASE(subscription, advertising_proxy_subscription);
305 advertising_proxy_subscription_cancel(advertising_proxy_subscription_t *subscription)
307 if (subscription->local_instance) {
308 adv_instance_unsubscribe(subscription->local_instance, subscription);
309 RELEASE_HERE(subscription->local_instance, adv_instance_state);
310 subscription->local_instance = NULL;
312 if (subscription->push_instance) {
313 adv_instance_unsubscribe(subscription->push_instance, subscription);
314 RELEASE_HERE(subscription->push_instance, adv_instance_state);
315 subscription->push_instance = NULL;
317 if (subscription->service) {
318 adv_service_unsubscribe(subscription->service, subscription);
319 RELEASE_HERE(subscription->service, adv_service_state);
320 subscription->service = NULL;
331 advertising_proxy_subscription_t *subscription = NULL;
341 subscription = advertising_proxy_subscription_create();
343 if (subscription == NULL) {
347 advertising_proxy_subscription_t *tmp = subscription;
348 RETAIN_HERE(subscription, advertising_proxy_subscription); // For callback
351 RELEASE_HERE(subscription, advertising_proxy_subscription); // For callback
353 *subscription_ret = subscription;
354 subscription = NULL;
357 if (subscription != NULL) {
358 RELEASE_HERE(subscription, advertising_proxy_subscription);
412 advertising_proxy_subscription_t *subscription = service->subscribers[i];
413 if (subscription != NULL) {
414 subscription->service_callback(subscription, error, interface_index,
430 advertising_proxy_subscription_t *subscription = NULL;
444 subscription = advertising_proxy_subscription_create();
445 if (subscription == NULL) {
454 adv_service_state_subscriber_add(service, subscription);
455 subscription->service = service;
456 RETAIN_HERE(subscription->service, adv_service_state);
458 subscription->service_callback = callback;
459 subscription->context = context;
484 *subscription_ret = subscription;
485 subscription = NULL;
489 if (subscription != NULL) {
490 advertising_proxy_subscription_cancel(subscription);
491 RELEASE_HERE(subscription, advertising_proxy_subscription);
519 advertising_proxy_subscription_t *subscription = instance->subscribers[i];
520 if (subscription != NULL) {
521 subscription->instance_callback(subscription, error, interface_index,
538 advertising_proxy_subscription_t *subscription = NULL;
551 subscription = advertising_proxy_subscription_create();
552 if (subscription == NULL) {
561 adv_instance_state_subscriber_add(local_instance, subscription);
562 subscription->local_instance = local_instance;
563 RETAIN_HERE(subscription->local_instance, adv_instance_state);
565 subscription->instance_callback = callback;
566 subscription->context = context;
592 adv_instance_state_subscriber_add(push_instance, subscription);
593 subscription->push_instance = push_instance;
594 RETAIN_HERE(subscription->push_instance, adv_instance_state);
614 *subscription_ret = subscription;
615 subscription = NULL;
628 if (subscription != NULL) {
629 advertising_proxy_subscription_cancel(subscription);
630 RELEASE_HERE(subscription, advertising_proxy_subscription);