From 3666a49022f84b3d1888f630a78f3f8f28aadde1 Mon Sep 17 00:00:00 2001
From: Martin Sustrik <sustrik@fastmq.commkdir>
Date: Sat, 29 Aug 2009 10:32:21 +0200
Subject: bug in identifying current thread fixed

---
 src/thread.cpp | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)

(limited to 'src/thread.cpp')

diff --git a/src/thread.cpp b/src/thread.cpp
index 77993e2..d5b889d 100644
--- a/src/thread.cpp
+++ b/src/thread.cpp
@@ -38,6 +38,16 @@ void zmq::thread_t::stop ()
     win_assert (rc != WAIT_FAILED);
 }
 
+zmq::thread_t::id_t zmq::thread_t::id ()
+{
+    return GetCurrentThreadId ();
+}
+
+bool zmq::thread_t::equal (id_t id1_, id_t id2_)
+{
+    return id1_ == id2_;
+}
+
 unsigned int __stdcall zmq::thread_t::thread_routine (void *arg_)
 {
     thread_t *self = (thread_t*) arg_;
@@ -63,6 +73,16 @@ void zmq::thread_t::stop ()
     errno_assert (rc == 0);
 }
 
+zmq::thread_t::id_t zmq::thread_t::id ()
+{
+    return pthread_self ();
+}
+
+bool zmq::thread_t::equal (id_t id1_, id_t id2_)
+{
+    return pthread_equal (id1_, id2_) != 0;
+}
+
 void *zmq::thread_t::thread_routine (void *arg_)
 {
 #if !defined ZMQ_HAVE_OPENVMS
-- 
cgit v1.2.3