pegasus/src/Pegasus/Common/Thread.cpp - diff

Return to Thread.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/Thread.cpp between version 1.17 and 1.100.2.5

version 1.17, 2002/06/01 00:56:40

version 1.100.2.5, 2008/10/23 18:58:28

Line 1

//%/////////////////////////////////////////////////////////////////////////////

//%2006////////////////////////////////////////////////////////////////////////

// The Open Group, Tivoli Systems

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// IBM Corp.; EMC Corporation, The Open Group.

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; Symantec Corporation; The Open Group.

// Permission is hereby granted, free of charge, to any person obtaining a copy

// of this software and associated documentation files (the "Software"), to

Line 21

Line 29

//==============================================================================

// Author: Mike Day (mdday@us.ibm.com)

// Modified By: Rudy Schuet (rudy.schuet@compaq.com) 11/12/01

// added nsk platform support

//%/////////////////////////////////////////////////////////////////////////////

#include "Thread.h"

#include <Pegasus/Common/IPC.h>

#include <errno.h>

#include <exception>

#include <Pegasus/Common/Tracer.h>

#include "Time.h"

#if defined(PEGASUS_OS_TYPE_WINDOWS)

PEGASUS_USING_STD;

# include "ThreadWindows.cpp"

#elif defined(PEGASUS_OS_TYPE_UNIX)

# include "ThreadUnix.cpp"

#elif defined(PEGASUS_OS_TYPE_NSK)

# include "ThreadNsk.cpp"

#else

# error "Unsupported platform"

#endif

PEGASUS_NAMESPACE_BEGIN

void thread_data::default_delete(void * data)

//==============================================================================

// POSIX Threads Implementation:

//==============================================================================

#if defined(PEGASUS_HAVE_PTHREADS)

struct StartWrapperArg

{

if( data != NULL)

void *(PEGASUS_THREAD_CDECL * start) (void *);

::operator delete(data);

void *arg;

};

extern "C" void *_start_wrapper(void *arg_)

{

// Clean up dynamic memory now to prevent a leak if the thread is canceled.

StartWrapperArg arg;

arg.start = ((StartWrapperArg *) arg_)->start;

arg.arg = ((StartWrapperArg *) arg_)->arg;

delete (StartWrapperArg *) arg_;

// establish cancelability of the thread

pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);

pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);

void *return_value = (*arg.start) (arg.arg);

return return_value;

}

Boolean Thread::_signals_blocked = false;

void Thread::cancel()

{

_cancelled = true;

pthread_cancel(_handle.thid.thread);

}

// for non-native implementations

void Thread::test_cancel()

#ifndef PEGASUS_THREAD_CLEANUP_NATIVE

void Thread::cleanup_push( void (*routine)(void *), void *parm) throw(IPCException)

{

cleanup_handler *cu = new cleanup_handler(routine, parm);

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

try

pthread_testintr();

#else

pthread_testcancel();

#endif

}

Boolean Thread::is_cancelled()

{

_cleanup.insert_first(cu);

return _cancelled;

}

catch(IPCException&)

void Thread::thread_switch()

{

delete cu;

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

throw;

pthread_yield(NULL);

#else

sched_yield();

#endif

}

return;

ATTN: why are these missing on other platforms?

#if defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU)

void Thread::suspend()

{

pthread_kill(_handle.thid.thread, SIGSTOP);

}

void Thread::cleanup_pop(Boolean execute) throw(IPCException)

void Thread::resume()

{

cleanup_handler *cu ;

pthread_kill(_handle.thid.thread, SIGCONT);

try

}

#endif

void Thread::sleep(Uint32 msec)

{

cu = _cleanup.remove_first() ;

Threads::sleep(msec);

}

catch(IPCException&)

void Thread::join()

{

PEGASUS_ASSERT(0);

if (!_is_detached && !Threads::null(_handle.thid))

pthread_join(_handle.thid.thread, &_exit_code);

Threads::clear(_handle.thid);

}

if(execute == true)

cu->execute();

void Thread::thread_init()

delete cu;

{

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

pthread_setintr(PTHREAD_INTR_ENABLE);

pthread_setintrtype(PTHREAD_INTR_ASYNCHRONOUS);

#else

pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);

pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);

#endif

_cancel_enabled = true;

}

void Thread::detach()

