• source navigation  • diff markup  • identifier search  • freetext search  • 

Sources/ubus/ubusd.h

  1 /*
  2  * Copyright (C) 2011-2014 Felix Fietkau <nbd@openwrt.org>
  3  *
  4  * This program is free software; you can redistribute it and/or modify
  5  * it under the terms of the GNU Lesser General Public License version 2.1
  6  * as published by the Free Software Foundation
  7  *
  8  * This program is distributed in the hope that it will be useful,
  9  * but WITHOUT ANY WARRANTY; without even the implied warranty of
 10  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 11  * GNU General Public License for more details.
 12  */
 13 
 14 #ifndef __UBUSD_H
 15 #define __UBUSD_H
 16 
 17 #include <libubox/list.h>
 18 #include <libubox/uloop.h>
 19 #include <libubox/blobmsg.h>
 20 #include "ubus_common.h"
 21 #include "ubusd_id.h"
 22 #include "ubusd_obj.h"
 23 #include "ubusmsg.h"
 24 #include "ubusd_acl.h"
 25 
 26 #define UBUS_OBJ_HASH_BITS      4
 27 #define UBUS_CLIENT_MAX_TXQ_LEN UBUS_MAX_MSGLEN
 28 
 29 extern struct blob_buf b;
 30 
 31 struct ubus_msg_buf {
 32         uint32_t refcount; /* ~0: uses external data buffer */
 33         struct ubus_msghdr hdr;
 34         struct blob_attr *data;
 35         int fd;
 36         int len;
 37 };
 38 
 39 struct ubus_msg_buf_list {
 40         struct list_head list;
 41         struct ubus_msg_buf *msg;
 42 };
 43 
 44 struct ubus_client {
 45         struct ubus_id id;
 46         struct uloop_fd sock;
 47         struct blob_buf b;
 48 
 49         uid_t uid;
 50         gid_t gid;
 51         char *user;
 52         char *group;
 53 
 54         struct list_head objects;
 55 
 56         struct list_head tx_queue;
 57         unsigned int txq_ofs;
 58         unsigned int txq_len;
 59 
 60         struct ubus_msg_buf *pending_msg;
 61         struct ubus_msg_buf *retmsg;
 62         int pending_msg_offset;
 63         int pending_msg_fd;
 64         struct {
 65                 struct ubus_msghdr hdr;
 66                 struct blob_attr data;
 67         } hdrbuf;
 68 };
 69 
 70 struct ubus_path {
 71         struct list_head list;
 72         const char name[];
 73 };
 74 
 75 extern const char *ubusd_acl_dir;
 76 
 77 struct ubus_msg_buf *ubus_msg_new(void *data, int len, bool shared);
 78 void ubus_msg_send(struct ubus_client *cl, struct ubus_msg_buf *ub);
 79 ssize_t ubus_msg_writev(int fd, struct ubus_msg_buf *ub, size_t offset);
 80 void ubus_msg_free(struct ubus_msg_buf *ub);
 81 void ubus_msg_list_free(struct ubus_msg_buf_list *ubl);
 82 struct blob_attr **ubus_parse_msg(struct blob_attr *msg, size_t len);
 83 
 84 struct ubus_client *ubusd_proto_new_client(int fd, uloop_fd_handler cb);
 85 void ubusd_proto_receive_message(struct ubus_client *cl, struct ubus_msg_buf *ub);
 86 void ubusd_proto_free_client(struct ubus_client *cl);
 87 void ubus_proto_send_msg_from_blob(struct ubus_client *cl, struct ubus_msg_buf *ub,
 88                                    uint8_t type);
 89 
 90 typedef struct ubus_msg_buf *(*event_fill_cb)(void *priv, const char *id);
 91 void ubusd_event_init(void);
 92 void ubusd_event_cleanup_object(struct ubus_object *obj);
 93 void ubusd_send_obj_event(struct ubus_object *obj, bool add);
 94 int ubusd_send_event(struct ubus_client *cl, const char *id,
 95                      event_fill_cb fill_cb, void *cb_priv);
 96 
 97 void ubusd_acl_init(void);
 98 
 99 void ubusd_monitor_init(void);
100 void ubusd_monitor_message(struct ubus_client *cl, struct ubus_msg_buf *ub, bool send);
101 void ubusd_monitor_disconnect(struct ubus_client *cl);
102 
103 #endif
104 

This page was automatically generated by LXR 0.3.1.  •  OpenWrt