head	1.3;
access;
symbols
	SFIO_1999:1.1.1.2
	SFIO_1998:1.1.1.1
	ATT:1.1.1;
locks; strict;
comment	@ * @;


1.3
date	99.09.11.13.20.42;	author rse;	state Exp;
branches;
next	1.2;

1.2
date	99.09.11.12.42.09;	author rse;	state Exp;
branches;
next	1.1;

1.1
date	98.03.19.03.58.13;	author rse;	state Exp;
branches
	1.1.1.1;
next	;

1.1.1.1
date	98.03.19.03.58.13;	author rse;	state Exp;
branches;
next	1.1.1.2;

1.1.1.2
date	99.06.01.15.21.56;	author rse;	state Exp;
branches;
next	;


desc
@@


1.3
log
@Merge in Sfio 1999 changes
@
text
@#include	"sfdchdr.h"


/*	Discipline to treat a contiguous segment of a stream as a stream
**	in its own right. The hard part in all this is to allow multiple
**	segments of the stream to be used as substreams at the same time.
**
**	Written by David G. Korn and Kiem-Phong Vo (03/18/1998)
*/

typedef struct _subfile_s
{
	Sfdisc_t	disc;	/* sfio discipline */
	Sfio_t*		parent;	/* parent stream */
	Sfoff_t		offset;	/* starting offset */
	Sfoff_t		extent;	/* size wanted */
	Sfoff_t		here;	/* current seek location */
} Subfile_t;

#if __STD_C
static ssize_t streamio(Sfio_t* f, Void_t* buf, size_t n, Sfdisc_t* disc, int type)
#else
static ssize_t streamio(f, buf, n, disc, type)
Sfio_t*		f;
Void_t*		buf;
size_t		n;
Sfdisc_t*	disc;
int		type;
#endif
{
	reg Subfile_t	*su;
	reg Sfoff_t	here, parent;
	reg ssize_t	io;

	su = (Subfile_t*)disc;

	/* read just what we need */
	if(su->extent >= 0 && (ssize_t)n > (io = (ssize_t)(su->extent - su->here)) )
		n = io;
	if(n <= 0)
		return n;

	/* save current location in parent stream */
	parent = sfseek(su->parent,(Sfoff_t)0,1);

	/* read data */
	here = su->here + su->offset;
	if(sfseek(su->parent,here,0) != here)
		io = 0;
	else
	{	if(type == SF_WRITE) 
			io = sfwrite(su->parent,buf,n);
		else	io = sfread(su->parent,buf,n);
		if(io > 0)
			su->here += io;
	}

	/* restore parent current position */
	sfseek(su->parent,parent,0);

	return io;
}

#if __STD_C
static ssize_t streamwrite(Sfio_t* f, const Void_t* buf, size_t n, Sfdisc_t* disc)
#else
static ssize_t streamwrite(f, buf, n, disc)
Sfio_t*		f;
Void_t*		buf;
size_t		n;
Sfdisc_t*	disc;
#endif
{
	return streamio(f,(Void_t*)buf,n,disc,SF_WRITE);
}

#if __STD_C
static ssize_t streamread(Sfio_t* f, Void_t* buf, size_t n, Sfdisc_t* disc)
#else
static ssize_t streamread(f, buf, n, disc)
Sfio_t*		f;
Void_t*		buf;
size_t		n;
Sfdisc_t*	disc;
#endif
{
	return streamio(f,buf,n,disc,SF_READ);
}

#if __STD_C
static Sfoff_t streamseek(Sfio_t* f, Sfoff_t pos, int type, Sfdisc_t* disc)
#else
static Sfoff_t streamseek(f, pos, type, disc)
Sfio_t*		f;
Sfoff_t		pos;
int		type;
Sfdisc_t*	disc;
#endif
{
	reg Subfile_t*	su;
	reg Sfoff_t	here, parent;

	su = (Subfile_t*)disc;

	switch(type)
	{
	case 0:
		here = 0;
		break;
	case 1:
		here = su->here;
		break;
	case 2:
		if(su->extent >= 0)
			here = su->extent;
		else
		{	parent = sfseek(su->parent,(Sfoff_t)0,1);
			if((here = sfseek(su->parent,(Sfoff_t)0,2)) < 0)
				return -1;
			else	here -= su->offset;
			sfseek(su->parent,parent,0);
		}
		break;
	default:
		return -1;
	}

	pos += here;
	if(pos < 0 || (su->extent >= 0 && pos >= su->extent))
		return -1;

	return (su->here = pos);
}

