]> git.ipfire.org Git - thirdparty/rspamd.git/commitdiff
* Remove %m from logging it seems to be unsupported by FreeBSD printf version
authorVsevolod Stakhov <vsevolod@rambler-co.ru>
Mon, 2 Mar 2009 13:43:01 +0000 (16:43 +0300)
committerVsevolod Stakhov <vsevolod@rambler-co.ru>
Mon, 2 Mar 2009 13:43:01 +0000 (16:43 +0300)
12 files changed:
src/cfg_file.y
src/cfg_utils.c
src/controller.c
src/lmtp.c
src/lmtp_proto.c
src/main.c
src/memcached.c
src/message.c
src/plugins/surbl.c
src/statfile.c
src/util.c
src/worker.c

index 6667d01a12311165345622decc3ca1e4fad5fd55..7eee8516c68b212338774245db87418e272c0a88 100644 (file)
@@ -386,7 +386,7 @@ requirecmd:
                struct stat st;
                struct perl_module *cur;
                if (stat ($3, &st) == -1) {
-                       yyerror ("yyparse: cannot stat file %s, %m", $3);
+                       yyerror ("yyparse: cannot stat file %s, %s", $3, strerror (errno));
                        YYERROR;
                }
                cur = memory_pool_alloc (cfg->cfg_pool, sizeof (struct perl_module));
index e90fe11cb68e827e948ef4ad77e719841fb32c47..7efb9390d764c63ae14a6359d1f844d6aa7aadfa 100644 (file)
@@ -133,7 +133,7 @@ parse_bind_line (struct config_file *cf, char *str, enum rspamd_cred_type type)
                if (stat (copy, &st) == -1) {
                        if (errno == ENOENT) {
                                if ((fd = open (cur_tok, O_RDWR | O_TRUNC | O_CREAT, S_IWUSR | S_IRUSR)) == -1) {
-                                       yyerror ("parse_bind_line: cannot open path %s for making socket, %m", cur_tok);
+                                       yyerror ("parse_bind_line: cannot open path %s for making socket, %s", cur_tok, strerror (errno));
                                        return 0;
                                }
                                else {
@@ -142,13 +142,13 @@ parse_bind_line (struct config_file *cf, char *str, enum rspamd_cred_type type)
                                }
                        }
                        else {
-                               yyerror ("parse_bind_line: cannot stat path %s for making socket, %m", cur_tok);
+                               yyerror ("parse_bind_line: cannot stat path %s for making socket, %s", cur_tok, strerror (errno));
                                return 0;
                        }
                }
                else {
                        if (unlink (cur_tok) == -1) {
-                               yyerror ("parse_bind_line: cannot remove path %s for making socket, %m", cur_tok);
+                               yyerror ("parse_bind_line: cannot remove path %s for making socket, %s", cur_tok, strerror (errno));
                                return 0;
                        }
                }
index 503433d9b9dab79aaa774080c0e94d15e109671c..b02782caf38cb215c42810a13130db31313edee0 100644 (file)
@@ -486,7 +486,7 @@ accept_socket (int fd, short what, void *arg)
        
        new_session = g_malloc (sizeof (struct controller_session));
        if (new_session == NULL) {
-               msg_err ("accept_socket: cannot allocate memory for task, %m");
+               msg_err ("accept_socket: cannot allocate memory for task, %s", strerror (errno));
                return;
        }
        bzero (new_session, sizeof (struct controller_session));
