1 files changed, 75 insertions, 0 deletions
diff --git a/ACE/examples/APG/ThreadSafety/TSS.cpp b/ACE/examples/APG/ThreadSafety/TSS.cpp
new file mode 100644
index 00000000000..8cc875cb3ee
--- /dev/null
+++ b/ACE/examples/APG/ThreadSafety/TSS.cpp
@@ -0,0 +1,75 @@
+// $Id$
+
+#include "ace/config-lite.h"
+#if defined (ACE_HAS_THREADS)
+
+#include "ace/Synch.h"
+#include "ace/Task.h"
+#include "ClientContext.h"
+
+
+void*
+ClientContext::get_attribute (const char *name)
+{
+  void * value = 0;
+  attributeMap_.find (name, value);
+  return value;
+}
+
+void
+ClientContext::set_attribute (const char *name, void *value)
+{
+  attributeMap_.bind (name, value);
+}
+
+// Listing 2 code/ch14
+class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH>
+{
+public:
+  virtual int svc (void)
+  {
+    ACE_thread_t tid = this->thr_mgr ()->thr_self ();
+    // Set our identifier in TSS.
+    this->tss_ctx_->set_attribute ("thread_id", &tid);
+
+    while (handle_requests () > 0)
+      ;
+
+    return 0;
+  }
+
+  int handle_requests (void)
+  {
+    ACE_thread_t *tid =
+      (ACE_thread_t*)this->tss_ctx_->get_attribute ("thread_id");
+    ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) TSS TID: %d \n"),
+                *tid));
+
+    // do work.
+    return -1;
+  }
+
+private:
+  ACE_TSS<ClientContext> tss_ctx_;
+};
+// Listing 2
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  HA_CommandHandler handler;
+  handler.activate (THR_NEW_LWP | THR_JOINABLE, 5);
+  handler.wait ();
+  return 0;
+}
+
+#else
+#include "ace/OS_main.h"
+#include "ace/OS_NS_stdio.h"
+
+int ACE_TMAIN (int, ACE_TCHAR *[])
+{
+  ACE_OS::puts (ACE_TEXT ("This example requires threads."));
+  return 0;
+}
+
+#endif /* ACE_HAS_THREADS */