X-Git-Url: https://git.wh0rd.org/?p=dump.git;a=blobdiff_plain;f=rmt%2Frmt.c;h=863f12651c68bd103a1972fd52a2078a889ead97;hp=6f01bcce70c78793a6b2dbf87dbbc1458152c4ed;hb=HEAD;hpb=cdfe1392899d2aca4517e8f4b383a0422d878c1d

diff --git a/rmt/rmt.c b/rmt/rmt.c
index 6f01bcc..863f126 100644
--- a/rmt/rmt.c
+++ b/rmt/rmt.c
@@ -37,7 +37,7 @@
 
 #ifndef lint
 static const char rcsid[] =
-	"$Id: rmt.c,v 1.26 2003/04/08 19:52:37 stelian Exp $";
+	"$Id: rmt.c,v 1.29 2010/06/11 11:19:18 stelian Exp $";
 #endif /* not linux */
 
 /*
@@ -111,9 +111,10 @@ static int	rmt_version = 0;
 #define MTS_FLAGS	'f'
 #define MTS_BF		'b'
 
-char	*checkbuf __P((char *, int));
-void	 error __P((int));
-void	 getstring __P((char *));
+static char	*checkbuf __P((char *, int));
+static void	 error __P((int));
+static void	 getstring __P((char *));
+static unsigned long swaplong __P((unsigned long inv));
 #ifdef ERMT
 char	*cipher __P((char *, int, int));
 void	decrypt __P((void));
@@ -128,6 +129,8 @@ main(int argc, char *argv[])
 	unsigned long block = 0;
 	char *cp;
 
+	int magtape = 0;
+
 #ifdef ERMT
 	if (argc > 1 && strcmp(argv[1], "-d") == 0)
 		decrypt(); /* decrypt stdin to stdout, and exit() */
@@ -176,6 +179,10 @@ top:
 		if (tape < 0)
 			goto ioerror;
 		block = 0;
+		{
+		struct mtget mt_stat;
+		magtape = ioctl(tape, MTIOCGET, (char *)&mt_stat) == 0;
+		}
 		goto respond;
 
 	case 'C':
@@ -187,11 +194,77 @@ top:
 		block = 0;
 		goto respond;
 
+#ifdef USE_QFA
+#define LSEEK_GET_TAPEPOS 	10
+#define LSEEK_GO2_TAPEPOS	11
+#endif
+
 	case 'L':
 		getstring(count);
 		getstring(pos);
 		DEBUG2("rmtd: L %s %s\n", count, pos);
-		rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+		if (!magtape) { /* traditional */
+			switch (atoi(pos)) {
+			case SEEK_SET:
+			case SEEK_CUR:
+			case SEEK_END:
+				rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+				break;
+#ifdef USE_QFA
+			case LSEEK_GET_TAPEPOS:
+				rval = LSEEK(tape, (OFF_T)0, SEEK_CUR);
+				break;
+			case LSEEK_GO2_TAPEPOS:
+				rval = LSEEK(tape, (OFF_T)atoll(count), SEEK_SET);
+				break;
+#endif /* USE_QFA */
+			default:
+				errno = EINVAL;
+				goto ioerror;
+				break;
+			}
+		}
+		else {
+			switch (atoi(pos)) {
+			case SEEK_SET:
+			case SEEK_CUR:
+			case SEEK_END:
+				rval = LSEEK(tape, (OFF_T)atoll(count), atoi(pos));
+				break;
+#ifdef USE_QFA
+			case LSEEK_GET_TAPEPOS: /* QFA */
+			case LSEEK_GO2_TAPEPOS:
+				{
+				struct mtop buf;
+				long mtpos;
+
+				buf.mt_op = MTSETDRVBUFFER;
+				buf.mt_count = MT_ST_BOOLEANS | MT_ST_SCSI2LOGICAL;
+				if (ioctl(tape, MTIOCTOP, &buf) < 0) {
+					goto ioerror;
+				}
+
+				if (atoi(pos) == LSEEK_GET_TAPEPOS) { /* get tapepos */
+					if (ioctl(tape, MTIOCPOS, &mtpos) < 0) {
+						goto ioerror;
+					}
+					rval = (OFF_T)mtpos;
+				} else {
+					buf.mt_op = MTSEEK;
+					buf.mt_count = atoi(count);
+					if (ioctl(tape, MTIOCTOP, &buf) < 0) {
+						goto ioerror;
+					}
+					rval = (OFF_T)buf.mt_count;
+				}
+				}
+				break;
+#endif /* USE_QFA */
+			default:
+				errno = EINVAL;
+				goto ioerror;
+			}
+		}
 		if (rval < 0)
 			goto ioerror;
 		goto respond;