{

_is_detached = true;

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

pthread_t thread_id=_handle.thid.thread;

pthread_detach(&thread_id);

#else

pthread_detach(_handle.thid.thread);

#endif

}

ThreadStatus Thread::run()

{

StartWrapperArg *arg = new StartWrapperArg;

arg->start = _start;

arg->arg = this;

Threads::Type type =

_is_detached ? Threads::THREADS_DETACHED : Threads::THREADS_JOINABLE;

int rc = Threads::create(_handle.thid, type, _start_wrapper, arg);

// On Linux distributions released prior 2005, the implementation of

// Native POSIX Thread Library returns ENOMEM instead of EAGAIN when

// there

// are no insufficient memory. Hence we are checking for both. See bug

// 386.

if (rc == -1)

rc = errno;

if ((rc == EAGAIN) || (rc == ENOMEM))

{

Threads::clear(_handle.thid);

delete arg;

return PEGASUS_THREAD_INSUFFICIENT_RESOURCES;

}

else if (rc != 0)

{

Threads::clear(_handle.thid);

delete arg;

return PEGASUS_THREAD_SETUP_FAILURE;

}

return PEGASUS_THREAD_OK;

}

static sigset_t *block_signal_mask(sigset_t * sig)

{

sigemptyset(sig);

// should not be used for main()

sigaddset(sig, SIGHUP);

sigaddset(sig, SIGINT);

// maybe useless, since KILL can't be blocked according to POSIX

sigaddset(sig, SIGKILL);

sigaddset(sig, SIGABRT);

sigaddset(sig, SIGALRM);

sigaddset(sig, SIGPIPE);

// Note: older versions of the linux pthreads library use SIGUSR1 and SIGUSR2

// internally to stop and start threads that are blocking, the newer ones

// implement this through the kernel's real time signals

// since SIGSTOP/CONT can handle suspend()/resume() on Linux

// block them

// #if defined(PEGASUS_PLATFORM_LINUX_IX86_GNU)

// sigaddset(sig, SIGUSR1);

// sigaddset(sig, SIGUSR2);

// #endif

#if defined (PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) || defined (PEGASUS_OS_VMS)

sigprocmask(SIG_BLOCK, sig, NULL);

#else

pthread_sigmask(SIG_BLOCK, sig, NULL);

#endif

return sig;

}

//thread_data *Thread::put_tsd(const Sint8 *key, void (*delete_func)(void *), Uint32 size, void *value) throw(IPCException)

ATTN: remove this!

#if 1

static Uint32 _num_threads = 0;

static Mutex _num_threads_mutex;

#endif

Thread::Thread(

ThreadReturnType(PEGASUS_THREAD_CDECL* start) (void*),

void* parameter,

Boolean detached)

: _is_detached(detached),

_cancel_enabled(true),

_cancelled(false),

_start(start),

_cleanup(),

_tsd(),

_thread_parm(parameter),

_exit_code(0)

{

ATTN: remove this!

#if 1

Uint32 num_threads;

_num_threads_mutex.lock();

_num_threads++;

num_threads = _num_threads;

printf("Thread::Thread(): num_threads=%u\n", num_threads);

_num_threads_mutex.unlock();

#endif

#ifndef PEGASUS_THREAD_EXIT_NATIVE

Threads::clear(_handle.thid);

void Thread::exit_self(PEGASUS_THREAD_RETURN exit_code)

}

