]> git.ipfire.org Git - thirdparty/rng-tools.git/blobdiff - rngd.c
rngd_linux: Log a warning if write_wakeup_threshold can't be adjusted
[thirdparty/rng-tools.git] / rngd.c
diff --git a/rngd.c b/rngd.c
index 6a7f1204c85f290cc930ff914165c6d9cfeafeb0..f1b7e1a9165faf0cd75a9b1554c3704a9c6f4bbe 100644 (file)
--- a/rngd.c
+++ b/rngd.c
@@ -45,6 +45,7 @@
 #include <string.h>
 #include <argp.h>
 #include <syslog.h>
+#include <signal.h>
 
 #include "rngd.h"
 #include "fips.h"
@@ -57,7 +58,9 @@
  */
 
 /* Background/daemon mode */
-int am_daemon;                         /* Nonzero if we went daemon */
+bool am_daemon;                                /* True if we went daemon */
+
+bool server_running = true;            /* set to false, to stop daemon */
 
 /* Command line arguments and processing */
 const char *argp_program_version =
@@ -81,7 +84,10 @@ static struct argp_option options[] = {
          "Kernel device used for random number output (default: /dev/random)" },
 
        { "rng-device", 'r', "file", 0,
-         "Kernel device used for random number input (default: /dev/hw_random)" },
+         "Kernel device used for random number input (default: /dev/hwrng)" },
+
+       { "pid-file", 'p', "file", 0,
+         "File used for recording daemon PID, and multiple exclusion (default: /var/run/rngd.pid)" },
 
        { "random-step", 's', "nnn", 0,
          "Number of bytes written to random-device at a time (default: 64)" },
@@ -89,30 +95,43 @@ static struct argp_option options[] = {
        { "fill-watermark", 'W', "n", 0,
          "Do not stop feeding entropy to random-device until at least n bits of entropy are available in the pool (default: 2048), 0 <= n <= 4096" },
 
-       { "timeout", 't', "nnn", 0,
-         "Interval written to random-device when the entropy pool is full, in seconds (default: 60)" },
+       { "quiet", 'q', 0, 0, "Suppress error messages" },
+
+       { "verbose" ,'v', 0, 0, "Report available entropy sources" },
+
+       { "no-drng", 'd', "1|0", 0,
+         "Do not use drng as a source of random number input (default: 0)" },
+       
        { "no-tpm", 'n', "1|0", 0,
-         "do not use tpm as a source of random number input (default: 0)" },
+         "Do not use tpm as a source of random number input (default: 0)" },
 
        { 0 },
 };
 
 static struct arguments default_arguments = {
        .random_name    = "/dev/random",
-       .poll_timeout   = 60,
+       .pid_file       = "/var/run/rngd.pid",
        .random_step    = 64,
-       .fill_watermark = 2048,
-       .daemon         = 1,
-       .enable_tpm     = 1,
+       .daemon         = true,
+       .enable_drng    = true,
+       .enable_tpm     = true,
+       .quiet          = false,
+       .verbose        = false,
 };
 struct arguments *arguments = &default_arguments;
 
 static struct rng rng_default = {
-       .rng_name       = "/dev/hw_random",
+       .rng_name       = "/dev/hwrng",
        .rng_fd         = -1,
        .xread          = xread,
 };
 
+static struct rng rng_drng = {
+       .rng_name       = "drng",
+       .rng_fd         = -1,
+       .xread          = xread_drng,
+};
+
 static struct rng rng_tpm = {
        .rng_name       = "/dev/tpm0",
        .rng_fd         = -1,
@@ -130,23 +149,17 @@ static error_t parse_opt (int key, char *arg, struct argp_state *state)
        case 'o':
                arguments->random_name = arg;
                break;
+       case 'p':
+               arguments->pid_file = arg;
+               break;
        case 'r':
                rng_default.rng_name = arg;
                break;
-       case 't': {
-               float f;
-               if (sscanf(arg, "%f", &f) == 0)
-                       argp_usage(state);
-               else
-                       arguments->poll_timeout = f;
-               break;
-       }
-
        case 'f':
-               arguments->daemon = 0;
+               arguments->daemon = false;
                break;
        case 'b':
-               arguments->daemon = 1;
+               arguments->daemon = true;
                break;
        case 's':
                if (sscanf(arg, "%i", &arguments->random_step) == 0)
@@ -160,12 +173,26 @@ static error_t parse_opt (int key, char *arg, struct argp_state *state)
                        arguments->fill_watermark = n;
                break;
        }
+       case 'q':
+               arguments->quiet = true;
+               break;
+       case 'v':
+               arguments->verbose = true;
+               break;
+       case 'd': {
+               int n;
+               if ((sscanf(arg,"%i", &n) == 0) || ((n | 1)!=1))
+                       argp_usage(state);
+               else
+                       arguments->enable_drng = false;
+               break;
+       }
        case 'n': {
                int n;
                if ((sscanf(arg,"%i", &n) == 0) || ((n | 1)!=1))
                        argp_usage(state);
                else
-                       arguments->enable_tpm = 0;
+                       arguments->enable_tpm = false;
                break;
        }
 
@@ -179,30 +206,31 @@ static error_t parse_opt (int key, char *arg, struct argp_state *state)
 static struct argp argp = { options, parse_opt, NULL, doc };
 
 