@@ -528,14 +528,14 @@ start_controller (struct rspamd_worker *worker)
 
        if (worker->srv->cfg->control_family == AF_INET) {
                if ((listen_sock = make_socket (&worker->srv->cfg->control_addr, worker->srv->cfg->control_port)) == -1) {
-                       msg_err ("start_controller: cannot create tcp listen socket. %m");
+                       msg_err ("start_controller: cannot create tcp listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
        else {
                un_addr = (struct sockaddr_un *) alloca (sizeof (struct sockaddr_un));
                if (!un_addr || (listen_sock = make_unix_socket (worker->srv->cfg->control_host, un_addr)) == -1) {
-                       msg_err ("start_controller: cannot create unix listen socket. %m");
+                       msg_err ("start_controller: cannot create unix listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
@@ -543,7 +543,7 @@ start_controller (struct rspamd_worker *worker)
        start_time = time (NULL);
 
        if (listen (listen_sock, -1) == -1) {
-               msg_err ("start_controller: cannot listen on socket. %m");
+               msg_err ("start_controller: cannot listen on socket. %s", strerror (errno));
                exit(-errno);
        }
        
index fb7c8a8b05e94bb7a040a9308f7690945d2ca8b8..9503255a4794ac0ca0573389460e65915a462dc9 100644 (file)
@@ -283,20 +283,20 @@ start_lmtp_worker (struct rspamd_worker *worker)
        /* Create listen socket */
        if (worker->srv->cfg->lmtp_family == AF_INET) {
                if ((listen_sock = make_socket (&worker->srv->cfg->lmtp_addr, worker->srv->cfg->lmtp_port)) == -1) {
-                       msg_err ("start_lmtp: cannot create tcp listen socket. %m");
+                       msg_err ("start_lmtp: cannot create tcp listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
        else {
                un_addr = (struct sockaddr_un *) alloca (sizeof (struct sockaddr_un));
                if (!un_addr || (listen_sock = make_unix_socket (worker->srv->cfg->lmtp_host, un_addr)) == -1) {
-                       msg_err ("start_lmtp: cannot create unix listen socket. %m");
+                       msg_err ("start_lmtp: cannot create unix listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
        
        if (listen (listen_sock, -1) == -1) {
-               msg_err ("start_lmtp: cannot listen on socket. %m");
+               msg_err ("start_lmtp: cannot listen on socket. %s", strerror (errno));
                exit(-errno);
        }
        /* Accept event */
index 06bba02fee866860529bacfd2179dcfe1718830f..42bf3560a8979d4da8f5dd1d6593f254deed23ba 100644 (file)
@@ -432,7 +432,7 @@ lmtp_deliver_mta (struct worker_task *task)
                sock = make_socket (&task->cfg->deliver_addr, task->cfg->deliver_port);
        }
        if (sock == -1) {
-               msg_warn ("lmtp_deliver_mta: cannot create socket for %s, %m", task->cfg->deliver_host);
+               msg_warn ("lmtp_deliver_mta: cannot create socket for %s, %s", task->cfg->deliver_host, strerror (errno));
        }
 
        /* Socket options */
@@ -554,7 +554,7 @@ lmtp_deliver_lda (struct worker_task *task)
 
        if (pipe (p) == -1) {
                g_strfreev (argv);
-               msg_info ("lmtp_deliver_lda: cannot open pipe: %m");
+               msg_info ("lmtp_deliver_lda: cannot open pipe: %s", strerror (errno));
                return -1;
        }
        
@@ -562,13 +562,13 @@ lmtp_deliver_lda (struct worker_task *task)
 #ifdef HAVE_VFORK
        if ((cpid = vfork ()) == -1) {
                g_strfreev (argv);
-               msg_info ("lmtp_deliver_lda: cannot fork: %m");
+               msg_info ("lmtp_deliver_lda: cannot fork: %s", strerror (errno));
                return -1;
        }
 #else 
        if ((cpid = fork ()) == -1) {
                g_strfreev (argv);
-               msg_info ("lmtp_deliver_lda: cannot fork: %m");
+               msg_info ("lmtp_deliver_lda: cannot fork: %s", strerror (errno));
                return -1;
        }
 #endif
index 9c2da60b7af1547291e75704671bc8a3275ac0d6..da142d6a77a052c48e1ecc320d4b58e0f29d5831 100644 (file)
@@ -194,7 +194,7 @@ fork_worker (struct rspamd_main *rspamd, int listen_sock, int reconfig, enum pro
                                }
                                break;
                        case -1:
-                               msg_err ("fork_worker: cannot fork main process. %m");
+                               msg_err ("fork_worker: cannot fork main process. %s", strerror (errno));
                                pidfile_remove (rspamd->pfh);
                                exit (-errno);
                                break;
@@ -343,7 +343,7 @@ main (int argc, char **argv, char **env)
        PERL_SYS_INIT3 (&argc, &argv, &env);
        perl_interpreter = perl_alloc ();
        if (perl_interpreter == NULL) {
-               msg_err ("main: cannot allocate perl interpreter, %m");
+               msg_err ("main: cannot allocate perl interpreter, %s", strerror (errno));
                exit (-errno);
        }
 
@@ -355,20 +355,20 @@ main (int argc, char **argv, char **env)
 
        if (rspamd->cfg->bind_family == AF_INET) {
                if ((listen_sock = make_socket (&rspamd->cfg->bind_addr, rspamd->cfg->bind_port)) == -1) {
-                       msg_err ("main: cannot create tcp listen socket. %m");
+                       msg_err ("main: cannot create tcp listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
        else {
                un_addr = (struct sockaddr_un *) g_malloc (sizeof (struct sockaddr_un));
                if (!un_addr || (listen_sock = make_unix_socket (rspamd->cfg->bind_host, un_addr)) == -1) {
-                       msg_err ("main: cannot create unix listen socket. %m");
+                       msg_err ("main: cannot create unix listen socket. %s", strerror (errno));
                        exit(-errno);
                }
        }
 
        if (listen (listen_sock, -1) == -1) {
-               msg_err ("main: cannot listen on socket. %m");
+               msg_err ("main: cannot listen on socket. %s", strerror (errno));
                exit(-errno);
        }
        
index d2636f5e64f1dc4eb121f29140a76eb61c8f406a..2d369c87c7348f703b1252d8dcebc7e64c260524 100644 (file)
@@ -130,7 +130,7 @@ write_handler (int fd, short what, memcached_ctx_t *ctx)
                        iov[3].iov_base = CRLF;
                        iov[3].iov_len = sizeof (CRLF) - 1;
                        if (writev (ctx->sock, iov, 4) == -1) {
-                               memc_log (ctx, __LINE__, "memc_write: writev failed: %m");
+                               memc_log (ctx, __LINE__, "memc_write: writev failed: %s", strerror (errno));
                        }
                }
                else {
@@ -222,12 +222,12 @@ read_handler (int fd, short what, memcached_ctx_t *ctx)
                        iov[1].iov_base = read_buf;
                        iov[1].iov_len = r;
                        if (writev (ctx->sock, iov, 2) == -1) {
-                               memc_log (ctx, __LINE__, "memc_write: writev failed: %m");
+                               memc_log (ctx, __LINE__, "memc_write: writev failed: %s", strerror (errno));
                        }
                }
                else {
                        if (write (ctx->sock, read_buf, r) == -1) {
-                               memc_log (ctx, __LINE__, "memc_write: write failed: %m");
+                               memc_log (ctx, __LINE__, "memc_write: write failed: %s", strerror (errno));
                        }
                }
                event_del (&ctx->mem_ev);
@@ -311,7 +311,7 @@ read_handler (int fd, short what, memcached_ctx_t *ctx)
                        ctx->param->bufpos += r;
                }
                else {
-                       memc_log (ctx, __LINE__, "memc_read: read(v) failed: %d, %m", r);
+                       memc_log (ctx, __LINE__, "memc_read: read(v) failed: %d, %s", r, strerror (errno));
                        event_del (&ctx->mem_ev);
                        ctx->callback (ctx, SERVER_ERROR, ctx->callback_data);
                        return;
@@ -356,12 +356,12 @@ delete_handler (int fd, short what, memcached_ctx_t *ctx)
                        iov[1].iov_len = r;
                        ctx->param->bufpos = writev (ctx->sock, iov, 2);
                        if (ctx->param->bufpos == -1) {
-                               memc_log (ctx, __LINE__, "memc_write: writev failed: %m");
+                               memc_log (ctx, __LINE__, "memc_write: writev failed: %s", strerror (errno));
                        }
                }
                else {
                        if (write (ctx->sock, read_buf, r) == -1) {
-                               memc_log (ctx, __LINE__, "memc_write: write failed: %m");
+                               memc_log (ctx, __LINE__, "memc_write: write failed: %s", strerror (errno));
                        }
                }
                event_del (&ctx->mem_ev);
@@ -475,7 +475,7 @@ memc_make_udp_sock (memcached_ctx_t *ctx)
        ctx->sock = socket (PF_INET, SOCK_DGRAM, 0);
 
        if (ctx->sock == -1) {
-               memc_log (ctx, __LINE__, "memc_make_udp_sock: socket() failed: %m");
+               memc_log (ctx, __LINE__, "memc_make_udp_sock: socket() failed: %s", strerror (errno));
                return -1;
        }
 
@@ -510,7 +510,7 @@ memc_make_tcp_sock (memcached_ctx_t *ctx)
        ctx->sock = socket (PF_INET, SOCK_STREAM, 0);
 
        if (ctx->sock == -1) {
-               memc_log (ctx, __LINE__, "memc_make_tcp_sock: socket() failed: %m");
+               memc_log (ctx, __LINE__, "memc_make_tcp_sock: socket() failed: %s", strerror (errno));
                return -1;
        }
 
@@ -522,7 +522,7 @@ memc_make_tcp_sock (memcached_ctx_t *ctx)
                if (errno != EINPROGRESS) {
                        close (ctx->sock);
                        ctx->sock = -1;
-                       memc_log (ctx, __LINE__, "memc_make_tcp_sock: connect() failed: %m");
+                       memc_log (ctx, __LINE__, "memc_make_tcp_sock: connect() failed: %s", strerror (errno));
                        return -1;
                }
        }
index bce54c992f31c5cbd89034d32b6cd4a3f00cc558..c2651bdc8115565b66eb04ae7abce868a609e3f5 100644 (file)
@@ -312,7 +312,7 @@ mime_foreach_callback (GMimeObject *part, gpointer user_data)
                                }
                        }
                        else {
-                               msg_warn ("mime_foreach_callback: write to stream failed: %d, %m", errno);
+                               msg_warn ("mime_foreach_callback: write to stream failed: %d, %s", errno, strerror (errno));
                        }
                }
                else {
index 1940a5f572f774f6c2a540d462742aa6faebc4b6..d563e9cde15f6c2b0f6fb47b057b76887bc8273c 100644 (file)
@@ -471,7 +471,7 @@ redirector_callback (int fd, short what, void *arg)
                                event_add (&param->ev, &timeout);
                                r = snprintf (url_buf, sizeof (url_buf), "GET %s HTTP/1.0\r\n\r\n", struri (param->url));
                                if (write (param->sock, url_buf, r) == -1) {
-                                       msg_err ("redirector_callback: write failed %m");
+                                       msg_err ("redirector_callback: write failed %s", strerror (errno));
                                        event_del (&param->ev);
                                        param->task->save.saved --;
                                        if (param->task->save.saved == 0) {
@@ -555,7 +555,7 @@ register_redirector_call (struct uri *url, struct worker_task *task)
        s = socket (PF_INET, SOCK_STREAM, 0);
 
        if (s == -1) {
-               msg_info ("register_redirector_call: socket() failed: %m");
+               msg_info ("register_redirector_call: socket() failed: %s", strerror (errno));
                return; 
        }
 
@@ -566,7 +566,7 @@ register_redirector_call (struct uri *url, struct worker_task *task)
        if ((r = connect (s, (struct sockaddr*)&sc, sizeof (struct sockaddr_in))) == -1) {
                if (errno != EINPROGRESS) {
                        close (s);
-                       msg_info ("register_redirector_call: connect() failed: %m");
+                       msg_info ("register_redirector_call: connect() failed: %s", strerror (errno));
                }
        }
        param = memory_pool_alloc (task->task_pool, sizeof (struct redirector_param));
index 83d5382560042e5552dd5570b081bb4d2f86cc01..80c98825f12a8df1eb850eb5ad7bbb7920a78887 100644 (file)
@@ -125,7 +125,7 @@ statfile_pool_open (statfile_pool_t *pool, char *filename)
        }
 
        if (stat (filename, &st) == -1) {
-               msg_info ("statfile_pool_open: cannot stat file %s, error %m, %d", filename, errno);
+               msg_info ("statfile_pool_open: cannot stat file %s, error %s, %d", filename, strerror (errno), errno);
                return -1;
        }
        
@@ -144,13 +144,13 @@ statfile_pool_open (statfile_pool_t *pool, char *filename)
 
        new_file = memory_pool_alloc (pool->pool, sizeof (stat_file_t));
        if ((new_file->fd = open (filename, O_RDWR)) == -1 ) {
-               msg_info ("statfile_pool_open: cannot open file %s, error %m, %d", filename, errno);
+               msg_info ("statfile_pool_open: cannot open file %s, error %d, %s", filename, errno, strerror (errno));
                return -1;
        }
        
        if ((new_file->map = mmap (NULL, st.st_size, PROT_READ | PROT_WRITE, MAP_SHARED, new_file->fd, 0)) == NULL) {
                close (new_file->fd);
-               msg_info ("statfile_pool_open: cannot mmap file %s, error %m, %d", filename, errno);
+               msg_info ("statfile_pool_open: cannot mmap file %s, error %d, %s", filename, errno, strerror (errno));
                return -1;
        
        }
@@ -217,20 +217,20 @@ statfile_pool_create (statfile_pool_t *pool, char *filename, size_t blocks)
        }
 
        if ((fd = open (filename, O_RDWR | O_TRUNC | O_CREAT, S_IWUSR | S_IRUSR)) == -1 ) {
-               msg_info ("statfile_pool_create: cannot create file %s, error %m, %d", filename, errno);
+               msg_info ("statfile_pool_create: cannot create file %s, error %d, %s", filename, errno, strerror (errno));
                return -1;
        }
 
        header.create_time = (uint64_t)time (NULL);
        if (write (fd, &header, sizeof (header)) == -1) {
-               msg_info ("statfile_pool_create: cannot write header to file %s, error %m, %d", filename, errno);
+               msg_info ("statfile_pool_create: cannot write header to file %s, error %d, %s", filename, errno, strerror (errno));
                close (fd);
                return -1;
        }
        
        while (blocks --) {
                if (write (fd, &block, sizeof (block)) == -1) {
-                       msg_info ("statfile_pool_create: cannot write block to file %s, error %m, %d", filename, errno);
+                       msg_info ("statfile_pool_create: cannot write block to file %s, error %d, %s", filename, errno, strerror (errno));
                        close (fd);
                        return -1;
                }
index a7aea229cb3a8aece40b744085ab7ee0f781ef73..afcb13b23da20f84582dc13c69f764d0edf1b1de 100644 (file)
@@ -750,7 +750,7 @@ open_log (struct config_file *cfg)
                case RSPAMD_LOG_FILE:
                        cfg->log_fd = open (cfg->log_file, O_CREAT | O_WRONLY | O_APPEND, S_IWUSR | S_IRUSR | S_IRGRP | S_IROTH);
                        if (cfg->log_fd == -1) {
-                               msg_err ("open_log: cannot open desired log file: %s, %m", cfg->log_file);
+                               msg_err ("open_log: cannot open desired log file: %s, %s", cfg->log_file, strerror (errno));
                                return -1;
                        }
                        return 0;
index 03912930fd68ce128dff27adf19681463b460af8..dee49ef4df2e3e168ba0edc82f8c30316cf599f0 100644 (file)
@@ -233,10 +233,7 @@ accept_socket (int fd, short what, void *arg)
        setsockopt (nfd, SOL_SOCKET, SO_LINGER, (void *)&linger, sizeof(linger));
        
        new_task = g_malloc (sizeof (struct worker_task));
-       if (new_task == NULL) {
-               msg_err ("accept_socket: cannot allocate memory for task, %m");
-               return;
-       }
+
        msg_debug ("accept_socket: new task allocated: %p", new_task);
        bzero (new_task, sizeof (struct worker_task));
        new_task->worker = worker;
@@ -251,6 +248,7 @@ accept_socket (int fd, short what, void *arg)
        memory_pool_add_destructor (new_task->task_pool, (pool_destruct_func)rcpt_destruct, new_task);
        new_task->results = g_hash_table_new (g_str_hash, g_str_equal);
        memory_pool_add_destructor (new_task->task_pool, (pool_destruct_func)g_hash_table_destroy, new_task->results);
+
        worker->srv->stat->connections_count ++;
 
        /* Set up dispatcher */