{

// execute the cleanup stack and then return

Thread::~Thread()

while( _cleanup.count() )

{

ATTN: remove this!

#if 1

Uint32 num_threads;

_num_threads_mutex.lock();

_num_threads--;

num_threads = _num_threads;

printf("Thread::~Thread(): num_threads=%u\n", num_threads);

_num_threads_mutex.unlock();

<<<<<<< Thread.cpp

#endif

=======

//printf("Thread::~Thread(): num_threads=%u\n", num_threads);

>>>>>>> 1.100.2.4

try

{

cleanup_pop(true);

join();

empty_tsd();

}

catch(IPCException&)

catch (...)

{

PEGASUS_ASSERT(0);

// Do not allow the destructor to throw an exception

break;

}

_exit_code = exit_code;

exit_thread(exit_code);

_handle.thid = 0;

}

#endif /* PEGASUS_HAVE_PTHREADS */

#endif

//==============================================================================

// Windows Threads Implementation:

//==============================================================================

ThreadPool::ThreadPool(Sint16 initial_size,

#if defined(PEGASUS_HAVE_WINDOWS_THREADS)

const Sint8 *key,

Sint16 min,

Sint16 max,

struct timeval & alloc_wait,

struct timeval & dealloc_wait,

struct timeval & deadlock_detect)

: _max_threads(max), _min_threads(min),

_current_threads(0),

_pool(true), _running(true),

_dead(true), _dying(0)

{

_allocate_wait.tv_sec = alloc_wait.tv_sec;

_allocate_wait.tv_usec = alloc_wait.tv_usec;

_deallocate_wait.tv_sec = dealloc_wait.tv_sec;

_deallocate_wait.tv_usec = dealloc_wait.tv_usec;

_deadlock_detect.tv_sec = deadlock_detect.tv_sec;

_deadlock_detect.tv_usec = deadlock_detect.tv_usec;

memset(_key, 0x00, 17);

if(key != 0)

strncpy(_key, key, 16);

if(_max_threads < initial_size)

_max_threads = initial_size;

if(_min_threads > initial_size)

_min_threads = initial_size;

int i;

ThreadStatus Thread::run()

for(i = 0; i < initial_size; i++)

{

_link_pool(_init_thread());

// Note: A Win32 thread ID is not the same thing as a pthread ID.

}

// Win32 threads have both a thread ID and a handle. The handle

}

// is used in the wait functions, etc.

// So _handle.thid is actually the thread handle.

unsigned threadid = 0;

ThreadType tt;

tt.handle = (HANDLE) _beginthreadex(NULL, 0, _start, this, 0, &threadid);

_handle.thid = tt;

ThreadPool::~ThreadPool(void)

if (Threads::null(_handle.thid))

{

_dying++;

if (errno == EAGAIN)

Thread *th = 0;

th = _pool.remove_first();

while(th != 0)

{

Semaphore *sleep_sem = (Semaphore *)th->reference_tsd("sleep sem");

return PEGASUS_THREAD_INSUFFICIENT_RESOURCES;

}

if(sleep_sem == 0)

else

{

th->dereference_tsd();

return PEGASUS_THREAD_SETUP_FAILURE;

throw NullPointer();

}

sleep_sem->signal();

return PEGASUS_THREAD_OK;

sleep_sem->signal();

th->dereference_tsd();

// signal the thread's sleep semaphore

th->cancel();

th->join();

th->empty_tsd();

delete th;

th = _pool.remove_first();

}

th = _running.remove_first();

void Thread::cancel()

while(th != 0)

{

// signal the thread's sleep semaphore

_cancelled = true;

th->cancel();

th->join();

th->empty_tsd();

delete th;

th = _running.remove_first();

}

th = _dead.remove_first();

void Thread::test_cancel()

while(th != 0)

{

// signal the thread's sleep semaphore

if (_cancel_enabled && _cancelled)

th->cancel();

{

th->join();

exit_self(0);

th->empty_tsd();

delete th;

th = _dead.remove_first();

}

// make this static to the class

Boolean Thread::is_cancelled()

PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL ThreadPool::_loop(void *parm)

{

PEG_METHOD_ENTER(TRC_THREAD, "ThreadPool::_loop");

return _cancelled;

}

Thread *myself = (Thread *)parm;

void Thread::thread_switch()

if(myself == 0)

{

PEG_METHOD_EXIT();

Sleep(0);

throw NullPointer();

}

ThreadPool *pool = (ThreadPool *)myself->get_parm();

if(pool == 0 )

void Thread::sleep(Uint32 milliseconds)

{

PEG_METHOD_EXIT();

Sleep(milliseconds);

throw NullPointer();

}

Semaphore *sleep_sem = 0;

Semaphore *blocking_sem = 0;

struct timeval *deadlock_timer = 0;

try

void Thread::join()

{

sleep_sem = (Semaphore *)myself->reference_tsd("sleep sem");

if (!Threads::null(_handle.thid))

myself->dereference_tsd();

deadlock_timer = (struct timeval *)myself->reference_tsd("deadlock timer");

myself->dereference_tsd();

}

catch(IPCException &)

{

PEG_METHOD_EXIT();

if (!_is_detached)

myself->exit_self(0);

}

if(sleep_sem == 0 || deadlock_timer == 0)

{

PEG_METHOD_EXIT();

if (!_cancelled)

throw NullPointer();

{

// Emulate the unix join api. Caller sleeps until thread is

// done.

WaitForSingleObject(_handle.thid.handle, INFINITE);

}

else

while(pool->_dying < 1)

{

sleep_sem->wait();

// Currently this is the only way to ensure this code does

// not

// hang forever.

if (WaitForSingleObject(_handle.thid.handle, 10000) ==

WAIT_TIMEOUT)

{

TerminateThread(_handle.thid.handle, 0);

}

// when we awaken we reside on the running queue, not the pool queue

DWORD exit_code = 0;

if(pool->_dying > 0)

GetExitCodeThread(_handle.thid.handle, &exit_code);

break;

_exit_code = (ThreadReturnType) exit_code;

}

PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *_work)(void *) = 0;

CloseHandle(_handle.thid.handle);

void *parm = 0;

Threads::clear(_handle.thid);

}

try

void Thread::thread_init()

{

_work = (PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *)(void *)) \

_cancel_enabled = true;

myself->reference_tsd("work func");

myself->dereference_tsd();

parm = myself->reference_tsd("work parm");

myself->dereference_tsd();

blocking_sem = (Semaphore *)myself->reference_tsd("blocking sem");

myself->dereference_tsd();

}

