ust_fork(): close the ustcomm_app socket in the child on fork()
[ust.git] / libustcomm / ustcomm.h
CommitLineData
c39c72ee
PMF
1/* Copyright (C) 2009 Pierre-Marc Fournier
2 *
3 * This library is free software; you can redistribute it and/or
4 * modify it under the terms of the GNU Lesser General Public
5 * License as published by the Free Software Foundation; either
6 * version 2.1 of the License, or (at your option) any later version.
7 *
8 * This library 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 GNU
11 * Lesser General Public License for more details.
12 *
13 * You should have received a copy of the GNU Lesser General Public
14 * License along with this library; if not, write to the Free Software
15 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16 */
17
f9e5ce61
PMF
18#ifndef USTCOMM_H
19#define USTCOMM_H
20
21#include <sys/types.h>
b02e31e5 22#include <sys/un.h>
f9e5ce61 23
aca1ad90
PMF
24#include "kcompat.h"
25
397d8454 26#define SOCK_DIR "/tmp/ust-app-socks"
ab33e65c
PP
27#define UST_SIGNAL SIGIO
28
aca1ad90
PMF
29struct ustcomm_connection {
30 struct list_head list;
31 int fd;
5932431b
PMF
32 /* Data that has not yet been consumed: */
33 char *recv_buf;
34 int recv_buf_size;
35 int recv_buf_alloc;
aca1ad90
PMF
36};
37
3a7b90de 38/* ustcomm_server must be shallow-copyable */
811e4b93 39struct ustcomm_server {
b0540e11 40 /* the "server" socket for serving the external requests */
aca1ad90 41 int listen_fd;
d0b5f2b9 42 char *socketpath;
aca1ad90
PMF
43
44 struct list_head connections;
d0b5f2b9
PMF
45};
46
47struct ustcomm_ustd {
811e4b93
PMF
48 struct ustcomm_server server;
49};
aca1ad90 50
811e4b93
PMF
51struct ustcomm_app {
52 struct ustcomm_server server;
d0b5f2b9
PMF
53};
54
3a7b90de 55/* ustcomm_source must be shallow-copyable */
b02e31e5 56struct ustcomm_source {
811e4b93
PMF
57 int fd;
58 void *priv;
b02e31e5
PMF
59};
60
08230db7 61extern char *strdup_malloc(const char *s);
688760ef 62
3bb56863 63//int send_message_pid(pid_t pid, const char *msg, char **reply);
08230db7 64extern int ustcomm_request_consumer(pid_t pid, const char *channel);
d0b5f2b9 65
08230db7
PMF
66extern int ustcomm_ustd_recv_message(struct ustcomm_ustd *ustd, char **msg, struct ustcomm_source *src, int timeout);
67extern int ustcomm_app_recv_message(struct ustcomm_app *app, char **msg, struct ustcomm_source *src, int timeout);
3847c3ba 68
08230db7 69extern int ustcomm_init_app(pid_t pid, struct ustcomm_app *handle);
803a4f58 70extern void ustcomm_fini_app(struct ustcomm_app *handle);
393bc391 71extern void ustcomm_free_app(struct ustcomm_app *app);
d0b5f2b9 72
c97d4437 73extern int ustcomm_init_ustd(struct ustcomm_ustd *handle, const char *sock_path);
f9e5ce61 74
08230db7
PMF
75extern int ustcomm_connect_app(pid_t pid, struct ustcomm_connection *conn);
76extern int ustcomm_connect_path(const char *path, struct ustcomm_connection *conn, pid_t signalpid);
77extern int ustcomm_send_request(struct ustcomm_connection *conn, const char *req, char **reply);
78extern int ustcomm_send_reply(struct ustcomm_server *server, char *msg, struct ustcomm_source *src);
79extern int ustcomm_disconnect(struct ustcomm_connection *conn);
99b72dc0 80extern int ustcomm_close_all_connections(struct ustcomm_server *server);
3bb56863 81
7e92827d 82extern int nth_token_is(const char *str, const char *token, int tok_no);
b02e31e5 83
7e92827d 84extern char *nth_token(const char *str, int tok_no);
b02e31e5 85
08230db7 86extern int pid_is_online(pid_t);
ab33e65c 87
f9e5ce61 88#endif /* USTCOMM_H */
This page took 0.029774 seconds and 4 git commands to generate.