*** empty log message ***
authorMatthew Mondor <mmondor@pulsar-zone.net>
Sun, 27 Apr 2003 19:48:04 +0000 (19:48 +0000)
committerMatthew Mondor <mmondor@pulsar-zone.net>
Sun, 27 Apr 2003 19:48:04 +0000 (19:48 +0000)
14 files changed:
mmsoftware/mmftpd/ChangeLog
mmsoftware/mmftpd/src/mmftpd.c
mmsoftware/mmftpd/src/mmftpd.h
mmsoftware/mmlib/mmstat.3
mmsoftware/mmlib/mmstat.c
mmsoftware/mmlib/mmstat.h
mmsoftware/mmmail/ChangeLog
mmsoftware/mmmail/src/mmpop3d/mmpop3d.c
mmsoftware/mmmail/src/mmpop3d/mmpop3d.h
mmsoftware/mmmail/src/mmsmtpd/mmsmtpd.c
mmsoftware/mmmail/src/mmsmtpd/mmsmtpd.h
mmsoftware/mmstatd/ChangeLog
mmsoftware/mmstatd/src/mmstat.c
mmsoftware/mmstatd/src/mmstatd.c

index 99c0080..e673ceb 100644 (file)
@@ -1,9 +1,9 @@
-$Id: ChangeLog,v 1.12 2003/03/28 21:09:28 mmondor Exp $
+$Id: ChangeLog,v 1.13 2003/04/27 19:48:03 mmondor Exp $
 
 
 
 Release: mmftpd 0.0.16 devl
-Date   : March 28, 2003
+Date   : April 25, 2003
 By     : Matthew Mondor
 
 * Miscelaneous new features
@@ -18,9 +18,12 @@ By     : Matthew Mondor
     directories were visited recently to not flood the user with README file
     contents, when enabled.
   - Fixed ALIGN_CEIL alignment macros which used to always add bytes even
-    if the value was already aligned properly.
+    if the value was already aligned properly. A few bytes were often wasted
+    as the result of this.
   - Interface of various lower layer functions and macros were improved, and
     mmftpd was migrated to use the new ones.
+  - Where appropriate and possible, const keyword was added to the function
+    parameters.
 
 
 
index 93e6ab7..dccb5b9 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmftpd.c,v 1.15 2003/04/01 04:10:12 mmondor Exp $ */
+/* $Id: mmftpd.c,v 1.16 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2002-2003, Matthew Mondor
@@ -42,6 +42,9 @@
 #include <fcntl.h>
 #include <stdlib.h>
 #include <stdio.h>
+#ifdef __GLIBC__
+#include <crypt.h>
+#endif
 
 #include <sys/socket.h>
 #include <netinet/in.h>
@@ -77,7 +80,7 @@
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmftpd.c,v 1.15 2003/04/01 04:10:12 mmondor Exp $");
+MMRCSID("$Id: mmftpd.c,v 1.16 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
@@ -261,7 +264,7 @@ static int (*state_main[])(clientenv *) = {
  * of state functions/commands, and a message code and text that gets issued
  * when a NULL is found for a function.
  */