@@ -237,8 +310,10 @@ top:
 		cp = record;
 #endif
 		(void)sprintf(resp, "A%lld\n", (long long)rval);
-		(void)write(1, resp, strlen(resp));
-		(void)write(1, cp, rval);
+		if (write(1, resp, strlen(resp)) != strlen(resp))
+			goto ioerror;
+		if (write(1, cp, rval) != rval)
+			goto ioerror;
 		block += n >> 10;
 		goto top;
 
@@ -254,7 +329,7 @@ top:
 			struct mtop mtop;
 			mtop.mt_op = -1;
 			if (rmt_version) {
-				/* rmt version 1, assume UNIX client */
+				/* rmt version 1, assume UNIX/Solaris/Mac OS X client */
 				switch (atoi(op)) {
 #ifdef  MTWEOF
 					case 0:
@@ -295,6 +370,21 @@ top:
 					case 7:
 						mtop.mt_op = MTNOP;
 						break;
+#endif
+#ifdef  MTRETEN
+                    case 8:
+                        mtop.mt_op = MTRETEN;
+                        break;
+#endif
+#ifdef  MTERASE
+                    case 9:
+                        mtop.mt_op = MTERASE;
+                        break;
+#endif
+#ifdef  MTEOM
+                    case 10:
+                        mtop.mt_op = MTEOM;
+                        break;
 #endif
 				}
 				if (mtop.mt_op == -1) {
@@ -307,8 +397,9 @@ top:
 				mtop.mt_op = atoi(op);
 			}
 			mtop.mt_count = atoi(count);
-			if (ioctl(tape, MTIOCTOP, (char *)&mtop) < 0)
+			if (ioctl(tape, MTIOCTOP, (char *)&mtop) < 0) {
 				goto ioerror;
+			}
 			rval = mtop.mt_count;
 		}
 		goto respond;
@@ -355,8 +446,9 @@ top:
 				goto ioerror;
 		}
 		mtop.mt_count = atoi (count);
-		if (ioctl (tape, MTIOCTOP, (char *) &mtop) < 0)
+		if (ioctl (tape, MTIOCTOP, (char *) &mtop) < 0) {
 			goto ioerror;
+		}
 
 		rval = mtop.mt_count;
 
