X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=libustcomm%2Fustcomm.h;h=995295810a5fc80ee4f8fcd1cae87618ed821a03;hb=1031eea2a5a72a647577fa131e0e83f7644d7be7;hp=ed8470f773e92cb93b2018166ce4b0392b360b49;hpb=10f2b72421cdb8844440ddc49a836fb73ce1b495;p=ust.git diff --git a/libustcomm/ustcomm.h b/libustcomm/ustcomm.h index ed8470f..9952958 100644 --- a/libustcomm/ustcomm.h +++ b/libustcomm/ustcomm.h @@ -25,9 +25,12 @@ #include #define SOCK_DIR "/tmp/ust-app-socks" +#define USER_TMP_DIR "/tmp" +#define USER_SOCK_DIR_BASE "ust-socks-" +#define USER_SOCK_DIR USER_TMP_DIR "/" USER_SOCK_DIR_BASE struct ustcomm_sock { - struct list_head list; + struct cds_list_head list; int fd; int epoll_fd; }; @@ -78,12 +81,13 @@ enum tracectl_commands { STOP_TRACE, }; -struct ustcomm_trace_info { - char *trace; +struct ustcomm_single_field { + char *field; char data[USTCOMM_DATA_SIZE]; }; struct ustcomm_channel_info { + char *trace; char *channel; unsigned int subbuf_size; unsigned int subbuf_num; @@ -91,6 +95,7 @@ struct ustcomm_channel_info { }; struct ustcomm_buffer_info { + char *trace; char *channel; int ch_cpu; pid_t pid; @@ -101,16 +106,12 @@ struct ustcomm_buffer_info { }; struct ustcomm_marker_info { + char *trace; char *channel; char *marker; char data[USTCOMM_DATA_SIZE]; }; -struct ustcomm_sock_path { - char *sock_path; - char data[USTCOMM_DATA_SIZE]; -}; - struct ustcomm_pidunique { s64 pidunique; }; @@ -120,11 +121,11 @@ struct ustcomm_notify_buf_mapped { }; /* Ensure directory existence, usefull for unix sockets */ -extern int ensure_dir_exists(const char *dir); +extern int ensure_dir_exists(const char *dir, mode_t mode); /* Create and delete sockets */ extern struct ustcomm_sock * ustcomm_init_sock(int fd, int epoll_fd, - struct list_head *list); + struct cds_list_head *list); extern void ustcomm_del_sock(struct ustcomm_sock *sock, int keep_in_epoll); /* Create and delete named sockets */ @@ -158,6 +159,9 @@ extern int ustcomm_req(int sock, char *res_data); extern int ustcomm_request_consumer(pid_t pid, const char *channel); + +/* Returns the current users socket directory, must be freed */ +extern char *ustcomm_user_sock_dir(void); extern int ustcomm_connect_app(pid_t pid, int *app_fd); extern int ustcomm_connect_path(const char *path, int *connection_fd); @@ -177,20 +181,22 @@ extern char * ustcomm_restore_ptr(char *ptr, char *data_field, (size_t) (long)(struct_ptr)->data - (long)(struct_ptr) + (offset) /* Packing and unpacking functions, making life easier */ -extern int ustcomm_pack_trace_info(struct ustcomm_header *header, - struct ustcomm_trace_info *trace_inf, +extern int ustcomm_pack_single_field(struct ustcomm_header *header, + struct ustcomm_single_field *sf, const char *trace); -extern int ustcomm_unpack_trace_info(struct ustcomm_trace_info *trace_inf); +extern int ustcomm_unpack_single_field(struct ustcomm_single_field *sf); extern int ustcomm_pack_channel_info(struct ustcomm_header *header, struct ustcomm_channel_info *ch_inf, + const char *trace, const char *channel); extern int ustcomm_unpack_channel_info(struct ustcomm_channel_info *ch_inf); extern int ustcomm_pack_buffer_info(struct ustcomm_header *header, struct ustcomm_buffer_info *buf_inf, + const char *trace, const char *channel, int channel_cpu); @@ -198,16 +204,10 @@ extern int ustcomm_unpack_buffer_info(struct ustcomm_buffer_info *buf_inf); extern int ustcomm_pack_marker_info(struct ustcomm_header *header, struct ustcomm_marker_info *marker_inf, + const char *trace, const char *channel, const char *marker); extern int ustcomm_unpack_marker_info(struct ustcomm_marker_info *marker_inf); - -extern int ustcomm_pack_sock_path(struct ustcomm_header *header, - struct ustcomm_sock_path *sock_path_inf, - const char *socket_path); - -extern int ustcomm_unpack_sock_path(struct ustcomm_sock_path *sock_path_inf); - #endif /* USTCOMM_H */