afb8674c79
The thread pool is used by libzfs to implement parallel disk scanning. Without this change our dummy wrapper made `zpool import ZZZ` command to scan all disks sequentially from the single thread when searching for pools. This change makes it use two threads per CPU, same as in OpenSolaris. On system with 200 HDDs this change reduces ZFS pool import time from 35 to 22 seconds.
79 lines
2.0 KiB
C
79 lines
2.0 KiB
C
/*
|
|
* 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 2006 Sun Microsystems, Inc. All rights reserved.
|
|
* Use is subject to license terms.
|
|
*/
|
|
|
|
/*
|
|
* $FreeBSD$
|
|
*/
|
|
|
|
#ifndef _THREAD_POOL_H_
|
|
#define _THREAD_POOL_H_
|
|
|
|
#pragma ident "%Z%%M% %I% %E% SMI"
|
|
|
|
#include <sys/types.h>
|
|
#include <thread.h>
|
|
#include <pthread.h>
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
typedef struct tpool tpool_t; /* opaque thread pool descriptor */
|
|
|
|
#if defined(__STDC__)
|
|
|
|
extern tpool_t *tpool_create(uint_t min_threads, uint_t max_threads,
|
|
uint_t linger, pthread_attr_t *attr);
|
|
extern int tpool_dispatch(tpool_t *tpool,
|
|
void (*func)(void *), void *arg);
|
|
extern void tpool_destroy(tpool_t *tpool);
|
|
extern void tpool_abandon(tpool_t *tpool);
|
|
extern void tpool_wait(tpool_t *tpool);
|
|
extern void tpool_suspend(tpool_t *tpool);
|
|
extern int tpool_suspended(tpool_t *tpool);
|
|
extern void tpool_resume(tpool_t *tpool);
|
|
extern int tpool_member(tpool_t *tpool);
|
|
|
|
#else /* Non ANSI */
|
|
|
|
extern tpool_t *tpool_create();
|
|
extern int tpool_dispatch();
|
|
extern void tpool_destroy();
|
|
extern void tpool_abandon();
|
|
extern void tpool_wait();
|
|
extern void tpool_suspend();
|
|
extern int tpool_suspended();
|
|
extern void tpool_resume();
|
|
extern int tpool_member();
|
|
|
|
#endif /* __STDC__ */
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif /* _THREAD_POOL_H_ */
|