]>
git.wh0rd.org - dump.git/blob - common/dumprmt.c
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.27 2003/03/30 15:40:33 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 */
122 rmthost(const char *host
)
125 free((void *)rmtpeer
);
126 if ((rmtpeer
= strdup(host
)) == NULL
)
128 signal(SIGPIPE
, rmtconnaborted
);
133 rmtconnaborted(UNUSED(int signo
))
135 msg("Lost connection to remote host.\n");
144 if (select(errfd
+ 1, &r
, NULL
, NULL
, &t
)) {
148 if ((i
= read(errfd
, buf
, sizeof(buf
) - 1)) > 0) {
150 msg("on %s: %s%s", rmtpeer
, buf
,
151 buf
[i
- 1] == '\n' ? "" : "\n");
164 static struct servent
*sp
= NULL
;
165 static struct passwd
*pwd
= NULL
;
175 if (!rsh
&& sp
== NULL
) {
176 sp
= getservbyname(dokerberos
? "kshell" : "shell", "tcp");
178 errx(1, "%s/tcp: unknown service",
179 dokerberos
? "kshell" : "shell");
182 pwd
= getpwuid(getuid());
184 errx(1, "who are you?");
186 if ((cp
= strchr(rmtpeer
, '@')) != NULL
) {
193 tuser
= pwd
->pw_name
;
194 if ((rmt
= getenv("RMT")) == NULL
)
199 const char *rshcmd
[6];
207 /* Restore the uid and gid. We really don't want
208 * to execute whatever is put into RSH variable with
209 * more priviledges than needed... */
213 if ((rshpid
= piped_child(rshcmd
)) < 0) {
214 msg("cannot open connection\n");
219 /* Copy rmtpeer to rmtpeercopy to ignore the
220 return value from rcmd. I cannot figure if
221 this is this a bug in rcmd or in my code... */
222 rmtpeercopy
= (char *)rmtpeer
;
225 tormtape
= krcmd(&rmtpeercopy
, sp
->s_port
, tuser
, rmt
, &errfd
,
229 tormtape
= rcmd(&rmtpeercopy
, (u_short
)sp
->s_port
, pwd
->pw_name
,
232 msg("login to %s as %s failed.\n", rmtpeer
, tuser
);
235 size
= ntrec
* TP_BSIZE
;
236 if (size
> 60 * 1024) /* XXX */
238 /* Leave some space for rmt request/response protocol */
240 while (size
> TP_BSIZE
&&
241 setsockopt(tormtape
, SOL_SOCKET
, SO_SNDBUF
, &size
, sizeof (size
)) < 0)
243 (void)setsockopt(tormtape
, SOL_SOCKET
, SO_RCVBUF
, &size
, sizeof (size
));
244 throughput
= IPTOS_THROUGHPUT
;
245 if (setsockopt(tormtape
, IPPROTO_IP
, IP_TOS
,
246 &throughput
, sizeof(throughput
)) < 0)
247 perror("IP_TOS:IPTOS_THROUGHPUT setsockopt");
249 if (setsockopt(tormtape
, IPPROTO_TCP
, TCP_NODELAY
, &on
, sizeof (on
)) < 0)
250 perror("TCP_NODELAY setsockopt");
251 fromrmtape
= tormtape
;
253 (void)fprintf(stderr
, "Connection to %s established.\n", rmtpeer
);
258 okname(const char *cp0
)
263 for (cp
= cp0
; *cp
; cp
++) {
265 if (!isascii(c
) || !(isalnum(c
) || c
== '_' || c
== '-')) {
266 warnx("invalid user name %s\n", cp0
);
274 rmtopen(const char *tape
, const int mode
)
276 char buf
[MAXPATHLEN
];
279 rmtflags
= rmtflags_tochar(mode
);
280 (void)snprintf(buf
, sizeof (buf
), "O%s\n%d %s\n",
286 return (rmtcall(tape
, buf
));
293 if (rmtstate
!= TS_OPEN
)
295 rmtcall("close", "C\n");
296 rmtstate
= TS_CLOSED
;
300 rmtread(char *buf
, size_t count
)
306 (void)snprintf(line
, sizeof (line
), "R%u\n", (unsigned)count
);
307 n
= rmtcall("read", line
);
309 /* rmtcall() properly sets errno for us on errors. */
311 for (i
= 0; i
< n
; i
+= cc
) {
312 cc
= read(fromrmtape
, buf
+i
, n
- i
);
320 rmtwrite(const char *buf
, size_t count
)
324 (void)snprintf(line
, sizeof (line
), "W%ld\n", (long)count
);
325 write(tormtape
, line
, strlen(line
));
326 write(tormtape
, buf
, count
);
327 return (rmtreply("write"));
331 rmtseek(OFF_T offset
, int pos
)
335 (void)snprintf(line
, sizeof (line
), "L%lld\n%d\n", (long long)offset
, pos
);
336 return (rmtcall("seek", line
));
347 if (rmtstate
!= TS_OPEN
)
349 i
= rmtcall("status", "S");
350 if (i
< 0) return NULL
;
351 if (i
!= (int)sizeof(mts
)) {
352 msg("mtget sizes different between host (%d) "
353 "and remote tape (%d)", sizeof(mts
), i
);
354 for ( /* empty */; i
> 0; --i
)
358 for (i
= 0, cp
= (char *)&mts
; i
< (int)sizeof(mts
); i
++)
364 rmtioctl(int cmd
, int count
)
370 (void)snprintf(buf
, sizeof (buf
), "I%d\n%d\n", cmd
, count
);
371 return (rmtcall("ioctl", buf
));
375 rmtcall(const char *cmd
, const char *buf
)
378 if (write(tormtape
, buf
, strlen(buf
)) != (ssize_t
)strlen(buf
))
380 return (rmtreply(cmd
));
384 rmtreply(const char *cmd
)
387 char code
[30], emsg
[BUFSIZ
];
389 rmtgets(code
, sizeof (code
));
390 if (*code
== 'E' || *code
== 'F') {
391 rmtgets(emsg
, sizeof (emsg
));
392 msg("%s: %s", cmd
, emsg
);
393 errno
= atoi(code
+ 1);
395 rmtstate
= TS_CLOSED
;
399 /* Kill trailing newline */
400 cp
= code
+ strlen(code
);
401 if (cp
> code
&& *--cp
== '\n')
404 msg("Protocol to remote tape server botched (code \"%s\").\n",
408 return (OFF_T
)(atoll(code
+ 1));
416 if (read(fromrmtape
, &c
, 1) != 1)
421 /* Get a line (guaranteed to have a trailing newline). */
423 rmtgets(char *line
, size_t len
)
437 msg("Protocol to remote tape server botched.\n");
438 msg("(rmtgets got \"%s\").\n", line
);
442 int piped_child(const char **command
) {
444 int to_child_pipe
[2];
445 int from_child_pipe
[2];
447 if (pipe (to_child_pipe
) < 0) {
448 msg ("cannot create pipe: %s\n", strerror(errno
));
451 if (pipe (from_child_pipe
) < 0) {
452 msg ("cannot create pipe: %s\n", strerror(errno
));
457 msg ("cannot fork: %s\n", strerror(errno
));
461 if (dup2 (to_child_pipe
[0], STDIN_FILENO
) < 0) {
462 msg ("cannot dup2 pipe: %s\n", strerror(errno
));
465 if (close (to_child_pipe
[1]) < 0) {
466 msg ("cannot close pipe: %s\n", strerror(errno
));
469 if (close (from_child_pipe
[0]) < 0) {
470 msg ("cannot close pipe: %s\n", strerror(errno
));
473 if (dup2 (from_child_pipe
[1], STDOUT_FILENO
) < 0) {
474 msg ("cannot dup2 pipe: %s\n", strerror(errno
));
477 setpgid(0, getpid());
478 execvp (command
[0], (char *const *) command
);
479 msg("cannot exec %s: %s\n", command
[0], strerror(errno
));
482 if (close (to_child_pipe
[0]) < 0) {
483 msg ("cannot close pipe: %s\n", strerror(errno
));
486 if (close (from_child_pipe
[1]) < 0) {
487 msg ("cannot close pipe: %s\n", strerror(errno
));
490 tormtape
= to_child_pipe
[1];
491 fromrmtape
= from_child_pipe
[0];