Showing libburn users drive name link targets, using in libcdio its own names

This commit is contained in:
Thomas Schmitt 2009-12-27 09:20:10 +00:00
parent b2cb2991ff
commit f91ee4fb13
3 changed files with 98 additions and 62 deletions

View File

@ -1 +1 @@
#define Cdrskin_timestamP "2009.12.26.222656" #define Cdrskin_timestamP "2009.12.27.092057"

View File

@ -39,7 +39,8 @@ SIGKILL, SIGCHLD, SIGSTOP
/* The maximum size for a (SCSI) i/o transaction */ /* The maximum size for a (SCSI) i/o transaction */
/* Important : MUST be at least 32768 ! */ /* Important : MUST be at least 32768 ! */
#define BURN_OS_TRANSPORT_BUFFER_SIZE 65536 /* (It might be risky to use 64k. FreeBSD is said to can only 32k.) */
#define BURN_OS_TRANSPORT_BUFFER_SIZE 32768
/* To hold the position of the most recently delivered address from /* To hold the position of the most recently delivered address from
@ -59,4 +60,5 @@ typedef struct burn_drive_enumerator_struct burn_drive_enumerator_t;
*/ */
#define BURN_OS_TRANSPORT_DRIVE_ELEMENTS \ #define BURN_OS_TRANSPORT_DRIVE_ELEMENTS \
void *p_cdio; /* actually a pointer to CdIo_t */ \ void *p_cdio; /* actually a pointer to CdIo_t */ \
char libcdio_name[4096]; /* The drive path as used by libcdio */ \

View File

