haiwen/seafile-server
1
0
Fork 0
mirror of https://github.com/haiwen/seafile-server.git synced 2025-08-18 14:57:47 +00:00
Code Issues Releases Wiki Activity

Support seafevents.

Browse Source
This commit is contained in:
cuihaikuo 2019-01-08 18:03:04 +08:00
parent 106ee11eea
commit 39ffb0a162
2 changed files with 64 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
controller/seafile-controller.c
View File

@ -348,6 +348,42 @@ setup_env ()
setup_python_path(); setup_python_path();
} }
static int
start_seafevents() {
if (!ctl->has_seafevents)
return 0;
static char *seafevents_config_file = NULL;
static char *seafevents_log_file = NULL;
if (seafevents_config_file == NULL)
seafevents_config_file = g_build_filename (topdir,
"conf/seafevents.conf",
NULL);
if (seafevents_log_file == NULL)
seafevents_log_file = g_build_filename (ctl->logdir,
"seafevents.log",
NULL);
char *argv[] = {
(char *)get_python_executable(),
"-m", "seafevents.main",
"--config-file", seafevents_config_file,
"--logfile", seafevents_log_file,
"-P", ctl->pidfile[PID_SEAFEVENTS],
NULL
};
int pid = spawn_process (argv);
if (pid <= 0) {
seaf_warning ("Failed to spawn seafevents.\n");
return -1;
}
return 0;
}
static int static int
start_seafdav() { start_seafdav() {
static char *seafdav_log_file = NULL; static char *seafdav_log_file = NULL;
@ -446,6 +482,11 @@ check_process (void *data)
} }
} }
if (ctl->has_seafevents && need_restart(PID_SEAFEVENTS)) {
seaf_message ("seafevents need restart...\n");
start_seafevents ();
}
return TRUE; return TRUE;
} }
@ -541,6 +582,11 @@ on_ccnet_connected ()
if (start_seaf_server () < 0) if (start_seaf_server () < 0)
controller_exit(1); controller_exit(1);
if (ctl->has_seafevents && need_restart(PID_SEAFEVENTS)) {
if (start_seafevents() < 0)
controller_exit(1);
}
if (ctl->seafdav_config.enabled) { if (ctl->seafdav_config.enabled) {
if (need_restart(PID_SEAFDAV)) { if (need_restart(PID_SEAFDAV)) {
if (start_seafdav() < 0) if (start_seafdav() < 0)
@ -592,6 +638,8 @@ stop_ccnet_server ()
kill_by_force(PID_CCNET); kill_by_force(PID_CCNET);
kill_by_force(PID_SERVER); kill_by_force(PID_SERVER);
kill_by_force(PID_SEAFDAV); kill_by_force(PID_SEAFDAV);
if (ctl->has_seafevents)
kill_by_force(PID_SEAFEVENTS);
} }
static void static void
@ -608,6 +656,7 @@ init_pidfile_path (SeafileController *ctl)
ctl->pidfile[PID_CCNET] = g_build_filename (pid_dir, "ccnet.pid", NULL); ctl->pidfile[PID_CCNET] = g_build_filename (pid_dir, "ccnet.pid", NULL);
ctl->pidfile[PID_SERVER] = g_build_filename (pid_dir, "seaf-server.pid", NULL); ctl->pidfile[PID_SERVER] = g_build_filename (pid_dir, "seaf-server.pid", NULL);
ctl->pidfile[PID_SEAFDAV] = g_build_filename (pid_dir, "seafdav.pid", NULL); ctl->pidfile[PID_SEAFDAV] = g_build_filename (pid_dir, "seafdav.pid", NULL);
ctl->pidfile[PID_SEAFEVENTS] = g_build_filename (pid_dir, "seafevents.pid", NULL);
} }
static int static int
@ -661,6 +710,18 @@ seaf_controller_init (SeafileController *ctl,
return -1; return -1;
} }
char *seafevents_config_file = g_build_filename (topdir,
"conf/seafevents.conf",
NULL);
if (!g_file_test (seafevents_config_file, G_FILE_TEST_EXISTS)) {
seaf_message ("No seafevents.\n");
ctl->has_seafevents = FALSE;
} else {
ctl->has_seafevents = TRUE;
}
g_free (seafevents_config_file);
init_pidfile_path (ctl); init_pidfile_path (ctl);
setup_env (); setup_env ();

3
controller/seafile-controller.h
View File

@ -26,6 +26,7 @@ enum {
PID_CCNET = 0, PID_CCNET = 0,
PID_SERVER, PID_SERVER,
PID_SEAFDAV, PID_SEAFDAV,
PID_SEAFEVENTS,
N_PID N_PID
}; };
@ -56,5 +57,7 @@ struct _SeafileController {
char *pidfile[N_PID]; char *pidfile[N_PID];
SeafDavConfig seafdav_config; SeafDavConfig seafdav_config;
gboolean has_seafevents;
}; };
#endif #endif