git.gag.com Git - debian/amanda/blob - common-src/ssh-security.c

   1 /*
   2  * Amanda, The Advanced Maryland Automatic Network Disk Archiver
   3  * Copyright (c) 1999 University of Maryland
   4  * All Rights Reserved.
   5  *
   6  * Permission to use, copy, modify, distribute, and sell this software and its
   7  * documentation for any purpose is hereby granted without fee, provided that
   8  * the above copyright notice appear in all copies and that both that
   9  * copyright notice and this permission notice appear in supporting
  10  * documentation, and that the name of U.M. not be used in advertising or
  11  * publicity pertaining to distribution of the software without specific,
  12  * written prior permission.  U.M. makes no representations about the
  13  * suitability of this software for any purpose.  It is provided "as is"
  14  * without express or implied warranty.
  15  *
  16  * U.M. DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING ALL
  17  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL U.M.
  18  * BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  19  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION
  20  * OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN
  21  * CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  22  *
  23  * Authors: the Amanda Development Team.  Its members are listed in a
  24  * file named AUTHORS, in the root directory of this distribution.
  25  */
  26
  27 /*
  28  * $Id: ssh-security.c,v 1.23 2006/08/21 20:17:10 martinea Exp $
  29  *
  30  * ssh-security.c - security and transport over ssh or a ssh-like command.
  31  *
  32  * XXX still need to check for initial keyword on connect so we can skip
  33  * over shell garbage and other stuff that ssh might want to spew out.
  34  */
  35
  36 #include "amanda.h"
  37 #include "util.h"
  38 #include "event.h"
  39 #include "packet.h"
  40 #include "queue.h"
  41 #include "security.h"
  42 #include "security-util.h"
  43 #include "stream.h"
  44 #include "version.h"
  45
  46 /*
  47  * Number of seconds ssh has to start up
  48  */
  49 #define CONNECT_TIMEOUT 20
  50
  51 /*
  52  * Magic values for ssh_conn->handle
  53  */
  54 #define H_TAKEN -1              /* ssh_conn->tok was already read */
  55 #define H_EOF   -2              /* this connection has been shut down */
  56
  57 /*
  58  * Interface functions
  59  */
  60 static void     ssh_connect(const char *, char *(*)(char *, void *),
  61                         void (*)(void *, security_handle_t *, security_status_t),
  62                         void *, void *);
  63
  64 /*
  65  * This is our interface to the outside world.
  66  */
  67 const security_driver_t ssh_security_driver = {
  68     "SSH",
  69     ssh_connect,
  70     sec_accept,
  71     sec_close,
  72     stream_sendpkt,
  73     stream_recvpkt,
  74     stream_recvpkt_cancel,
  75     tcpma_stream_server,
  76     tcpma_stream_accept,
  77     tcpma_stream_client,
  78     tcpma_stream_close,
  79     sec_stream_auth,
  80     sec_stream_id,
  81     tcpm_stream_write,
  82     tcpm_stream_read,
  83     tcpm_stream_read_sync,
  84     tcpm_stream_read_cancel,
  85     tcpm_close_connection,
  86     NULL,
  87     NULL
  88 };
  89
  90 static int newhandle = 1;
  91
  92 /*
  93  * Local functions
  94  */
  95 static int runssh(struct tcp_conn *, const char *, const char *, const char *);
  96
  97 /*
  98  * ssh version of a security handle allocator.  Logically sets
  99  * up a network "connection".
 100  */
 101 static void
 102 ssh_connect(
 103     const char *        hostname,
 104     char *              (*conf_fn)(char *, void *),
 105     void                (*fn)(void *, security_handle_t *, security_status_t),
 106     void *              arg,
 107     void *              datap)
 108 {
 109     struct sec_handle *rh;
 110     char *amandad_path=NULL, *client_username=NULL, *ssh_keys=NULL;
 111
 112     assert(fn != NULL);
 113     assert(hostname != NULL);
 114
 115     auth_debug(1, "ssh_connect: %s\n", hostname);
 116
 117     rh = alloc(SIZEOF(*rh));
 118     security_handleinit(&rh->sech, &ssh_security_driver);
 119     rh->hostname = NULL;
 120     rh->rs = NULL;
 121     rh->ev_timeout = NULL;
 122     rh->rc = NULL;
 123
 124     rh->hostname = NULL;
 125     if (resolve_hostname(hostname, 0, NULL, &rh->hostname) || rh->hostname == NULL) {
 126         security_seterror(&rh->sech,
 127             _("%s: ssh could not resolve hostname"), hostname);
 128         (*fn)(arg, &rh->sech, S_ERROR);
 129         return;
 130     }
 131     rh->rs = tcpma_stream_client(rh, newhandle++);
 132     rh->rc->conf_fn = conf_fn;
 133     rh->rc->datap = datap;
 134
 135     if (rh->rs == NULL)
 136         goto error;
 137
 138     amfree(rh->hostname);
 139     rh->hostname = stralloc(rh->rs->rc->hostname);
 140
 141     /*
 142      * We need to open a new connection.
 143      *
 144      * XXX need to eventually limit number of outgoing connections here.
 145      */
 146     if(conf_fn) {
 147         amandad_path    = conf_fn("amandad_path", datap);
 148         client_username = conf_fn("client_username", datap);
 149         ssh_keys        = conf_fn("ssh_keys", datap);
 150     }
 151     if(rh->rc->read == -1) {
 152         if (runssh(rh->rs->rc, amandad_path, client_username, ssh_keys) < 0) {
 153             security_seterror(&rh->sech, _("can't connect to %s: %s"),
 154                               hostname, rh->rs->rc->errmsg);
 155             goto error;
 156         }
 157         rh->rc->refcnt++;
 158     }
 159
 160     /*
 161      * The socket will be opened async so hosts that are down won't
 162      * block everything.  We need to register a write event
 163      * so we will know when the socket comes alive.
 164      *
 165      * Overload rh->rs->ev_read to provide a write event handle.
 166      * We also register a timeout.
 167      */
 168     rh->fn.connect = fn;
 169     rh->arg = arg;
 170     rh->rs->ev_read = event_register((event_id_t)rh->rs->rc->write, EV_WRITEFD,
 171         sec_connect_callback, rh);
 172     rh->ev_timeout = event_register((event_id_t)CONNECT_TIMEOUT, EV_TIME,
 173         sec_connect_timeout, rh);
 174
 175     return;
 176
 177 error:
 178     (*fn)(arg, &rh->sech, S_ERROR);
 179 }
 180
 181 /*
 182  * Forks a ssh to the host listed in rc->hostname
 183  * Returns negative on error, with an errmsg in rc->errmsg.
 184  */
 185 static int
 186 runssh(
 187     struct tcp_conn *   rc,
 188     const char *        amandad_path,
 189     const char *        client_username,
 190     const char *        ssh_keys)
 191 {
 192     int rpipe[2], wpipe[2];
 193     char *xamandad_path = (char *)amandad_path;
 194     char *xclient_username = (char *)client_username;
 195     char *xssh_keys = (char *)ssh_keys;
 196
 197     memset(rpipe, -1, SIZEOF(rpipe));
 198     memset(wpipe, -1, SIZEOF(wpipe));
 199     if (pipe(rpipe) < 0 || pipe(wpipe) < 0) {
 200         rc->errmsg = newvstrallocf(rc->errmsg, _("pipe: %s"), strerror(errno));
 201         return (-1);
 202     }
 203
 204     switch (rc->pid = fork()) {
 205     case -1:
 206         rc->errmsg = newvstrallocf(rc->errmsg, _("fork: %s"), strerror(errno));
 207         aclose(rpipe[0]);
 208         aclose(rpipe[1]);
 209         aclose(wpipe[0]);
 210         aclose(wpipe[1]);
 211         return (-1);
 212     case 0:
 213         dup2(wpipe[0], 0);
 214         dup2(rpipe[1], 1);
 215         break;
 216     default:
 217         rc->read = rpipe[0];
 218         aclose(rpipe[1]);
 219         rc->write = wpipe[1];
 220         aclose(wpipe[0]);
 221         return (0);
 222     }
 223
 224     safe_fd(-1, 0);
 225
 226     if(!xamandad_path || strlen(xamandad_path) <= 1)
 227         xamandad_path = vstralloc(amlibexecdir, "/", "amandad",
 228                                  versionsuffix(), NULL);
 229     if(!xclient_username || strlen(xclient_username) <= 1)
 230         xclient_username = CLIENT_LOGIN;
 231     if(!ssh_keys || strlen(ssh_keys) <= 1) {
 232         execlp(SSH, SSH, SSH_OPTIONS, "-l", xclient_username,
 233                rc->hostname, xamandad_path, "-auth=ssh", "amdump", "amindexd",
 234                "amidxtaped", (char *)NULL);
 235     }
 236     else {
 237         execlp(SSH, SSH, SSH_OPTIONS, "-l", xclient_username,
 238                "-i", xssh_keys, rc->hostname, xamandad_path, "-auth=ssh",
 239                "amdump", "amindexd", "amidxtaped", (char *)NULL);
 240     }
 241     error("error: couldn't exec %s: %s", SSH, strerror(errno));
 242
 243     /* should never go here, shut up compiler warning */
 244     return(-1);
 245 }