X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=server.c;h=99482d9d17f36ab0cfdd1e86e29ca1a641e6cf28;hp=4f346e0c19d0dba2fad7d59719f3cd7c854a89be;hb=9163a0f2c295ef0b16ed09c46dffaec75478bb6a;hpb=806fcbb5a8c00d6b8c1a228b9b4d6b6758f613ca diff --git a/server.c b/server.c index 4f346e0c..99482d9d 100644 --- a/server.c +++ b/server.c @@ -205,7 +205,7 @@ static void shm_init(void) mmd->sender_cmd_data.cmd_num = -1; return; err_out: - PARA_EMERG_LOG("%s", para_strerror(-ret)); + PARA_EMERG_LOG("%s\n", para_strerror(-ret)); exit(EXIT_FAILURE); } @@ -257,18 +257,13 @@ static void parse_config(int override) struct server_cmdline_parser_params params = { .override = override, .initialize = 0, - .check_required = 0, - .check_ambiguity = 0 + .check_required = 1, + .check_ambiguity = 0, + .print_errors = 1 }; server_cmdline_parser_config_file(cf, &conf, ¶ms); conf.daemon_given = tmp; } - /* logfile */ - if (!conf.logfile_given && conf.daemon_given) { - ret = -1; - PARA_EMERG_LOG("fatal: daemon option, but no log file given\n"); - goto out; - } if (conf.logfile_given) logfile = open_log(conf.logfile_arg); ret = 1; @@ -385,10 +380,16 @@ static unsigned server_init(int argc, char **argv) { /* connector's address information */ int sockfd; - + struct server_cmdline_parser_params params = { + .override = 0, + .initialize = 1, + .check_required = 0, + .check_ambiguity = 0, + .print_errors = 1 + }; init_random_seed(); /* parse command line options */ - server_cmdline_parser(argc, argv, &conf); + server_cmdline_parser_ext(argc, argv, &conf, ¶ms); HANDLE_VERSION_FLAG("server", conf); para_drop_privileges(conf.user_arg, conf.group_arg); /* parse config file, open log and set defaults */ @@ -483,23 +484,12 @@ repeat: para_fd_set(signal_pipe, &rfds, &max_fileno); timeout = vss_preselect(&rfds, &wfds, &max_fileno); status_refresh(); - for (i = 0; senders[i].name; i++) { - if (!senders[i].pre_select) - continue; - senders[i].pre_select(&max_fileno, &rfds, &wfds); - } mmd_unlock(); ret = para_select(max_fileno + 1, &rfds, &wfds, timeout); mmd_lock(); - vss_post_select(&rfds, &wfds); if (ret < 0) goto repeat; - for (i = 0; senders[i].name; i++) { - if (!senders[i].post_select) - continue; - senders[i].post_select(&rfds, &wfds); - } - vss_send_chunk(); + vss_post_select(&rfds, &wfds); status_refresh(); if (FD_ISSET(signal_pipe, &rfds)) { int sig;