@ -161,6 +161,72 @@ static int sg_close_drive(struct burn_drive * d)
} }
static int sg_give_next_adr_raw(burn_drive_enumerator_t *idx,
char adr[], int adr_size, int initialize)
{
if (initialize == 1) {
idx->pos = idx->ppsz_cd_drives =
cdio_get_devices(DRIVER_DEVICE);
if (idx->ppsz_cd_drives == NULL)
return 0;
} else if (initialize == -1) {
if (*(idx->ppsz_cd_drives) != NULL)
cdio_free_device_list(idx->ppsz_cd_drives);
idx->ppsz_cd_drives = NULL;
}
if (idx->pos == NULL)
return 0;
if (*(idx->pos) == NULL)
return 0;
if (strlen(*(idx->pos)) >= adr_size)
return -1;
strcpy(adr, *(idx->pos));
(idx->pos)++;
return 1;
}
/* Resolve eventual softlink, E.g. /dev/cdrom . */
static int sg_resolve_link(char *in_path, char target[], int target_size,
int flag)
{
int i, max_link_depth = 100, ret;
char path[4096], link_target[4096];
struct stat stbuf;
if (strlen(in_path) >= sizeof(path)) {
if (strlen(in_path) >= target_size)
return -1;
strcpy(target, path);
return 1;
}
strcpy(path, in_path);
/* (burn_drive_resolve_link() relies on a completed drive list and
cannot be used here) */
for (i= 0; i < max_link_depth; i++) {
if (lstat(path, &stbuf) == -1) {
strcpy(path, in_path);
break; /* dead link */
}
if ((stbuf.st_mode & S_IFMT) != S_IFLNK)
break; /* found target */
ret = readlink(path, link_target, sizeof(link_target));
if (ret == -1) {
strcpy(path, in_path);
break; /* unreadable link pointer */
}
strcpy(path, link_target);
}
if (i >= max_link_depth) /* endless link loop */
strcpy(path, in_path);
if (strlen(path) >= target_size)
return -1;
strcpy(target, path);
return 1;
}
/* ----------------------------------------------------------------------- */ /* ----------------------------------------------------------------------- */
/* PORTING: Private functions which contain publicly needed functionality. */ /* PORTING: Private functions which contain publicly needed functionality. */
/* Their portable part must be performed. So it is probably best */ /* Their portable part must be performed. So it is probably best */
@ -172,8 +238,9 @@ static int sg_close_drive(struct burn_drive * d)
/** Wraps a detected drive into libburn structures and hands it over to /** Wraps a detected drive into libburn structures and hands it over to
libburn drive list. libburn drive list.
*/ */
static void enumerate_common(char *fname, int bus_no, int host_no, static void enumerate_common(char *fname, char *cdio_name,
int channel_no, int target_no, int lun_no) int bus_no, int host_no,
int channel_no, int target_no, int lun_no)
{ {
int ret; int ret;
struct burn_drive out; struct burn_drive out;
@ -193,6 +260,9 @@ static void enumerate_common(char *fname, int bus_no, int host_no,
/* Transport adapter is libcdio */ /* Transport adapter is libcdio */
/* Adapter specific handles and data */ /* Adapter specific handles and data */
out.p_cdio = NULL; out.p_cdio = NULL;
strcpy(out.libcdio_name, fname);
if (strlen(cdio_name) < sizeof(out.libcdio_name))
strcpy(out.libcdio_name, cdio_name);
/* PORTING: ---------------- end of non portable part ------------ */ /* PORTING: ---------------- end of non portable part ------------ */
@ -277,50 +347,17 @@ LIBBURN_MISCONFIGURATION_ = 0;
int sg_give_next_adr(burn_drive_enumerator_t *idx, int sg_give_next_adr(burn_drive_enumerator_t *idx,
char adr[], int adr_size, int initialize) char adr[], int adr_size, int initialize)
{ {
int i, max_link_depth = 100, ret; int ret;
char path[4096], link_target[4096]; char path[4096];
struct stat stbuf;
if (initialize == 1) { ret = sg_give_next_adr_raw(idx, adr, adr_size, initialize);
idx->pos = idx->ppsz_cd_drives = if (ret <= 0)
cdio_get_devices(DRIVER_DEVICE); return ret;
if (idx->ppsz_cd_drives == NULL) if (strlen(adr) >= sizeof(path))
return 0; return ret;
} else if (initialize == -1) { strcpy(path, adr);
if (*(idx->ppsz_cd_drives) != NULL) ret = sg_resolve_link(path, adr, adr_size, 0);
cdio_free_device_list(idx->ppsz_cd_drives); return ret;
idx->ppsz_cd_drives = NULL;
}
if (idx->pos == NULL)
return 0;
if (*(idx->pos) == NULL)
return 0;
/* Resolve eventual softlink, E.g. /dev/cdrom . */;
/* (burn_drive_resolve_link() relies on a completed drive list and
cannot be used here) */
strcpy(path, *(idx->pos));
for (i= 0; i < max_link_depth; i++) {
if (lstat(path, &stbuf) == -1) {
strcpy(path, *(idx->pos));
break; /* dead link */
}
if ((stbuf.st_mode & S_IFMT) != S_IFLNK)
break; /* found target */
ret = readlink(path, link_target, sizeof(link_target));
if (ret == -1) {
strcpy(path, *(idx->pos));
break; /* unreadable link pointer */
}
strcpy(path, link_target);
}
if (i >= max_link_depth) /* endless link loop */
strcpy(path, *(idx->pos));
if (strlen(path) >= adr_size)
return -1;
strcpy(adr, path);
(idx->pos)++;
return 1;
} }
@ -332,18 +369,22 @@ int scsi_enumerate_drives(void)
burn_drive_enumerator_t idx; burn_drive_enumerator_t idx;
int initialize = 1, ret, i_bus_no = -1; int initialize = 1, ret, i_bus_no = -1;
int i_host_no = -1, i_channel_no = -1, i_target_no = -1, i_lun_no = -1; int i_host_no = -1, i_channel_no = -1, i_target_no = -1, i_lun_no = -1;
char buf[64]; char buf[4096], target[4096];
while(1) { while(1) {
ret = sg_give_next_adr(&idx, buf, sizeof(buf), initialize); ret = sg_give_next_adr_raw(&idx, buf, sizeof(buf), initialize);
initialize = 0; initialize = 0;
if (ret <= 0) if (ret <= 0)
break; break;
if (burn_drive_is_banned(buf)) ret = sg_resolve_link(buf, target, sizeof(target), 0);
if (ret <= 0)
strcpy(target, buf);
if (burn_drive_is_banned(target))
continue; continue;
sg_obtain_scsi_adr(buf, &i_bus_no, &i_host_no, sg_obtain_scsi_adr(buf, &i_bus_no, &i_host_no,
&i_channel_no, &i_target_no, &i_lun_no); &i_channel_no, &i_target_no, &i_lun_no);
enumerate_common(buf, i_bus_no, i_host_no, i_channel_no, enumerate_common(target, buf,
i_bus_no, i_host_no, i_channel_no,
i_target_no, i_lun_no); i_target_no, i_lun_no);
} }
sg_give_next_adr(&idx, buf, sizeof(buf), -1); sg_give_next_adr(&idx, buf, sizeof(buf), -1);
@ -351,7 +392,7 @@ int scsi_enumerate_drives(void)
} }
/** Tells wether libburn has the given drive in use or exclusively reserved. /** Tells whether libburn has the given drive in use or exclusively reserved.
If it is "open" then libburn will eventually call sg_release() on it when If it is "open" then libburn will eventually call sg_release() on it when
it is time to give up usage resp. reservation. it is time to give up usage resp. reservation.
*/ */
@ -377,8 +418,9 @@ int sg_grab(struct burn_drive *d)
d->released = 0; d->released = 0;
return 1; return 1;
} }
if (d->libcdio_name[0] == 0) /* just to be sure it is initialized */
p_cdio = cdio_open_am(d->devname, DRIVER_DEVICE, strcpy(d->libcdio_name, d->devname);
p_cdio = cdio_open_am(d->libcdio_name, DRIVER_DEVICE,
burn_sg_open_o_excl ? "MMC_RDWR_EXCL" : "MMC_RDWR"); burn_sg_open_o_excl ? "MMC_RDWR_EXCL" : "MMC_RDWR");
if (p_cdio == NULL) { if (p_cdio == NULL) {
@ -471,15 +513,7 @@ int sg_issue_command(struct burn_drive *d, struct command *c)
memset(c->page->data, 0, BUFFER_SIZE); memset(c->page->data, 0, BUFFER_SIZE);
} else { } else {
dxfer_len = 0; dxfer_len = 0;
/* >>> remove this condition when #if LIBCDIO_VERSION_NUM < 83
is in effect above*/
#ifdef SCSI_MMC_HAS_DIR_NONE
e_direction = SCSI_MMC_DATA_NONE; e_direction = SCSI_MMC_DATA_NONE;
#else
e_direction = SCSI_MMC_DATA_READ;
#endif
} }
/* retry-loop */ /* retry-loop */