//bench/incr_svsem1.c
#include	"unpipc.h"

#define	MAXNTHREADS	100

int		nloop;

struct {
  int	semid;
  long	counter;
} shared;

struct sembuf	postop, waitop;

void	*incr(void *);

int
main(int argc, char **argv)
{
	int		i, nthreads;
	pthread_t	tid[MAXNTHREADS];
	union semun	arg;

	if (argc != 3)
		err_quit("usage: incr_svsem1 <#loops> <#threads>");
	nloop = atoi(argv[1]);
	nthreads = min(atoi(argv[2]), MAXNTHREADS);

		/*       0 */
	shared.semid = Semget(IPC_PRIVATE, 1, IPC_CREAT | SVSEM_MODE);
	arg.val = 0;
	Semctl(shared.semid, 0, SETVAL, arg);
	postop.sem_num = 0;		/*    semop */
	postop.sem_op  = 1;
	postop.sem_flg = 0;
	waitop.sem_num = 0;
	waitop.sem_op  = -1;
	waitop.sem_flg = 0;

		/*    */
	Set_concurrency(nthreads);
	for (i = 0; i < nthreads; i++) {
		Pthread_create(&tid[i], NULL, incr, NULL);
	}
		/*      */
	Start_time();
	Semop(shared.semid, &postop, 1);		/* up by 1 */

		/*     */
	for (i = 0; i < nthreads; i++) {
		Pthread_join(tid[i], NULL);
	}
	printf("microseconds: %.0f usec\n", Stop_time());
	if (shared.counter != nloop * nthreads)
		printf("error: counter = %ld\n", shared.counter);
	Semctl(shared.semid, 0, IPC_RMID);

	exit(0);
}
