| 1 | // **********************************************************************
 | 
|---|
| 2 | //
 | 
|---|
| 3 | // Copyright (c) 2000
 | 
|---|
| 4 | // Object Oriented Concepts, Inc.
 | 
|---|
| 5 | // Billerica, MA, USA
 | 
|---|
| 6 | //
 | 
|---|
| 7 | // All Rights Reserved
 | 
|---|
| 8 | //
 | 
|---|
| 9 | // **********************************************************************
 | 
|---|
| 10 | 
 | 
|---|
| 11 | #ifndef JTC_SYNC_H
 | 
|---|
| 12 | #define JTC_SYNC_H
 | 
|---|
| 13 | 
 | 
|---|
| 14 | //
 | 
|---|
| 15 | // This class is used to lock and unlock a monitor.
 | 
|---|
| 16 | //
 | 
|---|
| 17 | class JTCSynchronized
 | 
|---|
| 18 | {
 | 
|---|
| 19 |     //
 | 
|---|
| 20 |     // Hide copy constructor and assignment operator.
 | 
|---|
| 21 |     //
 | 
|---|
| 22 |     JTCSynchronized(const JTCSynchronized&);
 | 
|---|
| 23 |     void operator=(const JTCSynchronized&);
 | 
|---|
| 24 | 
 | 
|---|
| 25 |     const JTCMonitor* mon_; // Associated monitor.
 | 
|---|
| 26 |     const JTCMutex* mut_; // Associated mutex.
 | 
|---|
| 27 |     const JTCRecursiveMutex* nrmut_; // Associated recursive mutex.
 | 
|---|
| 28 | 
 | 
|---|
| 29 |     enum
 | 
|---|
| 30 |     {
 | 
|---|
| 31 |         LOCKED_MONITOR,
 | 
|---|
| 32 |         LOCKED_MUTEX,
 | 
|---|
| 33 |         LOCKED_RECURSIVE_MUTEX
 | 
|---|
| 34 |     }
 | 
|---|
| 35 |     lockType_; // The lock type
 | 
|---|
| 36 | 
 | 
|---|
| 37 | public:
 | 
|---|
| 38 | 
 | 
|---|
| 39 |     JTCSynchronized(const JTCMonitor& mon);
 | 
|---|
| 40 |     JTCSynchronized(const JTCMonitor& mon, bool internal);
 | 
|---|
| 41 |     JTCSynchronized(const JTCMutex& m);
 | 
|---|
| 42 |     JTCSynchronized(const JTCRecursiveMutex& m);
 | 
|---|
| 43 |     ~JTCSynchronized();
 | 
|---|
| 44 | };
 | 
|---|
| 45 | 
 | 
|---|
| 46 | //
 | 
|---|
| 47 | // Inlining the methods causes problems with CC 7.1 under SGI
 | 
|---|
| 48 | //
 | 
|---|
| 49 | #if !defined(__sgi)
 | 
|---|
| 50 | inline
 | 
|---|
| 51 | JTCSynchronized::JTCSynchronized(const JTCMonitor& mon)
 | 
|---|
| 52 |     : mon_(&mon), lockType_(LOCKED_MONITOR)
 | 
|---|
| 53 | {
 | 
|---|
| 54 |     mon_ -> lock(false);
 | 
|---|
| 55 | }
 | 
|---|
| 56 | 
 | 
|---|
| 57 | inline
 | 
|---|
| 58 | JTCSynchronized::JTCSynchronized(const JTCMonitor& mon, bool internal)
 | 
|---|
| 59 |     : mon_(&mon), lockType_(LOCKED_MONITOR)
 | 
|---|
| 60 | {
 | 
|---|
| 61 |     mon_ -> lock(internal);
 | 
|---|
| 62 | }
 | 
|---|
| 63 | 
 | 
|---|
| 64 | inline
 | 
|---|
| 65 | JTCSynchronized::JTCSynchronized(const JTCMutex& m)
 | 
|---|
| 66 |     : mut_(&m), lockType_(LOCKED_MUTEX)
 | 
|---|
| 67 | {
 | 
|---|
| 68 |     mut_ -> lock();
 | 
|---|
| 69 | }
 | 
|---|
| 70 | 
 | 
|---|
| 71 | inline
 | 
|---|
| 72 | JTCSynchronized::JTCSynchronized(const JTCRecursiveMutex& m)
 | 
|---|
| 73 |     : nrmut_(&m), lockType_(LOCKED_RECURSIVE_MUTEX)
 | 
|---|
| 74 | {
 | 
|---|
| 75 |     nrmut_ -> lock();
 | 
|---|
| 76 | }
 | 
|---|
| 77 | 
 | 
|---|
| 78 | inline
 | 
|---|
| 79 | JTCSynchronized::~JTCSynchronized()
 | 
|---|
| 80 | {
 | 
|---|
| 81 |     switch(lockType_)
 | 
|---|
| 82 |     {
 | 
|---|
| 83 |     case LOCKED_MONITOR:
 | 
|---|
| 84 |         mon_ -> unlock();
 | 
|---|
| 85 |         break;
 | 
|---|
| 86 |     case LOCKED_MUTEX:
 | 
|---|
| 87 |         mut_ -> unlock();
 | 
|---|
| 88 |         break;
 | 
|---|
| 89 |     case LOCKED_RECURSIVE_MUTEX:
 | 
|---|
| 90 |         nrmut_ -> unlock();
 | 
|---|
| 91 |         break;
 | 
|---|
| 92 |     }
 | 
|---|
| 93 | }
 | 
|---|
| 94 | #endif
 | 
|---|
| 95 | 
 | 
|---|
| 96 | #endif
 | 
|---|