summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
authorFelix Fietkau <nbd@openwrt.org>2013-09-24 10:47:47 +0200
committerFelix Fietkau <nbd@openwrt.org>2013-10-22 14:10:33 +0200
commitf16a15c39c872c5f42eb554deb4d956264c0c823 (patch)
tree86227c8d61416ef5847d093a887ee9a7d3d383f9
parente9f8c9c537c3f8fec3edbe2896bad2cc8647c487 (diff)
proto-shell: move script handler dump code to handler.c
Signed-off-by: Felix Fietkau <nbd@openwrt.org>
-rw-r--r--CMakeLists.txt2
-rw-r--r--handler.c119
-rw-r--r--handler.h24
-rw-r--r--proto-shell.c104
4 files changed, 145 insertions, 104 deletions
diff --git a/CMakeLists.txt b/CMakeLists.txt
index 777a8e8..632d1b9 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -11,7 +11,7 @@ IF(APPLE)
ENDIF()
SET(SOURCES
- main.c utils.c system.c tunnel.c
+ main.c utils.c system.c tunnel.c handler.c
interface.c interface-ip.c interface-event.c
iprule.c proto.c proto-static.c proto-shell.c
config.c device.c bridge.c vlan.c alias.c
diff --git a/handler.c b/handler.c
new file mode 100644
index 0000000..4d0a57a
--- /dev/null
+++ b/handler.c
@@ -0,0 +1,119 @@
+/*
+ * netifd - network interface daemon
+ * Copyright (C) 2012-2013 Felix Fietkau <nbd@openwrt.org>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2
+ * as published by the Free Software Foundation
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ */
+
+#define _GNU_SOURCE
+#include <glob.h>
+#include <fcntl.h>
+#include <stdio.h>
+#include <unistd.h>
+
+#include "netifd.h"
+#include "system.h"
+#include "handler.h"
+
+static int
+netifd_dir_push(int fd)
+{
+ int prev_fd = open(".", O_RDONLY | O_DIRECTORY);
+ system_fd_set_cloexec(prev_fd);
+ if (fd >= 0)
+ fchdir(fd);
+ return prev_fd;
+}
+
+static void
+netifd_dir_pop(int prev_fd)
+{
+ fchdir(prev_fd);
+ close(prev_fd);
+}
+
+int netifd_open_subdir(const char *name)
+{
+ int prev_dir;
+ int ret = -1;
+
+ prev_dir = netifd_dir_push(-1);
+ if (chdir(main_path)) {
+ perror("chdir(main path)");
+ goto out;
+ }
+
+ ret = open(name, O_RDONLY | O_DIRECTORY);
+ if (ret >= 0)
+ system_fd_set_cloexec(ret);
+
+out:
+ netifd_dir_pop(prev_dir);
+ return ret;
+}
+
+static void
+netifd_init_script_handler(const char *name, script_dump_cb cb)
+{
+ struct json_tokener *tok = NULL;
+ json_object *obj;
+ static char buf[512];
+ char *start, *cmd;
+ FILE *f;
+ int len;
+
+#define DUMP_SUFFIX " '' dump"
+
+ cmd = alloca(strlen(name) + 1 + sizeof(DUMP_SUFFIX));
+ sprintf(cmd, "%s" DUMP_SUFFIX, name);
+
+ f = popen(cmd, "r");
+ if (!f)
+ return;
+
+ do {
+ start = fgets(buf, sizeof(buf), f);
+ if (!start)
+ continue;
+
+ len = strlen(start);
+
+ if (!tok)
+ tok = json_tokener_new();
+
+ obj = json_tokener_parse_ex(tok, start, len);
+ if (!is_error(obj)) {
+ cb(name, obj);
+ json_object_put(obj);
+ json_tokener_free(tok);
+ tok = NULL;
+ } else if (start[len - 1] == '\n') {
+ json_tokener_free(tok);
+ tok = NULL;
+ }
+ } while (!feof(f) && !ferror(f));
+
+ if (tok)
+ json_tokener_free(tok);
+
+ pclose(f);
+}
+
+void netifd_init_script_handlers(int dir_fd, script_dump_cb cb)
+{
+ glob_t g;
+ int i, prev_fd;
+
+ prev_fd = netifd_dir_push(dir_fd);
+ glob("./*.sh", 0, NULL, &g);
+ for (i = 0; i < g.gl_pathc; i++)
+ netifd_init_script_handler(g.gl_pathv[i], cb);
+ netifd_dir_pop(prev_fd);
+}
diff --git a/handler.h b/handler.h
new file mode 100644
index 0000000..02438f2
--- /dev/null
+++ b/handler.h
@@ -0,0 +1,24 @@
+/*
+ * netifd - network interface daemon
+ * Copyright (C) 2012-2013 Felix Fietkau <nbd@openwrt.org>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2
+ * as published by the Free Software Foundation
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
+ */
+#ifndef __NETIFD_HANDLER_H
+#define __NETIFD_HANDLER_H
+
+#include <libubox/blobmsg_json.h>
+
+typedef void (*script_dump_cb)(const char *name, json_object *obj);
+
+int netifd_open_subdir(const char *name);
+void netifd_init_script_handlers(int dir_fd, script_dump_cb cb);
+
+#endif
diff --git a/proto-shell.c b/proto-shell.c
index 9c242e7..6ac8dab 100644
--- a/proto-shell.c
+++ b/proto-shell.c
@@ -16,21 +16,19 @@
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
-#include <glob.h>
#include <unistd.h>
-#include <fcntl.h>
#include <signal.h>
#include <arpa/inet.h>
#include <netinet/in.h>
-#include <libubox/blobmsg_json.h>
#include "netifd.h"
#include "interface.h"
#include "interface-ip.h"
#include "proto.h"
#include "system.h"
+#include "handler.h"
static int proto_fd = -1;
@@ -858,106 +856,6 @@ proto_shell_add_handler(const char *script, json_object *obj)
add_proto_handler(proto);
}
-typedef void (*script_dump_cb)(const char *name, json_object *obj);
-
-static int
-netifd_dir_push(int fd)
-{
- int prev_fd = open(".", O_RDONLY | O_DIRECTORY);
- system_fd_set_cloexec(prev_fd);
- if (fd >= 0)
- fchdir(fd);
- return prev_fd;
-}
-
-static void
-netifd_dir_pop(int prev_fd)
-{
- fchdir(prev_fd);
- close(prev_fd);
-}
-
-static int
-netifd_open_subdir(const char *name)
-{
- int prev_dir;
- int ret = -1;
-
- prev_dir = netifd_dir_push(-1);
- if (chdir(main_path)) {
- perror("chdir(main path)");
- goto out;
- }
-
- ret = open(name, O_RDONLY | O_DIRECTORY);
- if (ret >= 0)
- system_fd_set_cloexec(ret);
-
-out:
- netifd_dir_pop(prev_dir);
- return ret;
-}
-
-static void
-netifd_init_script_handler(const char *name, script_dump_cb cb)
-{
- struct json_tokener *tok = NULL;
- json_object *obj;
- static char buf[512];
- char *start, *cmd;
- FILE *f;
- int len;
-
-#define DUMP_SUFFIX " '' dump"
-
- cmd = alloca(strlen(name) + 1 + sizeof(DUMP_SUFFIX));
- sprintf(cmd, "%s" DUMP_SUFFIX, name);
-
- f = popen(cmd, "r");
- if (!f)
- return;
-
- do {
- start = fgets(buf, sizeof(buf), f);
- if (!start)
- continue;
-
- len = strlen(start);
-
- if (!tok)
- tok = json_tokener_new();
-
- obj = json_tokener_parse_ex(tok, start, len);
- if (!is_error(obj)) {
- cb(name, obj);
- json_object_put(obj);
- json_tokener_free(tok);
- tok = NULL;
- } else if (start[len - 1] == '\n') {
- json_tokener_free(tok);
- tok = NULL;
- }
- } while (!feof(f) && !ferror(f));
-
- if (tok)
- json_tokener_free(tok);
-
- pclose(f);
-}
-
-static void
-netifd_init_script_handlers(int dir_fd, script_dump_cb cb)
-{
- glob_t g;
- int i, prev_fd;
-
- prev_fd = netifd_dir_push(dir_fd);
- glob("./*.sh", 0, NULL, &g);
- for (i = 0; i < g.gl_pathc; i++)
- netifd_init_script_handler(g.gl_pathv[i], cb);
- netifd_dir_pop(prev_fd);
-}
-
static void __init proto_shell_init(void)
{
proto_fd = netifd_open_subdir("proto");