(file) Return to Threads.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/Threads.cpp between version 1.6 and 1.13.6.2

version 1.6, 2006/11/10 18:14:58 version 1.13.6.2, 2008/11/05 09:21:46
Line 37 
Line 37 
 #include "TSDKey.h" #include "TSDKey.h"
 #include "Once.h" #include "Once.h"
  
 #if defined(PEGASUS_PLATFORM_WIN32_IX86_MSVC)  #if defined(PEGASUS_OS_TYPE_WINDOWS)
 # include <sys/timeb.h> # include <sys/timeb.h>
 #endif #endif
   #if defined(PEGASUS_OS_ZOS)
   # include <unistd.h>
   #endif
   
   #if defined(PEGASUS_OS_SOLARIS)
   # include <unistd.h>
   #endif
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 47 
Line 54 
 { {
 #if defined(PEGASUS_HAVE_NANOSLEEP) #if defined(PEGASUS_HAVE_NANOSLEEP)
  
     struct timespec wait;      struct timespec wait, remwait;
     wait.tv_sec = msec / 1000;     wait.tv_sec = msec / 1000;
     wait.tv_nsec = (msec % 1000) * 1000000;     wait.tv_nsec = (msec % 1000) * 1000000;
     nanosleep(&wait, NULL);  
   
 #elif defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM)  
   
    int loop;  
    int microsecs = msec * 1000; /* convert from milliseconds to microseconds */  
  
    if (microsecs < 1000000)      while ((nanosleep(&wait, &remwait) == -1) && (errno == EINTR))
        usleep(microsecs);  
    else  
    {    {
        loop = microsecs / 1000000;          wait.tv_sec = remwait.tv_sec;
        for (int i = 0; i < loop; i++)          wait.tv_nsec = remwait.tv_nsec;
            usleep(1000000);  
        if ((loop*1000000) < microsecs)  
            usleep(microsecs - (loop*1000000));  
    }    }
  
 #elif defined(PEGASUS_PLATFORM_WIN32_IX86_MSVC)  #elif defined(PEGASUS_OS_TYPE_WINDOWS)
  
     if (msec == 0)     if (msec == 0)
     {     {
Line 89 
Line 85 
     }     }
     while (end.millitm > now.millitm && end.time >= now.time);     while (end.millitm > now.millitm && end.time >= now.time);
  
 #elif defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)  #else
     int seconds;  
     if (msec < 1000)     if (msec < 1000)
     {     {
         usleep(msec*1000);         usleep(msec*1000);
Line 102 
Line 97 
         // Usleep the remaining micro seconds         // Usleep the remaining micro seconds
         usleep( (msec*1000) % 1000000 );         usleep( (msec*1000) % 1000000 );
     }     }
 #elif defined(PEGASUS_OS_VMS)  
   
     ::sleep(msec / 1000);  
  
 #endif #endif
 } }
  
 //============================================================================== //==============================================================================
 // //
 // Thread id TSD:  
 //  
 //==============================================================================  
   
 static Once _once = PEGASUS_ONCE_INITIALIZER;  
 static TSDKeyType _key;  
   
 static void _create_key()  
 {  
     TSDKey::create(&_key);  
 }  
   
 static inline void _set_id_tsd(Uint32 id)  
 {  
     once(&_once, _create_key);  
     TSDKey::set_thread_specific(_key, (void*)(long)id);  
 }  
   
 static inline Uint32 _get_id_tsd()  
 {  
     once(&_once, _create_key);  
     void* ptr = TSDKey::get_thread_specific(_key);  
   
     if (!ptr)  
     {  
         // Main thread's id is 1!  
         return 1;  
     }  
   
     return (Uint32)(long)ptr;  
 }  
   
 //==============================================================================  
 //  
 // _get_stack_multiplier() // _get_stack_multiplier()
 // //
 //============================================================================== //==============================================================================
Line 190 
Line 148 
     }     }
  
     return _multiplier;     return _multiplier;
 #else  #elif defined(PEGASUS_PLATFORM_HPUX_PARISC_ACC)
     return 2;     return 2;
   #elif defined(PEGASUS_OS_AIX)
       return 2;
   #else
       return 1;
 #endif #endif
 } }
  
Line 228 
Line 190 
  
     // Stack size:     // Stack size:
  
 #if defined(PEGASUS_PLATFORM_HPUX_PARISC_ACC) || defined(PEGASUS_OS_VMS)      int multiplier = _get_stack_multiplier();
   
       if (multiplier != 1)
     {     {
         size_t stacksize;         size_t stacksize;
  
         if (pthread_attr_getstacksize(&attr, &stacksize) == 0)         if (pthread_attr_getstacksize(&attr, &stacksize) == 0)
         {         {
             int m = _get_stack_multiplier();              int rc = pthread_attr_setstacksize(&attr, stacksize * multiplier);
             int rc = pthread_attr_setstacksize(&attr, stacksize * m);  
             PEGASUS_ASSERT(rc == 0);             PEGASUS_ASSERT(rc == 0);
         }         }
     }     }
 #endif  
  
     // Scheduling policy:     // Scheduling policy:
  
 #if defined(PEGASUS_PLATFORM_SOLARIS_SPARC_GNU) || \  #if defined(PEGASUS_OS_SOLARIS)
     defined(PEGASUS_PLATFORM_SOLARIS_SPARC_CC)  
 # if defined SUNOS_5_7  
     pthread_attr_setschedpolicy(&attr, SCHED_RR);  
 # else  
     pthread_attr_setschedpolicy(&attr, SCHED_OTHER);     pthread_attr_setschedpolicy(&attr, SCHED_OTHER);
 # endif  
 #endif // PEGASUS_PLATFORM_SOLARIS_SPARC_GNU  #endif /* defined(PEGASUS_OS_SOLARIS) */
  
     // Create thread:     // Create thread:
  

Legend:
Removed from v.1.6  
changed lines
  Added in v.1.13.6.2
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2