summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/sys/Monitor.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2006-11-06 16:43:31 +0000
committerAlan Conway <aconway@apache.org>2006-11-06 16:43:31 +0000
commit0c3f1084652f7d81f1ca992676e90c158eeb3e65 (patch)
tree7488712d1ce7cc8ac5dcda656a36ee303d2d2e14 /cpp/src/qpid/sys/Monitor.h
parent7847c1c0326e654845868ab4ab4ec27863a3e777 (diff)
downloadqpid-python-0c3f1084652f7d81f1ca992676e90c158eeb3e65.tar.gz
Minor source reorg, see README.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@471789 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/sys/Monitor.h')
-rw-r--r--cpp/src/qpid/sys/Monitor.h56
1 files changed, 56 insertions, 0 deletions
diff --git a/cpp/src/qpid/sys/Monitor.h b/cpp/src/qpid/sys/Monitor.h
new file mode 100644
index 0000000000..ddda613b87
--- /dev/null
+++ b/cpp/src/qpid/sys/Monitor.h
@@ -0,0 +1,56 @@
+/*
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+#ifndef _Monitor_
+#define _Monitor_
+
+#include "apr-1/apr_thread_mutex.h"
+#include "apr-1/apr_thread_cond.h"
+#include "qpid/sys/Monitor.h"
+
+namespace qpid {
+namespace sys {
+
+class Monitor
+{
+ apr_pool_t* pool;
+ apr_thread_mutex_t* mutex;
+ apr_thread_cond_t* condition;
+
+ public:
+ Monitor();
+ virtual ~Monitor();
+ virtual void wait();
+ virtual void wait(u_int64_t time);
+ virtual void notify();
+ virtual void notifyAll();
+ virtual void acquire();
+ virtual void release();
+};
+
+class Locker
+{
+ public:
+ Locker(Monitor& monitor_) : monitor(monitor_) { monitor.acquire(); }
+ ~Locker() { monitor.release(); }
+ private:
+ Monitor& monitor;
+};
+}}
+
+
+#endif