summaryrefslogtreecommitdiff
path: root/src/ipc.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/ipc.c')
-rw-r--r--src/ipc.c94
1 files changed, 94 insertions, 0 deletions
diff --git a/src/ipc.c b/src/ipc.c
new file mode 100644
index 0000000..4cc38dc
--- /dev/null
+++ b/src/ipc.c
@@ -0,0 +1,94 @@
+/* ipc.c
+
+Copyright (C) 1999-2003 Tom Gilbert.
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to
+deal in the Software without restriction, including without limitation the
+rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
+sell copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies of the Software and its documentation and acknowledgment shall be
+given in the documentation and software packages that this Software was
+used.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
+THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER
+IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
+CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+*/
+
+#include "feh.h"
+#include "debug.h"
+#include "options.h"
+
+static int session_id = 0;
+static char *socket_name;
+static int socket_fd = 0;
+
+int feh_ipc_create_socket(void) {
+ struct sockaddr_un saddr;
+ int i;
+
+ if ((socket_fd = socket(AF_UNIX, SOCK_STREAM, 0)) != -1) {
+ for (i = 0; ; i++) {
+ saddr.sun_family = AF_UNIX;
+ snprintf(saddr.sun_path, 108, "%s/feh_%s.%d", feh_get_tmp_dir(), feh_get_user_name(), i);
+/*
+ if (!feh_remote_is_running(i)) {
+ if ((unlink(saddr.sun_path) == -1) && errno != ENOENT) {
+ close(socket_fd);
+ eprintf("feh_ipc_create_socket: failed to unlink %s:", saddr.sun_path);
+ }
+ } else {
+ continue;
+ }
+*/
+ if (bind(socket_fd, (struct sockaddr *) &saddr, sizeof(saddr)) != -1) {
+ session_id = i;
+ socket_name = estrdup(saddr.sun_path);
+ listen(socket_fd, 50);
+ break;
+ } else {
+ close(socket_fd);
+ eprintf("feh_ipc_create_socket: failed to bind %s to a socket:", saddr.sun_path);
+ }
+ }
+ } else {
+ eprintf("feh_ipc_create_socket: failed to open socket:");
+ }
+}
+
+int feh_ipc_get_session_id(void) {
+ return session_id;
+}
+
+void feh_ipc_cleanup(void) {
+ close(socket_fd);
+ unlink(socket_name);
+ free(socket_name);
+}
+
+static void feh_ipc_write_packet(int fd, void *data, int length) {
+ feh_ipc_server_header header;
+ header.version = FEH_IPC_VERSION;
+ header.data_length = length;
+ if (data && length > 0) {
+ write(fd, data, length);
+ }
+}
+
+static void feh_ipc_write_int(int fd, int val) {
+ feh_ipc_write_packet(fd, &val, sizeof(int));
+}
+
+static void feh_ipc_write_string(int fd, char *string) {
+ feh_ipc_write_packet(fd, &string, string ? strlen(string) + 1 : 0);
+}
+
+