/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,2009 Teddy Hogeborn
6
 
 * Copyright © 2008,2009 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 */
 
30
#include <errno.h>              /* errno, EEXIST */
34
31
#include <stdio.h>              /* perror() */
35
 
#include <stdlib.h>             /* EXIT_FAILURE, NULL, size_t, free(),
 
32
#include <stdlib.h>             /* EXIT_FAILURE, NULL, size_t, free(), 
36
33
                                   realloc(), EXIT_SUCCESS */
37
34
#include <fcntl.h>              /* open(), O_RDONLY */
38
35
#include <unistd.h>             /* read(), close(), write(),
39
36
                                   STDOUT_FILENO */
40
 
#include <sysexits.h>           /* EX_OSERR, EX_OSFILE,
41
 
                                   EX_UNAVAILABLE, EX_IOERR */
42
37
 
43
38
 
44
39
int main(__attribute__((unused))int argc,
48
43
  
49
44
  /* Create FIFO */
50
45
  const char passfifo[] = "/lib/cryptsetup/passfifo";
51
 
  ret = mkfifo(passfifo, S_IRUSR | S_IWUSR);
52
 
  if(ret == -1){
53
 
    int e = errno;
 
46
  ret = TEMP_FAILURE_RETRY(mkfifo(passfifo, S_IRUSR | S_IWUSR));
 
47
  if(ret == -1 and errno != EEXIST){
54
48
    perror("mkfifo");
55
 
    switch(e){
56
 
    case EACCES:
57
 
    case ENOTDIR:
58
 
    case ELOOP:
59
 
      return EX_OSFILE;
60
 
    case ENAMETOOLONG:
61
 
    case ENOSPC:
62
 
    case EROFS:
63
 
    default:
64
 
      return EX_OSERR;
65
 
    case ENOENT:
66
 
      return EX_UNAVAILABLE;    /* no "/lib/cryptsetup"? */
67
 
    case EEXIST:
68
 
      break;                    /* not an error */
69
 
    }
 
49
    return EXIT_FAILURE;
70
50
  }
71
51
  
72
52
  /* Open FIFO */
73
 
  int fifo_fd = open(passfifo, O_RDONLY);
 
53
  int fifo_fd = TEMP_FAILURE_RETRY(open(passfifo, O_RDONLY));
74
54
  if(fifo_fd == -1){
75
 
    int e = errno;
76
55
    perror("open");
77
 
    switch(e){
78
 
    case EACCES:
79
 
    case ENOENT:
80
 
    case EFAULT:
81
 
      return EX_UNAVAILABLE;
82
 
    case ENAMETOOLONG:
83
 
    case EMFILE:
84
 
    case ENFILE:
85
 
    case ENOMEM:
86
 
    default:
87
 
      return EX_OSERR;
88
 
    case ENOTDIR:
89
 
    case ELOOP:
90
 
      return EX_OSFILE;
91
 
    }
 
56
    return EXIT_FAILURE;
92
57
  }
93
58
  
94
59
  /* Read from FIFO */
97
62
  {
98
63
    size_t buf_allocated = 0;
99
64
    const size_t blocksize = 1024;
100
 
    do {
 
65
    do{
101
66
      if(buf_len + blocksize > buf_allocated){
102
67
        char *tmp = realloc(buf, buf_allocated + blocksize);
103
68
        if(tmp == NULL){
104
69
          perror("realloc");
105
70
          free(buf);
106
 
          return EX_OSERR;
 
71
          return EXIT_FAILURE;
107
72
        }
108
73
        buf = tmp;
109
74
        buf_allocated += blocksize;
110
75
      }
111
 
      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));
112
78
      if(sret == -1){
113
 
        int e = errno;
 
79
        perror("read");
114
80
        free(buf);
115
 
        errno = e;
116
 
        perror("read");
117
 
        switch(e){
118
 
        case EBADF:
119
 
        case EFAULT:
120
 
        case EINVAL:
121
 
        default:
122
 
          return EX_OSERR;
123
 
        case EIO:
124
 
          return EX_IOERR;
125
 
        case EISDIR:
126
 
          return EX_UNAVAILABLE;
127
 
        }
 
81
        return EXIT_FAILURE;
128
82
      }
129
83
      buf_len += (size_t)sret;
130
 
    } while(sret != 0);
 
84
    }while(sret != 0);
131
85
  }
132
86
  
133
87
  /* Close FIFO */
134
 
  close(fifo_fd);
 
88
  TEMP_FAILURE_RETRY(close(fifo_fd));
135
89
  
136
90
  /* Print password to stdout */
137
91
  size_t written = 0;
138
92
  while(written < buf_len){
139
 
    sret = write(STDOUT_FILENO, buf + written, buf_len - written);
 
93
    sret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO, buf + written,
 
94
                                    buf_len - written));
140
95
    if(sret == -1){
141
 
      int e = errno;
 
96
      perror("write");
142
97
      free(buf);
143
 
      errno = e;
144
 
      perror("write");
145
 
      switch(e){
146
 
      case EBADF:
147
 
      case EFAULT:
148
 
      case EINVAL:
149
 
        return EX_OSFILE;
150
 
      case EFBIG:
151
 
      case EIO:
152
 
      case ENOSPC:
153
 
      default:
154
 
        return EX_IOERR;
155
 
      }
 
98
      return EXIT_FAILURE;
156
99
    }
157
100
    written += (size_t)sret;
158
101
  }
159
102
  free(buf);
160
103
  
161
 
  ret = close(STDOUT_FILENO);
162
 
  if(ret == -1){
163
 
    int e = errno;
164
 
    perror("close");
165
 
    switch(e){
166
 
    case EBADF:
167
 
      return EX_OSFILE;
168
 
    case EIO:
169
 
    default:
170
 
      return EX_IOERR;
171
 
    }
172
 
  }
173
104
  return EXIT_SUCCESS;
174
105
}