X-Git-Url: https://git.archive.openwrt.org/?p=project%2Fubus.git;a=blobdiff_plain;f=libubus.h;h=698e356513c3ac5e406ac0539e28d82ba328f5b5;hp=b741e652916e7b0488b0da6f9ae8b82e0cbd08a2;hb=ea76fb270d40e11f3c4b02671babc47ffe836646;hpb=7b262aec3843912d68e020f0750b6f96e2f7c8e3 diff --git a/libubus.h b/libubus.h index b741e65..698e356 100644 --- a/libubus.h +++ b/libubus.h @@ -6,12 +6,17 @@ #include "ubusmsg.h" #include "ubus_common.h" +struct ubus_context; struct ubus_msg_src; struct ubus_object; struct ubus_request; struct ubus_request_data; +struct ubus_object_data; -typedef int (*ubus_handler_t)(struct ubus_object *obj, +typedef void (*ubus_lookup_handler_t)(struct ubus_context *ctx, + struct ubus_object_data *obj, + void *priv); +typedef int (*ubus_handler_t)(struct ubus_context *ctx, struct ubus_object *obj, struct ubus_request_data *req, const char *method, struct blob_attr *msg); typedef void (*ubus_data_handler_t)(struct ubus_request *req, @@ -87,6 +92,13 @@ struct ubus_context { } msgbuf; }; +struct ubus_object_data { + uint32_t id; + uint32_t type_id; + const char *path; + struct blob_attr *signature; +}; + struct ubus_request_data { uint32_t object; uint32_t peer; @@ -105,6 +117,7 @@ struct ubus_request { uint32_t peer; uint32_t seq; + ubus_data_handler_t raw_data_cb; ubus_data_handler_t data_cb; ubus_complete_handler_t complete_cb; @@ -119,16 +132,8 @@ void ubus_free(struct ubus_context *ctx); const char *ubus_strerror(int error); -/* ----------- helpers for message handling ----------- */ - -struct blob_attr **ubus_parse_msg(struct blob_attr *msg); - /* ----------- raw request handling ----------- */ -/* start a raw request */ -int ubus_start_request(struct ubus_context *ctx, struct ubus_request *req, - struct blob_attr *msg, int cmd, uint32_t peer); - /* wait for a request to complete and return its status */ int ubus_complete_request(struct ubus_context *ctx, struct ubus_request *req); @@ -139,6 +144,13 @@ void ubus_complete_request_async(struct ubus_context *ctx, /* abort an asynchronous request */ void ubus_abort_request(struct ubus_context *ctx, struct ubus_request *req); +/* ----------- objects ----------- */ + +int ubus_lookup(struct ubus_context *ctx, const char *path, + ubus_lookup_handler_t cb, void *priv); + +int ubus_lookup_id(struct ubus_context *ctx, const char *path, uint32_t *id); + /* ----------- rpc ----------- */ /* invoke a method on a specific object */ @@ -152,4 +164,6 @@ void ubus_invoke_async(struct ubus_context *ctx, uint32_t obj, const char *metho /* make an object visible to remote connections */ int ubus_publish(struct ubus_context *ctx, struct ubus_object *obj); - +/* send a reply to an incoming object method call */ +int ubus_send_reply(struct ubus_context *ctx, struct ubus_request_data *req, + struct blob_attr *msg);