source: unix.c @ fa8f57b

Last change on this file since fa8f57b was c467adc, checked in by dequis <dx@…>, at 2015-11-03T11:43:04Z

sighandler_crash: Mark irc socket as blocking before writing

Just to ensure the whole thing gets written, since this can't be async
for obvious reasons.

  • Property mode set to 100644
File size: 8.9 KB
RevLine 
[5ebff60]1/********************************************************************\
[b7d3cc34]2  * BitlBee -- An IRC to other IM-networks gateway                     *
3  *                                                                    *
[0e788f5]4  * Copyright 2002-2012 Wilmer van der Gaast and others                *
[b7d3cc34]5  \********************************************************************/
6
7/* Main file (Unix specific part)                                       */
8
9/*
10  This program is free software; you can redistribute it and/or modify
11  it under the terms of the GNU General Public License as published by
12  the Free Software Foundation; either version 2 of the License, or
13  (at your option) any later version.
14
15  This program is distributed in the hope that it will be useful,
16  but WITHOUT ANY WARRANTY; without even the implied warranty of
17  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  GNU General Public License for more details.
19
20  You should have received a copy of the GNU General Public License with
21  the Debian GNU/Linux distribution in /usr/share/common-licenses/GPL;
[6f10697]22  if not, write to the Free Software Foundation, Inc., 51 Franklin St.,
23  Fifth Floor, Boston, MA  02110-1301  USA
[b7d3cc34]24*/
25
26#include "bitlbee.h"
[7c9db24]27
28#include "arc.h"
29#include "base64.h"
[b7d3cc34]30#include "commands.h"
31#include "protocols/nogaim.h"
32#include "help.h"
[54879ab]33#include "ipc.h"
[7c9db24]34#include "md5.h"
35#include "misc.h"
[b7d3cc34]36#include <signal.h>
37#include <unistd.h>
38#include <sys/time.h>
[d25f6fc]39#include <sys/wait.h>
[aaf92a9]40#include <pwd.h>
[badd148]41#include <locale.h>
[ad46e4d]42#include <grp.h>
[b7d3cc34]43
[d150a9d]44#if defined(OTR_BI) || defined(OTR_PI)
45#include "otr.h"
46#endif
47
[5ebff60]48global_t global;        /* Against global namespace pollution */
[b7d3cc34]49
[2e99039]50static struct {
51        int fd[2];
52        int tag;
53} shutdown_pipe = {{-1 , -1}, 0};
54
[5ebff60]55static void sighandler_shutdown(int signal);
56static void sighandler_crash(int signal);
[b7d3cc34]57
[5ebff60]58static int crypt_main(int argc, char *argv[]);
[7c9db24]59
[5ebff60]60int main(int argc, char *argv[])
[b7d3cc34]61{
62        int i = 0;
[58bc4e6]63        char *old_cwd = NULL;
[b7d3cc34]64        struct sigaction sig, old;
[5ebff60]65
[badd148]66        /* Required to make iconv to ASCII//TRANSLIT work. This makes BitlBee
67           system-locale-sensitive. :-( */
[5ebff60]68        setlocale(LC_CTYPE, "");
69
70        if (argc > 1 && strcmp(argv[1], "-x") == 0) {
71                return crypt_main(argc, argv);
72        }
73
[d25f6fc]74        log_init();
[5ebff60]75
76        global.conf_file = g_strdup(CONF_FILE_DEF);
77        global.conf = conf_load(argc, argv);
78        if (global.conf == NULL) {
79                return(1);
80        }
81
[60c1a4e]82        b_main_init();
[5ebff60]83
[3fc6c32]84        /* libpurple doesn't like fork()s after initializing itself, so if
85           we use it, do this init a little later (in case we're running in
86           ForkDaemon mode). */
87#ifndef WITH_PURPLE
88        nogaim_init();
89#endif
[5ebff60]90
[858ea01]91#ifdef OTR_BI
[5ebff60]92        otr_init();
[858ea01]93#endif
[5ebff60]94
95        global.helpfile = g_strdup(HELP_FILE);
96        if (help_init(&global.help, global.helpfile) == NULL) {
97                log_message(LOGLVL_WARNING, "Error opening helpfile %s.", HELP_FILE);
[5674207]98        }
[b7d3cc34]99
[5ebff60]100        global.storage = storage_init(global.conf->primary_storage, global.conf->migrate_storage);
101        if (global.storage == NULL) {
102                log_message(LOGLVL_ERROR, "Unable to load storage backend '%s'", global.conf->primary_storage);
103                return(1);
[b7d3cc34]104        }
[5ebff60]105
106        if (global.conf->runmode == RUNMODE_INETD) {
107                log_link(LOGLVL_ERROR, LOGOUTPUT_IRC);
108                log_link(LOGLVL_WARNING, LOGOUTPUT_IRC);
109
110                i = bitlbee_inetd_init();
111                log_message(LOGLVL_INFO, "%s %s starting in inetd mode.", PACKAGE, BITLBEE_VERSION);
112
113        } else if (global.conf->runmode == RUNMODE_DAEMON) {
114                log_link(LOGLVL_ERROR, LOGOUTPUT_CONSOLE);
115                log_link(LOGLVL_WARNING, LOGOUTPUT_CONSOLE);
[99318ad]116
[b7d3cc34]117                i = bitlbee_daemon_init();
[5ebff60]118                log_message(LOGLVL_INFO, "%s %s starting in daemon mode.", PACKAGE, BITLBEE_VERSION);
119        } else if (global.conf->runmode == RUNMODE_FORKDAEMON) {
120                log_link(LOGLVL_ERROR, LOGOUTPUT_CONSOLE);
121                log_link(LOGLVL_WARNING, LOGOUTPUT_CONSOLE);
[156bbd7]122
[54879ab]123                /* In case the operator requests a restart, we need this. */
[5ebff60]124                old_cwd = g_malloc(256);
125                if (getcwd(old_cwd, 255) == NULL) {
126                        log_message(LOGLVL_WARNING, "Could not save current directory: %s", strerror(errno));
127                        g_free(old_cwd);
[54879ab]128                        old_cwd = NULL;
129                }
[5ebff60]130
[d25f6fc]131                i = bitlbee_daemon_init();
[5ebff60]132                log_message(LOGLVL_INFO, "%s %s starting in forking daemon mode.", PACKAGE, BITLBEE_VERSION);
133        }
134        if (i != 0) {
135                return(i);
[d25f6fc]136        }
[5ebff60]137
138        if ((global.conf->user && *global.conf->user) &&
139            (global.conf->runmode == RUNMODE_DAEMON ||
140             global.conf->runmode == RUNMODE_FORKDAEMON) &&
141            (!getuid() || !geteuid())) {
[aaf92a9]142                struct passwd *pw = NULL;
[5ebff60]143                pw = getpwnam(global.conf->user);
144                if (pw) {
145                        initgroups(global.conf->user, pw->pw_gid);
146                        setgid(pw->pw_gid);
147                        setuid(pw->pw_uid);
148                } else {
149                        log_message(LOGLVL_WARNING, "Failed to look up user %s.", global.conf->user);
[ad46e4d]150                }
[aaf92a9]151        }
[5ebff60]152
[b7d3cc34]153        /* Catch some signals to tell the user what's happening before quitting */
[5ebff60]154        memset(&sig, 0, sizeof(sig));
[7233f68]155        sig.sa_handler = SIG_IGN;
[5ebff60]156        sigaction(SIGCHLD, &sig, &old);
157        sigaction(SIGPIPE, &sig, &old);
[b7d3cc34]158        sig.sa_flags = SA_RESETHAND;
[7233f68]159        sig.sa_handler = sighandler_crash;
[5ebff60]160        sigaction(SIGSEGV, &sig, &old);
[7233f68]161
[2e99039]162        sighandler_shutdown_setup();
163
164        sig.sa_handler = sighandler_shutdown;
165        sigaction(SIGINT, &sig, &old);
166        sigaction(SIGTERM, &sig, &old);
[5ebff60]167
168        if (!getuid() || !geteuid()) {
169                log_message(LOGLVL_WARNING, "BitlBee is running with root privileges. Why?");
170        }
171
[ba9edaa]172        b_main_run();
[5ebff60]173
[0fbda193]174        /* Mainly good for restarting, to make sure we close the help.txt fd. */
[5ebff60]175        help_free(&global.help);
176
177        if (global.restart) {
[54879ab]178                char *fn = ipc_master_save_state();
[daae10f]179                char *env;
[5ebff60]180
181                env = g_strdup_printf("_BITLBEE_RESTART_STATE=%s", fn);
182                putenv(env);
183                g_free(fn);
[daae10f]184                /* Looks like env should *not* be freed here as putenv
185                   doesn't make a copy. Odd. */
[5ebff60]186
187                i = chdir(old_cwd);
188                close(global.listen_socket);
189
190                if (execv(argv[0], argv) == -1) {
[cd63d58]191                        /* Apparently the execve() failed, so let's just
192                           jump back into our own/current main(). */
193                        /* Need more cleanup code to make this work. */
194                        return 1; /* main( argc, argv ); */
[5ebff60]195                }
[54879ab]196        }
[5ebff60]197
198        return(0);
[b7d3cc34]199}
200
[5ebff60]201static int crypt_main(int argc, char *argv[])
[7c9db24]202{
203        int pass_len;
204        unsigned char *pass_cr, *pass_cl;
[5ebff60]205
206        if (argc < 4 || (strcmp(argv[2], "hash") != 0 &&
207                         strcmp(argv[2], "unhash") != 0 && argc < 5)) {
208                printf("Supported:\n"
209                       "  %s -x enc <key> <cleartext password>\n"
210                       "  %s -x dec <key> <encrypted password>\n"
211                       "  %s -x hash <cleartext password>\n"
212                       "  %s -x unhash <hashed password>\n"
213                       "  %s -x chkhash <hashed password> <cleartext password>\n",
214                       argv[0], argv[0], argv[0], argv[0], argv[0]);
215        } else if (strcmp(argv[2], "enc") == 0) {
[5535a47]216                char *encoded;
217
218                pass_len = arc_encode(argv[4], strlen(argv[4]), &pass_cr, argv[3], 12);
219
220                encoded = base64_encode(pass_cr, pass_len);
221                printf("%s\n", encoded);
222                g_free(encoded);
223                g_free(pass_cr);
[5ebff60]224        } else if (strcmp(argv[2], "dec") == 0) {
[5535a47]225                pass_len = base64_decode(argv[4], &pass_cr);
[5ebff60]226                arc_decode(pass_cr, pass_len, (char **) &pass_cl, argv[3]);
227                printf("%s\n", pass_cl);
[5535a47]228
229                g_free(pass_cr);
230                g_free(pass_cl);
[5ebff60]231        } else if (strcmp(argv[2], "hash") == 0) {
[7c9db24]232                md5_byte_t pass_md5[21];
233                md5_state_t md5_state;
[5535a47]234                char *encoded;
[5ebff60]235
236                random_bytes(pass_md5 + 16, 5);
237                md5_init(&md5_state);
238                md5_append(&md5_state, (md5_byte_t *) argv[3], strlen(argv[3]));
239                md5_append(&md5_state, pass_md5 + 16, 5);   /* Add the salt. */
240                md5_finish(&md5_state, pass_md5);
241
[5535a47]242                encoded = base64_encode(pass_md5, 21);
243                printf("%s\n", encoded);
244                g_free(encoded);
[5ebff60]245        } else if (strcmp(argv[2], "unhash") == 0) {
246                printf("Hash %s submitted to a massive Beowulf cluster of\n"
247                       "overclocked 486s. Expect your answer next year somewhere around this time. :-)\n", argv[3]);
248        } else if (strcmp(argv[2], "chkhash") == 0) {
249                char *hash = strncmp(argv[3], "md5:", 4) == 0 ? argv[3] + 4 : argv[3];
250                int st = md5_verify_password(argv[4], hash);
251
252                printf("Hash %s given password.\n", st == 0 ? "matches" : "does not match");
253
[7c9db24]254                return st;
255        }
[5ebff60]256
[7c9db24]257        return 0;
258}
259
[2e99039]260/* Set up a pipe for SIGTERM/SIGINT so the actual signal handler doesn't do anything unsafe */
261void sighandler_shutdown_setup()
262{
263        if (shutdown_pipe.fd[0] != -1) {
264                /* called again from a forked process, clean up to avoid propagating the signal */
265                b_event_remove(shutdown_pipe.tag);
266                close(shutdown_pipe.fd[0]);
267                close(shutdown_pipe.fd[1]);
268        }
269
270        if (pipe(shutdown_pipe.fd) == 0) {
271                shutdown_pipe.tag = b_input_add(shutdown_pipe.fd[0], B_EV_IO_READ, bitlbee_shutdown, NULL);
272        }
273}
274
[7233f68]275/* Signal handler for SIGTERM and SIGINT */
[5ebff60]276static void sighandler_shutdown(int signal)
[b7d3cc34]277{
[7233f68]278        /* Write a single null byte to the pipe, just to send a message to the main loop.
279         * This gets handled by bitlbee_shutdown (the b_input_add callback for this pipe) */
[2e99039]280        write(shutdown_pipe.fd[1], "", 1);
[7233f68]281}
282
283/* Signal handler for SIGSEGV
284 * A desperate attempt to tell the user that everything is wrong in the world.
285 * Avoids using irc_abort() because it has several unsafe calls to malloc */
[5ebff60]286static void sighandler_crash(int signal)
[7233f68]287{
288        GSList *l;
289        const char *message = "ERROR :BitlBee crashed! (SIGSEGV received)\r\n";
290        int len = strlen(message);
291
[5ebff60]292        for (l = irc_connection_list; l; l = l->next) {
[7233f68]293                irc_t *irc = l->data;
[c467adc]294                sock_make_blocking(irc->fd);
[5ebff60]295                write(irc->fd, message, len);
[b7d3cc34]296        }
[7233f68]297
[5ebff60]298        raise(signal);
[b7d3cc34]299}
300
301double gettime()
302{
303        struct timeval time[1];
304
[5ebff60]305        gettimeofday(time, 0);
306        return((double) time->tv_sec + (double) time->tv_usec / 1000000);
[b7d3cc34]307}
Note: See TracBrowser for help on using the repository browser.