catch(IPCException &)

void Thread::detach()

{

PEG_METHOD_EXIT();

_is_detached = true;

myself->exit_self(0);

}

if(_work == 0)

Thread::Thread(ThreadReturnType(PEGASUS_THREAD_CDECL * start) (void *),

void *parameter,

Boolean detached):_is_detached(detached),

_cancel_enabled(true),

_cancelled(false),

_start(start), _cleanup(), _tsd(), _thread_parm(parameter), _exit_code(0)

{

PEG_METHOD_EXIT();

Threads::clear(_handle.thid);

throw NullPointer();

}

gettimeofday(deadlock_timer, NULL);

_work(parm);

if( blocking_sem != 0 )

Thread::~Thread()

blocking_sem->signal();

{

// put myself back onto the available list

try

{

pool->_running.remove((void *)myself);

join();

pool->_link_pool(myself);

empty_tsd();

}

catch(IPCException &)

catch (...)

{

PEG_METHOD_EXIT();

myself->exit_self(0);

}

// wait to be awakend by the thread pool destructor

sleep_sem->wait();

myself->test_cancel();

PEG_METHOD_EXIT();

myself->exit_self(0);

return((PEGASUS_THREAD_RETURN)0);

}

void ThreadPool::allocate_and_awaken(void *parm,

#endif /* PEGASUS_HAVE_WINDOWS_THREADS */

PEGASUS_THREAD_RETURN \

(PEGASUS_THREAD_CDECL *work)(void *),

Semaphore *blocking)

throw(IPCException)

{

PEG_METHOD_ENTER(TRC_THREAD, "ThreadPool::allocate_and_awaken");

struct timeval start;

gettimeofday(&start, NULL);

Thread *th = _pool.remove_first();

// wait for the right interval and try again

//==============================================================================

while(th == 0 && _dying < 1)

{

// Common implementation:

_check_deadlock(&start) ;

//==============================================================================

if(_current_threads < _max_threads)

void thread_data::default_delete(void *data)

{

th = _init_thread();

if (data != NULL)

continue;

::operator delete(data);

}

pegasus_yield();

th = _pool.remove_first();

}

void language_delete(void *data)

if(_dying < 1)

{

// initialize the thread data with the work function and parameters

if (data != NULL)

Tracer::trace(TRC_THREAD, Tracer::LEVEL4,

"Initializing thread with work function and parameters: parm = %p",

parm);

th->delete_tsd("work func");

th->put_tsd("work func", NULL,

sizeof( PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *)(void *)),

(void *)work);

th->delete_tsd("work parm");

th->put_tsd("work parm", NULL, sizeof(void *), parm);

th->delete_tsd("blocking sem");

if(blocking != 0 )

th->put_tsd("blocking sem", NULL, sizeof(Semaphore *), blocking);

// put the thread on the running list

_running.insert_first(th);

// signal the thread's sleep semaphore to awaken it

Semaphore *sleep_sem = (Semaphore *)th->reference_tsd("sleep sem");

if(sleep_sem == 0)

{

th->dereference_tsd();

AutoPtr < AcceptLanguageList > al(static_cast <

PEG_METHOD_EXIT();

AcceptLanguageList * >(data));

throw NullPointer();

}

Tracer::trace(TRC_THREAD, Tracer::LEVEL4, "Signal thread to awaken");

sleep_sem->signal();

th->dereference_tsd();

}

