123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960 |
- #ifndef __UBUSD_H
- #define __UBUSD_H
- #include <libubox/list.h>
- #include <libubox/uloop.h>
- #include <libubox/blobmsg.h>
- #include "ubus_common.h"
- #include "ubusd_id.h"
- #include "ubusd_obj.h"
- #include "ubusmsg.h"
- #define UBUSD_CLIENT_BACKLOG 32
- #define UBUS_OBJ_HASH_BITS 4
- struct ubus_msg_buf {
- uint32_t refcount; /* ~0: uses external data buffer */
- struct ubus_msghdr hdr;
- struct blob_attr *data;
- int len;
- };
- struct ubus_client {
- struct ubus_id id;
- struct uloop_fd sock;
- struct list_head objects;
- struct ubus_msg_buf *tx_queue[UBUSD_CLIENT_BACKLOG];
- unsigned int txq_cur, txq_tail, txq_ofs;
- struct ubus_msg_buf *pending_msg;
- int pending_msg_offset;
- struct {
- struct ubus_msghdr hdr;
- struct blob_attr data;
- } hdrbuf;
- };
- struct ubus_path {
- struct list_head list;
- const char name[];
- };
- struct ubus_msg_buf *ubus_msg_new(void *data, int len, bool shared);
- void ubus_msg_send(struct ubus_client *cl, struct ubus_msg_buf *ub, bool free);
- struct ubus_msg_buf *ubus_msg_ref(struct ubus_msg_buf *ub);
- void ubus_msg_free(struct ubus_msg_buf *ub);
- struct ubus_client *ubusd_get_client_by_id(uint32_t id);
- void ubusd_receive_message(struct ubus_client *cl, struct ubus_msg_buf *ub);
- bool ubusd_send_hello(struct ubus_client *cl);
- struct blob_attr **ubus_parse_msg(struct blob_attr *msg);
- void ubusd_event_init(void);
- void ubusd_event_cleanup_object(struct ubus_object *obj);
- #endif
|