/usr/include/CLucene/LuceneThreads.h is in libclucene-dev 2.3.3.4-4build1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 | /*------------------------------------------------------------------------------
* Copyright (C) 2003-2006 Ben van Klinken and the CLucene Team
*
* Distributable under the terms of either the Apache License (Version 2.0) or
* the GNU Lesser General Public License, as specified in the COPYING file.
------------------------------------------------------------------------------*/
#ifndef _LuceneThreads_h
#define _LuceneThreads_h
CL_NS_DEF(util)
class CLuceneThreadIdCompare;
#if defined(_CL_DISABLE_MULTITHREADING)
#define SCOPED_LOCK_MUTEX(theMutex)
#define DEFINE_MUTEX(x)
#define DEFINE_MUTABLE_MUTEX(x)
#define DEFINE_CONDITION(x)
#define STATIC_DEFINE_MUTEX(x)
#define CONDITION_WAIT(theMutex, theCondition)
#define CONDITION_NOTIFYALL(theCondition)
#define _LUCENE_CURRTHREADID 1
#define _LUCENE_THREADID_TYPE int
#define _LUCENE_THREAD_FUNC(name, argName) int name(void* argName)
#define _LUCENE_THREAD_FUNC_RETURN(val) return (int)val;
#define _LUCENE_THREAD_CREATE(func, arg) (*func)(arg)
#define _LUCENE_THREAD_JOIN(value) //nothing to do...
#define _LUCENE_THREADMUTEX void*
#define _LUCENE_ATOMIC_INC(theInteger) (++(*theInteger))
#define _LUCENE_ATOMIC_DEC(theInteger) (--(*theInteger))
#define _LUCENE_ATOMIC_INT int
#else
#if defined(_LUCENE_DONTIMPLEMENT_THREADMUTEX)
//do nothing
#else
class mutexGuard;
#if defined(_CL_HAVE_PTHREAD)
#define _LUCENE_THREADID_TYPE pthread_t
#define _LUCENE_THREAD_FUNC(name, argName) void* name(void* argName) //< use this macro to correctly define the thread start routine
#define _LUCENE_THREAD_FUNC_RETURN(val) return (void*)val;
typedef void* (luceneThreadStartRoutine)(void* lpThreadParameter );
class CLUCENE_SHARED_EXPORT mutex_thread
{
public:
struct Internal;
Internal* _internal;
mutex_thread(const mutex_thread& clone);
mutex_thread();
~mutex_thread();
void lock();
void unlock();
static _LUCENE_THREADID_TYPE _GetCurrentThreadId();
static _LUCENE_THREADID_TYPE CreateThread(luceneThreadStartRoutine* func, void* arg);
static void JoinThread(_LUCENE_THREADID_TYPE id);
void Wait(mutex_thread* shared_lock);
void NotifyAll();
};
class CLUCENE_SHARED_EXPORT shared_condition{
private:
class Internal;
Internal* _internal;
public:
shared_condition();
~shared_condition();
void Wait(mutex_thread* shared_lock);
void NotifyAll();
};
#ifdef _CL_HAVE_GCC_ATOMIC_FUNCTIONS
#define _LUCENE_ATOMIC_INT uint32_t
#define _LUCENE_ATOMIC_INT_SET(x,v) x=v
#define _LUCENE_ATOMIC_INT_GET(x) x
#else
class CLUCENE_SHARED_EXPORT __LUCENE_ATOMIC_INT{
public:
int value;
CL_NS(util)::mutex_thread THIS_LOCK;
};
#define _LUCENE_ATOMIC_INT CL_NS(util)::__LUCENE_ATOMIC_INT
#define _LUCENE_ATOMIC_INT_SET(x,v) x.value=v
#define _LUCENE_ATOMIC_INT_GET(x) x.value
#endif
class CLUCENE_SHARED_EXPORT atomic_threads{
public:
static int32_t atomic_increment(_LUCENE_ATOMIC_INT* theInteger);
static int32_t atomic_decrement(_LUCENE_ATOMIC_INT* theInteger);
};
#define _LUCENE_ATOMIC_INC(theInteger) CL_NS(util)::atomic_threads::atomic_increment(theInteger)
#define _LUCENE_ATOMIC_DEC(theInteger) CL_NS(util)::atomic_threads::atomic_decrement(theInteger)
#elif defined(_CL_HAVE_WIN32_THREADS)
#define _LUCENE_THREADID_TYPE uint64_t
#define _LUCENE_THREAD_FUNC(name, argName) void __stdcall name(void* argName) //< use this macro to correctly define the thread start routine
#define _LUCENE_THREAD_FUNC_RETURN(val) CL_NS(util)::mutex_thread::_exitThread(val)
#define _LUCENE_ATOMIC_INC(theInteger) CL_NS(util)::mutex_thread::atomic_increment(theInteger)
#define _LUCENE_ATOMIC_DEC(theInteger) CL_NS(util)::mutex_thread::atomic_decrement(theInteger)
#ifdef _M_X64
#define _LUCENE_ATOMIC_INT long long
#else
#define _LUCENE_ATOMIC_INT long
#endif
#define _LUCENE_ATOMIC_INT_SET(x,v) x=v
#define _LUCENE_ATOMIC_INT_GET(x) x
typedef void (__stdcall luceneThreadStartRoutine)(void* lpThreadParameter );
class CLUCENE_SHARED_EXPORT mutex_thread
{
private:
struct Internal;
Internal* _internal;
public:
mutex_thread(const mutex_thread& clone);
mutex_thread();
~mutex_thread();
void lock();
void unlock();
static void _exitThread(int ret);
static _LUCENE_THREADID_TYPE _GetCurrentThreadId();
static _LUCENE_THREADID_TYPE CreateThread(luceneThreadStartRoutine* func, void* arg);
static void JoinThread(_LUCENE_THREADID_TYPE id);
static int32_t atomic_increment(_LUCENE_ATOMIC_INT* theInteger);
static int32_t atomic_decrement(_LUCENE_ATOMIC_INT* theInteger);
};
class CLUCENE_SHARED_EXPORT shared_condition{
private:
class Internal;
Internal* _internal;
public:
shared_condition();
~shared_condition();
void Wait(mutex_thread* shared_lock);
void NotifyAll();
};
#else
#error A valid thread library was not found
#endif //mutex types
#define _LUCENE_THREAD_CREATE(func, arg) CL_NS(util)::mutex_thread::CreateThread(func,arg)
#define _LUCENE_THREAD_JOIN(id) CL_NS(util)::mutex_thread::JoinThread(id)
#define _LUCENE_CURRTHREADID CL_NS(util)::mutex_thread::_GetCurrentThreadId()
#define _LUCENE_THREADMUTEX CL_NS(util)::mutex_thread
#define _LUCENE_THREADCOND CL_NS(util)::shared_condition
#endif //don't implement
/** @internal */
class CLUCENE_SHARED_EXPORT mutexGuard
{
private:
_LUCENE_THREADMUTEX* mrMutex;
mutexGuard(const mutexGuard& clone);
public:
mutexGuard( _LUCENE_THREADMUTEX& rMutex );
~mutexGuard();
};
#define SCOPED_LOCK_MUTEX(theMutex) CL_NS(util)::mutexGuard theMutexGuard(theMutex);
#define DEFINE_MUTEX(theMutex) _LUCENE_THREADMUTEX theMutex;
#define DEFINE_CONDITION(theCondition) _LUCENE_THREADCOND theCondition;
#define DEFINE_MUTABLE_MUTEX(theMutex) mutable _LUCENE_THREADMUTEX theMutex;
#define STATIC_DEFINE_MUTEX(theMutex) static _LUCENE_THREADMUTEX theMutex;
#define CONDITION_WAIT(theMutex, theCondition) theCondition.Wait(&theMutex);
#define CONDITION_NOTIFYALL(theCondition) theCondition.NotifyAll();
#endif //_CL_DISABLE_MULTITHREADING
CL_NS_END
#endif
|