-static int update_kernel_random(int random_step, double poll_timeout,
-       unsigned char *buf, fips_ctx_t *fipsctx)
+static int update_kernel_random(int random_step,
+       unsigned char *buf, fips_ctx_t *fipsctx_in)
 {
        unsigned char *p;
        int fips;
 
-       fips = fips_run_rng_test(fipsctx, buf);
+       fips = fips_run_rng_test(fipsctx_in, buf);
        if (fips) {
-               message(LOG_DAEMON|LOG_ERR, "failed fips test\n");
+               if (!arguments->quiet)
+                       message(LOG_DAEMON|LOG_ERR, "failed fips test\n");
                return 1;
        }
 
        for (p = buf; p + random_step <= &buf[FIPS_RNG_BUFFER_SIZE];
                 p += random_step) {
                random_add_entropy(p, random_step);
-               random_sleep(poll_timeout);
+               random_sleep();
        }
        return 0;
 }
 
-static void do_loop(int random_step, double poll_timeout)
+static void do_loop(int random_step)
 {
        unsigned char buf[FIPS_RNG_BUFFER_SIZE];
-       int retval;
+       int retval = 0;
        int no_work = 0;
 
        while (no_work < 100) {
@@ -214,6 +242,9 @@ static void do_loop(int random_step, double poll_timeout)
                {
                        int rc;
 
+                       if (!server_running)
+                               return;
+
                        if (iter->disabled)
                                continue;       /* failed, no work */
 
@@ -224,14 +255,14 @@ static void do_loop(int random_step, double poll_timeout)
                        work_done = true;
 
                        rc = update_kernel_random(random_step,
-                                            poll_timeout, buf,
-                                            iter->fipsctx);
+                                            buf, iter->fipsctx);
                        if (rc == 0)
-                               continue;       /* succeeded, work done */
+                               break;  /* succeeded, work done */
 
                        iter->failures++;
                        if (iter->failures == MAX_RNG_FAILURES) {
-                               message(LOG_DAEMON|LOG_ERR,
+                               if (!arguments->quiet)
+                                       message(LOG_DAEMON|LOG_ERR,
                                        "too many FIPS failures, disabling entropy source\n");
                                iter->disabled = true;
                        }
@@ -241,28 +272,64 @@ static void do_loop(int random_step, double poll_timeout)
                        no_work++;
        }
 
-       message(LOG_DAEMON|LOG_ERR,
+       if (!arguments->quiet)
+               message(LOG_DAEMON|LOG_ERR,
                "No entropy sources working, exiting rngd\n");
 }
 
+static void term_signal(int signo)
+{
+       server_running = false;
+}
+
 int main(int argc, char **argv)
 {
        int rc_rng = 1;
+       int rc_drng = 1;
        int rc_tpm = 1;
+       int pid_fd = -1;
+
+       openlog("rngd", 0, LOG_DAEMON);
+
+       /* Get the default watermark level for this platform */
+       arguments->fill_watermark = default_watermark();
 
        /* Parsing of commandline parameters */
        argp_parse(&argp, argc, argv, 0, 0, arguments);
 
        /* Init entropy sources, and open TRNG device */
        rc_rng = init_entropy_source(&rng_default);
+       if (arguments->enable_drng)
+               rc_drng = init_drng_entropy_source(&rng_drng);
        if (arguments->enable_tpm)
                rc_tpm = init_tpm_entropy_source(&rng_tpm);
 
-       if (rc_rng && rc_tpm) {
-               message(LOG_DAEMON|LOG_ERR,
-                       "can't open entropy source(tpm or intel/amd rng)");
-               message(LOG_DAEMON|LOG_ERR,
-                       "Maybe RNG device modules are not loaded\n");
+       if (rc_rng && rc_drng && rc_tpm) {
+               if (!arguments->quiet) {
+                       message(LOG_DAEMON|LOG_ERR,
+                               "can't open entropy source(tpm or intel/amd rng)");
+                       message(LOG_DAEMON|LOG_ERR,
+                               "Maybe RNG device modules are not loaded\n");
+               }
+               return 1;
+       }
+
+       if (arguments->verbose) {
+               printf("Available entropy sources:\n");
+               if (!rc_rng)
+                       printf("\tIntel/AMD hardware rng\n");
+               if (!rc_drng)
+                       printf("\tDRNG\n");
+               if (!rc_tpm)
+                       printf("\tTPM\n");
+       }
+
+       if (rc_rng
+               && (rc_drng || !arguments->enable_drng)
+               && (rc_tpm || !arguments->enable_tpm)) {
+               if (!arguments->quiet)
+                       message(LOG_DAEMON|LOG_ERR,
+               "No entropy source available, shutting down\n");
                return 1;
        }
 
@@ -270,19 +337,30 @@ int main(int argc, char **argv)
        init_kernel_rng(arguments->random_name);
 
        if (arguments->daemon) {
-               am_daemon = 1;
+               am_daemon = true;
 
                if (daemon(0, 0) < 0) {
-                       fprintf(stderr, "can't daemonize: %s\n",
+                       if(!arguments->quiet)
+                               fprintf(stderr, "can't daemonize: %s\n",
                                strerror(errno));
                        return 1;
                }
 
-               openlog("rngd", 0, LOG_DAEMON);
+               /* require valid, locked PID file to proceed */
+               pid_fd = write_pid_file(arguments->pid_file);
+               if (pid_fd < 0)
+                       return 1;
+
+               signal(SIGHUP, SIG_IGN);
+               signal(SIGPIPE, SIG_IGN);
+               signal(SIGINT, term_signal);
+               signal(SIGTERM, term_signal);
        }
 
-       do_loop(arguments->random_step,
-               arguments->poll_timeout ? : -1.0);
+       do_loop(arguments->random_step);
+
+       if (pid_fd >= 0)
+               unlink(arguments->pid_file);
 
        return 0;
 }