else

_pool.insert_first(th);

PEG_METHOD_EXIT();

Boolean Thread::_signals_blocked = false;

}

#ifndef PEGASUS_OS_ZOS

TSDKeyType Thread::_platform_thread_key = TSDKeyType(-1);

// caller is responsible for only calling this routine during slack periods

#else

// but should call it at least once per _deadlock_detect with the running q

TSDKeyType Thread::_platform_thread_key;

// and at least once per _deallocate_wait for the pool q

#endif

Boolean Thread::_key_initialized = false;

Boolean Thread::_key_error = false;

Uint32 ThreadPool::kill_dead_threads(void)

void Thread::cleanup_push(void (*routine) (void *), void *parm)

throw(IPCException)

{

struct timeval now;

AutoPtr < cleanup_handler > cu(new cleanup_handler(routine, parm));

gettimeofday(&now, NULL);

_cleanup.insert_front(cu.get());

Uint32 bodies = 0;

cu.release();

return;

}

// first go thread the dead q and clean it up as much as possible

void Thread::cleanup_pop(Boolean execute)

while(_dead.count() > 0)

{

Thread *dead = _dead.remove_first();

if(dead == 0)

throw NullPointer();

if(dead->_handle.thid != 0)

{

dead->detach();

AutoPtr < cleanup_handler > cu;

destroy_thread(dead->_handle.thid, 0);

try

dead->_handle.thid = 0;

while(dead->_cleanup.count() )

{

// this may throw a permission exception,

cu.reset(_cleanup.remove_front());

// which I will remove from the code prior to stabilizing

dead->cleanup_pop(true);

}

catch (IPCException &)

{

PEGASUS_ASSERT(0);

}

delete dead;

if (execute == true)

cu->execute();

}

DQueue<Thread> * map[2] =

{

&_pool, &_running

};

DQueue<Thread> *q = 0;

int i = 0;

AtomicInt needed(0);

for( q = map[i] ; i < 2; i++, q = map[i])

void Thread::exit_self(ThreadReturnType exit_code)

{

if(q->count() > 0 )

#if !defined(PEGASUS_PLATFORM_AIX_RS_IBMCXX) \

&& !defined(PEGASUS_PLATFORM_PASE_ISERIES_IBMCXX)

Threads::exit(exit_code);

#else

// execute the cleanup stack and then return

while (_cleanup.size())

{

try

{

q->try_lock();

cleanup_pop(true);

}

catch(AlreadyLocked &)

catch (IPCException &)

{

q++;

PEGASUS_ASSERT(0);

continue;

break;

}

struct timeval dt = { 0, 0 };

struct timeval *dtp;

Thread *th = 0;

th = q->next(th);

while (th != 0 )

{

try

{

dtp = (struct timeval *)th->try_reference_tsd("deadlock timer");

}

catch(AlreadyLocked &)

_exit_code = exit_code;

{

Threads::exit(exit_code);

th = q->next(th);

Threads::clear(_handle.thid);

continue;

#endif

}

if(dtp != 0)

Sint8 Thread::initializeKey()

{

memcpy(&dt, dtp, sizeof(struct timeval));

PEG_METHOD_ENTER(TRC_THREAD, "Thread::initializeKey");

if (!Thread::_key_initialized)

}

th->dereference_tsd();

struct timeval deadlock_timeout;

if( true == check_time(&dt, get_deadlock_detect(&deadlock_timeout) ))

{

// if we are deallocating from the pool, escape if we are

if (Thread::_key_error)

// down to the minimum thread count

_current_threads--;

if( _current_threads.value() <= (Uint32)_min_threads )

{

if( i == 0)

PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,

"Thread: ERROR - thread key error");

return -1;

}

if (TSDKey::create(&Thread::_platform_thread_key) == 0)

{

_current_threads++;

PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,

th = q->next(th);

"Thread: able to create a thread key");

continue;

Thread::_key_initialized = true;

}

else

{

// we are killing a hung thread and we will drop below the

PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,

// minimum. create another thread to make up for the one

"Thread: ERROR - unable to create a thread key");

// we are about to kill

Thread::_key_error = true;

needed++;

return -1;

}

th = q->remove_no_lock((void *)th);

PEG_METHOD_EXIT();

return 0;

}

if(th != 0)

Thread *Thread::getCurrent()

{

th->delete_tsd("work func");

PEG_METHOD_ENTER(TRC_THREAD, "Thread::getCurrent");

th->put_tsd("work func", NULL,

if (Thread::initializeKey() != 0)

sizeof( PEGASUS_THREAD_RETURN (PEGASUS_THREAD_CDECL *)(void *)),

(void *)&_undertaker);

th->delete_tsd("work parm");

th->put_tsd("work parm", NULL, sizeof(void *), th);

// signal the thread's sleep semaphore to awaken it

Semaphore *sleep_sem = (Semaphore *)th->reference_tsd("sleep sem");

if(sleep_sem == 0)

{

th->dereference_tsd();

return NULL;

throw NullPointer();

}

// put the thread on the dead list

_dead.insert_first(th);

bodies++;

sleep_sem->signal();

th->dereference_tsd();

th = 0;

}

PEG_METHOD_EXIT();

return (Thread *) TSDKey::get_thread_specific(_platform_thread_key);

}