-static struct state states[] = {
+static const struct state states[] = {
     {state_auth, 530, "Authenticate first"},
     {state_main, 502, "Unimplemented"}
 };
@@ -269,7 +272,7 @@ static struct state states[] = {
 static int LOGLEVEL;
 
 /* Quick index to end of transfer messages */
-static struct tr_messages tr_msg[] = {
+static const struct tr_messages tr_msg[] = {
     {226, "Transfer complete"},
     {426, "Transfer aborted"},
     {426, "Transfer timeout"},
@@ -2397,7 +2400,7 @@ main(int argc, char **argv)
        {async_getuserline, sizeof(struct async_getuserline_msg)},
        {NULL, 0}
     };
-    MMSTAT vstat;
+    mmstat_t vstat;
 
     /* Advertize */
     printf("\r\n+++ %s (%s)\r\n\r\n", DAEMON_NAME, DAEMON_VERSION);
index c9aeee2..727d238 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmftpd.h,v 1.9 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmftpd.h,v 1.10 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2000-2003, Matthew Mondor
@@ -205,7 +205,7 @@ typedef struct clientenv {
     struct fifonode *fifobuf;    /* Internal buffer for visited */
     struct iface *iface;         /* To obtain our server hostname */
     struct async_clenv *aclenv;          /* Thread context for async_call() support */
-    MMSTAT vstat, pstat;         /* Handles for mmstat */
+    mmstat_t vstat, pstat;       /* Handles for mmstat */
 } clientenv;
 
 /* This structure is shared by simultanious logins of a same user. It thus
index 2a03ae5..e617218 100644 (file)
@@ -1,4 +1,4 @@
-.\" $Id: mmstat.3,v 1.3 2003/01/09 08:07:08 mmondor Exp $
+.\" $Id: mmstat.3,v 1.4 2003/04/27 19:48:04 mmondor Exp $
 .\"
 .\" Copyright (C) 2002-2003, Matthew Mondor
 .\" All rights reserved.
@@ -31,7 +31,7 @@
 .\"
 .Dd January 1, 2003
 .Os
-.Dt MMSTAT 3
+.Dt mmstat_t 3
 .Sh NAME
 .Nm mmstat
 .Nd Statistical book-keeper with transaction isolation and recovery support
 .Ft bool
 .Fn mmstat_initialize "void"
 .Ft bool
-.Fn mmstat_init "MMSTAT *mms" "bool persistant" "bool autoflush"
+.Fn mmstat_init "mmstat_t *mms" "bool persistant" "bool autoflush"
 .Ft bool
-.Fn mmstat "MMSTAT *mms" "enum stat_type type" "int64_t value" "char *fmt" "..."
+.Fn mmstat "mmstat_t *mms" "enum stat_type type" "int64_t value" \
+"const char *fmt" "..."
 .Ft bool
-.Fn mmstat_transact "MMSTAT *mms" "bool lock"
-.Ft MMSTATRES *
-.Fn mmstat_report "char *fmt" "..."
-.Ft MMSTATRES *
-.Fn mmstat_freeres "MMSTATRES *res"
-.Ft MMSTATENT *
-.Fn mmstat_nextres "MMSTATRES *res"
+.Fn mmstat_transact "mmstat_t *mms" "bool lock"
+.Ft mmstatres_t *
+.Fn mmstat_report "const char *fmt" "..."
+.Ft mmstatres_t *
+.Fn mmstat_freeres "mmstatres_t *res"
+.Ft mmstatent_t *
+.Fn mmstat_nextres "mmstatres_t *res"
 .Ft bool
-.Fn mmstat_rotate "char *pattern" "char *prefix"
+.Fn mmstat_rotate "const char *pattern" "const char *prefix"
 .Sh DESCRIPTION
 mmstat consists of a daemon (mmstatd) and library API (mmstat). mmstatd
 handles a statistical database on a key/value pair basis and stores for
@@ -85,7 +86,7 @@ file to read. Otherwise the default consists of
 .Nm /etc/mmstatd.conf .
 .Pp
 .Fn mmstat_init
-initializes supplied MMSTAT
+initializes supplied mmstat_t
 .Fa mms
 object. This is required before calling other mmstat functions using this
 handle. It in fact transforms the object into a handle suitable for other
@@ -160,7 +161,7 @@ allows to obtain results one by one from the
 .Fa res
 handle obtained from
 .Fn mmstat_report
-sequencially. The results are obtained into an MMSTATENT structure, as defined
+sequencially. The results are obtained into an mmstatent_t structure, as defined
 in
 .Aq Pa mmstat.h
 (described below).
@@ -171,7 +172,7 @@ typedef mmstat_entry {
     uid_t uid;
     char key[KEY_SIZE];
     bool persistant;
-} MMSTATENT;
+} mmstatent_t;
 .Ed
 .Pp
 .Fn mmstat_rotate
@@ -204,7 +205,7 @@ returns TRUE if the set of operations could be processed, or FALSE otherwise.
 .Pp
 .Fn mmstat_report
 returns an
-.Fa MMSTATRES
+.Fa mmstatres_t
 results handle pointer on success, or NULL on error.
 .Pp
 .Fn mmstat_freeres
@@ -212,9 +213,9 @@ always returns NULL.
 .Pp
 .Fn mmstat_nextres
 returns the next entry of results as an
-.Fa MMSTATENT
+.Fa mmstatent_t
 pointer in the specified
-.Fa MMSTATRES
+.Fa mmstatres_t
 set, but returns NULL when reaching the end of results.
 .Pp
 .Fn mmstat_rotate
index 6d0d8aa..e4f7d04 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmstat.c,v 1.3 2003/01/08 20:57:46 mmondor Exp $ */
+/* $Id: mmstat.c,v 1.4 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2002-2003, Matthew Mondor
@@ -57,7 +57,7 @@
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmstat.c,v 1.3 2003/01/08 20:57:46 mmondor Exp $");
+MMRCSID("$Id: mmstat.c,v 1.4 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
@@ -84,7 +84,7 @@ static struct sockaddr_un laddr;
 /* Public API mmstat functions */
 
 bool
-mmstat_init(MMSTAT *mms, bool persistant, bool autoflush)
+mmstat_init(mmstat_t *mms, bool persistant, bool autoflush)
 {
     bool ret = FALSE;
 
@@ -101,7 +101,7 @@ mmstat_init(MMSTAT *mms, bool persistant, bool autoflush)
 
 
 bool
-mmstat(MMSTAT *mms, enum stat_type type, int64_t value, char *fmt, ...)
+mmstat(mmstat_t *mms, enum stat_type type, int64_t value, const char *fmt, ...)
 {
     bool ok = FALSE;
     struct log_entry *entry;
@@ -142,7 +142,7 @@ mmstat(MMSTAT *mms, enum stat_type type, int64_t value, char *fmt, ...)
 
 
 bool
-mmstat_transact(MMSTAT *mms, bool lock)
+mmstat_transact(mmstat_t *mms, bool lock)
 {
     bool ok = FALSE;
 
@@ -166,10 +166,10 @@ mmstat_transact(MMSTAT *mms, bool lock)
 }
 
 
-MMSTATRES *
-mmstat_report(char *fmt, ...)
+mmstatres_t *
+mmstat_report(const char *fmt, ...)
 {
-    MMSTATRES *res = NULL;
+    mmstatres_t *res = NULL;
     struct sockaddr_un sun;
     va_list arg_ptr;
     char key[KEY_SIZE], c;
@@ -181,7 +181,7 @@ mmstat_report(char *fmt, ...)
        va_end(arg_ptr);
        connect_log = FALSE;
        if (mmstat_initialized || mmstat_initialize()) {
-           if ((res = malloc(sizeof(MMSTATRES)))) {
+           if ((res = malloc(sizeof(mmstatres_t)))) {
                if ((res->fd = socket(AF_LOCAL, SOCK_STREAM, 0)) != -1) {
                    mm_memclr(&sun, sizeof(struct sockaddr_un));
                    sun.sun_family = AF_UNIX;
@@ -205,8 +205,8 @@ mmstat_report(char *fmt, ...)
 }
 
 
-MMSTATENT *
-mmstat_nextres(MMSTATRES *res)
+mmstatent_t *
+mmstat_nextres(mmstatres_t *res)
 {
     struct pollfd fds[] = {
        {res->fd, POLLIN, 0}
@@ -215,8 +215,8 @@ mmstat_nextres(MMSTATRES *res)
     for (;;) {
        if (poll(fds, 1, -1) == 1) {
            if (fds[0].revents & POLLIN) {
-               if (read(res->fd, &res->entry, sizeof(MMSTATENT)) ==
-                       sizeof(MMSTATENT))
+               if (read(res->fd, &res->entry, sizeof(mmstatent_t)) ==
+                       sizeof(mmstatent_t))
                    return (&res->entry);
                else break;
            }
@@ -227,8 +227,8 @@ mmstat_nextres(MMSTATRES *res)
 }
 
 
-MMSTATRES *
-mmstat_freeres(MMSTATRES *res)
+mmstatres_t *
+mmstat_freeres(mmstatres_t *res)
 {
     close(res->fd);
     free(res);
@@ -238,7 +238,7 @@ mmstat_freeres(MMSTATRES *res)
 
 
 bool
-mmstat_rotate(char *pattern, char *prefix)
+mmstat_rotate(const char *pattern, const char *prefix)
 {
     struct sockaddr_un sun;
     int fd;
index a57dccd..1373522 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmstat.h,v 1.3 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmstat.h,v 1.4 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2002-2003, Matthew Mondor
@@ -34,8 +34,8 @@
 
 
 
-#ifndef MMSTAT_H
-#define MMSTAT_H
+#ifndef mmstat_t_H
+#define mmstat_t_H
 
 
 
 #define MAX_TRANSACT   16
 #define KEY_SIZE       128
 
+typedef struct mmstat_entry    mmstatent_t;
+typedef struct mmstat_handle   mmstat_t;
+typedef struct mmstat_report   mmstatres_t;
+
 
 
 
@@ -69,13 +73,13 @@ enum stat_type {
     STAT_DELETE = 5
 };
 
-typedef struct mmstat_entry {
+struct mmstat_entry {
     int64_t value;
     time_t created, modified;
     uid_t uid;
     char key[KEY_SIZE];
     bool persistant;
-} MMSTATENT;
+};
 
 /* We keep the hash table of the key and rest of data into separate lists so
  * that frequently referenced hash table does not get swapped out of physical
@@ -89,7 +93,7 @@ typedef struct mmstat_entry {
  */
 struct data_node {
     pnode_t node;
-    struct mmstat_entry entry;
+    mmstatent_t entry;
 };
 struct key_node {
     pnode_t node;
@@ -120,16 +124,16 @@ struct log_entry {
     } un;
 };
 
-typedef struct mmstat_handle {
+struct mmstat_handle {
     bool persistant, transaction, autoflush;
     int transact_pos;
     struct log_entry entries[MAX_TRANSACT];
-} MMSTAT;
+};
 
-typedef struct mmstat_report {
+struct mmstat_report {
     int fd;
-    struct mmstat_entry entry;
-} MMSTATRES;
+    mmstatent_t entry;
+};
 
 struct mmstat_config {
     char USER[32], GROUPS[256], LOG_FACILITY[32], PID_FILE[256],
@@ -146,13 +150,13 @@ struct mmstat_config {
 /* PROTOTYPES */
 
 bool mmstat_initialize(void);
-bool mmstat_init(MMSTAT *, bool, bool);
-bool mmstat(MMSTAT *, enum stat_type, int64_t, char *, ...);
-bool mmstat_transact(MMSTAT *, bool);
-MMSTATRES *mmstat_report(char *, ...);
-MMSTATENT *mmstat_nextres(MMSTATRES *);
-MMSTATRES *mmstat_freeres(MMSTATRES *);
-bool mmstat_rotate(char *, char *);
+bool mmstat_init(mmstat_t *, bool, bool);
+bool mmstat(mmstat_t *, enum stat_type, int64_t, const char *, ...);
+bool mmstat_transact(mmstat_t *, bool);
+mmstatres_t *mmstat_report(const char *, ...);
+mmstatent_t *mmstat_nextres(mmstatres_t *);
+mmstatres_t *mmstat_freeres(mmstatres_t *);
+bool mmstat_rotate(const char *, const char *);
 
 
 
index 1d47cb6..753f580 100644 (file)
@@ -1,14 +1,15 @@
-$Id: ChangeLog,v 1.13 2003/03/28 21:09:29 mmondor Exp $
+$Id: ChangeLog,v 1.14 2003/04/27 19:48:04 mmondor Exp $
 
 
 
 Release: mmmail 0.0.22 devl
-Date   : March 28, 2003
+Date   : April 25, 2003
 By     : Matthew Mondor
 
 * Various
   - Fixed ALIGN_CEIL alignment macros which used to always add bytes even
-    if the value was already aligned properly.
+    if the value was already aligned properly. As a result a few bytes of
+    memory were often wasted.
   - Interface of various lower layer functions and macros were improved, and
     mmftpd was migrated to use the new ones.
 
index 4b7a48f..4831374 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmpop3d.c,v 1.9 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmpop3d.c,v 1.10 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2000-2003, Matthew Mondor
 #include <fcntl.h>
 #include <stdlib.h>
 #include <stdio.h>
+#include <unistd.h>
+#ifdef __GLIBC__
+#include <crypt.h>
+#endif
 
 #include <sys/socket.h>
 #include <netinet/in.h>
@@ -72,7 +76,7 @@
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmpop3d.c,v 1.9 2003/03/28 21:09:29 mmondor Exp $");
+MMRCSID("$Id: mmpop3d.c,v 1.10 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
@@ -134,7 +138,7 @@ static int (*state_main[])(clientenv *) = {
 };
 
 /* And here are our states */
-static struct state states[] = {
+static const struct state states[] = {
     {state_auth, FALSE, "Authenticate first"},
     {state_main, FALSE, "Already authenticated"}
 };
@@ -254,7 +258,7 @@ main(int argc, char **argv)
        _pth_mutex_unlock,
        _pth_thread_yield 
     };
-    MMSTAT vstat;
+    mmstat_t vstat;
 
     /* Set defaults */
     *CONF.CHROOT_DIR = 0;
index d25420b..bd641ad 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmpop3d.h,v 1.5 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmpop3d.h,v 1.6 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2000-2003, Matthew Mondor
@@ -59,7 +59,7 @@
 /* DEFINITIONS */
 
 #define DAEMON_NAME    "mmpop3d"
-#define DAEMON_VERSION "mmmail-0.0.21/mmondor"
+#define DAEMON_VERSION "mmmail-0.0.22/mmondor"
 
 /* Negative states are used by the state swapper, others are real states */
 #define STATE_ERROR    -3
@@ -122,7 +122,7 @@ typedef struct clientenv {
     bool login;                        /* For all_quit() */
     struct iface *iface;       /* Current interface user connected through */
     struct async_clenv *aclenv;        /* Thread context for async_call() */
-    MMSTAT vstat, pstat;       /* mmstat(3) handles */
+    mmstat_t vstat, pstat;     /* mmstat(3) handles */
 } clientenv;
 
 /* Used for mmfd thread support delegation/abstraction */
index 65412a3..d17fb53 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmsmtpd.c,v 1.13 2003/03/30 21:06:00 mmondor Exp $ */
+/* $Id: mmsmtpd.c,v 1.14 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2001-2003, Matthew Mondor
@@ -74,7 +74,7 @@
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmsmtpd.c,v 1.13 2003/03/30 21:06:00 mmondor Exp $");
+MMRCSID("$Id: mmsmtpd.c,v 1.14 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
@@ -114,7 +114,7 @@ static int (*state_all[])(clientenv *) = {
 };
 
 /* The definitions of our many various states (-: */
-static struct state states[] = {
+static const struct state states[] = {
     {state_all, 0, "Abnormal error"}
 };
 
@@ -142,7 +142,7 @@ static pool_t pmutexes;
 static fdbcontext fdbc;
 
 /* Quick index to RCPT command replies (see mmsmtpd.h for matching defines) */
-static struct reply_messages rcpt_msg[] = {
+static const struct reply_messages rcpt_msg[] = {
     {250, "Recipient ok"},
     {503, "Use MAIL first"},
     {552, "Too many recipients"},
@@ -154,7 +154,7 @@ static struct reply_messages rcpt_msg[] = {
 };
 
 /* Fast index to DATA replies (see headerfile for matching keywords) */
-static struct reply_messages data_msg[] = {
+static const struct reply_messages data_msg[] = {
     {354, "Submit message ending with a single ."},
     {250, "Ok, mail delivered"},
     {552, "Too much mail data"},
@@ -293,7 +293,7 @@ main(int argc, char **argv)
        _pth_mutex_unlock,
        _pth_thread_yield
     };
-    MMSTAT vstat;
+    mmstat_t vstat;
 
     /* Set defaults */
     *CONF.CHROOT_DIR = 0;
index 15537f5..0e2412d 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmsmtpd.h,v 1.10 2003/03/30 21:06:01 mmondor Exp $ */
+/* $Id: mmsmtpd.h,v 1.11 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2000-2003, Matthew Mondor
@@ -59,7 +59,7 @@
 
 /* DEFINITIONS */
 #define DAEMON_NAME    "mmsmtpd"
-#define DAEMON_VERSION "mmmail-0.0.21/mmondor"
+#define DAEMON_VERSION "mmmail-0.0.22/mmondor"
 
 /* Negative states are used by the state swapper, others are real states */
 #define STATE_ERROR    -3
@@ -143,7 +143,7 @@ typedef struct clientenv {
     struct iface *iface;       /* Current interface user connected through */
     struct async_clenv *aclenv;        /* Thread context for async_call() */
     list_t rcpt;               /* Cached recepients to send mail to */
-    MMSTAT vstat, pstat;       /* mmstat(3) handles */
+    mmstat_t vstat, pstat;     /* mmstat(3) handles */
 } clientenv;
 
 /* Used for RCPT addresses */
index 4b5dc25..e86989b 100644 (file)
@@ -1,4 +1,4 @@
-$Id: ChangeLog,v 1.1 2003/01/10 03:52:36 mmondor Exp $
+$Id: ChangeLog,v 1.2 2003/04/27 19:48:04 mmondor Exp $
 
 
 
@@ -27,3 +27,13 @@ By     : Matthew Mondor
     own mmstat service for instance.
   - mmstatd can now be specified configuration file to use on the command
     line arguments.
+
+
+
+Release: mmstatd 0.0.7 devl
+Date   : April 25, 2003
+By     : Matthew Mondor
+
+* Minor interface change
+  - MMSTAT, MMSTATENT and MMSTATRES data types were changed to mmstat_t,
+    mmstatent_t and mmstatres_t for consistency with other mmsoftware style.
index cd02df0..bd303de 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmstat.c,v 1.7 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmstat.c,v 1.8 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2002-2003, Matthew Mondor
@@ -52,7 +52,7 @@
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmstat.c,v 1.7 2003/03/28 21:09:29 mmondor Exp $");
+MMRCSID("$Id: mmstat.c,v 1.8 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
@@ -61,7 +61,7 @@ MMRCSID("$Id: mmstat.c,v 1.7 2003/03/28 21:09:29 mmondor Exp $");
 
 struct entnode {
     pnode_t node;
-    MMSTATENT ent;
+    mmstatent_t ent;
 };
 
 
@@ -131,8 +131,8 @@ int stat_report(int argc, char **argv)
     list_t list;
     pool_t pool;
     struct entnode *entnod;
-    MMSTATRES *res;
-    MMSTATENT *ent;
+    mmstatres_t *res;
+    mmstatent_t *ent;
     int ret = 0;
     char key[KEY_SIZE];
 
@@ -151,7 +151,7 @@ int stat_report(int argc, char **argv)
                while ((ent = mmstat_nextres(res))) {
                    if ((entnod = (struct entnode *)pool_alloc(&pool,
                                    FALSE))) {
-                       mm_memcpy(&entnod->ent, ent, sizeof(MMSTATENT));
+                       mm_memcpy(&entnod->ent, ent, sizeof(mmstatent_t));
                        LIST_APPEND(&list, (node_t *)entnod);
                    } else
                        break;
@@ -194,8 +194,8 @@ int stat_hreport(int argc, char **argv)
     pool_t pool;
     list_t list;
     struct entnode *entnod;
-    MMSTATRES *res;
-    MMSTATENT *ent;
+    mmstatres_t *res;
+    mmstatent_t *ent;
     int ret = 0;
     char key[KEY_SIZE];
     bool nomem = FALSE;
@@ -216,7 +216,7 @@ int stat_hreport(int argc, char **argv)
                while ((ent = mmstat_nextres(res))) {
                    if ((entnod = (struct entnode *)pool_alloc(&pool,
                                    FALSE))) {
-                       mm_memcpy(&entnod->ent, ent, sizeof(MMSTATENT));
+                       mm_memcpy(&entnod->ent, ent, sizeof(mmstatent_t));
                        LIST_APPEND(&list, (node_t *)entnod);
                    } else
                        break;
@@ -276,7 +276,7 @@ int stat_hreport(int argc, char **argv)
 static
 int stat_reset(int argc, char **argv)
 {
-    MMSTAT mms;
+    mmstat_t mms;
     int i, ret = 0;
     char *arg, *args[3];
     bool persistant = FALSE, autoflush = FALSE, ok = TRUE;
@@ -314,7 +314,7 @@ int stat_reset(int argc, char **argv)
 static int
 stat_update(int argc, char **argv)
 {
-    MMSTAT mms;
+    mmstat_t mms;
     int i, ret = 0;
     char *arg, *args[3];
     bool persistant = FALSE, autoflush = FALSE, ok = TRUE;
@@ -352,7 +352,7 @@ stat_update(int argc, char **argv)
 static int
 stat_delete(int argc, char **argv)
 {
-    MMSTAT mms;
+    mmstat_t mms;
     int i, ret = 0;
 
     if (argc > 2) {
index 420b576..c08d8ba 100644 (file)
@@ -1,4 +1,4 @@
-/* $Id: mmstatd.c,v 1.6 2003/03/28 21:09:29 mmondor Exp $ */
+/* $Id: mmstatd.c,v 1.7 2003/04/27 19:48:04 mmondor Exp $ */
 
 /*
  * Copyright (C) 2002-2003, Matthew Mondor
 
 MMCOPYRIGHT("@(#) Copyright (c) 2002-2003\n\
 \tMatthew Mondor. All rights reserved.\n");
-MMRCSID("$Id: mmstatd.c,v 1.6 2003/03/28 21:09:29 mmondor Exp $");
+MMRCSID("$Id: mmstatd.c,v 1.7 2003/04/27 19:48:04 mmondor Exp $");
 
 
 
 
 /* PROTOTYPES */
 
-static pid_t spawn_process(int (*)(void *), void *, bool);
+static pid_t process_spawn(int (*)(void *), void *, bool);
 static void sighandler(int);
 static bool checklock(char *);
 static int unix_init(char *, gid_t, mode_t, int, bool, bool);
 static bool log_match(const char *, const char *);
-static bool writelogentries(int, struct log_entry *, int, int *, long *,
+static bool logentries_write(int, struct log_entry *, int, int *, long *,
                off_t *);
-static bool readlogentry(int, struct log_entry *, int *, long *, off_t *);
-static int readlogentries(int, struct log_entry *, int, int *, long *, off_t *);
-static bool processlogentry(struct log_entry *, bool);
-static bool processlogentries(struct log_entry *, int, bool);
-/* static void debuglogentry(char, struct log_entry *); */
-static void load_db(long *, off_t *);
-static bool load_db_v0_0_1(FILE *, long *, long *);
-static bool load_db_v0_0_2(FILE *, long *, off_t *);
-static bool load_db_v0_0_3(FILE *, long *, off_t *);
-static void sync_db(long, off_t, bool);
-static void free_db(void);
-static void recover_db(void);
-static void writestats(int, char *);
-static void rotatestats(char *, char *);
+static bool logentry_read(int, struct log_entry *, int *, long *, off_t *);
+static int logentries_read(int, struct log_entry *, int, int *, long *,
+       off_t *);
+static bool logentry_process(struct log_entry *, bool);
+static bool logentries_process(struct log_entry *, int, bool);
+/* static void logentry_debug(char, struct log_entry *); */
+static void db_load(long *, off_t *);
+static bool db_load_v0_0_1(FILE *, long *, long *);
+static bool db_load_v0_0_2(FILE *, long *, off_t *);
+static bool db_load_v0_0_3(FILE *, long *, off_t *);
+static void db_sync(long, off_t, bool);
+static void db_free(void);
+static void db_recover(void);
+static void stats_write(int, char *);
+static void stats_rotate(char *, char *);
 
 int main(int, char **);
 
@@ -133,7 +134,7 @@ static bool run = TRUE, pipesend = TRUE, kdirection = TRUE, ddirection = TRUE;
 /* FUNCTIONS */
 
 static pid_t
-spawn_process(int (*function)(void *), void *params, bool leader)
+process_spawn(int (*function)(void *), void *params, bool leader)
 {
     pid_t pid = -1;
     int fd;
@@ -302,7 +303,7 @@ log_match(const char *str, const char *pat)
  * fatal error (eg: disk full).
  */
 static bool
-writelogentries(int pfd, struct log_entry *entries, int len, int *fd,
+logentries_write(int pfd, struct log_entry *entries, int len, int *fd,
        long *lognum, off_t *logpos)
 {
     ssize_t l;
@@ -371,7 +372,7 @@ writelogentries(int pfd, struct log_entry *entries, int len, int *fd,
  * could be read. We return TRUE if an entry could be read.
  */
 static bool
-readlogentry(int pfd, struct log_entry *entry, int *fd, long *lognum,
+logentry_read(int pfd, struct log_entry *entry, int *fd, long *lognum,
        off_t *logpos)
 {
     char filename[256], c;
@@ -400,7 +401,7 @@ readlogentry(int pfd, struct log_entry *entry, int *fd, long *lognum,
                                ok = TRUE;
                            else
                                syslog(LOG_NOTICE,
-                                      "readlogentry() - partial read");
+                                      "logentry_read() - partial read");
                            break;
                        }
                    }
@@ -409,7 +410,7 @@ readlogentry(int pfd, struct log_entry *entry, int *fd, long *lognum,
        }
 
        if (ok) {
-           /* debuglogentry('|', entry); */
+           /* logentry_debug('|', entry); */
            *logpos += sizeof(struct log_entry);
            /* If required switch to next logfile */
            if (entry->type == STAT_NEWFILE) {
@@ -422,7 +423,7 @@ readlogentry(int pfd, struct log_entry *entry, int *fd, long *lognum,
                    *lognum = entry->un.newfile.lognum;
                    redo = TRUE;
                } else {
-                   syslog(LOG_NOTICE, "* readlogentry() - open()");
+                   syslog(LOG_NOTICE, "* logentry_read() - open()");
                    ok = FALSE;
                }
            }
@@ -449,7 +450,7 @@ readlogentry(int pfd, struct log_entry *entry, int *fd, long *lognum,
  * additionnal entry than specified maximum size.
  */
 static int
-readlogentries(int pfd, struct log_entry *entries, int max, int *fd,
+logentries_read(int pfd, struct log_entry *entries, int max, int *fd,
        long *lognum, off_t *logpos)
 {
     struct log_entry *ptr;
@@ -460,14 +461,14 @@ readlogentries(int pfd, struct log_entry *entries, int max, int *fd,
     ptr = entries;
     len = 0;
 
-    if (readlogentry(pfd, entries, fd, lognum, logpos)) {
+    if (logentry_read(pfd, entries, fd, lognum, logpos)) {
        if (entries->type == STAT_TRANSACT) {
            if (entries->un.transact.begin) transact = TRUE;
            else {
                /* Mismatch */
                len = 0;
                syslog(LOG_NOTICE,
-                       "readlogentries() - Mismatched transaction start");
+                       "logentries_read() - Mismatched transaction start");
            }
        } else
            len++;
@@ -481,10 +482,10 @@ readlogentries(int pfd, struct log_entry *entries, int max, int *fd,
     while (transact) {
        if (len > max) {
            len = 0;
-           syslog(LOG_NOTICE, "readlogentries() - MAX_TRANSACT exceeded");
+           syslog(LOG_NOTICE, "logentries_read() - MAX_TRANSACT exceeded");
            break;
        }
-       if (!readlogentry(pfd, ptr, fd, lognum, logpos)) {
+       if (!logentry_read(pfd, ptr, fd, lognum, logpos)) {
            len = 1;
            break;
        } else {
@@ -493,7 +494,7 @@ readlogentries(int pfd, struct log_entry *entries, int max, int *fd,
                    /* Mismatch */
                    len = 0;
                    syslog(LOG_NOTICE,
-                          "readlogentries() - Mismatched transaction end");
+                          "logentries_read() - Mismatched transaction end");
                }
                break;
            } else {
@@ -512,13 +513,13 @@ readlogentries(int pfd, struct log_entry *entries, int max, int *fd,
  * function.
  */
 static bool
-processlogentry(struct log_entry *entry, bool tmp)
+logentry_process(struct log_entry *entry, bool tmp)
 {
     bool ok;
     u_int64_t hash;
     enum stat_type type;
 
-    /* debuglogentry(':', entry); */
+    /* logentry_debug(':', entry); */
 
     ok = TRUE;
     type = entry->type;
@@ -658,13 +659,13 @@ processlogentry(struct log_entry *entry, bool tmp)
 
 
 static bool
-processlogentries(struct log_entry *entries, int len, bool tmp)
+logentries_process(struct log_entry *entries, int len, bool tmp)
 {
     int i;
     bool ok = TRUE;
 
     for (i = 0; i < len; i++) {
-       if (!processlogentry(&entries[i], tmp)) {
+       if (!logentry_process(&entries[i], tmp)) {
            ok = FALSE;
            break;
        }
@@ -677,7 +678,7 @@ processlogentries(struct log_entry *entries, int len, bool tmp)
 /* Only used for debugging when testing/developing */
 /*
 static void
-debuglogentry(char c, struct log_entry *entry)
+logentry_debug(char c, struct log_entry *entry)
 {
     switch (entry->type) {
        case STAT_TRANSACT:
@@ -719,7 +720,7 @@ debuglogentry(char c, struct log_entry *entry)
  */
 /* XXX Make file format portable among various endian architectures */
 static void
-load_db(long *lognum, off_t *logpos)
+db_load(long *lognum, off_t *logpos)
 {
     char filename[256];
     FILE *fh;
@@ -748,14 +749,14 @@ load_db(long *lognum, off_t *logpos)
                        case 2:
                            /* mmstatd 0.0.2, db v2 */
                            syslog(LOG_NOTICE,
-                                   "load_db() - loading db of v2");
-                           ok = load_db_v0_0_2(fh, lognum, logpos);
+                                   "db_load() - loading db of v2");
+                           ok = db_load_v0_0_2(fh, lognum, logpos);
                            break;
                        case 3:
                            /* mmstatd 0.0.3 db v3 */
                            syslog(LOG_NOTICE,
-                                   "load_db() - loading db of v3");
-                           ok = load_db_v0_0_3(fh, lognum, logpos);
+                                   "db_load() - loading db of v3");
+                           ok = db_load_v0_0_3(fh, lognum, logpos);
                            break;
                        default:
                            {
@@ -767,8 +768,8 @@ load_db(long *lognum, off_t *logpos)
                                 */
                                fseek(fh, 0, SEEK_SET);
                                syslog(LOG_NOTICE,
-                                       "load_db() - loading db of v1");
-                               ok = load_db_v0_0_1(fh, &o_lognum, &o_logpos);
+                                       "db_load() - loading db of v1");
+                               ok = db_load_v0_0_1(fh, &o_lognum, &o_logpos);
                                *lognum = o_lognum;
                                *logpos = (off_t)o_logpos;
                            }
@@ -777,17 +778,17 @@ load_db(long *lognum, off_t *logpos)
                } else ok = FALSE;
                fclose(fh);
            } else
-               syslog(LOG_NOTICE, "load_db() - New database");
+               syslog(LOG_NOTICE, "db_load() - New database");
        }
     }
     if (!ok) {
-       syslog(LOG_NOTICE, "load_db() - Error loading database (corrupt)");
+       syslog(LOG_NOTICE, "db_load() - Error loading database (corrupt)");
     }
 }
 
 
 static bool
-load_db_v0_0_1(FILE *fh, long *lognum, long *logpos)
+db_load_v0_0_1(FILE *fh, long *lognum, long *logpos)
 {
     struct key_node *knod = NULL;
     struct data_node *dnod = NULL;
@@ -836,7 +837,7 @@ load_db_v0_0_1(FILE *fh, long *lognum, long *logpos)
 
 
 static bool
-load_db_v0_0_2(FILE *fh, long *lognum, off_t *logpos)
+db_load_v0_0_2(FILE *fh, long *lognum, off_t *logpos)
 {
     struct key_node *knod = NULL;
     struct data_node *dnod = NULL;
@@ -885,7 +886,7 @@ load_db_v0_0_2(FILE *fh, long *lognum, off_t *logpos)
 
 
 static bool
-load_db_v0_0_3(FILE *fh, long *lognum, off_t *logpos)
+db_load_v0_0_3(FILE *fh, long *lognum, off_t *logpos)
 {
     struct key_node *knod = NULL;
     struct data_node *dnod = NULL;
@@ -940,7 +941,7 @@ load_db_v0_0_3(FILE *fh, long *lognum, off_t *logpos)
  */
 /* XXX Make file format portable among various endian architectures */
 static void
-sync_db(long lognum, off_t logpos, bool all)
+db_sync(long lognum, off_t logpos, bool all)
 {
     char old_db[256], new_db[256];
     FILE *fh;
@@ -1024,7 +1025,7 @@ sync_db(long lognum, off_t logpos, bool all)
 
 
 static void
-free_db(void)
+db_free(void)
 {
     if (POOL_VALID(&data_pool)) pool_destroy(&data_pool);
     LIST_INIT(&data_list);
@@ -1038,7 +1039,7 @@ free_db(void)
  * be executed when the logging daemon process is not running.
  */
 static void
-recover_db(void)
+db_recover(void)
 {
     int fd;
     long lognum, len;
@@ -1054,7 +1055,7 @@ recover_db(void)
      */
     ok = FALSE;
     snprintf(filename, 255, "%s/%s", CONF.ENV_DIR, "mmstatd.db");
-    load_db(&lognum, &logpos);
+    db_load(&lognum, &logpos);
 
     /* If any, start processing logs, but make sure to only start after
      * lognum/logpos, if there are any remaining, since we are only
@@ -1063,27 +1064,27 @@ recover_db(void)
     snprintf(filename, 255, "%s/%08ld.log", CONF.ENV_DIR, lognum);
     if ((fd = open(filename, O_RDONLY)) != -1) {
        if (logpos > 0) lseek(fd, logpos, SEEK_SET);
-       while ((len = readlogentries(-1, lentry, MAX_TRANSACT, &fd, &lognum,
+       while ((len = logentries_read(-1, lentry, MAX_TRANSACT, &fd, &lognum,
                        &logpos)))
-           if (!processlogentries(lentry, len, FALSE)) {
-               syslog(LOG_NOTICE, "recover_db() - processlogentries()");
+           if (!logentries_process(lentry, len, FALSE)) {
+               syslog(LOG_NOTICE, "db_recover() - logentries_process()");
                break;
            }
        close(fd);
     } else
-       syslog(LOG_NOTICE, "recover_db() - open(%s)", filename);
+       syslog(LOG_NOTICE, "db_recover() - open(%s)", filename);
 
     /* Sync back db to disk and delete obsolete recovery logs */
     lognum = 0;
     logpos = 0;
-    sync_db(lognum, logpos, TRUE);
-    free_db();
+    db_sync(lognum, logpos, TRUE);
+    db_free();
 }
 
 
 /* key char array should be KEY_SIZE bytes in size */
 static void
-writestats(int fd, char *key)
+stats_write(int fd, char *key)
 {
     u_int64_t hash;
     struct data_node *dnod;
@@ -1099,7 +1100,7 @@ writestats(int fd, char *key)
            /* Full statistics report request */
            for (dnod = (struct data_node *)data_list.top; dnod && pipesend;
                    dnod = (struct data_node *)dnod->node.node.next)
-               write(fd, &dnod->entry, sizeof(MMSTATENT));
+               write(fd, &dnod->entry, sizeof(mmstatent_t));
            ddirection = 0;
        } else {
            for (ptr = key; *ptr; ptr++)
@@ -1110,7 +1111,7 @@ writestats(int fd, char *key)
                        dnod && pipesend;
                        dnod = (struct data_node *)dnod->node.node.next) {
                    if (log_match(dnod->entry.key, key))
-                       write(fd, &dnod->entry, sizeof(MMSTATENT));
+                       write(fd, &dnod->entry, sizeof(mmstatent_t));
                }
                ddirection = 0;
            } else {
@@ -1128,7 +1129,7 @@ writestats(int fd, char *key)
                kdirection = !kdirection;
                if (knod && pipesend) {
                    dnod = knod->data;
-                   write(fd, &dnod->entry, sizeof(MMSTATENT));
+                   write(fd, &dnod->entry, sizeof(mmstatent_t));
                }
            }
        }
@@ -1137,7 +1138,7 @@ writestats(int fd, char *key)
 
 
 static void
-rotatestats(char *pattern, char *prefix)
+stats_rotate(char *pattern, char *prefix)
 {
     struct key_node *knod;
     char key[KEY_SIZE + 1];
@@ -1297,9 +1298,9 @@ main(int argc, char **argv)
     if (mmdropprivs(uid, gids, ngids)) {
        mmfreegidarray(gids);
        /* Launch the librarian process */
-       if ((librarian_pid = spawn_process(librarian_init, NULL, TRUE))
+       if ((librarian_pid = process_spawn(librarian_init, NULL, TRUE))
                == -1) {
-           syslog(LOG_NOTICE, "* main() - spawn_process(librarian)");
+           syslog(LOG_NOTICE, "* main() - process_spawn(librarian)");
            ret = -1;
        }
     } else {
@@ -1330,13 +1331,13 @@ librarian_init(void *args)
        syslog(LOG_NOTICE, "* librarian_init() - Can't write pid file");
 
     /* Perform recovery */
-    recover_db();
+    db_recover();
 
     /* Prepare our notification pipe */
     if (!(pipe(pipefds))) {
 
        /* Start the logger process */
-       if ((logger_pid = spawn_process(logger_init, NULL, FALSE)) != -1) {
+       if ((logger_pid = process_spawn(logger_init, NULL, FALSE)) != -1) {
            char filename[256];
            long lognum;
            off_t logpos;
@@ -1349,7 +1350,7 @@ librarian_init(void *args)
                            TRUE, TRUE)) != -1) {
                syslog(LOG_NOTICE, "Loading database");
                /* Because we recovered, lognum and logpos will be 0 */
-               load_db(&lognum, &logpos);
+               db_load(&lognum, &logpos);
                /* Make sure that we open for reading the file that the logger
                 * opened for writing
                 */
@@ -1366,8 +1367,8 @@ librarian_init(void *args)
                } else
                    syslog(LOG_NOTICE, "* librarian_init() - open(%s)",
                            filename);
-               sync_db(lognum, logpos, FALSE);
-               free_db();
+               db_sync(lognum, logpos, FALSE);
+               db_free();
                close(ufd);
                unlink(CONF.STAT_SOCKET);
            } else
@@ -1375,7 +1376,7 @@ librarian_init(void *args)
                        CONF.STAT_SOCKET);
        } else
            syslog(LOG_NOTICE,
-                   "* librarian_init() - spawn_process(librarian)");
+                   "* librarian_init() - process_spawn(librarian)");
 
        close(pipefds[0]);
        pipefds[0] = -1;
@@ -1419,9 +1420,9 @@ librarian_main(int pfd, int ufd, int lfd, long *lognum, off_t *logpos)
        if (poll(fds, 2, 60000) > 0) {
            /* Process more log entries if any */
            if (fds[0].revents & POLLIN) {
-               if ((len = readlogentries(pfd, entries, MAX_TRANSACT, &lfd,
+               if ((len = logentries_read(pfd, entries, MAX_TRANSACT, &lfd,
                                lognum, logpos)))
-                   processlogentries(entries, len, TRUE);
+                   logentries_process(entries, len, TRUE);
            }
            /* Verify if we obtain a report request connection */
            if (fds[1].revents & POLLIN) {
@@ -1456,14 +1457,14 @@ librarian_main(int pfd, int ufd, int lfd, long *lognum, off_t *logpos)
                                        if (read(sfd, key, KEY_SIZE) ==
                                                KEY_SIZE) {
                                            shutdown(sfd, SHUT_RD);
-                                           if (pipesend) writestats(sfd, key);
+                                           if (pipesend) stats_write(sfd, key);
                                        }
                                    } else if (c == 'r') {
                                        if (read(sfd, key, KEY_SIZE) ==
                                                KEY_SIZE &&
                                                read(sfd, key2, KEY_SIZE) ==
                                                KEY_SIZE) {
-                                           rotatestats(key, key2);
+                                           stats_rotate(key, key2);
                                            /* Force immediate db sync */
                                            secs += CONF.SYNC_INTERVAL;
                                        }
@@ -1484,7 +1485,7 @@ librarian_main(int pfd, int ufd, int lfd, long *lognum, off_t *logpos)
        secs += (time(NULL) - otim);
        if (secs > CONF.SYNC_INTERVAL) {
            secs = 0;
-           sync_db(*lognum, *logpos, FALSE);
+           db_sync(*lognum, *logpos, FALSE);
        }
     }
 }
@@ -1608,7 +1609,7 @@ logger_main(int pfd, int ufd, int lfd, long *lognum, off_t *logpos)
                         * it consists of a transaction.
                         */
                        if (len == sizeof(struct log_entry)) {
-                           if (!writelogentries(pfd, entries, 1, &lfd, lognum,
+                           if (!logentries_write(pfd, entries, 1, &lfd, lognum,
                                        logpos))
                                syslog(LOG_NOTICE,
                                        "logger_main() - Error writing logs!");
@@ -1619,7 +1620,7 @@ logger_main(int pfd, int ufd, int lfd, long *lognum, off_t *logpos)
                                        &aentries[MAX_TRANSACT + 1],
                                        sizeof(struct log_entry));
                            t += 2;
-                           if (!writelogentries(pfd, aentries, t, &lfd,
+                           if (!logentries_write(pfd, aentries, t, &lfd,
                                        lognum, logpos))
                                syslog(LOG_NOTICE,
                                       "logger_main() - Error writing logs!");