#if __STD_C
static int streamexcept(Sfio_t* f, int type, Void_t* data, Sfdisc_t* disc)
#else
static int streamexcept(f, type, data, disc)
Sfio_t*		f;
int		type;
Void_t*		data;
Sfdisc_t*	disc;
#endif
{
	if(type == SF_FINAL || type == SF_DPOP)
		free(disc);
	return 0;
}

#if __STD_C
int sfdcsubstream(Sfio_t* f, Sfio_t* parent, Sfoff_t offset, Sfoff_t extent)
#else
int sfdcsubstream(f, parent, offset, extent)
Sfio_t*	f;	/* stream */
Sfio_t*	parent; /* parent stream */
Sfoff_t	offset;	/* offset in parent stream */
Sfoff_t	extent;	/* desired size */
#endif
{
	reg Subfile_t*	su;
	reg Sfoff_t	here;

	/* establish that we can seek to offset */
	if((here = sfseek(parent,(Sfoff_t)0,1)) < 0 || sfseek(parent,offset,0) < 0)
		return -1;
	else	sfseek(parent,here,0);

	if(!(su = (Subfile_t*)malloc(sizeof(Subfile_t))) )
		return -1;

	su->disc.readf = streamread;
	su->disc.writef = streamwrite;
	su->disc.seekf = streamseek;
	su->disc.exceptf = streamexcept;
	su->parent = parent;
	su->offset = offset;
	su->extent = extent;

	if(sfdisc(f, (Sfdisc_t*)su) != (Sfdisc_t*)su)
	{	free(su);
		return -1;
	}

	return 0;
}
@


1.2
log
@Incorporate stuff from RSE's Sfio98 variant
@
text
@d38 1
a38 1
	if(su->extent >= 0 && n > (io = (ssize_t)(su->extent - su->here)) )
d151 1
a151 1
int sfdcsubstream(Sfio_t* f, Sfoff_t offset, Sfoff_t extent)
d153 1
a153 1
int sfdcsubstream(f, offset, extent)
d155 2
a156 1
Sfoff_t	offset;	/* offset in f */
d164 1
a164 1
	if((here = sfseek(f,(Sfoff_t)0,1)) < 0 || sfseek(f,offset,0) < 0)
d166 1
a166 1
	else	sfseek(f,here,0);
d175 1
a175 1
	su->parent = f;
@


1.1
log
@Initial revision
@
text
@d136 1
a136 1
static streamexcept(Sfio_t* f, int type, Void_t* data, Sfdisc_t* disc)
d138 1
a138 1
static streamexcept(f, type, data, disc)
@


1.1.1.1
log
@Import of Sfio1998
@
text
@@


1.1.1.2
log
@Import of Sfio1999
@
text
@d38 1
a38 1
	if(su->extent >= 0 && (ssize_t)n > (io = (ssize_t)(su->extent - su->here)) )
d151 1
a151 1
int sfdcsubstream(Sfio_t* f, Sfio_t* parent, Sfoff_t offset, Sfoff_t extent)
d153 1
a153 1
int sfdcsubstream(f, parent, offset, extent)
d155 1
a155 2
Sfio_t*	parent; /* parent stream */
Sfoff_t	offset;	/* offset in parent stream */
d163 1
a163 1
	if((here = sfseek(parent,(Sfoff_t)0,1)) < 0 || sfseek(parent,offset,0) < 0)
d165 1
a165 1
	else	sfseek(parent,here,0);
d174 1
a174 1
	su->parent = parent;
@