threadflow.h

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 */

#ifndef _FB_THREADFLOW_H
#define	_FB_THREADFLOW_H

#include "filebench.h"

#define	AL_READ  1
#define	AL_WRITE 2

#ifdef HAVE_AIO
typedef struct aiolist {
	int		al_type;
	struct aiolist	*al_next;
	struct aiolist	*al_worknext;
	struct aiocb64	 al_aiocb;
} aiolist_t;
#endif

#define	THREADFLOW_MAXFD 128
#define	THREADFLOW_USEISM 0x1

typedef struct threadflow {
	char		tf_name[128];	/* Name */
	int		tf_attrs;	/* Attributes */
	int		tf_instance;	/* Instance number */
	int		tf_running;	/* Thread running indicator */
	int		tf_abort;	/* Shutdown thread */
	int		tf_utid;	/* Unique id for thread */
	int 	tf_nid; 	/* Numa node to schedule the thread */
	struct procflow	*tf_process;	/* Back pointer to process */
	pthread_t	tf_tid;		/* Thread id */
	pthread_mutex_t	tf_lock;	/* Mutex around threadflow */
	avd_t		tf_instances;	/* Number of instances for this flow */
	struct threadflow *tf_next;	/* Next on proc list */
	struct flowop	*tf_thrd_fops;	/* Flowop list */
	caddr_t		tf_mem;		/* Private Memory */
	avd_t		tf_memsize;	/* Private Memory size attribute */
	fbint_t		tf_constmemsize; /* constant copy of memory size */
	fb_fdesc_t	tf_fd[THREADFLOW_MAXFD + 1]; /* Thread local fd's */
	filesetentry_t	*tf_fse[THREADFLOW_MAXFD + 1]; /* Thread local files */
	int		tf_fdrotor;	/* Rotating fd within set */
	struct flowstats	tf_stats;	/* Thread statistics */
	hrtime_t	tf_stime;	/* Start time of current flowop: used to measure the latency of the flowop */
#ifdef HAVE_AIO
	aiolist_t	*tf_aiolist;	/* List of async I/Os */
#endif
	avd_t		tf_ioprio;	/* ioprio attribute */

} threadflow_t;

/* Thread attrs */
#define	THREADFLOW_DEFAULTMEM 1024*1024LL;

threadflow_t *threadflow_define(procflow_t *, char *name,
    threadflow_t *inherit, avd_t instances);
threadflow_t *threadflow_find(threadflow_t *, char *);
int threadflow_init(procflow_t *);
void flowop_start(threadflow_t *threadflow);
void threadflow_allstarted(pid_t pid, threadflow_t *threadflow);
void threadflow_delete_all(threadflow_t **threadlist);

#endif	/* _FB_THREADFLOW_H */