7 #include <event2/bufferevent.h>
8 #include <event2/buffer.h>
9 #include <event2/listener.h>
10 #include <event2/util.h>
11 #include <event2/event.h>
12 #include <sys/socket.h>
16 #define MAX_LINE 16384
18 static const char MESSAGE[] = "Hello, World!\n";
20 static const char PATH[] = "./roura";
22 static void listener_cb(evutil_socket_t, short, void *);
23 static void conn_read_cb(struct bufferevent *, void *);
24 static void conn_write_cb(struct bufferevent *, void *);
25 static void conn_event_cb(struct bufferevent *, short, void *);
26 static void signal_cb(evutil_socket_t, short, void *);
27 static void print_socket_info(int);
29 int main(int argc, char **argv) {
30 struct event_base *base;
31 evutil_socket_t listener;
32 struct event *listener_event;
33 struct event *signal_event;
35 struct sockaddr_un sun;
37 setvbuf(stdout, NULL, _IONBF, 0);
39 base = event_base_new();
41 fprintf(stderr, "Could not initialize libevent!\n");
45 memset(&sun, 0, sizeof (sun));
46 sun.sun_family = AF_UNIX;
47 strcpy(sun.sun_path, PATH);
49 listener = socket(AF_UNIX, SOCK_STREAM, 0);
50 evutil_make_socket_nonblocking(listener);
52 if (bind(listener, (struct sockaddr*) &sun, sizeof (sun)) < 0) {
53 fprintf(stderr, "Could not create domain socket: %s!\n", PATH);
57 if (listen(listener, 16) < 0) {
58 fprintf(stderr, "Could not listen\n");
62 listener_event = event_new(base, listener, EV_READ | EV_PERSIST, listener_cb, (void*) base);
64 if (!listener_event) {
65 fprintf(stderr, "Could not do event_new\n");
69 event_add(listener_event, NULL);
71 signal_event = evsignal_new(base, SIGINT, signal_cb, (void *) base);
73 if (!signal_event || event_add(signal_event, NULL) < 0) {
74 fprintf(stderr, "Could not create/add a signal event!\n");
78 event_base_dispatch(base);
80 event_free(listener_event);
81 event_free(signal_event);
82 event_base_free(base);
84 // smažeme soket na disku / soubor -- jinak by program příště spadl na bind()
91 static void listener_cb(evutil_socket_t listener, short event, void *user_data) {
92 struct event_base *base = (event_base *) user_data;
93 struct bufferevent *bev;
95 struct sockaddr_storage ss;
96 socklen_t slen = sizeof (ss);
97 int fd = accept(listener, (struct sockaddr*) &ss, &slen);
99 fprintf(stderr, "Unable to accept(): %d", fd);
101 } else if (fd > FD_SETSIZE) {
102 // FD_SETSIZE = 1024 -- Proč? Co když bude spojení víc?
107 evutil_make_socket_nonblocking(fd);
109 print_socket_info(fd);
111 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
113 fprintf(stderr, "Error constructing bufferevent!");
114 event_base_loopbreak(base);
117 bufferevent_setcb(bev, conn_read_cb, conn_write_cb, conn_event_cb, (void*) "TODO: tady bude informace o spojení");
118 bufferevent_setwatermark(bev, EV_READ, 0, MAX_LINE);
119 bufferevent_enable(bev, EV_READ | EV_WRITE);
121 printf("někdo se k nám připojil! / %p\n", bev);
123 bufferevent_write(bev, MESSAGE, strlen(MESSAGE));
126 static void conn_read_cb(struct bufferevent *bev, void *user_data) {
127 printf("conn_read_cb: user_data = '%s'\n", (char*) user_data);
129 /* This callback is invoked when there is data to read on bev. */
130 struct evbuffer *input = bufferevent_get_input(bev);
131 struct evbuffer *output = bufferevent_get_output(bev);
132 struct event_base *base = bufferevent_get_base(bev);
134 size_t len = evbuffer_get_length(input);
135 char *data = (char*) malloc(len);
136 evbuffer_copyout(input, data, len);
137 printf("we got some data: %s\n", data);
139 if (memcmp(data, "exit\n", len) == 0) {
140 struct timeval delay = {2, 123};
141 printf("Klient říká, že máme končit; ukončuji program během %ld sekund a %ld mikrosekund.\n", delay.tv_sec, delay.tv_usec);
142 event_base_loopexit(base, &delay);
145 evbuffer_add(output, "echo: ", 6);
146 /* Copy all the data from the input buffer to the output buffer. */
147 evbuffer_add_buffer(output, input);
151 static void conn_write_cb(struct bufferevent *bev, void *user_data) {
152 printf("conn_write_cb: user_data = '%s'\n", (char*) user_data);
154 struct evbuffer *output = bufferevent_get_output(bev);
155 if (evbuffer_get_length(output) == 0) {
156 printf("flushed answer / %p\n", bev);
157 /* nebudeme ukončovat spojení
158 bufferevent_free(bev);
163 static void conn_event_cb(struct bufferevent *bev, short events, void *user_data) {
164 printf("conn_event_cb: user_data = '%s'\n", (char*) user_data);
166 if (events & BEV_EVENT_EOF) {
167 printf("Connection closed.\n");
168 } else if (events & BEV_EVENT_ERROR) {
169 printf("Got an error on the connection: %s\n", strerror(errno));
172 // None of the other events can happen here, since we haven't enabled timeouts
173 bufferevent_free(bev);
176 static void signal_cb(evutil_socket_t sig, short events, void *user_data) {
177 struct event_base *base = (event_base *) user_data;
178 struct timeval delay = {2, 123};
180 printf("Zachycen SIGINT (Ctrl+C); ukončuji program během %ld sekund a %ld mikrosekund.\n", delay.tv_sec, delay.tv_usec);
182 event_base_loopexit(base, &delay);
185 static void print_socket_info(int fd) {
187 unsigned int cl = sizeof (cr);
189 if (getsockopt(fd, SOL_SOCKET, SO_PEERCRED, &cr, &cl) == 0) {
190 printf("připojený klient: pid=%d, uid=%d, gid=%d\n", cr.pid, cr.uid, cr.gid);