Lines Matching refs:r
53 int r; member
82 static void async_wait_done(int r, mapper_async_wait*);
87 static void async_subtree_done(int r, mapper_async_subtree*);
148 int r; in async_wait_timeout_callback() local
153 r = sd_bus_call_method_async( in async_wait_timeout_callback()
158 if (r < 0) in async_wait_timeout_callback()
160 async_wait_done(r, wait); in async_wait_timeout_callback()
171 int r; in async_wait_getobject_callback() local
187 r = sd_bus_message_get_errno(m); in async_wait_getobject_callback()
189 if ((r == EBUSY || r == ENOBUFS) && data->retry < mapper_busy_retries) in async_wait_getobject_callback()
191 r = sd_event_now(wait->loop, CLOCK_MONOTONIC, &next_retry); in async_wait_getobject_callback()
192 if (r < 0) in async_wait_getobject_callback()
194 async_wait_done(r, wait); in async_wait_getobject_callback()
199 r = sd_event_add_time(wait->loop, &data->event_source, CLOCK_MONOTONIC, in async_wait_getobject_callback()
202 if (r < 0) in async_wait_getobject_callback()
204 async_wait_done(r, wait); in async_wait_getobject_callback()
211 if (r) in async_wait_getobject_callback()
213 async_wait_done(-r, wait); in async_wait_getobject_callback()
238 int r; in async_wait_get_objects() local
252 r = sd_bus_call_method_async( in async_wait_get_objects()
257 if (r < 0) in async_wait_get_objects()
260 fprintf(stderr, "Error invoking method: %s\n", strerror(-r)); in async_wait_get_objects()
261 return r; in async_wait_get_objects()
271 int r; in async_wait_match_introspection_complete() local
279 r = async_wait_get_objects(wait); in async_wait_match_introspection_complete()
280 if (r < 0) in async_wait_match_introspection_complete()
282 async_wait_done(r, wait); in async_wait_match_introspection_complete()
288 static void async_wait_done(int r, mapper_async_wait* w) in async_wait_done() argument
301 w->callback(r, w->userdata); in async_wait_done()
336 int r; in mapper_wait_async() local
353 r = 0; in mapper_wait_async()
360 r = -ENOMEM; in mapper_wait_async()
367 r = -ENOMEM; in mapper_wait_async()
372 r = sd_bus_add_match(conn, &wait->introspection_slot, in mapper_wait_async()
375 if (r < 0) in mapper_wait_async()
377 fprintf(stderr, "Error adding match rule: %s\n", strerror(-r)); in mapper_wait_async()
381 r = sd_bus_add_match(conn, &wait->intf_slot, in mapper_wait_async()
384 if (r < 0) in mapper_wait_async()
386 fprintf(stderr, "Error adding match rule: %s\n", strerror(-r)); in mapper_wait_async()
390 r = async_wait_get_objects(wait); in mapper_wait_async()
391 if (r < 0) in mapper_wait_async()
393 fprintf(stderr, "Error calling method: %s\n", strerror(-r)); in mapper_wait_async()
412 return r; in mapper_wait_async()
418 int r; in async_subtree_timeout_callback() local
422 r = sd_bus_call_method_async( in async_subtree_timeout_callback()
428 if (r < 0) in async_subtree_timeout_callback()
430 async_subtree_done(r, subtree); in async_subtree_timeout_callback()
439 int r; in async_subtree_getpaths_callback() local
448 r = sd_bus_message_get_errno(m); in async_subtree_getpaths_callback()
455 r = 0; in async_subtree_getpaths_callback()
463 if ((r == EBUSY || r == ENOBUFS) && subtree->retry < mapper_busy_retries) in async_subtree_getpaths_callback()
465 r = sd_event_now(subtree->loop, CLOCK_MONOTONIC, &next_retry); in async_subtree_getpaths_callback()
466 if (r < 0) in async_subtree_getpaths_callback()
468 async_subtree_done(r, subtree); in async_subtree_getpaths_callback()
473 r = sd_event_add_time(subtree->loop, &subtree->event_source, in async_subtree_getpaths_callback()
477 if (r < 0) in async_subtree_getpaths_callback()
479 async_subtree_done(r, subtree); in async_subtree_getpaths_callback()
486 if (r) in async_subtree_getpaths_callback()
488 async_subtree_done(-r, subtree); in async_subtree_getpaths_callback()
494 r = sd_bus_message_enter_container(m, SD_BUS_TYPE_ARRAY, "s"); in async_subtree_getpaths_callback()
495 if (r < 0) in async_subtree_getpaths_callback()
497 async_subtree_done(r, subtree); in async_subtree_getpaths_callback()
501 r = sd_bus_message_at_end(m, false); in async_subtree_getpaths_callback()
502 if (r < 0) in async_subtree_getpaths_callback()
504 async_subtree_done(r, subtree); in async_subtree_getpaths_callback()
511 if (r) in async_subtree_getpaths_callback()
521 int r = 0; in async_subtree_getpaths() local
525 r = sd_bus_call_method_async( in async_subtree_getpaths()
531 if (r < 0) in async_subtree_getpaths()
533 fprintf(stderr, "Error invoking method: %s\n", strerror(-r)); in async_subtree_getpaths()
534 return r; in async_subtree_getpaths()
543 int r; in async_subtree_match_callback() local
551 r = async_subtree_getpaths(subtree); in async_subtree_match_callback()
552 if (r < 0) in async_subtree_match_callback()
554 async_subtree_done(r, subtree); in async_subtree_match_callback()
560 static void async_subtree_done(int r, mapper_async_subtree* t) in async_subtree_done() argument
572 t->callback(r, t->userdata); in async_subtree_done()
581 int r = 0; in mapper_subtree_async() local
601 r = sd_bus_add_match(conn, &subtree->slot, interfaces_removed_match, in mapper_subtree_async()
603 if (r < 0) in mapper_subtree_async()
605 fprintf(stderr, "Error adding match rule: %s\n", strerror(-r)); in mapper_subtree_async()
612 r = -EINVAL; in mapper_subtree_async()
616 r = async_subtree_getpaths(subtree); in mapper_subtree_async()
617 if (r < 0) in mapper_subtree_async()
619 fprintf(stderr, "Error calling method: %s\n", strerror(-r)); in mapper_subtree_async()
632 return r; in mapper_subtree_async()
639 int r, retry = 0; in mapper_get_object() local
641 r = sd_bus_message_new_method_call( in mapper_get_object()
645 if (r < 0) in mapper_get_object()
650 r = sd_bus_message_append(request, "s", obj); in mapper_get_object()
651 if (r < 0) in mapper_get_object()
655 r = sd_bus_message_append(request, "as", 0, NULL); in mapper_get_object()
656 if (r < 0) in mapper_get_object()
663 r = sd_bus_call(conn, request, 0, NULL, reply); in mapper_get_object()
664 if (r == -EBUSY || r == -ENOBUFS) in mapper_get_object()
676 if (r < 0) in mapper_get_object()
684 return r; in mapper_get_object()
691 int r; in mapper_get_service() local
693 r = mapper_get_object(conn, obj, &reply); in mapper_get_service()
694 if (r < 0) in mapper_get_service()
699 r = sd_bus_message_enter_container(reply, 0, NULL); in mapper_get_service()
700 if (r < 0) in mapper_get_service()
705 r = sd_bus_message_enter_container(reply, 0, NULL); in mapper_get_service()
706 if (r < 0) in mapper_get_service()
711 r = sd_bus_message_read(reply, "s", &tmp); in mapper_get_service()
712 if (r < 0) in mapper_get_service()
722 return r; in mapper_get_service()