| [1016] | 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 | 
|---|