diff options
author | Jo-Philipp Wich <jo@mein.io> | 2024-03-13 23:54:27 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-03-13 23:54:27 +0100 |
commit | 55ee75b6e08c64a850f9da2613eef127f8014d98 (patch) | |
tree | 4a0a1376a000ab0a4f5d038a375086f39d395025 /lib | |
parent | 11628e715386e4aff181980b7edffeafdcb82a70 (diff) | |
parent | 99837f280b61de646d1635248e70827754553bef (diff) |
Merge pull request #191 from jow-/ubus-clear-errors
ubus: automatically clear error information
Diffstat (limited to 'lib')
-rw-r--r-- | lib/ubus.c | 61 | ||||
-rw-r--r-- | lib/uci.c | 37 | ||||
-rw-r--r-- | lib/uloop.c | 67 |
3 files changed, 84 insertions, 81 deletions
@@ -20,6 +20,7 @@ #include "ucode/module.h" +#define ok_return(expr) do { set_error(0, NULL); return (expr); } while(0) #define err_return(err, ...) do { set_error(err, __VA_ARGS__); return NULL; } while(0) static struct { @@ -100,7 +101,7 @@ _args_get(uc_vm_t *vm, size_t nargs, ...) va_end(ap); - return true; + ok_return(true); } #define args_get(vm, nargs, ...) do { if (!_args_get(vm, nargs, __VA_ARGS__, NULL)) return NULL; } while(0) @@ -505,7 +506,7 @@ uc_ubus_connect(uc_vm_t *vm, size_t nargs) ubus_add_uloop(&c->ctx); - return uc_resource_new(conn_type, c); + ok_return(uc_resource_new(conn_type, c)); } static void @@ -544,7 +545,7 @@ _conn_get(uc_vm_t *vm, uc_ubus_connection_t **conn) *conn = c; - return true; + ok_return(true); } #define conn_get(vm, ptr) do { if (!_conn_get(vm, ptr)) return NULL; } while(0) @@ -573,7 +574,7 @@ uc_ubus_list(uc_vm_t *vm, size_t nargs) err_return(rv, NULL); } - return res; + ok_return(res); } static void @@ -707,7 +708,7 @@ uc_ubus_call(uc_vm_t *vm, size_t nargs) err_return(rv, "Failed to invoke function '%s' on object '%s'", ucv_string_get(funname), ucv_string_get(objname)); - return res.res; + ok_return(res.res); } static uc_value_t * @@ -780,7 +781,7 @@ uc_ubus_defer(uc_vm_t *vm, size_t nargs) err_return(rv, "Failed to invoke function '%s' on object '%s'", ucv_string_get(funname), ucv_string_get(objname)); - return res; + ok_return(res); } @@ -841,7 +842,7 @@ uc_ubus_request_reply(uc_vm_t *vm, size_t nargs) uc_ubus_request_finish(*callctx, code, reply); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -867,7 +868,7 @@ uc_ubus_request_error(uc_vm_t *vm, size_t nargs) uc_ubus_request_finish(*callctx, code, NULL); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } @@ -884,7 +885,7 @@ uc_ubus_notify_completed(uc_vm_t *vm, size_t nargs) if (!notifyctx || !*notifyctx) err_return(UBUS_STATUS_INVALID_ARGUMENT, "Invalid notify context"); - return ucv_boolean_new((*notifyctx)->complete); + ok_return(ucv_boolean_new((*notifyctx)->complete)); } static uc_value_t * @@ -896,12 +897,12 @@ uc_ubus_notify_abort(uc_vm_t *vm, size_t nargs) err_return(UBUS_STATUS_INVALID_ARGUMENT, "Invalid notify context"); if ((*notifyctx)->complete) - return ucv_boolean_new(false); + ok_return(ucv_boolean_new(false)); ubus_abort_request((*notifyctx)->ctx, &(*notifyctx)->req.req); (*notifyctx)->complete = true; - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static void @@ -1032,12 +1033,12 @@ uc_ubus_object_notify(uc_vm_t *vm, size_t nargs) ucv_put(res); - return ucv_int64_new(rv); + ok_return(ucv_int64_new(rv)); } ubus_complete_request_async((*uuobj)->ctx, ¬ifyctx->req.req); - return res; + ok_return(res); } @@ -1071,7 +1072,7 @@ uc_ubus_object_remove(uc_vm_t *vm, size_t nargs) if (rv != UBUS_STATUS_OK) err_return(rv, "Failed to remove object"); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } @@ -1087,7 +1088,7 @@ uc_ubus_object_subscribed(uc_vm_t *vm, size_t nargs) if (!uuobj || !*uuobj) err_return(UBUS_STATUS_INVALID_ARGUMENT, "Invalid object context"); - return ucv_boolean_new((*uuobj)->obj.has_subscribers); + ok_return(ucv_boolean_new((*uuobj)->obj.has_subscribers)); } @@ -1398,7 +1399,7 @@ uc_ubus_object_methods_validate(uc_value_t *methods) } } - return true; + ok_return(true); } static bool @@ -1571,7 +1572,7 @@ uc_ubus_publish(uc_vm_t *vm, size_t nargs) uuobj->ctx = &c->ctx; uuobj->registry_index = object_reg_add(vm, ucv_get(res), ucv_get(methods), ucv_get(subscribecb)); - return res; + ok_return(res); } @@ -1605,7 +1606,7 @@ uc_ubus_listener_remove(uc_vm_t *vm, size_t nargs) if (rv != UBUS_STATUS_OK) err_return(rv, "Failed to remove listener object"); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static void @@ -1660,7 +1661,7 @@ uc_ubus_listener(uc_vm_t *vm, size_t nargs) uul->registry_index = listener_reg_add(vm, ucv_get(res), ucv_get(cb)); - return res; + ok_return(res); } static uc_value_t * @@ -1686,7 +1687,7 @@ uc_ubus_event(uc_vm_t *vm, size_t nargs) if (rv != UBUS_STATUS_OK) err_return(rv, "Unable to send event"); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } @@ -1774,7 +1775,7 @@ uc_ubus_subscriber_subunsub_common(uc_vm_t *vm, size_t nargs, bool subscribe) subscribe ? "subscribe" : "unsubscribe", ucv_string_get(objname)); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -1814,7 +1815,7 @@ uc_ubus_subscriber_remove(uc_vm_t *vm, size_t nargs) if (rv != UBUS_STATUS_OK) err_return(rv, "Failed to remove subscriber object"); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -1857,7 +1858,7 @@ uc_ubus_subscriber(uc_vm_t *vm, size_t nargs) uusub->registry_index = subscriber_reg_add(vm, ucv_get(res), ucv_get(notify_cb), ucv_get(remove_cb)); - return res; + ok_return(res); } @@ -1915,7 +1916,7 @@ uc_ubus_remove(uc_vm_t *vm, size_t nargs) err_return(UBUS_STATUS_INVALID_ARGUMENT, "Unhandled resource type"); } - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } @@ -1929,7 +1930,7 @@ uc_ubus_disconnect(uc_vm_t *vm, size_t nargs) ubus_shutdown(&c->ctx); c->ctx.sock.fd = -1; - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -1938,9 +1939,9 @@ uc_ubus_defer_completed(uc_vm_t *vm, size_t nargs) uc_ubus_deferred_t **d = uc_fn_this("ubus.deferred"); if (!d || !*d) - return NULL; + err_return(UBUS_STATUS_INVALID_ARGUMENT, "Invalid deferred context"); - return ucv_boolean_new((*d)->complete); + ok_return(ucv_boolean_new((*d)->complete)); } static uc_value_t * @@ -1949,10 +1950,10 @@ uc_ubus_defer_abort(uc_vm_t *vm, size_t nargs) uc_ubus_deferred_t **d = uc_fn_this("ubus.deferred"); if (!d || !*d) - return NULL; + err_return(UBUS_STATUS_INVALID_ARGUMENT, "Invalid deferred context"); if ((*d)->complete) - return ucv_boolean_new(false); + ok_return(ucv_boolean_new(false)); ubus_abort_request((*d)->ctx, &(*d)->request); uloop_timeout_cancel(&(*d)->timeout); @@ -1966,7 +1967,7 @@ uc_ubus_defer_abort(uc_vm_t *vm, size_t nargs) (*d)->complete = true; - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } @@ -53,6 +53,7 @@ #include "ucode/module.h" +#define ok_return(expr) do { last_error = 0; return (expr); } while(0) #define err_return(err) do { last_error = err; return NULL; } while(0) static int last_error = 0; @@ -178,7 +179,7 @@ uc_uci_cursor(uc_vm_t *vm, size_t nargs) err_return(rv); } - return uc_resource_new(cursor_type, c); + ok_return(uc_resource_new(cursor_type, c)); } @@ -366,7 +367,7 @@ uc_uci_load(uc_vm_t *vm, size_t nargs) if (uci_load(*c, s, NULL)) err_return((*c)->err); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } /** @@ -406,11 +407,11 @@ uc_uci_unload(uc_vm_t *vm, size_t nargs) if (!strcmp(e->name, ucv_string_get(conf))) { uci_unload(*c, uci_to_package(e)); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } } - return ucv_boolean_new(false); + ok_return(ucv_boolean_new(false)); } static int @@ -548,26 +549,26 @@ uc_uci_get_any(uc_vm_t *vm, size_t nargs, bool all) if (!ptr.s) err_return(UCI_ERR_NOTFOUND); - return section_to_uval(vm, ptr.s, -1); + ok_return(section_to_uval(vm, ptr.s, -1)); } if (!ptr.p) err_return(UCI_ERR_NOTFOUND); - return package_to_uval(vm, ptr.p); + ok_return(package_to_uval(vm, ptr.p)); } if (ptr.option) { if (!ptr.o) err_return(UCI_ERR_NOTFOUND); - return option_to_uval(vm, ptr.o); + ok_return(option_to_uval(vm, ptr.o)); } if (!ptr.s) err_return(UCI_ERR_NOTFOUND); - return ucv_string_new(ptr.s->type); + ok_return(ucv_string_new(ptr.s->type)); } /** @@ -739,7 +740,7 @@ uc_uci_get_first(uc_vm_t *vm, size_t nargs) continue; if (!opt) - return ucv_string_new(sc->e.name); + ok_return(ucv_string_new(sc->e.name)); ptr.package = ucv_string_get(conf); ptr.section = sc->e.name; @@ -755,7 +756,7 @@ uc_uci_get_first(uc_vm_t *vm, size_t nargs) if (!(ptr.flags & UCI_LOOKUP_COMPLETE)) err_return(UCI_ERR_NOTFOUND); - return option_to_uval(vm, ptr.o); + ok_return(option_to_uval(vm, ptr.o)); } err_return(UCI_ERR_NOTFOUND); @@ -1040,7 +1041,7 @@ uc_uci_set(uc_vm_t *vm, size_t nargs) err_return(rv); } - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } /** @@ -1119,7 +1120,7 @@ uc_uci_delete(uc_vm_t *vm, size_t nargs) if (rv != UCI_OK) err_return(rv); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } /** @@ -1228,7 +1229,7 @@ uc_uci_rename(uc_vm_t *vm, size_t nargs) if (rv != UCI_OK) err_return(rv); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } /** @@ -1336,7 +1337,7 @@ uc_uci_reorder(uc_vm_t *vm, size_t nargs) if (rv != UCI_OK) err_return(rv); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static int @@ -1406,7 +1407,7 @@ uc_uci_pkg_command(uc_vm_t *vm, size_t nargs, enum pkg_cmd cmd) if (res != UCI_OK) err_return(res); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } /** @@ -1687,7 +1688,7 @@ uc_uci_changes(uc_vm_t *vm, size_t nargs) free(configs); - return res; + ok_return(res); } /** @@ -1789,7 +1790,7 @@ uc_uci_foreach(uc_vm_t *vm, size_t nargs) break; } - return ucv_boolean_new(ret); + ok_return(ucv_boolean_new(ret)); } /** @@ -1832,7 +1833,7 @@ uc_uci_configs(uc_vm_t *vm, size_t nargs) free(configs); - return a; + ok_return(a); } diff --git a/lib/uloop.c b/lib/uloop.c index 053efce..bccb699 100644 --- a/lib/uloop.c +++ b/lib/uloop.c @@ -25,6 +25,7 @@ #include "ucode/module.h" #include "ucode/platform.h" +#define ok_return(expr) do { last_error = 0; return (expr); } while(0) #define err_return(err) do { last_error = err; return NULL; } while(0) static uc_resource_type_t *timer_type, *handle_type, *process_type, *task_type, *pipe_type; @@ -113,7 +114,7 @@ uc_uloop_init(uc_vm_t *vm, size_t nargs) if (rv == -1) err_return(errno); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -130,13 +131,13 @@ uc_uloop_run(uc_vm_t *vm, size_t nargs) rv = uloop_run_timeout(t); - return ucv_int64_new(rv); + ok_return(ucv_int64_new(rv)); } static uc_value_t * uc_uloop_cancelling(uc_vm_t *vm, size_t nargs) { - return ucv_boolean_new(uloop_cancelling()); + ok_return(ucv_boolean_new(uloop_cancelling())); } static uc_value_t * @@ -149,7 +150,7 @@ uc_uloop_running(uc_vm_t *vm, size_t nargs) active = uloop_cancelling(); uloop_cancelled = prev; - return ucv_boolean_new(active); + ok_return(ucv_boolean_new(active)); } static uc_value_t * @@ -157,7 +158,7 @@ uc_uloop_end(uc_vm_t *vm, size_t nargs) { uloop_end(); - return NULL; + ok_return(NULL); } static uc_value_t * @@ -165,7 +166,7 @@ uc_uloop_done(uc_vm_t *vm, size_t nargs) { uloop_done(); - return NULL; + ok_return(NULL); } @@ -202,7 +203,7 @@ uc_uloop_timer_set(uc_vm_t *vm, size_t nargs) rv = uloop_timeout_set(&(*timer)->timeout, t); - return ucv_boolean_new(rv == 0); + ok_return(ucv_boolean_new(rv == 0)); } static uc_value_t * @@ -220,7 +221,7 @@ uc_uloop_timer_remaining(uc_vm_t *vm, size_t nargs) rem = (int64_t)uloop_timeout_remaining(&(*timer)->timeout); #endif - return ucv_int64_new(rem); + ok_return(ucv_int64_new(rem)); } static uc_value_t * @@ -236,7 +237,7 @@ uc_uloop_timer_cancel(uc_vm_t *vm, size_t nargs) uc_uloop_timeout_clear(timer); - return ucv_boolean_new(rv == 0); + ok_return(ucv_boolean_new(rv == 0)); } static void @@ -276,7 +277,7 @@ uc_uloop_timer(uc_vm_t *vm, size_t nargs) timer->registry_index = uc_uloop_reg_add(res, callback); - return res; + ok_return(res); } @@ -305,7 +306,7 @@ uc_uloop_handle_fileno(uc_vm_t *vm, size_t nargs) if (!handle || !*handle) err_return(EINVAL); - return ucv_int64_new((*handle)->fd.fd); + ok_return(ucv_int64_new((*handle)->fd.fd)); } static uc_value_t * @@ -316,7 +317,7 @@ uc_uloop_handle_handle(uc_vm_t *vm, size_t nargs) if (!handle || !*handle) err_return(EINVAL); - return ucv_get((*handle)->handle); + ok_return(ucv_get((*handle)->handle)); } static uc_value_t * @@ -335,7 +336,7 @@ uc_uloop_handle_delete(uc_vm_t *vm, size_t nargs) if (rv != 0) err_return(errno); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static void @@ -435,7 +436,7 @@ uc_uloop_handle(uc_vm_t *vm, size_t nargs) handle->registry_index = uc_uloop_reg_add(res, callback); - return res; + ok_return(res); } @@ -461,7 +462,7 @@ uc_uloop_process_pid(uc_vm_t *vm, size_t nargs) if (!process || !*process) err_return(EINVAL); - return ucv_int64_new((*process)->process.pid); + ok_return(ucv_int64_new((*process)->process.pid)); } static uc_value_t * @@ -480,7 +481,7 @@ uc_uloop_process_delete(uc_vm_t *vm, size_t nargs) if (rv != 0) err_return(EINVAL); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static void @@ -562,7 +563,7 @@ uc_uloop_process(uc_vm_t *vm, size_t nargs) process->registry_index = uc_uloop_reg_add(res, callback); - return res; + ok_return(res); } @@ -645,7 +646,7 @@ uc_uloop_pipe_send_common(uc_vm_t *vm, uc_value_t *msg, int fd) if (!rv) err_return(errno); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -660,7 +661,7 @@ uc_uloop_pipe_send(uc_vm_t *vm, size_t nargs) if (!(*pipe)->has_receiver) err_return(EPIPE); - return uc_uloop_pipe_send_common(vm, msg, (*pipe)->output); + ok_return(uc_uloop_pipe_send_common(vm, msg, (*pipe)->output)); } static bool @@ -773,7 +774,7 @@ uc_uloop_pipe_sending(uc_vm_t *vm, size_t nargs) if (!pipe || !*pipe) err_return(EINVAL); - return ucv_boolean_new((*pipe)->has_sender); + ok_return(ucv_boolean_new((*pipe)->has_sender)); } static uc_value_t * @@ -784,7 +785,7 @@ uc_uloop_pipe_receiving(uc_vm_t *vm, size_t nargs) if (!pipe || !*pipe) err_return(EINVAL); - return ucv_boolean_new((*pipe)->has_receiver); + ok_return(ucv_boolean_new((*pipe)->has_receiver)); } @@ -840,7 +841,7 @@ uc_uloop_task_pid(uc_vm_t *vm, size_t nargs) if ((*task)->finished) err_return(ESRCH); - return ucv_int64_new((*task)->process.pid); + ok_return(ucv_int64_new((*task)->process.pid)); } static uc_value_t * @@ -860,7 +861,7 @@ uc_uloop_task_kill(uc_vm_t *vm, size_t nargs) if (rv == -1) err_return(errno); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static uc_value_t * @@ -871,7 +872,7 @@ uc_uloop_task_finished(uc_vm_t *vm, size_t nargs) if (!task || !*task) err_return(EINVAL); - return ucv_boolean_new((*task)->finished); + ok_return(ucv_boolean_new((*task)->finished)); } static void @@ -1047,7 +1048,7 @@ uc_uloop_task(uc_vm_t *vm, size_t nargs) task->registry_index = uc_uloop_reg_add(res, cbs); - return res; + ok_return(res); } @@ -1085,7 +1086,7 @@ uc_uloop_interval_set(uc_vm_t *vm, size_t nargs) rv = uloop_interval_set(&(*interval)->interval, t); - return ucv_boolean_new(rv == 0); + ok_return(ucv_boolean_new(rv == 0)); } static uc_value_t * @@ -1096,7 +1097,7 @@ uc_uloop_interval_remaining(uc_vm_t *vm, size_t nargs) if (!interval || !*interval) err_return(EINVAL); - return ucv_int64_new(uloop_interval_remaining(&(*interval)->interval)); + ok_return(ucv_int64_new(uloop_interval_remaining(&(*interval)->interval))); } static uc_value_t * @@ -1107,7 +1108,7 @@ uc_uloop_interval_expirations(uc_vm_t *vm, size_t nargs) if (!interval || !*interval) err_return(EINVAL); - return ucv_int64_new((*interval)->interval.expirations); + ok_return(ucv_int64_new((*interval)->interval.expirations)); } static uc_value_t * @@ -1123,7 +1124,7 @@ uc_uloop_interval_cancel(uc_vm_t *vm, size_t nargs) uc_uloop_interval_clear(interval); - return ucv_boolean_new(rv == 0); + ok_return(ucv_boolean_new(rv == 0)); } static void @@ -1163,7 +1164,7 @@ uc_uloop_interval(uc_vm_t *vm, size_t nargs) interval->registry_index = uc_uloop_reg_add(res, callback); - return res; + ok_return(res); } #endif @@ -1191,7 +1192,7 @@ uc_uloop_signal_signo(uc_vm_t *vm, size_t nargs) if (!signal || !*signal) err_return(EINVAL); - return ucv_int64_new((*signal)->signal.signo); + ok_return(ucv_int64_new((*signal)->signal.signo)); } static uc_value_t * @@ -1210,7 +1211,7 @@ uc_uloop_signal_delete(uc_vm_t *vm, size_t nargs) if (rv != 0) err_return(EINVAL); - return ucv_boolean_new(true); + ok_return(ucv_boolean_new(true)); } static void @@ -1273,7 +1274,7 @@ uc_uloop_signal(uc_vm_t *vm, size_t nargs) signal->registry_index = uc_uloop_reg_add(res, callback); - return res; + ok_return(res); } #endif |