2 * Ported to Linux's Second Extended File System as part of the
3 * dump and restore backup suit
4 * Remy Card <card@Linux.EU.Org>, 1994-1997
5 * Stelian Pop <stelian@popies.net>, 1999-2000
6 * Stelian Pop <stelian@popies.net> - AlcĂ´ve <www.alcove.com>, 2000-2002
10 * Copyright (c) 1980, 1993
11 * The Regents of the University of California. All rights reserved.
13 * Redistribution and use in source and binary forms, with or without
14 * modification, are permitted provided that the following conditions
16 * 1. Redistributions of source code must retain the above copyright
17 * notice, this list of conditions and the following disclaimer.
18 * 2. Redistributions in binary form must reproduce the above copyright
19 * notice, this list of conditions and the following disclaimer in the
20 * documentation and/or other materials provided with the distribution.
21 * 3. Neither the name of the University nor the names of its contributors
22 * may be used to endorse or promote products derived from this software
23 * without specific prior written permission.
25 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
26 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
27 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
28 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
29 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
30 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
31 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
32 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
33 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
34 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
39 static const char rcsid[] =
40 "$Id: dumprmt.c,v 1.28 2003/10/26 16:05:45 stelian Exp $";
44 #include <sys/param.h>
46 #include <sys/socket.h>
50 #include <sys/types.h>
51 #ifdef HAVE_EXT2FS_EXT2_FS_H
52 #include <ext2fs/ext2_fs.h>
54 #include <linux/ext2_fs.h>
56 #include <bsdcompat.h>
59 #include <sys/vnode.h>
61 #include <ufs/inode.h>
63 #include <ufs/ufs/dinode.h>
66 #include <netinet/in.h>
67 #include <netinet/in_systm.h>
68 #include <netinet/ip.h>
69 #include <netinet/tcp.h>
71 #include <protocols/dumprestore.h>
75 #include <compaterr.h>
87 #include <ext2fs/ext2fs.h>
90 #include <pathnames.h>
91 #include "dump.h" /* for X_STARTUP, X_ABORT etc */
96 static int rmtstate = TS_CLOSED;
97 static int tormtape = -1;
98 static int fromrmtape = -1;
100 static const char *rmtpeer = 0;
102 static int okname __P((const char *));
103 static OFF_T rmtcall __P((const char *, const char *));
104 static void rmtconnaborted __P((int));
105 static int rmtgetb __P((void));
106 static int rmtgetconn __P((void));
107 static void rmtgets __P((char *, size_t));
108 static OFF_T rmtreply __P((const char *));
109 static int piped_child __P((const char **command));
111 int krcmd __P((char **, int /*u_short*/, char *, char *, int *, char *));
114 static int errfd = -1;
115 extern int dokerberos;
116 extern int ntrec; /* blocking factor on tape */
117 extern int abortifconnerr; /* set to 1 if this lib should exit on connection errors
118 otherwise just print a message using msg */
124 rmthost(const char *host)
127 free((void *)rmtpeer);
128 if ((rmtpeer = strdup(host)) == NULL)
130 signal(SIGPIPE, rmtconnaborted);
135 rmtconnaborted(UNUSED(int signo))
137 msg("Lost connection to remote host.\n");
146 if (select(errfd + 1, &r, NULL, NULL, &t)) {
150 if ((i = read(errfd, buf, sizeof(buf) - 1)) > 0) {
152 msg("on %s: %s%s", rmtpeer, buf,
153 buf[i - 1] == '\n' ? "" : "\n");
166 static struct servent *sp = NULL;
167 static struct passwd *pwd = NULL;
177 if (!rsh && sp == NULL) {
178 sp = getservbyname(dokerberos ? "kshell" : "shell", "tcp");
180 if (abortifconnerr) {
181 errx(1, "%s/tcp: unknown service", dokerberos ? "kshell" : "shell");
183 msg("%s/tcp: unknown service", dokerberos ? "kshell" : "shell");
189 pwd = getpwuid(getuid());
191 if (abortifconnerr) {
192 errx(1, "who are you?");
199 if ((cp = strchr(rmtpeer, '@')) != NULL) {
202 if (!okname(tuser)) {
203 if (abortifconnerr) {
211 tuser = pwd->pw_name;
212 if ((rmt = getenv("RMT")) == NULL)
217 const char *rshcmd[6];
225 /* Restore the uid and gid. We really don't want
226 * to execute whatever is put into RSH variable with
227 * more priviledges than needed... */
231 if ((rshpid = piped_child(rshcmd)) < 0) {
232 msg("cannot open connection\n");
237 /* Copy rmtpeer to rmtpeercopy to ignore the
238 return value from rcmd. I cannot figure if
239 this is this a bug in rcmd or in my code... */
240 rmtpeercopy = (char *)rmtpeer;
243 tormtape = krcmd(&rmtpeercopy, sp->s_port, tuser, rmt, &errfd,
247 tormtape = rcmd(&rmtpeercopy, (u_short)sp->s_port, pwd->pw_name,
250 msg("login to %s as %s failed.\n", rmtpeer, tuser);
253 size = ntrec * TP_BSIZE;
254 if (size > 60 * 1024) /* XXX */
256 /* Leave some space for rmt request/response protocol */
258 while (size > TP_BSIZE &&
259 setsockopt(tormtape, SOL_SOCKET, SO_SNDBUF, &size, sizeof (size)) < 0)
261 (void)setsockopt(tormtape, SOL_SOCKET, SO_RCVBUF, &size, sizeof (size));
262 throughput = IPTOS_THROUGHPUT;
263 if (setsockopt(tormtape, IPPROTO_IP, IP_TOS,
264 &throughput, sizeof(throughput)) < 0)
265 perror("IP_TOS:IPTOS_THROUGHPUT setsockopt");
267 if (setsockopt(tormtape, IPPROTO_TCP, TCP_NODELAY, &on, sizeof (on)) < 0)
268 perror("TCP_NODELAY setsockopt");
269 fromrmtape = tormtape;
271 (void)fprintf(stdout, "Connection to %s established.\n", rmtpeer);
276 okname(const char *cp0)
281 for (cp = cp0; *cp; cp++) {
283 if (!isascii(c) || !(isalnum(c) || c == '_' || c == '-')) {
284 warnx("invalid user name %s\n", cp0);
292 rmtopen(const char *tape, const int mode)
294 char buf[MAXPATHLEN];
297 rmtflags = rmtflags_tochar(mode);
298 (void)snprintf(buf, sizeof (buf), "O%s\n%d %s\n",
304 return (rmtcall(tape, buf));
311 if (rmtstate != TS_OPEN)
313 rmtcall("close", "C\n");
314 rmtstate = TS_CLOSED;
318 rmtread(char *buf, size_t count)
324 (void)snprintf(line, sizeof (line), "R%u\n", (unsigned)count);
325 n = rmtcall("read", line);
327 /* rmtcall() properly sets errno for us on errors. */
331 for (i = 0; i < n; i += cc) {
332 cc = read(fromrmtape, buf+i, n - i);
340 rmtwrite(const char *buf, size_t count)
344 (void)snprintf(line, sizeof (line), "W%ld\n", (long)count);
345 write(tormtape, line, strlen(line));
346 write(tormtape, buf, count);
347 return (rmtreply("write"));
351 rmtseek(OFF_T offset, int pos)
355 (void)snprintf(line, sizeof (line), "L%lld\n%d\n", (long long)offset, pos);
356 return (rmtcall("seek", line));
367 if (rmtstate != TS_OPEN)
369 i = rmtcall("status", "S");
370 if (i < 0) return NULL;
371 if (i != (int)sizeof(mts)) {
372 msg("mtget sizes different between host (%d) "
373 "and remote tape (%d)", sizeof(mts), i);
374 for ( /* empty */; i > 0; --i)
378 for (i = 0, cp = (char *)&mts; i < (int)sizeof(mts); i++)
384 rmtioctl(int cmd, int count)
390 (void)snprintf(buf, sizeof (buf), "I%d\n%d\n", cmd, count);
391 return (rmtcall("ioctl", buf));
395 rmtcall(const char *cmd, const char *buf)
398 if (write(tormtape, buf, strlen(buf)) != (ssize_t)strlen(buf))
400 return (rmtreply(cmd));
404 rmtreply(const char *cmd)
407 char code[30], emsg[BUFSIZ];
409 rmtgets(code, sizeof (code));
410 if (*code == 'E' || *code == 'F') {
411 rmtgets(emsg, sizeof (emsg));
412 msg("%s: %s", cmd, emsg);
413 errno = atoi(code + 1);
415 rmtstate = TS_CLOSED;
419 /* Kill trailing newline */
420 cp = code + strlen(code);
421 if (cp > code && *--cp == '\n')
424 msg("Protocol to remote tape server botched (code \"%s\").\n",
428 return (OFF_T)(atoll(code + 1));
436 if (read(fromrmtape, &c, 1) != 1)
441 /* Get a line (guaranteed to have a trailing newline). */
443 rmtgets(char *line, size_t len)
457 msg("Protocol to remote tape server botched.\n");
458 msg("(rmtgets got \"%s\").\n", line);
462 int piped_child(const char **command) {
464 int to_child_pipe[2];
465 int from_child_pipe[2];
467 if (pipe (to_child_pipe) < 0) {
468 msg ("cannot create pipe: %s\n", strerror(errno));
471 if (pipe (from_child_pipe) < 0) {
472 msg ("cannot create pipe: %s\n", strerror(errno));
477 msg ("cannot fork: %s\n", strerror(errno));
481 if (dup2 (to_child_pipe[0], STDIN_FILENO) < 0) {
482 msg ("cannot dup2 pipe: %s\n", strerror(errno));
485 if (close (to_child_pipe[1]) < 0) {
486 msg ("cannot close pipe: %s\n", strerror(errno));
489 if (close (from_child_pipe[0]) < 0) {
490 msg ("cannot close pipe: %s\n", strerror(errno));
493 if (dup2 (from_child_pipe[1], STDOUT_FILENO) < 0) {
494 msg ("cannot dup2 pipe: %s\n", strerror(errno));
497 setpgid(0, getpid());
498 execvp (command[0], (char *const *) command);
499 msg("cannot exec %s: %s\n", command[0], strerror(errno));
502 if (close (to_child_pipe[0]) < 0) {
503 msg ("cannot close pipe: %s\n", strerror(errno));
506 if (close (from_child_pipe[1]) < 0) {
507 msg ("cannot close pipe: %s\n", strerror(errno));
510 tormtape = to_child_pipe[1];
511 fromrmtape = from_child_pipe[0];