xueye/cdrtools
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity
main
cdrtools/readcd/readcd.c

3186 lines
72 KiB
C
Raw Permalink Normal View History

Initial commit
2025-06-15 04:19:58 +08:00
/* @(#)readcd.c 1.127 16/01/24 Copyright 1987, 1995-2016 J. Schilling */
#include <schily/mconfig.h>
#ifndef lint
static UConst char sccsid[] =
"@(#)readcd.c 1.127 16/01/24 Copyright 1987, 1995-2016 J. Schilling";
#endif
/*
* Skeleton for the use of the scg genearal SCSI - driver
*
* Copyright (c) 1987, 1995-2016 J. Schilling
*/
/*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* See the file CDDL.Schily.txt in this distribution for details.
* A copy of the CDDL is also available via the Internet at
* http://www.opensource.org/licenses/cddl1.txt
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file CDDL.Schily.txt from this distribution.
*/
#include <schily/mconfig.h>
#include <schily/stdio.h>
#include <schily/standard.h>
#include <schily/unistd.h>
#include <schily/stdlib.h>
#include <schily/string.h>
#include <schily/fcntl.h>
#include <schily/time.h>
#include <schily/errno.h>
#include <schily/signal.h>
#include <schily/schily.h>
#include <schily/nlsdefs.h>
#include <schily/priv.h>
#include <schily/io.h> /* for setmode() prototype */
#include <scg/scgcmd.h>
#include <scg/scsireg.h>
#include <scg/scsitransp.h>
#include "scsi_scan.h"
#include "scsimmc.h"
#define qpto96 __nothing__
#include "cdrecord.h"
#include "cdrdeflt.h"
#undef qpto96
#include "movesect.h"
#include <ecc.h>
#include <edc.h>
#include "version.h"
char cdr_version[] = VERSION;
#if defined(PROTOTYPES)
#define UINT_C(a) (a##u)
#define ULONG_C(a) (a##ul)
#define USHORT_C(a) (a##uh)
#define CONCAT(a, b) a##b
#else
#define UINT_C(a) ((unsigned)(a))
#define ULONG_C(a) ((unsigned long)(a))
#define USHORT_C(a) ((unsigned short)(a))
/* CSTYLED */
#define CONCAT(a, b) a/**/b
#endif
extern BOOL getlong __PR((char *, long *, long, long));
extern BOOL getint __PR((char *, int *, int, int));
typedef struct {
long start;
long end;
long sptr; /* sectors per transfer */
BOOL askrange;
char *name;
} parm_t;
typedef struct {
int errors;
int c2_errors;
int c2_maxerrs;
int c2_errsecs;
int c2_badsecs;
int secsize; /* The output sector size on the file */
int isecsize; /* The input sector size from the medium */
BOOL ismmc;
} rparm_t;
typedef struct {
int c1_errors;
int c2_errors;
int cu_errors;
int pi_errors;
} cxerror_t;
typedef int (*start_cx_func_t) __PR((SCSI*)); /* initiates a scan */
typedef int (*end_cx_func_t) __PR((SCSI*)); /* ends a scan */
typedef int (*one_interval_func_t) __PR((SCSI *, /* scans a certain range, */
cxerror_t *, /* should be 75 sectors. */
long, void *)); /* Return value is the next */
/* sector to be scanned */
/*
* Describes one set of functions needed to perform an cx scan.
*/
typedef struct {
start_cx_func_t start_func;
end_cx_func_t end_func;
one_interval_func_t one_interval_func;
} cx_scan_procedure_t;
LOCAL BOOL mmc_isplextor __PR((SCSI* scgp));
LOCAL int plextor_init_cx_scan __PR((SCSI* scgp));
LOCAL int plextor_init_pi8_scan __PR((SCSI* scgp));
LOCAL int plextor_init_pif_scan __PR((SCSI* scgp));
LOCAL int plextor_end_scan __PR((SCSI* scgp));
LOCAL int plextor_read_cx_values __PR((SCSI* scgp, cxerror_t *pe, BOOL dopi));
LOCAL int nec_init_cx_scan __PR((SCSI* scgp));
LOCAL int nec_end_scan __PR((SCSI* scgp));
LOCAL int nec_scan_one_interval __PR((SCSI* scgp, cxerror_t *pe, long addr, void *p));
LOCAL int plextor_scan_one_interval __PR((SCSI* scgp, cxerror_t *pe, long addr, void *p));
LOCAL int plextor_scan_one_dvd_interval __PR((SCSI* scgp, cxerror_t *pe, long addr, void *p));
/*
* Currently, Plextor and NEC cx scanning is supported
*/
cx_scan_procedure_t cx_scan_procedures[] = {
{ plextor_init_cx_scan,
plextor_end_scan,
plextor_scan_one_interval },
{ nec_init_cx_scan,
nec_end_scan,
nec_scan_one_interval },
{ NULL }
};
struct exargs {
SCSI *scgp;
int old_secsize;
int flags;
int exflags;
int excode;
char oerr[3];
} exargs;
EXPORT BOOL cvt_cyls __PR((void));
EXPORT BOOL cvt_bcyls __PR((void));
EXPORT void print_defect_list __PR((void));
LOCAL void usage __PR((int ret));
EXPORT int main __PR((int ac, char **av));
LOCAL void scg_openerr __PR((char *errstr));
LOCAL int find_drive __PR((SCSI *scgp, char *dev));
LOCAL void intr __PR((int sig));
LOCAL void exscsi __PR((int excode, void *arg));
#ifdef __needed__
LOCAL void excdr __PR((int excode, void *arg));
#endif
LOCAL int prstats __PR((void));
LOCAL int prstats_silent __PR((void));
LOCAL void dorw __PR((SCSI *scgp, char *filename, char *sectors));
LOCAL void doit __PR((SCSI *scgp));
LOCAL void read_disk __PR((SCSI *scgp, parm_t *parmp));
#ifdef CLONE_WRITE
LOCAL void readcd_disk __PR((SCSI *scgp, parm_t *parmp));
LOCAL void read_lin __PR((SCSI *scgp, parm_t *parmp));
LOCAL int read_secheader __PR((SCSI *scgp, long addr));
LOCAL int read_ftoc __PR((SCSI *scgp, parm_t *parmp, BOOL do_sectype));
LOCAL void read_sectypes __PR((SCSI *scgp, FILE *f));
LOCAL void get_sectype __PR((SCSI *scgp, long addr, char *st));
#endif
LOCAL void readc2_disk __PR((SCSI *scgp, parm_t *parmp));
LOCAL void readcx_disk __PR((SCSI *scgp, parm_t *parmp));
LOCAL void readpi_disk __PR((SCSI *scgp, parm_t *parmp));
LOCAL int fread_data __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
#ifdef CLONE_WRITE
LOCAL int fread_2448 __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fread_2448_16 __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fread_2352 __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fread_2048 __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fread_lin __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
#endif
LOCAL int bits __PR((int c));
LOCAL int bitidx __PR((int c));
LOCAL int fread_c2 __PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fdata_null __PR((rparm_t *rp, caddr_t bp, long addr, int cnt));
LOCAL int fdata_c2 __PR((rparm_t *rp, caddr_t bp, long addr, int cnt));
#ifdef used
LOCAL int read_scsi_g1 __PR((SCSI *scgp, caddr_t bp, long addr, int cnt));
#endif
EXPORT int write_scsi __PR((SCSI *scgp, caddr_t bp, long addr, int cnt));
EXPORT int write_g0 __PR((SCSI *scgp, caddr_t bp, long addr, int cnt));
EXPORT int write_g1 __PR((SCSI *scgp, caddr_t bp, long addr, int cnt));
#ifdef used
LOCAL void Xrequest_sense __PR((SCSI *scgp));
#endif
LOCAL int read_retry __PR((SCSI *scgp, caddr_t bp, long addr, long cnt,
int (*rfunc)(SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt),
rparm_t *rp));
LOCAL void read_generic __PR((SCSI *scgp, parm_t *parmp,
int (*rfunc)(SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt),
rparm_t *rp,
int (*dfunc)(rparm_t *rp, caddr_t bp, long addr, int cnt)
));
LOCAL void write_disk __PR((SCSI *scgp, parm_t *parmp));
LOCAL int choice __PR((int n));
LOCAL void ra __PR((SCSI *scgp));
EXPORT int read_da __PR((SCSI *scgp, caddr_t bp, long addr, int cnt, int framesize, int subcode));
LOCAL int read_sectors __PR((SCSI *scgp, void *p, long addr, int cnt));
LOCAL int read_dvd_sectors __PR((SCSI *scgp, void *p, long addr, int cnt));
EXPORT int read_cd __PR((SCSI *scgp, caddr_t bp, long addr, int cnt, int framesize, int data, int subch));
LOCAL void oldmode __PR((SCSI *scgp, int *errp, int *retrp));
LOCAL void domode __PR((SCSI *scgp, int err, int retr));
LOCAL void qpto96 __PR((Uchar *sub, Uchar *subq, int dop));
LOCAL void ovtime __PR((SCSI *scgp));
LOCAL void add_bad __PR((long addr));
LOCAL void print_bad __PR((void));
LOCAL void priv_warn __PR((const char *what, const char *msg));
struct timeval starttime;
struct timeval stoptime;
int didintr;
int exsig;
char *Sbuf;
long Sbufsize = -1L;
/*#define MAX_RETRY 32*/
#define MAX_RETRY 128
int help;
int xdebug;
int lverbose;
int quiet;
BOOL is_suid;
BOOL is_cdrom;
BOOL is_dvd;
BOOL is_bd;
BOOL do_write;
BOOL c2scan;
BOOL cxscan;
BOOL pi8scan;
BOOL pifscan;
BOOL plot;
BOOL fulltoc;
BOOL clone;
BOOL edc_corr;
BOOL noerror;
BOOL nocorr;
BOOL notrunc;
int retries = MAX_RETRY;
int maxtry = 0;
int meshpoints;
BOOL do_factor;
struct scsi_format_data fmt;
/*XXX*/EXPORT BOOL cvt_cyls() { return (FALSE); }
/*XXX*/EXPORT BOOL cvt_bcyls() { return (FALSE); }
/*XXX*/EXPORT void print_defect_list() {}
LOCAL void
usage(ret)
int ret;
{
error(_("Usage:\treadcd [options]\n"));
error(_("Options:\n"));
error(_("\t-version print version information and exit\n"));
error(_("\tdev=target SCSI target to use\n"));
error(_("\tscgopts=spec SCSI options for libscg\n"));
error(_("\tf=filename Name of file to read/write\n"));
error(_("\tsectors=range Range of sectors to read/write\n"));
error(_("\tspeed=# set speed of drive (MMC only)\n"));
error(_("\tts=# set maximum transfer size for a single SCSI command\n"));
error(_("\t-w Switch to write mode\n"));
error(_("\t-c2scan Do a C2 error scan\n"));
error(_("\t-cxscan Do a C1/C2/CU scan (only available on a few drives)\n"));
error(_("\t-pi8scan Do a DVD pisum8 scan (only available on a few drives)\n"));
error(_("\t-pifscan Do a DVD pif scan (only available on a few drives)\n"));
error(_("\t-plot Print data suitable for gnuplot\n"));
#ifdef CLONE_WRITE
error(_("\t-fulltoc Retrieve the full TOC\n"));
error(_("\t-clone Retrieve the full TOC and all data\n"));
error(_("\t-edc-corr Try to do user level Reed Solomon repair (experimental)\n"));
#endif
error(_("\ttimeout=# set the default SCSI command timeout to #.\n"));
error(_("\tdebug=#,-d Set to # or increment misc debug level\n"));
error(_("\tkdebug=#,kd=# do Kernel debugging\n"));
error(_("\t-quiet,-q be more quiet in error retry mode\n"));
error(_("\t-verbose,-v increment general verbose level by one\n"));
error(_("\t-Verbose,-V increment SCSI command transport verbose level by one\n"));
error(_("\t-silent,-s do not print status of failed SCSI commands\n"));
error(_("\t-scanbus scan the SCSI bus and exit\n"));
error(_("\t-noerror do not abort on error\n"));
#ifdef CLONE_WRITE
error(_("\t-nocorr do not apply error correction in drive\n"));
#endif
error(_("\t-notrunc do not truncate outputfile in read mode\n"));
error(_("\tretries=# set retry count (default is %d)\n"), retries);
error(_("\t-overhead meter SCSI command overhead times\n"));
error(_("\tmeshpoints=# print read-speed at # locations\n"));
error(_("\t-factor try to use speed factor with meshpoints=# if possible\n"));
error("\n");
error(_("sectors=0-0 will read nothing, sectors=0-1 will read one sector starting from 0\n"));
exit(ret);
}
/* CSTYLED */
char opts[] = "debug#,d+,kdebug#,kd#,timeout#,quiet,q,verbose+,v+,Verbose+,V+,x+,xd#,silent,s,help,h,version,scanbus,dev*,scgopts*,sectors*,w,c2scan,cxscan,pi8scan,pifscan,plot,fulltoc,clone,edc-corr,noerror,nocorr,notrunc,retries#,factor,f*,speed#,ts&,overhead,meshpoints#";
EXPORT int
main(ac, av)
int ac;
char *av[];
{
char *dev = NULL;
char *scgopts = NULL;
int fcount;
int cac;
char * const *cav;
#if defined(USE_NLS)
char *dir;
#endif
int scsibus = -1;
int target = -1;
int lun = -1;
int silent = 0;
int verbose = 0;
int kdebug = 0;
int debug = 0;
int deftimeout = 40;
int pversion = 0;
int scanbus = 0;
int speed = -1;
int dooverhead = 0;
SCSI *scgp;
char *filename = NULL;
char *sectors = NULL;
#ifdef HAVE_SOLARIS_PPRIV
/*
* Try to gain additional privs on Solaris
*/
do_pfexec(ac, av,
PRIV_FILE_DAC_READ,
PRIV_SYS_DEVICES,
PRIV_NET_PRIVADDR,
NULL);
#endif
save_args(ac, av);
#if defined(USE_NLS)
(void) setlocale(LC_ALL, "");
#if !defined(TEXT_DOMAIN) /* Should be defined by cc -D */
#define TEXT_DOMAIN "cdrecord" /* Use this only if it weren't */
#endif
dir = searchfileinpath("share/locale", F_OK,
SIP_ANY_FILE|SIP_NO_PATH, NULL);
if (dir)
(void) bindtextdomain(TEXT_DOMAIN, dir);
else
#if defined(PROTOTYPES) && defined(INS_BASE)
(void) bindtextdomain(TEXT_DOMAIN, INS_BASE "/share/locale");
#else
(void) bindtextdomain(TEXT_DOMAIN, "/usr/share/locale");
#endif
(void) textdomain(TEXT_DOMAIN);
#endif
cac = --ac;
cav = ++av;
if (getallargs(&cac, &cav, opts,
&debug, &debug,
&kdebug, &kdebug,
&deftimeout,
&quiet, &quiet,
&lverbose, &lverbose,
&verbose, &verbose,
&xdebug, &xdebug,
&silent, &silent,
&help, &help, &pversion,
&scanbus, &dev, &scgopts, &sectors, &do_write,
&c2scan, &cxscan, &pi8scan, &pifscan,
&plot,
&fulltoc, &clone,
&edc_corr,
&noerror, &nocorr,
&notrunc, &retries, &do_factor, &filename,
&speed, getnum, &Sbufsize,
&dooverhead, &meshpoints) < 0) {
errmsgno(EX_BAD, _("Bad flag: %s.\n"), cav[0]);
usage(EX_BAD);
}
if (help)
usage(0);
if (pversion) {
printf(_("readcd %s (%s-%s-%s) Copyright (C) 1987, 1995-2016 %s\n"),
cdr_version,
HOST_CPU, HOST_VENDOR, HOST_OS,
_("Joerg Schilling"));
exit(0);
}
fcount = 0;
cac = ac;
cav = av;
while (getfiles(&cac, &cav, opts) > 0) {
fcount++;
if (fcount == 1) {
if (*astoi(cav[0], &target) != '\0') {
errmsgno(EX_BAD,
_("Target '%s' is not a Number.\n"),
cav[0]);
usage(EX_BAD);
/* NOTREACHED */
}
}
if (fcount == 2) {
if (*astoi(cav[0], &lun) != '\0') {
errmsgno(EX_BAD,
_("Lun is '%s' not a Number.\n"),
cav[0]);
usage(EX_BAD);
/* NOTREACHED */
}
}
if (fcount == 3) {
if (*astoi(cav[0], &scsibus) != '\0') {
errmsgno(EX_BAD,
_("Scsibus is '%s' not a Number.\n"),
cav[0]);
usage(EX_BAD);
/* NOTREACHED */
}
}
cac--;
cav++;
}
/*
* The following scg_open() call needs more privileges, so we check for
* sufficient privileges here.
* The check has been introduced as some Linux distributions miss the
* skills to perceive the necessity for the needed privileges. So we
* warn which features are impaired by actually missing privileges.
*/
if (!priv_eff_priv(SCHILY_PRIV_FILE_DAC_READ))
priv_warn("file read", "You will not be able to open all needed devices.");
#ifndef __SUNOS5
/*
* Due to a design bug in the Solaris USCSI ioctl, we don't need
* PRIV_FILE_DAC_WRITE to send SCSI commands and most installations
* probably don't grant PRIV_FILE_DAC_WRITE. Once we need /dev/scg*,
* we would need to test for PRIV_FILE_DAC_WRITE also.
*/
if (!priv_eff_priv(SCHILY_PRIV_FILE_DAC_WRITE))
priv_warn("file write", "You will not be able to open all needed devices.");
#endif
if (!priv_eff_priv(SCHILY_PRIV_SYS_DEVICES))
priv_warn("device",
"You may not be able to send all needed SCSI commands, this my cause various unexplainable problems.");
if (!priv_eff_priv(SCHILY_PRIV_NET_PRIVADDR))
priv_warn("network", "You will not be able to do remote SCSI.");
/*error("dev: '%s'\n", dev);*/
if (!scanbus)
cdr_defaults(&dev, NULL, NULL, &Sbufsize, NULL);
if (debug) {
printf("dev: '%s'\n", dev);
}
if (dev || scanbus || (scsibus < 0 && target < 0 && lun < 0)) {
char errstr[80];
/*
* Call scg_remote() to force loading the remote SCSI transport
* library code that is located in librscg instead of the dummy
* remote routines that are located inside libscg.
*/
scg_remote();
if (dev != NULL &&
((strncmp(dev, "HELP", 4) == 0) ||
(strncmp(dev, "help", 4) == 0))) {
scg_help(stderr);
exit(0);
}
if ((scgp = scg_open(dev, errstr, sizeof (errstr), debug, lverbose)) == (SCSI *)0) {
scg_openerr(errstr);
/* NOTREACHED */
}
if (!scanbus && scg_scsibus(scgp) < 0 &&
scg_target(scgp) < 0 && scg_lun(scgp) < 0) {
int i = find_drive(scgp, dev);
if (i < 0) {
scg_openerr("");
/* NOTREACHED */
}
}
} else {
if (scsibus == -1 && target >= 0 && lun >= 0)
scsibus = 0;
scgp = scg_smalloc();
scgp->debug = debug;
scgp->kdebug = kdebug;
scg_settarget(scgp, scsibus, target, lun);
if (scg__open(scgp, NULL) <= 0)
comerr(_("Cannot open SCSI driver.\n"));
}
if (scgopts) {
int i = scg_opts(scgp, scgopts);
if (i <= 0)
exit(i < 0 ? EX_BAD : 0);
}
scgp->silent = silent;
scgp->verbose = verbose;
scgp->debug = debug;
scgp->kdebug = kdebug;
scg_settimeout(scgp, deftimeout);
if (Sbufsize < 0)
Sbufsize = 256*1024L;
Sbufsize = scg_bufsize(scgp, Sbufsize);
if ((Sbuf = scg_getbuf(scgp, Sbufsize)) == NULL)
comerr(_("Cannot get SCSI I/O buffer.\n"));
/*
* Did we get our privs from suid?
*/
is_suid = priv_from_priv();
/*
* This is only for OS that do not support fine grained privs.
*/
if (!is_suid) {
#ifdef HAVE_ISSETUGID
is_suid = issetugid();
#else
is_suid = geteuid() != getuid();
#endif
}
/*
* Drop privs we do not need anymore.
* We no longer need:
* file_dac_read,net_privaddr
* We still need:
* sys_devices
*/
if (is_suid || getuid() != 0)
priv_drop();
/*
* We don't need root privilleges anymore.
*/
#ifdef HAVE_SETREUID
if (setreuid(-1, getuid()) < 0)
#else
#ifdef HAVE_SETEUID
if (seteuid(getuid()) < 0)
#else
if (setuid(getuid()) < 0)
#endif
#endif
comerr(_("Panic cannot set back effective uid.\n"));
/* code to use SCG */
if (scanbus) {
int i = select_target(scgp, stdout);
if (i < 0) {
scg_openerr("");
/* NOTREACHED */
}
exit(0);
}
seterrno(0);
if (!do_inquiry(scgp, FALSE)) {
int err = geterrno();
if (err == EPERM || err == EACCES) {
scg_openerr("");
/* NOTREACHED */
}
}
allow_atapi(scgp, TRUE); /* Try to switch to 10 byte mode cmds */
if (is_mmc(scgp, NULL, NULL)) {
int rspeed;
int wspeed;
/*
* At this point we know that we have a SCSI-3/mmc compliant drive.
* Unfortunately ATAPI drives violate the SCSI spec in returning
* a response data format of '1' which from the SCSI spec would
* tell us not to use the "PF" bit in mode select. As ATAPI drives
* require the "PF" bit to be set, we 'correct' the inquiry data.
*/
if (scgp->inq->data_format < 2)
scgp->inq->data_format = 2;
if ((rspeed = get_curprofile(scgp)) >= 0) {
if (rspeed >= 0x08 && rspeed < 0x10)
is_cdrom = TRUE;
if (rspeed >= 0x10 && rspeed < 0x20)
is_dvd = TRUE;
if (rspeed >= 0x40 && rspeed < 0x50)
is_bd = TRUE;
} else {
BOOL dvd;
mmc_check(scgp, NULL, NULL, NULL, NULL, &dvd, NULL);
if (dvd == FALSE) {
is_cdrom = TRUE;
} else {
char xb[32];
if (read_dvd_structure(scgp, (caddr_t)xb, 32, 0, 0, 0, 0) >= 0) {
/*
* If read DVD structure is supported and works, then
* we must have a DVD media in the drive. Signal to
* use the DVD driver.
*/
is_dvd = TRUE;
} else {
is_cdrom = TRUE;
}
}
}
if (speed > 0)
speed *= 177;
if (speed > 0xFFFF || speed < 0)
speed = 0xFFFF;
scsi_set_speed(scgp, speed, speed, ROTCTL_CLV);
if (scsi_get_speed(scgp, &rspeed, &wspeed) >= 0) {
error(_("Read speed: %5d kB/s (CD %3dx, DVD %2dx, BD %2dx).\n"),
rspeed, rspeed/176, rspeed/1385, rspeed/4495);
error(_("Write speed: %5d kB/s (CD %3dx, DVD %2dx, BD %2dx).\n"),
wspeed, wspeed/176, wspeed/1385, wspeed/4495);
}
}
exargs.scgp = scgp;
exargs.old_secsize = -1;
/* exargs.flags = flags;*/
exargs.exflags = 0;
exargs.excode = 0;
exargs.oerr[2] = 0;
/*
* Install exit handler before we change the drive status.
*/
on_comerr(exscsi, &exargs);
signal(SIGINT, intr);
signal(SIGTERM, intr);
if (dooverhead) {
ovtime(scgp);
comexit(0);
}
if (is_suid) {
if (scgp->inq->type != INQ_ROMD)
comerrno(EX_BAD, _("Not root. Will only work on CD-ROM in suid/priv mode\n"));
}
if (filename || sectors || c2scan || cxscan || pi8scan || pifscan ||
meshpoints || fulltoc ||
clone || edc_corr) {
dorw(scgp, filename, sectors);
} else {
doit(scgp);
}
comexit(exargs.excode);
return (exargs.excode);
}
LOCAL void
scg_openerr(errstr)
char *errstr;
{
int err = geterrno();
errmsgno(err, _("%s%sCannot open or use SCSI driver.\n"), errstr, errstr[0]?". ":"");
errmsgno(EX_BAD, _("For possible targets try 'readcd -scanbus'.%s\n"),
geteuid() ? _(" Make sure you are root."):"");
errmsgno(EX_BAD, _("For possible transport specifiers try 'readcd dev=help'.\n"));
exit(err);
}
LOCAL int
find_drive(scgp, dev)
SCSI *scgp;
char *dev;
{
int ntarget;
error(_("No target specified, trying to find one...\n"));
ntarget = find_target(scgp, INQ_ROMD, -1);
if (ntarget < 0)
return (ntarget);
if (ntarget == 1) {
/*
* Simple case, exactly one CD-ROM found.
*/
find_target(scgp, INQ_ROMD, 1);
} else if (ntarget <= 0 && (ntarget = find_target(scgp, INQ_WORM, -1)) == 1) {
/*
* Exactly one CD-ROM acting as WORM found.
*/
find_target(scgp, INQ_WORM, 1);
} else if (ntarget <= 0) {
/*
* No single CD-ROM or WORM found.
*/
errmsgno(EX_BAD, _("No CD/DVD/BD-Recorder target found.\n"));
errmsgno(EX_BAD, _("Your platform may not allow to scan for SCSI devices.\n"));
comerrno(EX_BAD, _("Call 'readcd dev=help' or ask your sysadmin for possible targets.\n"));
} else {
errmsgno(EX_BAD, _("Too many CD/DVD/BD-Recorder targets found.\n"));
select_target(scgp, stdout);
comerrno(EX_BAD, _("Select a target from the list above and use 'readcd dev=%s%sb,t,l'.\n"),
dev?dev:"", dev?(dev[strlen(dev)-1] == ':'?"":":"):"");
}
error(_("Using dev=%s%s%d,%d,%d.\n"),
dev?dev:"", dev?(dev[strlen(dev)-1] == ':'?"":":"):"",
scg_scsibus(scgp), scg_target(scgp), scg_lun(scgp));
return (ntarget);
}
/*
* XXX Leider kann man vim Signalhandler keine SCSI Kommandos verschicken
* XXX da meistens das letzte SCSI Kommando noch laeuft.
* XXX Eine Loesung waere ein Abort Callback in SCSI *.
*/
LOCAL void
intr(sig)
int sig;
{
didintr++;
exsig = sig;
/* comexit(sig);*/
}
/* ARGSUSED */
LOCAL void
exscsi(excode, arg)
int excode;
void *arg;
{
struct exargs *exp = (struct exargs *)arg;
int i;
/*
* Try to restore the old sector size.
*/
if (exp != NULL && exp->exflags == 0) {
for (i = 0; i < 10*100; i++) {
if (!exp->scgp->running)
break;
if (i == 10) {
errmsgno(EX_BAD,
_("Waiting for current SCSI command to finish.\n"));
}
usleep(100000);
}
if (!exp->scgp->running) {
if (exp->oerr[2] != 0) {
domode(exp->scgp, exp->oerr[0], exp->oerr[1]);
}
if (exp->old_secsize > 0 && exp->old_secsize != 2048)
select_secsize(exp->scgp, exp->old_secsize);
}
exp->exflags++; /* Make sure that it only get called once */
}
}
#ifdef __needed__
LOCAL void
excdr(excode, arg)
int excode;
void *arg;
{
exscsi(excode, arg);
#ifdef needed
/* Do several other restores/statistics here (see cdrecord.c) */
#endif
}
#endif
/*
* Return milliseconds since start time.
*/
LOCAL int
prstats()
{
int sec;
int usec;
int tmsec;
if (gettimeofday(&stoptime, (struct timezone *)0) < 0)
comerr(_("Cannot get time\n"));
sec = stoptime.tv_sec - starttime.tv_sec;
usec = stoptime.tv_usec - starttime.tv_usec;
tmsec = sec*1000 + usec/1000;
#ifdef lint
tmsec = tmsec; /* Bisz spaeter */
#endif
if (usec < 0) {
sec--;
usec += 1000000;
}
error(_("Time total: %d.%03dsec\n"), sec, usec/1000);
return (1000*sec + (usec / 1000));
}
/*
* Return milliseconds since start time, but be silent this time.
*/
LOCAL int
prstats_silent()
{
int sec;
int usec;
int tmsec;
if (gettimeofday(&stoptime, (struct timezone *)0) < 0)
comerr(_("Cannot get time\n"));
sec = stoptime.tv_sec - starttime.tv_sec;
usec = stoptime.tv_usec - starttime.tv_usec;
tmsec = sec*1000 + usec/1000;
#ifdef lint
tmsec = tmsec; /* Bisz spaeter */
#endif
if (usec < 0) {
sec--;
usec += 1000000;
}
return (1000*sec + (usec / 1000));
}
LOCAL void
dorw(scgp, filename, sectors)
SCSI *scgp;
char *filename;
char *sectors;
{
parm_t params;
char *p = NULL;
params.start = 0;
params.end = -1;
params.sptr = -1;
params.askrange = FALSE;
params.name = NULL;
if (filename)
params.name = filename;
if (meshpoints > 0) {
if (params.name == NULL)
params.name = "/dev/null";
}
if (sectors)
p = astol(sectors, &params.start);
if (p && *p == '-')
p = astol(++p, &params.end);
if (p && *p != '\0')
comerrno(EX_BAD, _("Not a valid sector range '%s'\n"), sectors);
if (!wait_unit_ready(scgp, 60))
comerrno(EX_BAD, _("Device not ready.\n"));
#ifdef CLONE_WRITE
if (fulltoc) {
if (params.name == NULL)
params.name = "/dev/null";
read_ftoc(scgp, &params, FALSE);
} else if (clone || edc_corr) {
if (!is_mmc(scgp, NULL, NULL))
comerrno(EX_BAD, _("Unsupported device for clone mode.\n"));
if (!edc_corr)
noerror = TRUE;
if (retries == MAX_RETRY)
retries = 10;
if (params.name == NULL)
params.name = "/dev/null";
if (clone)
if (read_ftoc(scgp, &params, TRUE) < 0)
comerrno(EX_BAD, _("Read fulltoc problems.\n"));
readcd_disk(scgp, &params);
} else
#endif
if (c2scan) {
noerror = TRUE;
if (retries == MAX_RETRY)
retries = 10;
if (params.name == NULL)
params.name = "/dev/null";
readc2_disk(scgp, &params);
} else if (cxscan) {
if (plot && lverbose == 0)
lverbose = 1;
noerror = TRUE;
if (retries == MAX_RETRY)
retries = 10;
if (params.name == NULL)
params.name = "/dev/null";
readcx_disk(scgp, &params);
} else if (pi8scan || pifscan) {
if (plot && lverbose == 0)
lverbose = 1;
noerror = TRUE;
if (retries == MAX_RETRY)
retries = 10;
if (params.name == NULL)
params.name = "/dev/null";
readpi_disk(scgp, &params);
} else if (do_write)
write_disk(scgp, &params);
else
read_disk(scgp, &params);
}
LOCAL void
doit(scgp)
SCSI *scgp;
{
int i = 0;
parm_t params;
params.start = 0;
params.end = -1;
params.sptr = -1;
params.askrange = TRUE;
params.name = "/dev/null";
for (;;) {
if (!wait_unit_ready(scgp, 60))
comerrno(EX_BAD, _("Device not ready.\n"));
printf(_("0:read 1:veri 2:erase 3:read buffer 4:cache 5:ovtime 6:cap\n"));
printf(_("7:wne 8:floppy 9:verify 10:checkcmds 11:read disk 12:write disk\n"));
printf(_("13:scsireset 14:seektest 15: readda 16: reada 17: c2err\n"));
#ifdef CLONE_WRITE
printf(_("18:readcd 19: lin 20: full toc\n"));
#endif
getint(_("Enter selection:"), &i, 0, 20);
if (didintr)
return;
switch (i) {
case 5: ovtime(scgp); break;
case 11: read_disk(scgp, 0); break;
case 12: write_disk(scgp, 0); break;
case 15: ra(scgp); break;
/* case 16: reada_disk(scgp, 0, 0); break;*/
case 17: readc2_disk(scgp, &params); break;
#ifdef CLONE_WRITE
case 18: readcd_disk(scgp, 0); break;
case 19: read_lin(scgp, 0); break;
case 20: read_ftoc(scgp, 0, FALSE); break;
#endif
}
}
}
LOCAL void
read_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
rparm_t rp;
read_capacity(scgp);
print_capacity(scgp, stderr);
rp.errors = 0;
rp.c2_errors = 0;
rp.c2_maxerrs = 0;
rp.c2_errsecs = 0;
rp.c2_badsecs = 0;
rp.isecsize = rp.secsize = scgp->cap->c_bsize;
read_generic(scgp, parmp, fread_data, &rp, fdata_null);
}
#ifdef CLONE_WRITE
LOCAL void
readcd_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
rparm_t rp;
int osecsize = 2048;
int oerr = 0;
int oretr = 10;
int (*funcp)__PR((SCSI *_scgp, rparm_t *_rp, caddr_t bp, long addr, int cnt));
scgp->silent++;
if (read_capacity(scgp) >= 0)
osecsize = scgp->cap->c_bsize;
scgp->silent--;
if (osecsize != 2048)
select_secsize(scgp, 2048);
read_capacity(scgp);
print_capacity(scgp, stderr);
rp.errors = 0;
rp.c2_errors = 0;
rp.c2_maxerrs = 0;
rp.c2_errsecs = 0;
rp.c2_badsecs = 0;
rp.isecsize = rp.secsize = 2448;
rp.ismmc = is_mmc(scgp, NULL, NULL);
funcp = fread_2448;
wait_unit_ready(scgp, 10);
if (fread_2448(scgp, &rp, Sbuf, 0, 0) < 0) {
errmsgno(EX_BAD, _("read 2448 failed\n"));
if (rp.ismmc &&
fread_2448_16(scgp, &rp, Sbuf, 0, 0) >= 0) {
errmsgno(EX_BAD, _("read 2448_16 : OK\n"));
funcp = fread_2448_16;
}
}
if (edc_corr) {
funcp = fread_2048;
rp.secsize = 2048; /* We ouput CD-ROM data sectors */
rp.isecsize = 2352; /* We read CD-DA sectors from CD */
}
oldmode(scgp, &oerr, &oretr);
exargs.oerr[0] = oerr;
exargs.oerr[1] = oretr;
exargs.oerr[2] = 0xFF;
if (parmp == NULL) /* XXX Nur am Anfang!!! */
domode(scgp, -1, -1);
else
domode(scgp, nocorr?0x21:0x20, 10);
read_generic(scgp, parmp, funcp, &rp, fdata_null);
if (osecsize != 2048)
select_secsize(scgp, osecsize);
domode(scgp, oerr, oretr);
}
/* ARGSUSED */
LOCAL void
read_lin(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
parm_t parm;
rparm_t rp;
read_capacity(scgp);
print_capacity(scgp, stderr);
parm.start = ULONG_C(0xF0000000);
parm.end = ULONG_C(0xFF000000);
parm.name = "DDD";
rp.errors = 0;
rp.c2_errors = 0;
rp.c2_maxerrs = 0;
rp.c2_errsecs = 0;
rp.c2_badsecs = 0;
rp.isecsize = rp.secsize = 2448;
rp.ismmc = is_mmc(scgp, NULL, NULL);
domode(scgp, -1, -1);
read_generic(scgp, &parm, fread_lin, &rp, fdata_null);
}
LOCAL int
read_secheader(scgp, addr)
SCSI *scgp;
long addr;
{
rparm_t rp;
int osecsize = 2048;
int ret = 0;
scgp->silent++;
if (read_capacity(scgp) >= 0)
osecsize = scgp->cap->c_bsize;
scgp->silent--;
if (osecsize != 2048)
select_secsize(scgp, 2048);
read_capacity(scgp);
rp.errors = 0;
rp.c2_errors = 0;
rp.c2_maxerrs = 0;
rp.c2_errsecs = 0;
rp.c2_badsecs = 0;
rp.isecsize = rp.secsize = 2352;
rp.ismmc = is_mmc(scgp, NULL, NULL);
wait_unit_ready(scgp, 10);
fillbytes(Sbuf, 2352, '\0');
if (fread_2352(scgp, &rp, Sbuf, addr, 1) < 0) {
ret = -1;
}
if (osecsize != 2048)
select_secsize(scgp, osecsize);
return (ret);
}
/* ARGSUSED */
LOCAL int
read_ftoc(scgp, parmp, do_sectype)
SCSI *scgp;
parm_t *parmp;
BOOL do_sectype;
{
FILE *f;
int i;
char filename[1024];
struct tocheader *tp;
char *p;
char xb[256];
int len;
char xxb[10000];
strcpy(filename, "toc.dat");
if (parmp != NULL &&
strcmp(parmp->name, "/dev/null") != 0) {
len = strlen(parmp->name);
if (len > (sizeof (filename)-5)) {
len = sizeof (filename)-5;
}
js_snprintf(filename, sizeof (filename), "%.*s.toc", len, parmp->name);
}
tp = (struct tocheader *)xb;
fillbytes((caddr_t)xb, sizeof (xb), '\0');
if (read_toc(scgp, xb, 0, sizeof (struct tocheader), 0, FMT_FULLTOC) < 0) {
if (scgp->silent == 0 || scgp->verbose > 0)
errmsgno(EX_BAD, _("Cannot read TOC header\n"));
return (-1);
}
len = a_to_u_2_byte(tp->len) + sizeof (struct tocheader)-2;
error(_("TOC len: %d. First Session: %d Last Session: %d.\n"), len, tp->first, tp->last);
/*
* XXX there is a bug in some ASPI versions that
* XXX cause a hang with odd transfer lengths.
* XXX We should workaround the problem where it exists
* XXX but the problem may exist elsewhere too.
*/
if (len & 1)
len++;
if (read_toc(scgp, xxb, 0, len, 0, FMT_FULLTOC) < 0) {
if (len & 1) {
/*
* Work around a bug in some operating systems that do not
* handle odd byte DMA correctly for ATAPI drives.
*/
wait_unit_ready(scgp, 30);
read_toc(scgp, xb, 0, sizeof (struct tocheader), 0, FMT_FULLTOC);
wait_unit_ready(scgp, 30);
if (read_toc(scgp, xxb, 0, len+1, 0, FMT_FULLTOC) >= 0) {
goto itworked;
}
}
if (scgp->silent == 0)
errmsgno(EX_BAD, _("Cannot read full TOC\n"));
return (-1);
}
itworked:
f = fileopen(filename, "wctb");
if (f == NULL)
comerr(_("Cannot open '%s'.\n"), filename);
filewrite(f, xxb, len);
if (do_sectype)
read_sectypes(scgp, f);
fflush(f);
fclose(f);
p = &xxb[4];
for (; p < &xxb[len]; p += 11) {
for (i = 0; i < 11; i++)
error("%02X ", p[i] & 0xFF);
error("\n");
}
/*
* List all lead out start times to give information about multi
* session disks.
*/
p = &xxb[4];
for (; p < &xxb[len]; p += 11) {
if ((p[3] & 0xFF) == 0xA2) {
error(_("Lead out %d: %ld\n"), p[0], msf_to_lba(p[8], p[9], p[10], TRUE));
}
}
return (0);
}
LOCAL void
read_sectypes(scgp, f)
SCSI *scgp;
FILE *f;
{
char sect;
sect = SECT_AUDIO;
get_sectype(scgp, 4, &sect);
if (f != NULL)
filewrite(f, &sect, 1);
if (xdebug)
scg_prbytes(_("sec 0"), (Uchar *)Sbuf, 16);
sect = SECT_AUDIO;
get_sectype(scgp, scgp->cap->c_baddr-4, &sect);
if (f != NULL)
filewrite(f, &sect, 1);
if (xdebug) {
scg_prbytes(_("sec E"), (Uchar *)Sbuf, 16);
error(_("baddr: %ld\n"), (long)scgp->cap->c_baddr);
}
}
LOCAL void
get_sectype(scgp, addr, st)
SCSI *scgp;
long addr;
char *st;
{
char *synchdr = "\0\377\377\377\377\377\377\377\377\377\377\0";
int sectype = SECT_AUDIO;
int i;
long raddr = addr;
#define _MAX_TRY_ 20
scgp->silent++;
for (i = 0; i < _MAX_TRY_ && read_secheader(scgp, raddr) < 0; i++) {
if (addr == 0)
raddr++;
else
raddr--;
}
scgp->silent--;
if (i >= _MAX_TRY_) {
error(_("Sectype (%ld) is CANNOT\n"), addr);
return;
} else if (i > 0) {
error(_("Sectype (%ld) needed %d retries\n"), addr, i);
}
#undef _MAX_TRY_
if (cmpbytes(Sbuf, synchdr, 12) < 12) {
if (xdebug)
error(_("Sectype (%ld) is AUDIO\n"), addr);
if (st)
*st = SECT_AUDIO;
return;
}
if (xdebug)
error(_("Sectype (%ld) is DATA\n"), addr);
if (Sbuf[15] == 0) {
if (xdebug)
error(_("Sectype (%ld) is MODE 0\n"), addr);
sectype = SECT_MODE_0;
} else if (Sbuf[15] == 1) {
if (xdebug)
error(_("Sectype (%ld) is MODE 1\n"), addr);
sectype = SECT_ROM;
} else if (Sbuf[15] == 2) {
if (xdebug)
error(_("Sectype (%ld) is MODE 2\n"), addr);
if ((Sbuf[16+2] & 0x20) == 0 &&
(Sbuf[16+4+2] & 0x20) == 0) {
if (xdebug)
error(_("Sectype (%ld) is MODE 2 form 1\n"), addr);
sectype = SECT_MODE_2_F1;
} else if ((Sbuf[16+2] & 0x20) != 0 &&
(Sbuf[16+4+2] & 0x20) != 0) {
if (xdebug)
error(_("Sectype (%ld) is MODE 2 form 2\n"), addr);
sectype = SECT_MODE_2_F2;
} else {
if (xdebug)
error(_("Sectype (%ld) is MODE 2 formless\n"), addr);
sectype = SECT_MODE_2;
}
} else {
error(_("Sectype (%ld) is UNKNOWN\n"), addr);
}
if (st)
*st = sectype;
if (xdebug)
error(_("Sectype (%ld) is 0x%02X\n"), addr, sectype);
}
#endif /* CLONE_WRITE */
char zeroblk[512];
LOCAL void
readc2_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
rparm_t rp;
int osecsize = 2048;
int oerr = 0;
int oretr = 10;
scgp->silent++;
if (read_capacity(scgp) >= 0)
osecsize = scgp->cap->c_bsize;
scgp->silent--;
if (osecsize != 2048)
select_secsize(scgp, 2048);
read_capacity(scgp);
print_capacity(scgp, stderr);
rp.errors = 0;
rp.c2_errors = 0;
rp.c2_maxerrs = 0;
rp.c2_errsecs = 0;
rp.c2_badsecs = 0;
rp.isecsize = rp.secsize = 2352 + 294; /* CD-DA + C2 bit pointers */
rp.ismmc = is_mmc(scgp, NULL, NULL);
oldmode(scgp, &oerr, &oretr);
exargs.oerr[0] = oerr;
exargs.oerr[1] = oretr;
exargs.oerr[2] = 0xFF;
domode(scgp, 0x21, 10);
read_generic(scgp, parmp, fread_c2, &rp, fdata_c2);
if (osecsize != 2048)
select_secsize(scgp, osecsize);
domode(scgp, oerr, oretr);
printf(_("Total of %d hard read errors.\n"), rp.errors);
printf(_("C2 errors total: %d bytes in %d sectors on disk\n"), rp.c2_errors, rp.c2_errsecs);
printf(_("C2 errors rate: %f%% per byte, %f%% per sector\n"),
(100.0*rp.c2_errors)/scgp->cap->c_baddr/2352,
(100.0*rp.c2_errsecs)/scgp->cap->c_baddr);
printf(_("C2 errors on worst sector: %d, sectors with 100+ C2 errors: %d\n"), rp.c2_maxerrs, rp.c2_badsecs);
}
LOCAL void
readcx_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
long addr = 0L;
long end = 0L;
int secs; /* # of seconds */
cxerror_t errors;
cxerror_t stats;
cxerror_t max_errors;
cx_scan_procedure_t *sp;
BOOL askrange = FALSE;
BOOL isrange = FALSE;
FILE *f = stdout;
if (is_suid) {
if (scgp->inq->type != INQ_ROMD)
comerrno(EX_BAD, _("Not root. Will only read from CD in suid/priv mode\n"));
}
scgp->silent++;
if (read_capacity(scgp) >= 0)
end = scgp->cap->c_baddr + 1;
scgp->silent--;
print_capacity(scgp, stderr);
if (parmp == NULL || parmp->askrange)
askrange = TRUE;
if (parmp != NULL && !askrange && (parmp->start <= parmp->end))
isrange = TRUE;
if ((end <= 0 && isrange) || (askrange && scg_yes(_("Ignore disk size? "))))
end = 10000000; /* Hack to read empty (e.g. blank=fast) disks */
if (parmp) {
addr = parmp->start;
if (parmp->end != -1 && parmp->end < end)
end = parmp->end;
}
for (sp = cx_scan_procedures; sp->start_func; sp++) {
if ((*sp->start_func)(scgp) >= 0)
break;
}
if (sp->start_func == NULL)
comerrno(EX_BAD, _("Unsupported drive for -cxscan\n"));
secs = (end - addr) / 75; /* Compute # of seconds */
fillbytes(&stats, sizeof (stats), '\0');
fillbytes(&max_errors, sizeof (max_errors), '\0');
while (addr < end) {
addr = (*sp->one_interval_func)(scgp, &errors, addr, Sbuf);
stats.c1_errors += errors.c1_errors;
stats.c2_errors += errors.c2_errors;
stats.cu_errors += errors.cu_errors;
stats.pi_errors += errors.pi_errors;
max_errors.c1_errors = max(max_errors.c1_errors, errors.c1_errors);
max_errors.c2_errors = max(max_errors.c2_errors, errors.c2_errors);
max_errors.cu_errors = max(max_errors.cu_errors, errors.cu_errors);
max_errors.pi_errors = max(max_errors.pi_errors, errors.pi_errors);
if (lverbose > 1 ||
(lverbose > 0 &&
(errors.c1_errors || errors.c2_errors || errors.cu_errors))) {
if (plot) {
printf("%8ld %4d %4d %4d\n",
addr,
errors.c1_errors, errors.c2_errors,
errors.cu_errors);
flush();
} else {
printf(" %3ldm %02lds: C1: %4d, C2: %4d, CU: %4d\n",
addr/75/60, addr/75%60,
errors.c1_errors, errors.c2_errors,
errors.cu_errors);
}
}
if (didintr) {
(*sp->end_func)(scgp);
comexit(exsig);
}
}
if (plot)
f = stderr;
fprintf(f, _("\n\ntotal result:\n\n"));
fprintf(f, _("total: C1: %5d, C2: %5d, CU: %5d\n"),
stats.c1_errors, stats.c2_errors, stats.cu_errors);
fprintf(f, _("max : C1: %5d, C2: %5d, CU: %5d\n"),
max_errors.c1_errors, max_errors.c2_errors,
max_errors.cu_errors);
fprintf(f, _("avg/s: C1: %5.1f, C2: %5.1f, CU: %5.1f\n\n"),
(float)stats.c1_errors/secs,
(float)stats.c2_errors/secs,
(float)stats.cu_errors/secs);
(*sp->end_func)(scgp);
}
LOCAL void
readpi_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
long addr = 0L;
long end = 0L;
int secs; /* # of seconds */
cxerror_t errors;
cxerror_t stats;
cxerror_t max_errors;
BOOL askrange = FALSE;
BOOL isrange = FALSE;
FILE *f = stdout;
if (is_suid) {
if (scgp->inq->type != INQ_ROMD)
comerrno(EX_BAD, _("Not root. Will only read from CD in suid/priv mode\n"));
}
scgp->silent++;
if (read_capacity(scgp) >= 0)
end = scgp->cap->c_baddr + 1;
scgp->silent--;
print_capacity(scgp, stderr);
if (parmp == NULL || parmp->askrange)
askrange = TRUE;
if (parmp != NULL && !askrange && (parmp->start <= parmp->end))
isrange = TRUE;
if ((end <= 0 && isrange) || (askrange && scg_yes(_("Ignore disk size? "))))
end = 10000000; /* Hack to read empty (e.g. blank=fast) disks */
if (parmp) {
addr = parmp->start;
if (parmp->end != -1 && parmp->end < end)
end = parmp->end;
}
if (pifscan) {
if (plextor_init_pif_scan(scgp) < 0)
comerrno(EX_BAD, _("Unsupported drive for -pifscan\n"));
} else if (plextor_init_pi8_scan(scgp) < 0)
comerrno(EX_BAD, _("Unsupported drive for -pi8scan\n"));
secs = (end - addr) / (8*16); /* Compute # of blocks */
if (pifscan)
secs = (end - addr) / (16); /* Compute # of blocks */
fillbytes(&stats, sizeof (stats), '\0');
fillbytes(&max_errors, sizeof (max_errors), '\0');
while (addr < end) {
addr = plextor_scan_one_dvd_interval(scgp, &errors, addr, Sbuf);
stats.c1_errors += errors.c1_errors;
stats.c2_errors += errors.c2_errors;
stats.cu_errors += errors.cu_errors;
stats.pi_errors += errors.pi_errors;
max_errors.c1_errors = max(max_errors.c1_errors, errors.c1_errors);
max_errors.c2_errors = max(max_errors.c2_errors, errors.c2_errors);
max_errors.cu_errors = max(max_errors.cu_errors, errors.cu_errors);
max_errors.pi_errors = max(max_errors.pi_errors, errors.pi_errors);
if (lverbose > 1 ||
(lverbose > 0 && errors.pi_errors)) {
printf(" %8ld %6d\n",
addr,
errors.pi_errors);
if (plot)
flush();
}
if (didintr) {
plextor_end_scan(scgp);
comexit(exsig);
}
}
if (plot)
f = stderr;
fprintf(f, _("\n\ntotal result:\n\n"));
fprintf(f, _("total: PI: %8d\n"),
stats.pi_errors);
fprintf(f, _("max : PI: %8d\n"),
max_errors.pi_errors);
fprintf(f, _("avg sum: PI: %8.1f\n\n"),
(float)stats.pi_errors/secs);
plextor_end_scan(scgp);
}
/* ARGSUSED */
LOCAL int
fread_data(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
return (read_g1(scgp, bp, addr, cnt));
}
#ifdef CLONE_WRITE
LOCAL int
fread_2448(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
if (rp->ismmc) {
return (read_cd(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC */
(1 << 7 | 3 << 5 | 1 << 4 | 1 << 3),
/* plus all subchannels RAW */
1));
} else {
return (read_da(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC + all subch */
0x02));
}
}
LOCAL int
fread_2448_16(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
if (rp->ismmc) {
track_t trackdesc;
int ret;
int i;
char *p;
trackdesc.isecsize = 2368;
trackdesc.secsize = 2448;
ret = read_cd(scgp, bp, addr, cnt, 2368,
/* Sync + all headers + user data + EDC/ECC */
(1 << 7 | 3 << 5 | 1 << 4 | 1 << 3),
/* subchannels P/Q */
2);
if (ret < 0)
return (ret);
scatter_secs(&trackdesc, bp, cnt);
for (i = 0, p = bp+2352; i < cnt; i++) {
#ifdef more_than_q_sub
if ((p[15] & 0x80) != 0)
printf("P");
#endif
/*
* As the drives don't return P-sub, we check
* whether the index equals 0.
*/
qpto96((Uchar *)p, (Uchar *)p, p[2] == 0);
p += 2448;
}
return (ret);
} else {
comerrno(EX_BAD, _("Cannot fread_2448_16 on non MMC drives\n"));
return (read_da(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC + all subch */
0x02));
}
}
LOCAL int
fread_2352(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
if (rp->ismmc) {
return (read_cd(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC */
(1 << 7 | 3 << 5 | 1 << 4 | 1 << 3),
/* NO subchannels */
0));
} else {
comerrno(EX_BAD, _("Cannot fread_2352 on non MMC drives\n"));
return (read_da(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC + all subch */
0x02));
}
}
/*
* -ledc_ecc_dec read variant: read CD-DA sectors (2352 bytes) and output
* corrected CD-ROM sectors (2048 bytes).
*/
int edc_OK = 0;
LOCAL int
fread_2048(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
int ret;
char *from;
char *to;
char *p;
int i = 0;
int secsize = rp->secsize;
BOOL OK = TRUE;
rp->secsize = rp->isecsize;
fillbytes(bp, rp->secsize * cnt, '\0');
ret = fread_2352(scgp, rp, bp, addr, cnt);
rp->secsize = secsize;
from = bp;
from += 16;
to = bp;
p = bp;
while (i < cnt) {
int crc;
crc = crc_check((unsigned char *)p, MODE_1);
ret = do_decode_L2((unsigned char *)p, MODE_1, FALSE, 0);
if (ret < 0)
OK = FALSE;
if (crc == 0 && ret == 0) {
edc_OK++;
error("Corrected: total %d Block %ld\n", edc_OK, addr+i);
}
move2048(from, to);
from += 2352;
to += 2048;
p += 2352;
i++;
}
if (OK)
return (0);
else
return (-1);
}
LOCAL int
fread_lin(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
if (addr != ULONG_C(0xF0000000))
addr = ULONG_C(0xFFFFFFFF);
return (read_cd(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC */
(1 << 7 | 3 << 5 | 1 << 4 | 1 << 3),
/* plus all subchannels RAW */
1));
}
#endif /* CLONE_WRITE */
LOCAL int
bits(c)
int c;
{
int n = 0;
if (c & 0x01)
n++;
if (c & 0x02)
n++;
if (c & 0x04)
n++;
if (c & 0x08)
n++;
if (c & 0x10)
n++;
if (c & 0x20)
n++;
if (c & 0x40)
n++;
if (c & 0x80)
n++;
return (n);
}
LOCAL int
bitidx(c)
int c;
{
if (c & 0x80)
return (0);
if (c & 0x40)
return (1);
if (c & 0x20)
return (2);
if (c & 0x10)
return (3);
if (c & 0x08)
return (4);
if (c & 0x04)
return (5);
if (c & 0x02)
return (6);
if (c & 0x01)
return (7);
return (-1);
}
LOCAL int
fread_c2(scgp, rp, bp, addr, cnt)
SCSI *scgp;
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
if (rp->ismmc) {
return (read_cd(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC + C2 */
/* (1 << 7 | 3 << 5 | 1 << 4 | 1 << 3 | 2 << 1),*/
(1 << 7 | 3 << 5 | 1 << 4 | 1 << 3 | 1 << 1),
/* without subchannels */
0));
} else {
return (read_da(scgp, bp, addr, cnt, rp->secsize,
/* Sync + all headers + user data + EDC/ECC + C2 */
0x04));
}
}
/* ARGSUSED */
LOCAL int
fdata_null(rp, bp, addr, cnt)
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
return (0);
}
LOCAL int
fdata_c2(rp, bp, addr, cnt)
rparm_t *rp;
caddr_t bp;
long addr;
int cnt;
{
int i;
int j;
int k;
char *p;
p = &bp[2352];
for (i = 0; i < cnt; i++, p += (2352+294)) {
/* scg_prbytes("XXX ", p, 294);*/
if ((j = cmpbytes(p, zeroblk, 294)) < 294) {
printf(_("C2 in sector: %3ld first at byte: %4d (0x%02X)"), addr+i,
j*8 + bitidx(p[j]), p[j]&0xFF);
for (j = 0, k = 0; j < 294; j++)
k += bits(p[j]);
printf(_(" total: %4d errors\n"), k);
/* scg_prbytes("XXX ", p, 294);*/
rp->c2_errors += k;
if (k > rp->c2_maxerrs)
rp->c2_maxerrs = k;
rp->c2_errsecs++;
if (k >= 100)
rp->c2_badsecs += 1;
}
}
return (0);
}
#ifdef used
LOCAL int
read_scsi_g1(scgp, bp, addr, cnt)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
{
register struct scg_cmd *scmd = scgp->scmd;
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = bp;
/* scmd->size = cnt*512;*/
scmd->size = cnt*scgp->cap->c_bsize;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G1_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g1_cdb.cmd = 0x28;
scmd->cdb.g1_cdb.lun = scg_lun(scgp);
g1_cdbaddr(&scmd->cdb.g1_cdb, addr);
g1_cdblen(&scmd->cdb.g1_cdb, cnt);
scgp->cmdname = "read extended";
return (scg_cmd(scgp));
}
#endif
#define G0_MAXADDR 0x1FFFFFL
EXPORT int
write_scsi(scgp, bp, addr, cnt)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
{
if (addr <= G0_MAXADDR)
return (write_g0(scgp, bp, addr, cnt));
else
return (write_g1(scgp, bp, addr, cnt));
}
EXPORT int
write_g0(scgp, bp, addr, cnt)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
{
register struct scg_cmd *scmd = scgp->scmd;
if (scgp->cap->c_bsize <= 0)
raisecond("capacity_not_set", 0L);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = bp;
scmd->size = cnt*scgp->cap->c_bsize;
scmd->flags = SCG_DISRE_ENA;
scmd->cdb_len = SC_G0_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g0_cdb.cmd = SC_WRITE;
scmd->cdb.g0_cdb.lun = scg_lun(scgp);
g0_cdbaddr(&scmd->cdb.g0_cdb, addr);
scmd->cdb.g0_cdb.count = (Uchar)cnt;
scgp->cmdname = "write_g0";
return (scg_cmd(scgp));
}
EXPORT int
write_g1(scgp, bp, addr, cnt)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
{
register struct scg_cmd *scmd = scgp->scmd;
if (scgp->cap->c_bsize <= 0)
raisecond("capacity_not_set", 0L);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = bp;
scmd->size = cnt*scgp->cap->c_bsize;
scmd->flags = SCG_DISRE_ENA;
scmd->cdb_len = SC_G1_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g1_cdb.cmd = SC_EWRITE;
scmd->cdb.g1_cdb.lun = scg_lun(scgp);
g1_cdbaddr(&scmd->cdb.g1_cdb, addr);
g1_cdblen(&scmd->cdb.g1_cdb, cnt);
scgp->cmdname = "write_g1";
return (scg_cmd(scgp));
}
#ifdef used
LOCAL void
Xrequest_sense(scgp)
SCSI *scgp;
{
char sense_buf[32];
struct scg_cmd ocmd;
int sense_count;
char *cmdsave;
register struct scg_cmd *scmd = scgp->scmd;
cmdsave = scgp->cmdname;
movebytes(scmd, &ocmd, sizeof (*scmd));
fillbytes((caddr_t)sense_buf, sizeof (sense_buf), '\0');
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = (caddr_t)sense_buf;
scmd->size = sizeof (sense_buf);
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G0_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g1_cdb.cmd = 0x3;
scmd->cdb.g1_cdb.lun = scg_lun(scgp);
scmd->cdb.g0_cdb.count = sizeof (sense_buf);
scgp->cmdname = "request sense";
scg_cmd(scgp);
sense_count = sizeof (sense_buf) - scg_getresid(scgp);
movebytes(&ocmd, scmd, sizeof (*scmd));
scmd->sense_count = sense_count;
movebytes(sense_buf, (Uchar *)&scmd->sense, scmd->sense_count);
scgp->cmdname = cmdsave;
scg_printerr(scgp);
scg_printresult(scgp); /* XXX restore key/code in future */
}
#endif
LOCAL int
read_retry(scgp, bp, addr, cnt, rfunc, rp)
SCSI *scgp;
caddr_t bp;
long addr;
long cnt;
int (*rfunc)__PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
rparm_t *rp;
{
/* int secsize = scgp->cap->c_bsize;*/
int secsize = rp->secsize;
int try = 0;
int err;
char dummybuf[8192];
if (secsize > sizeof (dummybuf)) {
errmsgno(EX_BAD, _("Cannot retry, sector size %d too big.\n"), secsize);
return (-1);
}
errmsgno(EX_BAD, _("Retrying from sector %ld.\n"), addr);
while (cnt > 0) {
error(".");
do {
if (didintr)
comexit(exsig); /* XXX besseres Konzept?!*/
wait_unit_ready(scgp, 120);
if (try >= 10) { /* First 10 retries without seek */
if ((try % 8) == 0) {
error("+"); /* Read last sector */
scgp->silent++;
(*rfunc)(scgp, rp, dummybuf, scgp->cap->c_baddr, 1);
scgp->silent--;
} else if ((try % 4) == 0) {
error("-"); /* Read first sector */
scgp->silent++;
(*rfunc)(scgp, rp, dummybuf, 0, 1);
scgp->silent--;
} else {
error("~"); /* Read random sector */
scgp->silent++;
(*rfunc)(scgp, rp, dummybuf, choice(scgp->cap->c_baddr), 1);
scgp->silent--;
}
if (didintr)
comexit(exsig); /* XXX besseres Konzept?!*/
wait_unit_ready(scgp, 120);
}
if (didintr)
comexit(exsig); /* XXX besseres Konzept?!*/
fillbytes(bp, secsize, 0);
scgp->silent++;
err = (*rfunc)(scgp, rp, bp, addr, 1);
scgp->silent--;
if (err < 0) {
err = scgp->scmd->ux_errno;
/* error("\n");*/
/* errmsgno(err, "Cannot read source disk\n");*/
} else {
if (scg_getresid(scgp)) {
error(_("\nresid: %d\n"), scg_getresid(scgp));
/*
* If we use -ledc_ecc_dec for
* correction, let the correction
* happen on an upper layer.
*/
if (!edc_corr)
return (-1);
}
break;
}
} while (++try < retries);
if (try >= retries) {
error("\n");
errmsgno(err, _("Error on sector %ld not corrected. Total of %d errors.\n"),
addr, ++rp->errors);
if (scgp->silent <= 1 && lverbose > 0)
scg_printerr(scgp);
add_bad(addr);
if (!noerror)
return (-1);
errmsgno(EX_BAD, _("-noerror set, continuing ...\n"));
} else {
if (try >= maxtry)
maxtry = try;
if (try > 1) {
error("\n");
errmsgno(EX_BAD,
_("Error on sector %ld corrected after %d tries. Total of %d errors.\n"),
addr, try, rp->errors);
}
}
try = 0;
cnt -= 1;
addr += 1;
bp += secsize;
}
return (0);
}
LOCAL void
read_generic(scgp, parmp, rfunc, rp, dfunc)
SCSI *scgp;
parm_t *parmp;
int (*rfunc)__PR((SCSI *scgp, rparm_t *rp, caddr_t bp, long addr, int cnt));
rparm_t *rp;
int (*dfunc)__PR((rparm_t *rp, caddr_t bp, long addr, int cnt));
{
char filename[512];
char *defname = NULL;
FILE *f;
long addr = 0L;
long old_addr = 0L;
long num;
long end = 0L;
long start = 0L;
long cnt = 0L;
long next_point = 0L;
long secs_per_point = 0L;
double speed;
int msec;
int old_msec = 0;
int err = 0;
BOOL askrange = FALSE;
BOOL isrange = FALSE;
int secsize = rp->secsize;
int i = 0;
if (is_suid) {
if (scgp->inq->type != INQ_ROMD)
comerrno(EX_BAD, _("Not root. Will only read from CD in suid/priv mode\n"));
}
if (parmp == NULL || parmp->askrange)
askrange = TRUE;
if (parmp != NULL && !askrange && (parmp->start <= parmp->end))
isrange = TRUE;
filename[0] = '\0';
scgp->silent++;
if (read_capacity(scgp) >= 0)
end = scgp->cap->c_baddr + 1;
scgp->silent--;
if ((end <= 0 && isrange) || (askrange && scg_yes(_("Ignore disk size? "))))
end = 10000000; /* Hack to read empty (e.g. blank=fast) disks */
if (parmp) {
if (parmp->name)
defname = parmp->name;
if (defname != NULL) {
error(_("Copy from SCSI (%d,%d,%d) disk to file '%s'\n"),
scg_scsibus(scgp), scg_target(scgp), scg_lun(scgp),
defname);
}
addr = start = parmp->start;
if (parmp->end != -1 && parmp->end < end)
end = parmp->end;
cnt = Sbufsize / secsize;
/*
* XXX clean up this hack in future.
*/
if (edc_corr)
cnt = Sbufsize / rp->isecsize;
}
if (defname == NULL) {
defname = "disk.out";
error(_("Copy from SCSI (%d,%d,%d) disk to file\n"),
scg_scsibus(scgp), scg_target(scgp), scg_lun(scgp));
error(_("Enter filename [%s]: "), defname); flush();
(void) getline(filename, sizeof (filename));
}
if (askrange) {
addr = start;
getlong(_("Enter starting sector for copy:"), &addr, start, end-1);
/* getlong(_("Enter starting sector for copy:"), &addr, -300, end-1);*/
start = addr;
}
if (askrange) {
num = end - addr;
getlong(_("Enter number of sectors to copy:"), &num, 1L, num);
end = addr + num;
}
if (askrange) {
/* XXX askcnt */
cnt = Sbufsize / secsize;
/*
* XXX clean up this hack in future.
*/
if (edc_corr)
cnt = Sbufsize / rp->isecsize;
getlong(_("Enter number of sectors per copy:"), &cnt, 1L, cnt);
}
if (filename[0] == '\0')
strncpy(filename, defname, sizeof (filename));
filename[sizeof (filename)-1] = '\0';
if (streql(filename, "-")) {
f = stdout;
setmode(STDOUT_FILENO, O_BINARY);
} else if ((f = fileopen(filename, notrunc?"wcub":"wctub")) == NULL)
comerr(_("Cannot open '%s'.\n"), filename);
file_raise(f, FALSE);
error(_("end: %8ld\n"), end);
if (gettimeofday(&starttime, (struct timezone *)0) < 0)
comerr(_("Cannot get start time\n"));
if (meshpoints > 0) {
if ((end-start) < meshpoints)
secs_per_point = 1;
else
secs_per_point = (end-start) / meshpoints;
next_point = start + secs_per_point;
old_addr = start;
}
for (; addr < end; addr += cnt) {
if (didintr)
comexit(exsig); /* XXX besseres Konzept?!*/
if ((addr + cnt) > end)
cnt = end - addr;
if (meshpoints > 0) {
if (addr > next_point) {
msec = prstats_silent();
if ((msec - old_msec) == 0) /* Avoid division by zero */
msec = old_msec + 1;
speed = ((addr - old_addr)/(1000.0/secsize)) / (0.001*(msec - old_msec));
if (do_factor) {
if (is_cdrom)
speed /= 176.400 * (secsize/2352.0);
else if (is_dvd)
speed /= 1385.0;
if (is_bd)
speed /= 4495.0;
}
error(_("addr: %8ld cnt: %ld"), addr, cnt);
printf("%8ld %8.2f\n", addr, speed);
if (plot)
flush();
error("\r");
next_point += secs_per_point;
old_addr = addr;
old_msec = msec;
i++;
if (meshpoints < 100)
flush();
else if (i % (meshpoints/100) == 0)
flush();
}
}
error(_("addr: %8ld cnt: %ld\r"), addr, cnt);
scgp->silent++;
if ((*rfunc)(scgp, rp, Sbuf, addr, cnt) < 0) {
scgp->silent--;
err = scgp->scmd->ux_errno;
if (quiet) {
error("\n");
} else if (scgp->silent == 0) {
scg_printerr(scgp);
}
errmsgno(err, _("Cannot read source disk\n"));
if (read_retry(scgp, Sbuf, addr, cnt, rfunc, rp) < 0) {
exargs.excode = -2;
goto out;
}
} else {
scgp->silent--;
if (scg_getresid(scgp)) {
error(_("\nresid: %d\n"), scg_getresid(scgp));
/*
* If we use -ledc_ecc_dec for
* correction, let the correction
* happen on an upper layer, but make it an
* error in case of DMA residual problems.
*/
if (!edc_corr)
goto out;
}
}
(*dfunc)(rp, Sbuf, addr, cnt);
if (filewrite(f, Sbuf, cnt * secsize) < 0) {
err = geterrno();
error("\n");
errmsgno(err, _("Cannot write '%s'\n"), filename);
exargs.excode = err;
break;
}
}
error(_("addr: %8ld"), addr);
out:
error("\n");
msec = prstats();
if (msec == 0) /* Avoid division by zero */
msec = 1;
#ifdef OOO
error(_("Read %.2f kB at %.1f kB/sec.\n"),
(double)(addr - start)/(1024.0/scgp->cap->c_bsize),
(double)((addr - start)/(1024.0/scgp->cap->c_bsize)) / (0.001*msec));
#else
error(_("Read %.2f kB at %.1f kB/sec.\n"),
(double)(addr - start)/(1024.0/secsize),
(double)((addr - start)/(1024.0/secsize)) / (0.001*msec));
#endif
print_bad();
}
LOCAL void
write_disk(scgp, parmp)
SCSI *scgp;
parm_t *parmp;
{
char filename[512];
char *defname = "disk.out";
FILE *f;
long addr = 0L;
long cnt;
long amt;
long end = 0L;
int msec;
int start;
if (is_suid)
comerrno(EX_BAD, _("Not root. Will not write in suid/priv mode\n"));
filename[0] = '\0';
if (read_capacity(scgp) >= 0) {
end = scgp->cap->c_baddr + 1;
print_capacity(scgp, stderr);
}
if (end <= 1)
end = 10000000; /* Hack to write empty disks */
if (parmp) {
if (parmp->name)
defname = parmp->name;
error(_("Copy from file '%s' to SCSI (%d,%d,%d) disk\n"),
defname,
scg_scsibus(scgp), scg_target(scgp), scg_lun(scgp));
addr = start = parmp->start;
if (parmp->end != -1 && parmp->end < end)
end = parmp->end;
cnt = Sbufsize / scgp->cap->c_bsize;
} else {
error(_("Copy from file to SCSI (%d,%d,%d) disk\n"),
scg_scsibus(scgp), scg_target(scgp), scg_lun(scgp));
error(_("Enter filename [%s]: "), defname); flush();
(void) getline(filename, sizeof (filename));
error(_("Notice: reading from file always starts at file offset 0.\n"));
getlong(_("Enter starting sector for copy:"), &addr, 0L, end-1);
start = addr;
cnt = end - addr;
getlong(_("Enter number of sectors to copy:"), &end, 1L, end);
end = addr + cnt;
cnt = Sbufsize / scgp->cap->c_bsize;
getlong(_("Enter number of sectors per copy:"), &cnt, 1L, cnt);
/* error("end: %8ld\n", end);*/
}
if (filename[0] == '\0')
strncpy(filename, defname, sizeof (filename));
filename[sizeof (filename)-1] = '\0';
if (streql(filename, "-")) {
f = stdin;
setmode(STDIN_FILENO, O_BINARY);
} else if ((f = fileopen(filename, "rub")) == NULL)
comerr(_("Cannot open '%s'.\n"), filename);
error(_("end: %8ld\n"), end);
if (gettimeofday(&starttime, (struct timezone *)0) < 0)
comerr(_("Cannot get start time\n"));
for (; addr < end; addr += cnt) {
if (didintr)
comexit(exsig); /* XXX besseres Konzept?!*/
if ((addr + cnt) > end)
cnt = end - addr;
error(_("addr: %8ld cnt: %ld\r"), addr, cnt);
if ((amt = fileread(f, Sbuf, cnt * scgp->cap->c_bsize)) < 0)
comerr(_("Cannot read '%s'\n"), filename);
if (amt == 0)
break;
if ((amt / scgp->cap->c_bsize) < cnt)
cnt = amt / scgp->cap->c_bsize;
if (write_scsi(scgp, Sbuf, addr, cnt) < 0)
comerrno(scgp->scmd->ux_errno,
_("Cannot write destination disk\n"));
}
error(_("addr: %8ld\n"), addr);
msec = prstats();
if (msec == 0) /* Avoid division by zero */
msec = 1;
error(_("Wrote %.2f kB at %.1f kB/sec.\n"),
(double)(addr - start)/(1024.0/scgp->cap->c_bsize),
(double)((addr - start)/(1024.0/scgp->cap->c_bsize)) / (0.001*msec));
}
LOCAL int
choice(n)
int n;
{
#if defined(HAVE_DRAND48)
extern double drand48 __PR((void));
return (drand48() * n);
#else
# if defined(HAVE_RAND)
extern int rand __PR((void));
return (rand() % n);
# else
return (0);
# endif
#endif
}
LOCAL void
ra(scgp)
SCSI *scgp;
{
/* char filename[512];*/
FILE *f;
/* long addr = 0L;*/
/* long cnt;*/
/* long end;*/
/* int msec;*/
/* int start;*/
/* int err = 0;*/
select_secsize(scgp, 2352);
read_capacity(scgp);
print_capacity(scgp, stderr);
fillbytes(Sbuf, 50*2352, 0);
if (read_g1(scgp, Sbuf, 0, 50) < 0)
errmsg(_("read CD\n"));
f = fileopen("DDA", "wctb");
/* filewrite(f, Sbuf, 50 * 2352 - scg_getresid(scgp));*/
filewrite(f, Sbuf, 50 * 2352);
fclose(f);
}
#define g5x_cdblen(cdb, len) ((cdb)->count[0] = ((len) >> 16L)& 0xFF,\
(cdb)->count[1] = ((len) >> 8L) & 0xFF,\
(cdb)->count[2] = (len) & 0xFF)
EXPORT int
read_da(scgp, bp, addr, cnt, framesize, subcode)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
int framesize;
int subcode;
{
register struct scg_cmd *scmd = scgp->scmd;
if (scgp->cap->c_bsize <= 0)
raisecond("capacity_not_set", 0L);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = bp;
scmd->size = cnt*framesize;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xd8;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
g5_cdbaddr(&scmd->cdb.g5_cdb, addr);
g5_cdblen(&scmd->cdb.g5_cdb, cnt);
scmd->cdb.g5_cdb.res10 = subcode;
scgp->cmdname = "read_da";
return (scg_cmd(scgp));
}
LOCAL int
read_sectors(scgp, p, addr, cnt)
SCSI *scgp;
void *p;
long addr;
int cnt;
{
int csize;
int clusters;
int rest;
int i;
int pos;
if (addr + cnt > scgp->cap->c_baddr + 1)
cnt = scgp->cap->c_baddr + 1 - addr;
csize = Sbufsize / (2352 + 294);
clusters = cnt / csize;
rest = cnt % csize;
pos = addr;
for (i = 0; i < clusters; i++) {
read_cd(scgp, p, pos, csize, 2352 + 294, 0xFA, 0);
pos += csize;
}
if (rest)
read_cd(scgp, p, pos, rest, 2352 + 294, 0xFA, 0);
return (csize * clusters + rest);
}
LOCAL int
read_dvd_sectors(scgp, p, addr, cnt)
SCSI *scgp;
void *p;
long addr;
int cnt;
{
int csize;
int clusters;
int rest;
int i;
int pos;
if (addr + cnt > scgp->cap->c_baddr + 1)
cnt = scgp->cap->c_baddr + 1 - addr;
csize = Sbufsize / 2048;
clusters = cnt / csize;
rest = cnt % csize;
pos = addr;
for (i = 0; i < clusters; i++) {
read_g1(scgp, p, pos, csize);
pos += csize;
}
if (rest)
read_g1(scgp, p, pos, rest);
return (csize * clusters + rest);
}
LOCAL BOOL
mmc_isplextor(scgp)
SCSI *scgp;
{
if (scgp->inq != NULL &&
strncmp(scgp->inq->inq_vendor_info, "PLEXTOR", 7) == 0) {
return (TRUE);
}
return (FALSE);
}
LOCAL int
plextor_init_cx_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
if (!mmc_isplextor(scgp))
return (-1);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xEA;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x15;
scmd->cdb.cmd_cdb[3] = 0x01;
scgp->cmdname = "plextor_init_cx_scan";
return (scg_cmd(scgp));
}
LOCAL int
plextor_init_pi8_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
if (!mmc_isplextor(scgp))
return (-1);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xEA;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x15;
scmd->cdb.cmd_cdb[8] = 0x08;
scmd->cdb.cmd_cdb[9] = 0x10;
scgp->cmdname = "plextor_init_pi8_scan";
return (scg_cmd(scgp));
}
LOCAL int
plextor_init_pif_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
if (!mmc_isplextor(scgp))
return (-1);
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xEA;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x15;
scmd->cdb.cmd_cdb[8] = 0x01;
scmd->cdb.cmd_cdb[9] = 0x12;
scgp->cmdname = "plextor_init_pif_scan";
return (scg_cmd(scgp));
}
LOCAL int
nec_init_cx_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
int ret;
/*
* initialize scan mode
*/
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xF3;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x01;
scgp->cmdname = "nec_init_cx_scan";
ret = scg_cmd(scgp);
if (ret < 0)
return (ret);
/*
* set scan interval = 75 sectors
*/
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xF3;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x02;
scmd->cdb.cmd_cdb[8] = 75;
scgp->cmdname = "nec_set_cx_scan_interval";
return (scg_cmd(scgp));
}
LOCAL int
plextor_scan_one_interval(scgp, pe, addr, p)
SCSI* scgp;
cxerror_t *pe;
long addr;
void *p;
{
int i;
i = read_sectors(scgp, p, addr, 75);
plextor_read_cx_values(scgp, pe, FALSE);
return (addr + i);
}
LOCAL int
plextor_scan_one_dvd_interval(scgp, pe, addr, p)
SCSI* scgp;
cxerror_t *pe;
long addr;
void *p;
{
int i;
if (pifscan)
i = read_dvd_sectors(scgp, p, addr, 16);
else
i = read_dvd_sectors(scgp, p, addr, 16*8);
plextor_read_cx_values(scgp, pe, TRUE);
return (addr + i);
}
/* ARGSUSED */
LOCAL int
nec_scan_one_interval(scgp, pe, addr, p)
SCSI *scgp;
cxerror_t *pe;
long addr;
void *p;
{
register struct scg_cmd *scmd = scgp->scmd;
Uchar data[8];
int ret;
fillbytes(data, sizeof (data), '\0');
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 8;
scmd->addr = (caddr_t)data;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xF3;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x03;
scgp->cmdname = "nec_set_cx_scan_interval";
ret = scg_cmd(scgp);
if (ret < 0)
return (ret);
pe->c1_errors = a_to_u_2_byte(data+4);
pe->c2_errors = a_to_u_2_byte(data+6);
pe->cu_errors = 0;
return ((int)data[1] * 4500 + (int)data[2] * 75 + (int)data[3]);
}
LOCAL int
plextor_end_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->size = 0;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xEA;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x17;
scgp->cmdname = "plextor_end_scan";
return (scg_cmd(scgp));
}
LOCAL int
nec_end_scan(scgp)
SCSI *scgp;
{
register struct scg_cmd *scmd = scgp->scmd;
char data[8];
fillbytes(data, sizeof (data), '\0');
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = data;
scmd->size = 8;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xF3;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x0F;
scgp->cmdname = "nec_end_cx_scan";
return (scg_cmd(scgp));
}
LOCAL int
plextor_read_cx_values(scgp, pe, dopi)
SCSI *scgp;
cxerror_t *pe;
BOOL dopi;
{
register struct scg_cmd *scmd = scgp->scmd;
char data[52];
int ret;
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
fillbytes(data, sizeof (data), '\0');
scmd->addr = data;
scmd->size = dopi ? 52:0x1A;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xEA;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.cmd_cdb[1] |= 0x16;
scmd->cdb.cmd_cdb[2] = 0x01;
scmd->cdb.cmd_cdb[10] = dopi ? 52:0x1A;
scgp->cmdname = "plextor_read_cx_values";
ret = scg_cmd(scgp);
if (ret < 0) {
return (ret);
}
pe->c1_errors = a_to_u_2_byte(data+16) + /* E11 ??? */
a_to_u_2_byte(data+14) + /* E21 ??? */
a_to_u_2_byte(data+12); /* E31 ??? */
pe->c2_errors = a_to_u_2_byte(data+22);
pe->cu_errors = a_to_u_2_byte(data+20);
pe->pi_errors = a_to_u_4_byte(data+36);
return (ret);
}
EXPORT int
read_cd(scgp, bp, addr, cnt, framesize, data, subch)
SCSI *scgp;
caddr_t bp;
long addr;
int cnt;
int framesize;
int data;
int subch;
{
register struct scg_cmd *scmd = scgp->scmd;
fillbytes((caddr_t)scmd, sizeof (*scmd), '\0');
scmd->addr = bp;
scmd->size = cnt*framesize;
scmd->flags = SCG_RECV_DATA|SCG_DISRE_ENA;
scmd->cdb_len = SC_G5_CDBLEN;
scmd->sense_len = CCS_SENSE_LEN;
scmd->cdb.g5_cdb.cmd = 0xBE;
scmd->cdb.g5_cdb.lun = scg_lun(scgp);
scmd->cdb.g5_cdb.res = 0; /* expected sector type field ALL */
g5_cdbaddr(&scmd->cdb.g5_cdb, addr);
g5x_cdblen(&scmd->cdb.g5_cdb, cnt);
scmd->cdb.g5_cdb.count[3] = data & 0xFF;
scmd->cdb.g5_cdb.res10 = subch & 0x07;
scgp->cmdname = "read_cd";
return (scg_cmd(scgp));
}
LOCAL void
oldmode(scgp, errp, retrp)
SCSI *scgp;
int *errp;
int *retrp;
{
Uchar mode[0x100];
Uchar cmode[0x100];
Uchar *p;
int i;
int len;
fillbytes(mode, sizeof (mode), '\0');
fillbytes(cmode, sizeof (cmode), '\0');
if (!get_mode_params(scgp, 0x01, _("CD error recovery parameter"),
mode, (Uchar *)0, (Uchar *)cmode, (Uchar *)0, &len)) {
return;
}
if (xdebug)
scg_prbytes(_("Mode Sense Data"), mode, len);
mode[0] = 0;
mode[2] = 0; /* ??? ist manchmal 0x80 */
p = mode;
p += mode[3] + 4;
*p &= 0x3F;
if (xdebug)
scg_prbytes(_("Mode page 1:"), p, 0x10);
i = p[2];
if (errp != NULL)
*errp = i;
i = p[3];
if (retrp != NULL)
*retrp = i;
}
LOCAL void
domode(scgp, err, retr)
SCSI *scgp;
int err;
int retr;
{
Uchar mode[0x100];
Uchar cmode[0x100];
Uchar *p;
int i;
int len;
fillbytes(mode, sizeof (mode), '\0');
fillbytes(cmode, sizeof (cmode), '\0');
if (!get_mode_params(scgp, 0x01, _("CD error recovery parameter"),
mode, (Uchar *)0, (Uchar *)cmode, (Uchar *)0, &len)) {
return;
}
if (xdebug || (err == -1 && retr == -1)) {
scg_prbytes(_("Mode Sense Data"), mode, len);
}
mode[0] = 0;
mode[2] = 0; /* ??? ist manchmal 0x80 */
p = mode;
p += mode[3] + 4;
*p &= 0x3F;
if (xdebug || (err == -1 && retr == -1))
scg_prbytes(_("Mode page 1:"), p, 0x10);
i = p[2];
if (err == -1) {
getint(_("Error handling? "), &i, 0, 255);
p[2] = i;
} else {
if (xdebug)
error(_("Error handling set from %02X to %02X\n"),
p[2], err);
p[2] = err;
}
i = p[3];
if (retr == -1) {
getint(_("Retry count? "), &i, 0, 255);
p[3] = i;
} else {
if (xdebug)
error(_("Retry count set from %d to %d\n"),
p[3] & 0xFF, retr);
p[3] = retr;
}
if (xdebug || (err == -1 && retr == -1))
scg_prbytes(_("Mode Select Data"), mode, len);
mode_select(scgp, mode, len, 0, scgp->inq->data_format >= 2);
}
/*--------------------------------------------------------------------------*/
LOCAL void qpto96 __PR((Uchar *sub, Uchar *subq, int dop));
/*EXPORT void qpto96 __PR((Uchar *sub, Uchar *subq, int dop));*/
/*
* Q-Sub auf 96 Bytes bl<EFBFBD>hen und P-Sub addieren
*
* OUT: sub, IN: subqptr
*/
LOCAL void
/*EXPORT void*/
qpto96(sub, subqptr, dop)
Uchar *sub;
Uchar *subqptr;
int dop;
{
Uchar tmp[16];
Uchar *p;
int c;
int i;
if (subqptr == sub) {
movebytes(subqptr, tmp, 12);
subqptr = tmp;
}
fillbytes(sub, 96, '\0');
/* CSTYLED */
if (dop) for (i = 0, p = sub; i < 96; i++) {
*p++ |= 0x80;
}
for (i = 0, p = sub; i < 12; i++) {
c = subqptr[i] & 0xFF;
/*printf("%02X\n", c);*/
if (c & 0x80)
*p++ |= 0x40;
else
p++;
if (c & 0x40)
*p++ |= 0x40;
else
p++;
if (c & 0x20)
*p++ |= 0x40;
else
p++;
if (c & 0x10)
*p++ |= 0x40;
else
p++;
if (c & 0x08)
*p++ |= 0x40;
else
p++;
if (c & 0x04)
*p++ |= 0x40;
else
p++;
if (c & 0x02)
*p++ |= 0x40;
else
p++;
if (c & 0x01)
*p++ |= 0x40;
else
p++;
}
}
/*--------------------------------------------------------------------------*/
LOCAL void
ovtime(scgp)
SCSI *scgp;
{
register int i;
scgp->silent++;
(void) test_unit_ready(scgp);
scgp->silent--;
if (test_unit_ready(scgp) < 0)
return;
printf(_("Doing 1000 'TEST UNIT READY' operations.\n"));
if (gettimeofday(&starttime, (struct timezone *)0) < 0)
comerr(_("Cannot get start time\n"));
for (i = 1000; --i >= 0; ) {
(void) test_unit_ready(scgp);
if (didintr)
return;
}
prstats();
/*
* ATAPI drives do not like seek_g0()
*/
scgp->silent++;
i = seek_g0(scgp, 0L);
scgp->silent--;
if (i >= 0) {
printf(_("Doing 1000 'SEEK_G0 (0)' operations.\n"));
if (gettimeofday(&starttime, (struct timezone *)0) < 0)
comerr(_("Cannot get start time\n"));
for (i = 1000; --i >= 0; ) {
(void) seek_g0(scgp, 0L);
if (didintr)
return;
}
prstats();
}
scgp->silent++;
i = seek_g1(scgp, 0L);
scgp->silent--;
if (i < 0)
return;
printf(_("Doing 1000 'SEEK_G1 (0)' operations.\n"));
if (gettimeofday(&starttime, (struct timezone *)0) < 0)
comerr(_("Cannot get start time\n"));
for (i = 1000; --i >= 0; ) {
(void) seek_g1(scgp, 0L);
if (didintr)
return;
}
prstats();
}
#define BAD_INC 16
long *badsecs;
int nbad;
int maxbad;
LOCAL void
add_bad(addr)
long addr;
{
if (maxbad == 0) {
maxbad = BAD_INC;
badsecs = malloc(maxbad * sizeof (long));
if (badsecs == NULL)
comerr(_("No memory for bad sector list.\n"));
}
if (nbad >= maxbad) {
maxbad += BAD_INC;
badsecs = realloc(badsecs, maxbad * sizeof (long));
if (badsecs == NULL)
comerr(_("No memory to grow bad sector list.\n"));
}
badsecs[nbad++] = addr;
}
LOCAL void
print_bad()
{
int i;
if (nbad == 0)
return;
error(_("Max corected retry count was %d (limited to %d).\n"), maxtry, retries);
error(_("The following %d sector(s) could not be read correctly:\n"), nbad);
for (i = 0; i < nbad; i++)
error("%ld\n", badsecs[i]);
if (edc_corr)
error(_("Corrected by EDC: %d\n"), edc_OK);
}
LOCAL void
priv_warn(what, msg)
const char *what;
const char *msg;
{
errmsgno(EX_BAD, "Insufficient '%s' privileges. %s\n", what, msg);
}
Reference in New Issue Copy Permalink