th = q->next(th);

void Thread::setCurrent(Thread * thrd)

{

PEG_METHOD_ENTER(TRC_THREAD, "Thread::setCurrent");

if (Thread::initializeKey() == 0)

{

if (TSDKey::

set_thread_specific(Thread::_platform_thread_key,

(void *) thrd) == 0)

{

PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,

"Successful set Thread * into thread specific storage");

}

q->unlock();

else

while (needed.value() > 0)

{

_link_pool(_init_thread());

PEG_TRACE_CSTRING(TRC_THREAD, Tracer::LEVEL4,

needed--;

"ERROR: error setting Thread * into thread specific storage");

}

PEG_METHOD_EXIT();

}

AcceptLanguageList *Thread::getLanguages()

{

PEG_METHOD_ENTER(TRC_THREAD, "Thread::getLanguages");

return bodies;

Thread *curThrd = Thread::getCurrent();

if (curThrd == NULL)

return NULL;

AcceptLanguageList *acceptLangs =

(AcceptLanguageList *) curThrd->reference_tsd("acceptLanguages");

curThrd->dereference_tsd();

PEG_METHOD_EXIT();

return acceptLangs;

}

void Thread::setLanguages(AcceptLanguageList * langs)

Boolean ThreadPool::check_time(struct timeval *start, struct timeval *interval)

{

struct timeval now, finish, remaining;

PEG_METHOD_ENTER(TRC_THREAD, "Thread::setLanguages");

Uint32 usec;

gettimeofday(&now, NULL);

finish.tv_sec = start->tv_sec + interval->tv_sec;

usec = start->tv_usec + interval->tv_usec;

finish.tv_sec += (usec / 1000000);

usec %= 1000000;

finish.tv_usec = usec;

if ( timeval_subtract(&remaining, &finish, &now) )

Thread *currentThrd = Thread::getCurrent();

return true;

if (currentThrd != NULL)

else

{

return false;

// deletes the old tsd and creates a new one

currentThrd->put_tsd("acceptLanguages",

language_delete,

sizeof (AcceptLanguageList *), langs);

}

PEG_METHOD_EXIT();

}

PEGASUS_THREAD_RETURN ThreadPool::_undertaker( void *parm )

void Thread::clearLanguages()

{

Thread *myself = reinterpret_cast<Thread *>(parm);

PEG_METHOD_ENTER(TRC_THREAD, "Thread::clearLanguages");

if(myself != 0)

Thread *currentThrd = Thread::getCurrent();

if (currentThrd != NULL)

{

myself->detach();

// deletes the old tsd

myself->_handle.thid = 0;

currentThrd->delete_tsd("acceptLanguages");

myself->cancel();

myself->test_cancel();

myself->exit_self(0);

}

return((PEGASUS_THREAD_RETURN)0);

PEG_METHOD_EXIT();

}

// ATTN: not sure where to put this!

#ifdef PEGASUS_ZOS_SECURITY

bool isEnhancedSecurity = 99;

#endif

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.17
changed lines
	Added in v.1.100.2.5

No CVS admin address has been configured