321 lines
6.1 KiB
C
321 lines
6.1 KiB
C
/*-
|
|
* Copyright (c) 1980 The Regents of the University of California.
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. All advertising materials mentioning features or use of this software
|
|
* must display the following acknowledgement:
|
|
* This product includes software developed by the University of
|
|
* California, Berkeley and its contributors.
|
|
* 4. Neither the name of the University nor the names of its contributors
|
|
* may be used to endorse or promote products derived from this software
|
|
* without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
|
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
|
* SUCH DAMAGE.
|
|
*/
|
|
|
|
#ifndef lint
|
|
/* from: static char sccsid[] = "@(#)dumprmt.c 5.15 (Berkeley) 6/18/92"; */
|
|
static char *rcsid = "$Id: dumprmt.c,v 1.5 1993/12/22 10:24:42 cgd Exp $";
|
|
#endif /* not lint */
|
|
|
|
#ifdef sunos
|
|
#include <stdio.h>
|
|
#include <ctype.h>
|
|
#include <sys/param.h>
|
|
#include <sys/mtio.h>
|
|
#include <sys/ioctl.h>
|
|
#include <sys/socket.h>
|
|
#include <sys/stat.h>
|
|
#else
|
|
#include <sys/param.h>
|
|
#include <sys/mtio.h>
|
|
#include <sys/ioctl.h>
|
|
#include <sys/socket.h>
|
|
#include <sys/time.h>
|
|
#include <stdio.h>
|
|
#endif
|
|
#include <ufs/dinode.h>
|
|
#include <signal.h>
|
|
|
|
#include <netinet/in.h>
|
|
|
|
#include <netdb.h>
|
|
#include <protocols/dumprestore.h>
|
|
#include <pwd.h>
|
|
#ifdef __STDC__
|
|
#include <unistd.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#endif
|
|
#include "pathnames.h"
|
|
|
|
#define TS_CLOSED 0
|
|
#define TS_OPEN 1
|
|
|
|
static int rmtstate = TS_CLOSED;
|
|
int rmtape;
|
|
void rmtgetconn();
|
|
void rmtconnaborted();
|
|
int rmtreply();
|
|
int rmtgetb();
|
|
void rmtgets();
|
|
int rmtcall();
|
|
char *rmtpeer;
|
|
|
|
extern int ntrec; /* blocking factor on tape */
|
|
extern void msg();
|
|
|
|
extern void exit();
|
|
|
|
int
|
|
rmthost(host)
|
|
char *host;
|
|
{
|
|
|
|
rmtpeer = host;
|
|
signal(SIGPIPE, rmtconnaborted);
|
|
rmtgetconn();
|
|
if (rmtape < 0)
|
|
return (0);
|
|
return (1);
|
|
}
|
|
|
|
void
|
|
rmtconnaborted()
|
|
{
|
|
|
|
(void) fprintf(stderr, "rdump: Lost connection to remote host.\n");
|
|
(void) exit(1);
|
|
}
|
|
|
|
void
|
|
rmtgetconn()
|
|
{
|
|
static struct servent *sp = 0;
|
|
struct passwd *pw;
|
|
char *name = "root";
|
|
int size;
|
|
|
|
if (sp == 0) {
|
|
sp = getservbyname("shell", "tcp");
|
|
if (sp == 0) {
|
|
(void) fprintf(stderr,
|
|
"rdump: shell/tcp: unknown service\n");
|
|
(void) exit(1);
|
|
}
|
|
}
|
|
pw = getpwuid(getuid());
|
|
if (pw && pw->pw_name)
|
|
name = pw->pw_name;
|
|
rmtape = rcmd(&rmtpeer, (u_short)sp->s_port, name, name, _PATH_RMT,
|
|
(int *)0);
|
|
size = ntrec * TP_BSIZE;
|
|
while (size > TP_BSIZE &&
|
|
setsockopt(rmtape, SOL_SOCKET, SO_SNDBUF, &size, sizeof (size)) < 0)
|
|
size -= TP_BSIZE;
|
|
}
|
|
|
|
int
|
|
rmtopen(tape, mode)
|
|
char *tape;
|
|
int mode;
|
|
{
|
|
char buf[256];
|
|
|
|
(void)sprintf(buf, "O%s\n%d\n", tape, mode);
|
|
rmtstate = TS_OPEN;
|
|
return (rmtcall(tape, buf));
|
|
}
|
|
|
|
void
|
|
rmtclose()
|
|
{
|
|
|
|
if (rmtstate != TS_OPEN)
|
|
return;
|
|
rmtcall("close", "C\n");
|
|
rmtstate = TS_CLOSED;
|
|
}
|
|
|
|
int
|
|
rmtread(buf, count)
|
|
char *buf;
|
|
int count;
|
|
{
|
|
char line[30];
|
|
int n, i, cc;
|
|
extern errno;
|
|
|
|
(void)sprintf(line, "R%d\n", count);
|
|
n = rmtcall("read", line);
|
|
if (n < 0) {
|
|
errno = n;
|
|
return (-1);
|
|
}
|
|
for (i = 0; i < n; i += cc) {
|
|
cc = read(rmtape, buf+i, n - i);
|
|
if (cc <= 0) {
|
|
rmtconnaborted();
|
|
}
|
|
}
|
|
return (n);
|
|
}
|
|
|
|
int
|
|
rmtwrite(buf, count)
|
|
char *buf;
|
|
int count;
|
|
{
|
|
char line[30];
|
|
|
|
(void)sprintf(line, "W%d\n", count);
|
|
write(rmtape, line, strlen(line));
|
|
write(rmtape, buf, count);
|
|
return (rmtreply("write"));
|
|
}
|
|
|
|
void
|
|
rmtwrite0(count)
|
|
int count;
|
|
{
|
|
char line[30];
|
|
|
|
(void)sprintf(line, "W%d\n", count);
|
|
write(rmtape, line, strlen(line));
|
|
}
|
|
|
|
void
|
|
rmtwrite1(buf, count)
|
|
char *buf;
|
|
int count;
|
|
{
|
|
|
|
write(rmtape, buf, count);
|
|
}
|
|
|
|
int
|
|
rmtwrite2()
|
|
{
|
|
|
|
return (rmtreply("write"));
|
|
}
|
|
|
|
int
|
|
rmtseek(offset, pos)
|
|
int offset, pos;
|
|
{
|
|
char line[80];
|
|
|
|
(void)sprintf(line, "L%d\n%d\n", offset, pos);
|
|
return (rmtcall("seek", line));
|
|
}
|
|
|
|
struct mtget mts;
|
|
|
|
struct mtget *
|
|
rmtstatus()
|
|
{
|
|
register int i;
|
|
register char *cp;
|
|
|
|
if (rmtstate != TS_OPEN)
|
|
return (0);
|
|
rmtcall("status", "S\n");
|
|
for (i = 0, cp = (char *)&mts; i < sizeof(mts); i++)
|
|
*cp++ = rmtgetb();
|
|
return (&mts);
|
|
}
|
|
|
|
int
|
|
rmtioctl(cmd, count)
|
|
int cmd, count;
|
|
{
|
|
char buf[256];
|
|
|
|
if (count < 0)
|
|
return (-1);
|
|
(void)sprintf(buf, "I%d\n%d\n", cmd, count);
|
|
return (rmtcall("ioctl", buf));
|
|
}
|
|
|
|
int
|
|
rmtcall(cmd, buf)
|
|
char *cmd, *buf;
|
|
{
|
|
|
|
if (write(rmtape, buf, strlen(buf)) != strlen(buf))
|
|
rmtconnaborted();
|
|
return (rmtreply(cmd));
|
|
}
|
|
|
|
int
|
|
rmtreply(cmd)
|
|
char *cmd;
|
|
{
|
|
char code[30], emsg[BUFSIZ];
|
|
|
|
rmtgets(code, sizeof (code));
|
|
if (*code == 'E' || *code == 'F') {
|
|
rmtgets(emsg, sizeof (emsg));
|
|
msg("%s: %s\n", cmd, emsg, code + 1);
|
|
if (*code == 'F') {
|
|
rmtstate = TS_CLOSED;
|
|
return (-1);
|
|
}
|
|
return (-1);
|
|
}
|
|
if (*code != 'A') {
|
|
msg("Protocol to remote tape server botched (code %s?).\n",
|
|
code);
|
|
rmtconnaborted();
|
|
}
|
|
return (atoi(code + 1));
|
|
}
|
|
|
|
int
|
|
rmtgetb()
|
|
{
|
|
char c;
|
|
|
|
if (read(rmtape, &c, 1) != 1)
|
|
rmtconnaborted();
|
|
return (c);
|
|
}
|
|
|
|
void
|
|
rmtgets(cp, len)
|
|
char *cp;
|
|
int len;
|
|
{
|
|
|
|
while (len > 1) {
|
|
*cp = rmtgetb();
|
|
if (*cp == '\n') {
|
|
cp[1] = 0;
|
|
return;
|
|
}
|
|
cp++;
|
|
len--;
|
|
}
|
|
msg("Protocol to remote tape server botched (in rmtgets).\n");
|
|
rmtconnaborted();
|
|
}
|