@@ -366,12 +458,37 @@ top:
 	case 'S':		/* status */
 		DEBUG("rmtd: S\n");
 		{ struct mtget mtget;
-		  if (ioctl(tape, MTIOCGET, (char *)&mtget) < 0)
+
+		  if (ioctl(tape, MTIOCGET, (char *)&mtget) < 0) {
 			goto ioerror;
-		  rval = sizeof (mtget);
-		  (void)sprintf(resp, "A%lld\n", (long long)rval);
-		  (void)write(1, resp, strlen(resp));
-		  (void)write(1, (char *)&mtget, sizeof (mtget));
+		  }
+
+		  if (rmt_version) {
+			rval = sizeof(mtget);
+            		/* assume byte order:
+            		Linux on Intel (little), Solaris on SPARC (big), Mac OS X on PPC (big)
+            		thus need byte swapping from little to big
+            		*/
+			mtget.mt_type = swaplong(mtget.mt_type);
+			mtget.mt_resid = swaplong(mtget.mt_resid);
+			mtget.mt_dsreg = swaplong(mtget.mt_dsreg);
+			mtget.mt_gstat = swaplong(mtget.mt_gstat);
+			mtget.mt_erreg = swaplong(mtget.mt_erreg);
+			mtget.mt_fileno = swaplong(mtget.mt_fileno);
+			mtget.mt_blkno = swaplong(mtget.mt_blkno);
+			(void)sprintf(resp, "A%lld\n", (long long)rval);
+			if (write(1, resp, strlen(resp)) != strlen(resp))
+				goto ioerror;
+			if (write(1, (char *)&mtget, sizeof (mtget)) != sizeof(mtget))
+				goto ioerror;
+		  } else {
+		  	rval = sizeof (mtget);
+			(void)sprintf(resp, "A%lld\n", (long long)rval);
+			if (write(1, resp, strlen(resp)) != strlen(resp))
+				goto ioerror;
+			if (write(1, (char *)&mtget, sizeof (mtget)) != sizeof(mtget))
+				goto ioerror;
+		  }
 		  goto top;
 		}
 
@@ -379,11 +496,15 @@ top:
 	{	char s;
 		struct mtget mtget;
  
+		DEBUG ("rmtd: s\n");
+
 		if (read (0, &s, 1) != 1)
 			goto top;
+		DEBUG1 ("rmtd: s %d\n", s);
  
-		if (ioctl (tape, MTIOCGET, (char *) &mtget) < 0)
+		if (ioctl (tape, MTIOCGET, (char *) &mtget) < 0) {
 			goto ioerror;
+		}
 
 		switch (s) {
 			case MTS_TYPE:
@@ -418,11 +539,11 @@ top:
 		goto respond;
 	}
 
-        case 'V':               /* version */
-                getstring(op);
-                DEBUG1("rmtd: V %s\n", op);
-                rval = 2;
-                goto respond;
+	case 'V':	/* version */
+		getstring(op);
+		DEBUG1("rmtd: V %s\n", op);
+		rval = 2;
+		goto respond;
 
 	default:
 		DEBUG1("rmtd: garbage command %c\n", c);
@@ -431,14 +552,15 @@ top:
 respond:
 	DEBUG1("rmtd: A %lld\n", (long long)rval);
 	(void)sprintf(resp, "A%lld\n", (long long)rval);
-	(void)write(1, resp, strlen(resp));
+	if (write(1, resp, strlen(resp)) != strlen(resp))
+		goto ioerror;
 	goto top;
 ioerror:
 	error(errno);
 	goto top;
 }
 
-void getstring(char *bp)
+static void getstring(char *bp)
 {
 	int i;
 	char *cp = bp;
@@ -452,7 +574,7 @@ void getstring(char *bp)
 	cp[i] = '\0';
 }
 
-char *
+static char *
 checkbuf(char *record, int size)
 {
 
@@ -472,11 +594,30 @@ checkbuf(char *record, int size)
 	return (record);
 }
 
-void
+static void
 error(int num)
 {
 
 	DEBUG2("rmtd: E %d (%s)\n", num, strerror(num));
 	(void)snprintf(resp, sizeof(resp), "E%d\n%s\n", num, strerror(num));
-	(void)write(1, resp, strlen(resp));
+	if (write(1, resp, strlen(resp)) != strlen(resp))
+		DEBUG("rmtd: write error\n");
+}
+
+static unsigned long
+swaplong(unsigned long inv)
+{
+	 union lconv {
+		unsigned long   ul;
+		unsigned char   uc[4];
+	} *inp, outv;
+
+	inp = (union lconv *)&inv;
+
+	outv.uc[0] = inp->uc[3];
+	outv.uc[1] = inp->uc[2];
+	outv.uc[2] = inp->uc[1];
+	outv.uc[3] = inp->uc[0];
+
+	return (outv.ul);
 }