/mandos/trunk

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/trunk

« back to all changes in this revision

Viewing changes to plugins.d/askpass-fifo.c

  • Committer: Teddy Hogeborn
  • Date: 2008-12-10 01:26:02 UTC
  • mfrom: (237.1.2 mandos)
  • Revision ID: teddy@fukt.bsnet.se-20081210012602-vhz3h75xkj24t340
First version of a somewhat complete D-Bus server interface.  Also
change user/group name to "_mandos".

* debian/mandos.postinst: Rename old "mandos" user and group to
                          "_mandos"; create "_mandos" user and group
                          if none exist.
* debian/mandos-client.postinst: - '' -

* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
                        group name.

* mandos (_datetime_to_dbus_struct): New; was previously local.
  (Client.started): Renamed to "last_started".  All users changed.
  (Client.started): New; boolean.
  (Client.dbus_object_path): New.
  (Client.check_command): Renamed to "checker_command".  All users
                          changed.
  (Client.__init__): Set and use "self.dbus_object_path".  Set
                     "self.started".
  (Client.start): Update "self.started".  Emit "self.PropertyChanged"
                  signals for both "started" and "last_started".
  (Client.stop): Update "self.started".  Emit "self.PropertyChanged"
                 signal for "started".
  (Client.checker_callback): Take additional "command" argument.  All
                             callers changed. Emit
                             "self.PropertyChanged" signal.
  (Client.bump_timeout): Emit "self.PropertyChanged" signal for
                         "last_checked_ok".
  (Client.start_checker): Emit "self.PropertyChanged" signal for
                          "checker_running".
  (Client.stop_checker): Emit "self.PropertyChanged" signal for
                         "checker_running".
  (Client.still_valid): Bug fix: use "getattr(self, started, False)"
                        instead of "self.started" in case this client
                        object is so new that the "started" attribute
                        has not been created yet.
  (Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
  Client.GetCreated, Client.GetFingerprint, Client.GetHost,
  Client.GetInterval, Client.GetName, Client.GetStarted,
  Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
  Removed; all callers changed.
  (Client.CheckerCompleted): Add "condition" and "command" arguments.
                             All callers changed.
  (Client.GetAllProperties, Client.PropertyChanged): New.
  (Client.StillValid): Renamed to "IsStillValid".
  (Client.StartChecker): Changed to its own function to avoid the
                         return value from "Client.start_checker()".
  (Client.Stop): Changed to its own function to avoid the return value
                 from "Client.stop()".
  (main): Try "_mandos" before "mandos" as user and group name.
          Removed inner function "remove_from_clients".  New inner
          class "MandosServer".

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugins.d/askpass-fifo.c
1
1
/*  -*- coding: utf-8 -*- */
2
2
/*
3
 
 * Askpass-FIFO - Read a password from a FIFO and output it
 
3
 * Passprompt - Read a password from a FIFO and output it
4
4
 * 
5
 
 * Copyright © 2008-2011 Teddy Hogeborn
6
 
 * Copyright © 2008-2011 Björn Påhlsson
 
5
 * Copyright © 2008 Teddy Hogeborn
 
6
 * Copyright © 2008 Björn Påhlsson
7
7
 * 
8
8
 * This program is free software: you can redistribute it and/or
9
9
 * modify it under the terms of the GNU General Public License as
19
19
 * along with this program.  If not, see
20
20
 * <http://www.gnu.org/licenses/>.
21
21
 * 
22
 
 * Contact the authors at <mandos@fukt.bsnet.se>.
 
22
 * Contact the authors at <https://www.fukt.bsnet.se/~belorn/> and
 
23
 * <https://www.fukt.bsnet.se/~teddy/>.
23
24
 */
24
25
 
25
26
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY() */
26
27
#include <sys/types.h>          /* ssize_t */
27
28
#include <sys/stat.h>           /* mkfifo(), S_IRUSR, S_IWUSR */
28
29
#include <iso646.h>             /* and */
29
 
#include <errno.h>              /* errno, EACCES, ENOTDIR, ELOOP,
30
 
                                   ENAMETOOLONG, ENOSPC, EROFS,
31
 
                                   ENOENT, EEXIST, EFAULT, EMFILE,
32
 
                                   ENFILE, ENOMEM, EBADF, EINVAL, EIO,
33
 
                                   EISDIR, EFBIG */
34
 
#include <error.h>              /* error() */
35
 
#include <stdio.h>              /* fprintf(), vfprintf(),
36
 
                                   vasprintf() */
37
 
#include <stdlib.h>             /* EXIT_FAILURE, NULL, size_t, free(),
 
30
#include <errno.h>              /* errno, EEXIST */
 
31
#include <stdio.h>              /* perror() */
 
32
#include <stdlib.h>             /* EXIT_FAILURE, NULL, size_t, free(), 
38
33
                                   realloc(), EXIT_SUCCESS */
39
34
#include <fcntl.h>              /* open(), O_RDONLY */
40
35
#include <unistd.h>             /* read(), close(), write(),
41
36
                                   STDOUT_FILENO */
42
 
#include <sysexits.h>           /* EX_OSERR, EX_OSFILE,
43
 
                                   EX_UNAVAILABLE, EX_IOERR */
44
 
#include <string.h>             /* strerror() */
45
 
#include <stdarg.h>             /* va_list, va_start(), ... */
46
 
 
47
 
 
48
 
/* Function to use when printing errors */
49
 
void error_plus(int status, int errnum, const char *formatstring,
50
 
                ...){
51
 
  va_list ap;
52
 
  char *text;
53
 
  int ret;
54
 
  
55
 
  va_start(ap, formatstring);
56
 
  ret = vasprintf(&text, formatstring, ap);
57
 
  if (ret == -1){
58
 
    fprintf(stderr, "Mandos plugin %s: ",
59
 
            program_invocation_short_name);
60
 
    vfprintf(stderr, formatstring, ap);
61
 
    fprintf(stderr, ": ");
62
 
    fprintf(stderr, "%s\n", strerror(errnum));
63
 
    error(status, errno, "vasprintf while printing error");
64
 
    return;
65
 
  }
66
 
  fprintf(stderr, "Mandos plugin ");
67
 
  error(status, errnum, "%s", text);
68
 
  free(text);
69
 
}
 
37
 
70
38
 
71
39
int main(__attribute__((unused))int argc,
72
40
         __attribute__((unused))char **argv){
75
43
  
76
44
  /* Create FIFO */
77
45
  const char passfifo[] = "/lib/cryptsetup/passfifo";
78
 
  ret = mkfifo(passfifo, S_IRUSR | S_IWUSR);
79
 
  if(ret == -1){
80
 
    int e = errno;
81
 
    switch(e){
82
 
    case EACCES:
83
 
    case ENOTDIR:
84
 
    case ELOOP:
85
 
      error_plus(EX_OSFILE, errno, "mkfifo");
86
 
    case ENAMETOOLONG:
87
 
    case ENOSPC:
88
 
    case EROFS:
89
 
    default:
90
 
      error_plus(EX_OSERR, errno, "mkfifo");
91
 
    case ENOENT:
92
 
      /* no "/lib/cryptsetup"? */
93
 
      error_plus(EX_UNAVAILABLE, errno, "mkfifo");
94
 
    case EEXIST:
95
 
      break;                    /* not an error */
96
 
    }
 
46
  ret = TEMP_FAILURE_RETRY(mkfifo(passfifo, S_IRUSR | S_IWUSR));
 
47
  if(ret == -1 and errno != EEXIST){
 
48
    perror("mkfifo");
 
49
    return EXIT_FAILURE;
97
50
  }
98
51
  
99
52
  /* Open FIFO */
100
 
  int fifo_fd = open(passfifo, O_RDONLY);
 
53
  int fifo_fd = TEMP_FAILURE_RETRY(open(passfifo, O_RDONLY));
101
54
  if(fifo_fd == -1){
102
 
    int e = errno;
103
 
    error_plus(0, errno, "open");
104
 
    switch(e){
105
 
    case EACCES:
106
 
    case ENOENT:
107
 
    case EFAULT:
108
 
      return EX_UNAVAILABLE;
109
 
    case ENAMETOOLONG:
110
 
    case EMFILE:
111
 
    case ENFILE:
112
 
    case ENOMEM:
113
 
    default:
114
 
      return EX_OSERR;
115
 
    case ENOTDIR:
116
 
    case ELOOP:
117
 
      return EX_OSFILE;
118
 
    }
 
55
    perror("open");
 
56
    return EXIT_FAILURE;
119
57
  }
120
58
  
121
59
  /* Read from FIFO */
124
62
  {
125
63
    size_t buf_allocated = 0;
126
64
    const size_t blocksize = 1024;
127
 
    do {
 
65
    do{
128
66
      if(buf_len + blocksize > buf_allocated){
129
67
        char *tmp = realloc(buf, buf_allocated + blocksize);
130
68
        if(tmp == NULL){
131
 
          error_plus(0, errno, "realloc");
 
69
          perror("realloc");
132
70
          free(buf);
133
 
          return EX_OSERR;
 
71
          return EXIT_FAILURE;
134
72
        }
135
73
        buf = tmp;
136
74
        buf_allocated += blocksize;
137
75
      }
138
 
      sret = read(fifo_fd, buf + buf_len, buf_allocated - buf_len);
 
76
      sret = TEMP_FAILURE_RETRY(read(fifo_fd, buf + buf_len,
 
77
                                     buf_allocated - buf_len));
139
78
      if(sret == -1){
140
 
        int e = errno;
 
79
        perror("read");
141
80
        free(buf);
142
 
        errno = e;
143
 
        error_plus(0, errno, "read");
144
 
        switch(e){
145
 
        case EBADF:
146
 
        case EFAULT:
147
 
        case EINVAL:
148
 
        default:
149
 
          return EX_OSERR;
150
 
        case EIO:
151
 
          return EX_IOERR;
152
 
        case EISDIR:
153
 
          return EX_UNAVAILABLE;
154
 
        }
 
81
        return EXIT_FAILURE;
155
82
      }
156
83
      buf_len += (size_t)sret;
157
 
    } while(sret != 0);
 
84
    }while(sret != 0);
158
85
  }
159
86
  
160
87
  /* Close FIFO */
161
 
  close(fifo_fd);
 
88
  TEMP_FAILURE_RETRY(close(fifo_fd));
162
89
  
163
90
  /* Print password to stdout */
164
91
  size_t written = 0;
165
92
  while(written < buf_len){
166
 
    sret = write(STDOUT_FILENO, buf + written, buf_len - written);
 
93
    sret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO, buf + written,
 
94
                                    buf_len - written));
167
95
    if(sret == -1){
168
 
      int e = errno;
 
96
      perror("write");
169
97
      free(buf);
170
 
      errno = e;
171
 
      error_plus(0, errno, "write");
172
 
      switch(e){
173
 
      case EBADF:
174
 
      case EFAULT:
175
 
      case EINVAL:
176
 
        return EX_OSFILE;
177
 
      case EFBIG:
178
 
      case EIO:
179
 
      case ENOSPC:
180
 
      default:
181
 
        return EX_IOERR;
182
 
      }
 
98
      return EXIT_FAILURE;
183
99
    }
184
100
    written += (size_t)sret;
185
101
  }
186
102
  free(buf);
187
103
  
188
 
  ret = close(STDOUT_FILENO);
189
 
  if(ret == -1){
190
 
    int e = errno;
191
 
    error_plus(0, errno, "close");
192
 
    switch(e){
193
 
    case EBADF:
194
 
      return EX_OSFILE;
195
 
    case EIO:
196
 
    default:
197
 
      return EX_IOERR;
198
 
    }
199
 
  }
200
104
  return EXIT_SUCCESS;
201
105
}