mirror of
https://gitlab.com/libvirt/libvirt.git
synced 2024-12-29 00:55:22 +00:00
5bff668dfb
Historically threads are given a name based on the C function, and this name is just used inside libvirt. With OS level thread naming this name is now visible to debuggers, but also has to fit in 15 characters on Linux, so function names are too long in some cases. Reviewed-by: Michal Privoznik <mprivozn@redhat.com> Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
59 lines
2.3 KiB
C
59 lines
2.3 KiB
C
/*
|
|
* virthreadpool.h: a generic thread pool implementation
|
|
*
|
|
* Copyright (C) 2010 Hu Tao
|
|
* Copyright (C) 2010 Daniel P. Berrange
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library. If not, see
|
|
* <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include "internal.h"
|
|
|
|
typedef struct _virThreadPool virThreadPool;
|
|
typedef virThreadPool *virThreadPoolPtr;
|
|
|
|
typedef void (*virThreadPoolJobFunc)(void *jobdata, void *opaque);
|
|
|
|
#define virThreadPoolNew(min, max, prio, func, opaque) \
|
|
virThreadPoolNewFull(min, max, prio, func, #func, opaque)
|
|
|
|
virThreadPoolPtr virThreadPoolNewFull(size_t minWorkers,
|
|
size_t maxWorkers,
|
|
size_t prioWorkers,
|
|
virThreadPoolJobFunc func,
|
|
const char *name,
|
|
void *opaque) ATTRIBUTE_NONNULL(4);
|
|
|
|
size_t virThreadPoolGetMinWorkers(virThreadPoolPtr pool);
|
|
size_t virThreadPoolGetMaxWorkers(virThreadPoolPtr pool);
|
|
size_t virThreadPoolGetPriorityWorkers(virThreadPoolPtr pool);
|
|
size_t virThreadPoolGetCurrentWorkers(virThreadPoolPtr pool);
|
|
size_t virThreadPoolGetFreeWorkers(virThreadPoolPtr pool);
|
|
size_t virThreadPoolGetJobQueueDepth(virThreadPoolPtr pool);
|
|
|
|
void virThreadPoolFree(virThreadPoolPtr pool);
|
|
|
|
int virThreadPoolSendJob(virThreadPoolPtr pool,
|
|
unsigned int priority,
|
|
void *jobdata) ATTRIBUTE_NONNULL(1)
|
|
G_GNUC_WARN_UNUSED_RESULT;
|
|
|
|
int virThreadPoolSetParameters(virThreadPoolPtr pool,
|
|
long long int minWorkers,
|
|
long long int maxWorkers,
|
|
long long int prioWorkers);
|