Debug stub: associate NaClAppThread with IThread

src/trusted/debug_stub/posix/thread_impl.cc

 /*
  * Copyright (c) 2012 The Native Client Authors. All rights reserved.
  * Use of this source code is governed by a BSD-style license that can be
  * found in the LICENSE file.
  */
 
 #include <stdexcept>
 #include <string.h>
 
 #include "native_client/src/shared/platform/nacl_log.h"
@@ skipping 23 matching lines @@
   return mutex_;
 }
 
 static IThread::ThreadMap_t *ThreadGetMap() {
   static IThread::ThreadMap_t* map_ = new IThread::ThreadMap_t;
   return map_;
 }
 
 class Thread : public IThread {
  public:
-  explicit Thread(uint32_t id) : ref_(1), id_(id), state_(DEAD) {}
+  Thread(uint32_t id, struct NaClAppThread *natp)
+      : ref_(1), id_(id), natp_(natp), state_(DEAD) {}
   ~Thread() {}
 
   uint32_t GetId() {
     return id_;
   }
 
   State GetState() {
     return state_;
   }
 
@@ skipping 62 matching lines @@
       return NACL_SIGNAL_RETURN;
     } else {
       // Do not attempt to debug crashes in trusted code.
       return NACL_SIGNAL_SEARCH;
     }
   }
 
  private:
   uint32_t ref_;
   uint32_t id_;
+  struct NaClAppThread *natp_;
   State  state_;
   struct NaClSignalContext context_;
 
   friend class IThread;
 };
 
-// TODO(mseaborn): This is duplicated in the Windows version.
-IThread* IThread::Acquire(uint32_t id, bool create) {
+// TODO(eaeltsin): This is duplicated in the Windows version.
+IThread* IThread::Create(uint32_t id, struct NaClAppThread* natp) {
   MutexLock lock(ThreadGetLock());
   Thread* thread;
   ThreadMap_t &map = *ThreadGetMap();
 
-  // Check if we have that thread
   if (map.count(id)) {
-    thread = static_cast<Thread*>(map[id]);
-    thread->ref_++;
-    return thread;
+    NaClLog(LOG_FATAL, "IThread::Create: thread 0x%x already exists\n", id);
   }
 
-  // If not, can we create it?
-  if (create) {
-    // If not add it to the map
-    thread = new Thread(id);
-    map[id] = thread;
-    return thread;
+  thread = new Thread(id, natp);
+  map[id] = thread;
+  return thread;
+}
+
+// TODO(eaeltsin): This is duplicated in the Windows version.
+IThread* IThread::Acquire(uint32_t id) {
+  MutexLock lock(ThreadGetLock());
+  Thread* thread;
+  ThreadMap_t &map = *ThreadGetMap();
+
+  if (map.count(id) == 0) {
+    NaClLog(LOG_FATAL, "IThread::Acquire: thread 0x%x does not exist\n", id);
   }
 
-  return NULL;
+  thread = static_cast<Thread*>(map[id]);
+  thread->ref_++;
+  return thread;
 }
 
-// TODO(mseaborn): This is duplicated in the Windows version.
+// TODO(eaeltsin): This is duplicated in the Windows version.
 void IThread::Release(IThread *ithread) {
   MutexLock lock(ThreadGetLock());
   Thread* thread = static_cast<Thread*>(ithread);
   thread->ref_--;
 
   if (thread->ref_ == 0) {
     ThreadGetMap()->erase(thread->id_);
     delete static_cast<IThread*>(thread);
   }
 }
 
 void IThread::SetExceptionCatch(IThread::CatchFunc_t func, void *cookie) {
   NaClSignalHandlerAdd(Thread::SignalHandler);
   s_CatchFunc = func;
   s_CatchCookie = cookie;
 }
 
 
 }  // End of port namespace