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.43;	author rse;	state Exp;
branches;
next	1.2;

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

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

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

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


desc
@@


1.3
log
@Merge in Sfio 1999 changes
@
text
@#include	"sftest.h"
#undef fork

_BEGIN_EXTERNS_
extern int	fork();
extern pid_t wait();
_END_EXTERNS_

/* test to see if multiple writers to the same file create
** a consistent set of records.
*/

#define N_PROC	3
#define N_REC	1000
#define B_SIZE	1024

#if __STD_C
static ssize_t inspect(Sfio_t* f, const Void_t* buf, size_t n, Sfdisc_t* disc)
#else
static ssize_t inspect(f, buf, n, disc)
Sfio_t*		f;
Void_t* 	buf;
size_t		n;
Sfdisc_t*	disc;
#endif
{
	int	w, k;
	char*	s;
	Sfio_t*	sf;

	if(*((char*)buf + n-1) != '\n')
		terror("Not writing a whole record\n");

	sf = sfnew(NIL(Sfio_t*),(Void_t*)buf,n,-1,SF_STRING|SF_READ);
	while((s = sfgetr(sf,'\n',0)) )
	{	w = sfvalue(sf)-1;
		if(s[0] != s[w-1]-1)
			terror("Bad record\n");
		k = (s[2]-'0')*10 + (s[3]-'0');
		if(k != w)
			terror("Expect %d, get %d\n",k,w);
	}
	sfclose(sf);

	if((w = write(f->file,buf,n)) != (int)n)
		terror("Write %d returns %d\n",n,w);

	return w;
}

static Sfdisc_t	Disc[N_PROC];

extern int getpid();

int main()
{
	ssize_t	size[N_PROC][N_REC];
	int	count[N_PROC];
	char	record[N_PROC][128], *s;
	int	i, r, n;
	Sfio_t*	f;
	Sfio_t*	fa[N_PROC];
	char	buf[N_PROC][B_SIZE], b[N_PROC][128];
	ulong	u;
	char	path[128];

	/* create pseudo-random record sizes */
	u = 1;
	for(i = 0; i < N_PROC; ++i)
	for(r = 0; r < N_REC; ++r)
	{	u = u * 0x63c63cd9L + 0x9c39c33dL;
		size[i][r] = (ssize_t)(u%63) + 16;
	}

	/* records for different processes */
	for(i = 0; i < N_PROC; ++i)
	for(r = 0; r < 128; ++r)
		record[i][r] = '0' + 2*i;

	/* create file */
	sfsprintf(path,sizeof(path),"/tmp/sf%o",getpid());
	if(!(f = sfopen(NIL(Sfio_t*),path,"w+")) )
		terror("Opening temporary file %s\n",path);
	for(i = 0; i < N_PROC; ++i)
	{	fa[i] = sfopen(NIL(Sfio_t*), path, "a");
		sfsetbuf(fa[i], (Void_t*)buf[i], sizeof(buf[i]));
		sfset(fa[i], SF_WHOLE, 1);
		Disc[i].writef = inspect;
		sfdisc(fa[i], &Disc[i]);
	}

	/* fork processes */
	for(i = 0; i < N_PROC; ++i)
	{	switch(fork() )
		{ case -1:
			terror("Creating process %d\n", i);
		  case 0 :
			for(r = 0; r < N_REC; ++r)
			{	n = size[i][r]; s = b[i];
				memcpy(s,record[i],n-1);
				s[1] = '(';
				s[2] = ((n-1)/10) + '0';
				s[3] = ((n-1)%10) + '0';
				s[4] = ')';
				s[n-2] = s[0] + 1;
				s[n-1] = '\n';
				sfwrite(fa[i],s,n);
			}
			sfsync(fa[i]);
			return 0;
		}
	}

	for(i = 0; i < N_PROC; ++i)
	{	wait(&r);
		count[i] = 0;
	}

	n = 0;
	while((s = sfgetr(f,'\n',0)) )
	{	n += 1;
		if((i = s[0] - '0') < 0 || (i%2) != 0 || (i /= 2) >= N_PROC )
			terror("%d: Wrong record type\n", n);

		r = sfvalue(f);
		if(s[r-2] != s[0]+1)
			terror("%d: process%d, number=%d\n", n, i, count[i]);
		for(r -= 3; r > 4; --r)
			if(s[r] != s[0])
				terror("%d: process%d, count=%d\n", n, i, count[i]);

		if(sfvalue(f) != size[i][count[i]])
			terror("%d: process%d number=%d expected size=%d read size=%d\n",
				n, i, count[i], size[i][count[i]], sfvalue(f));

		count[i] += 1;
	}

	for(i = 0; i < N_PROC; ++i)
		if(count[i] != N_REC)
			terror("Bad count%d %d\n", i, count[i]);

	unlink(path);

	return 0;
}
@


1.2
log
@Incorporate stuff from RSE's Sfio98 variant
@
text
@d4 4
a7 1
pid_t wait();
d45 1
a45 1
	if((w = write(f->file,buf,n)) != n)
d53 2
d65 1
d81 3
a83 1
	f = sfopen(NIL(Sfio_t*),"/tmp/xxx","w+");
d85 1
a85 1
	{	fa[i] = sfopen(NIL(Sfio_t*), "/tmp/xxx", "a");
d109 2
a110 1
			exit(0);
d143 1
a143 1
	unlink("/tmp/xxx");
d145 1
a145 1
	exit(0);
@


1.1
log
@Initial revision
@
text
@d4 2
d50 1
a50 1
main()
@


1.1.1.1
log
@Import of Sfio1998
@
text
@@


1.1.1.2
log
@Import of Sfio1999
@
text
@a3 4
_BEGIN_EXTERNS_
extern int	fork();
_END_EXTERNS_

d40 1
a40 1
	if((w = write(f->file,buf,n)) != (int)n)
a57 2
	char	path[128];
	extern int getpid();
d73 1
a73 3
	sfsprintf(path,sizeof(path),"/tmp/sf%o",getpid());
	if(!(f = sfopen(NIL(Sfio_t*),path,"w+")) )
		terror("Opening temporary file %s\n",path);
d75 1
a75 1
	{	fa[i] = sfopen(NIL(Sfio_t*), path, "a");
d99 1
a99 2
			sfsync(fa[i]);
			return 0;
d132 1
a132 1
	unlink(path);
d134 1
a134 1
	return 0;
@