• 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 UBUSD_CLIENT_BACKLOG    32
 27 #define UBUS_OBJ_HASH_BITS      4
 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_client {
 40         struct ubus_id id;
 41         struct uloop_fd sock;
 42         struct blob_buf b;
 43 
 44         uid_t uid;
 45         gid_t gid;
 46         char *user;
 47         char *group;
 48 
 49         struct list_head objects;
 50 
 51         struct ubus_msg_buf *tx_queue[UBUSD_CLIENT_BACKLOG];
 52         unsigned int txq_cur, txq_tail, txq_ofs;
 53 
 54         struct ubus_msg_buf *pending_msg;
 55         struct ubus_msg_buf *retmsg;
 56         int pending_msg_offset;
 57         int pending_msg_fd;
 58         struct {
 59                 struct ubus_msghdr hdr;
 60                 struct blob_attr data;
 61         } hdrbuf;
 62 };
 63 
 64 struct ubus_path {
 65         struct list_head list;
 66         const char name[];
 67 };
 68 
 69 extern const char *ubusd_acl_dir;
 70 
 71 struct ubus_msg_buf *ubus_msg_new(void *data, int len, bool shared);
 72 void ubus_msg_send(struct ubus_client *cl, struct ubus_msg_buf *ub);
 73 ssize_t ubus_msg_writev(int fd, struct ubus_msg_buf *ub, size_t offset);
 74 void ubus_msg_free(struct ubus_msg_buf *ub);
 75 struct blob_attr **ubus_parse_msg(struct blob_attr *msg, size_t len);
 76 
 77 struct ubus_client *ubusd_proto_new_client(int fd, uloop_fd_handler cb);
 78 void ubusd_proto_receive_message(struct ubus_client *cl, struct ubus_msg_buf *ub);
 79 void ubusd_proto_free_client(struct ubus_client *cl);
 80 void ubus_proto_send_msg_from_blob(struct ubus_client *cl, struct ubus_msg_buf *ub,
 81                                    uint8_t type);
 82 
 83 typedef struct ubus_msg_buf *(*event_fill_cb)(void *priv, const char *id);
 84 void ubusd_event_init(void);
 85 void ubusd_event_cleanup_object(struct ubus_object *obj);
 86 void ubusd_send_obj_event(struct ubus_object *obj, bool add);
 87 int ubusd_send_event(struct ubus_client *cl, const char *id,
 88                      event_fill_cb fill_cb, void *cb_priv);
 89 
 90 void ubusd_acl_init(void);
 91 
 92 void ubusd_monitor_init(void);
 93 void ubusd_monitor_message(struct ubus_client *cl, struct ubus_msg_buf *ub, bool send);
 94 void ubusd_monitor_disconnect(struct ubus_client *cl);
 95 
 96 #endif
 97 

This page was automatically generated by LXR 0.3.1.  •  OpenWrt