| 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 | 
|---|