--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/usr/src/cmd/filebench/common/flowop.h	Tue Jun 02 18:56:50 2009 +0900
@@ -0,0 +1,145 @@
+/*
+ * 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 2008 Sun Microsystems, Inc.  All rights reserved.
+ * Use is subject to license terms.
+ */
+
+#ifndef	_FB_FLOWOP_H
+#define	_FB_FLOWOP_H
+
+
+#pragma ident	"@(#)flowop.h	1.3	08/02/20 SMI"
+
+#include "config.h"
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <sys/param.h>
+#include <sys/resource.h>
+#include <pthread.h>
+#ifndef HAVE_SYSV_SEM
+#include <semaphore.h>
+#endif
+#include "stats.h"
+#include "threadflow.h"
+#include "vars.h"
+#include "fileset.h"
+#include "filebench.h"
+
+#ifdef	__cplusplus
+extern "C" {
+#endif
+
+typedef struct flowop {
+	char		fo_name[128];	/* Name */
+	int		fo_instance;	/* Instance number */
+	struct flowop	*fo_next;	/* Next in global list */
+	struct flowop	*fo_threadnext;	/* Next in thread's list */
+	struct flowop	*fo_resultnext;	/* List of flowops in result */
+	struct threadflow *fo_thread;	/* Backpointer to thread */
+	int		(*fo_func)();	/* Method */
+	int		(*fo_init)();	/* Init Method */
+	void		(*fo_destruct)(); /* Destructor Method */
+	int		fo_type;	/* Type */
+	int		fo_attrs;	/* Flow op attribute */
+	fileset_t	*fo_fileset;	/* Fileset for op */
+	int		fo_fd;		/* File descriptor */
+	int		fo_fdnumber;	/* User specified file descriptor */
+	int		fo_srcfdnumber;	/* User specified src file descriptor */
+	var_integer_t	fo_iosize;	/* Size of operation */
+	var_integer_t	fo_wss;		/* Flow op working set size */
+	char		fo_targetname[128]; /* Target, for wakeup etc... */
+	struct flowop	*fo_targets;	/* List of targets matching name */
+	struct flowop	*fo_targetnext;	/* List of targets matching name */
+	var_integer_t	fo_iters;	/* Number of iterations of op */
+	var_integer_t	fo_value;	/* Attr */
+	var_integer_t	fo_sequential;	/* Attr */
+	var_integer_t	fo_random;	/* Attr */
+	var_integer_t	fo_stride;	/* Attr */
+	var_integer_t	fo_backwards;	/* Attr */
+	var_integer_t	fo_dsync;	/* Attr */
+	var_integer_t	fo_blocking;	/* Attr */
+	var_integer_t	fo_directio;	/* Attr */
+	var_integer_t	fo_rotatefd;	/* Attr */
+	flowstat_t	fo_stats;	/* Flow statistics */
+	pthread_cond_t	fo_cv;		/* Block/wakeup cv */
+	pthread_mutex_t	fo_lock;	/* Mutex around flowop */
+	char		*fo_buf;	/* Per-flowop buffer */
+	uint64_t	fo_buf_size;	/* current size of buffer */
+#ifdef HAVE_SYSV_SEM
+	int		fo_semid_lw;	/* sem id */
+	int		fo_semid_hw;	/* sem id for highwater block */
+#else
+	sem_t		fo_sem;		/* sem_t for posix semaphores */
+#endif /* HAVE_SYSV_SEM */
+	var_integer_t	fo_highwater;	/* value of highwater paramter */
+	void		*fo_idp;	/* id, for sems etc */
+	hrtime_t	fo_timestamp;	/* for ratecontrol, etc... */
+	int		fo_initted;	/* Set to one if initialized */
+	int64_t		fo_tputbucket;	/* Throughput bucket, for limiter */
+	uint64_t	fo_tputlast;	/* Throughput count, for delta's */
+
+} flowop_t;
+
+/* Flow Op Attrs */
+#define	FLOW_ATTR_SEQUENTIAL	0x1
+#define	FLOW_ATTR_RANDOM	0x2
+#define	FLOW_ATTR_STRIDE	0x4
+#define	FLOW_ATTR_BACKWARDS	0x8
+#define	FLOW_ATTR_DSYNC		0x10
+#define	FLOW_ATTR_BLOCKING	0x20
+#define	FLOW_ATTR_DIRECTIO	0x40
+#define	FLOW_ATTR_READ		0x80
+#define	FLOW_ATTR_WRITE		0x100
+
+#define	FLOW_MASTER -1	    /* Declaration of thread from script */
+#define	FLOW_DEFINITION 0   /* Prototype definition of flowop from library */
+
+#define	FLOW_TYPES	5
+#define	FLOW_TYPE_GLOBAL	0  /* Rolled up statistics */
+#define	FLOW_TYPE_IO		1  /* Op is an I/O, reflected in iops and lat */
+#define	FLOW_TYPE_AIO		2  /* Op is an async I/O, reflected in iops */
+#define	FLOW_TYPE_SYNC		3  /* Op is a sync event */
+#define	FLOW_TYPE_OTHER		4  /* Op is a something else */
+
+extern flowstat_t controlstats;
+
+void flowop_init(void);
+flowop_t *flowop_define(threadflow_t *, char *name, flowop_t *inherit,
+    int instance, int type);
+flowop_t *flowop_find(char *name);
+flowop_t *flowop_find_one(char *name, int instance);
+void flowoplib_usage(void);
+void flowoplib_init(void);
+void flowop_delete_all(flowop_t **threadlist);
+void flowop_endop(threadflow_t *threadflow, flowop_t *flowop, int64_t bytes);
+void flowop_beginop(threadflow_t *threadflow, flowop_t *flowop);
+void flowop_destruct_all_flows(threadflow_t *threadflow);
+
+#ifdef	__cplusplus
+}
+#endif
+
+#endif	/* _FB_FLOWOP_H */