workers: Map the current thread-id to the WorkerRunLoop.

content/child/worker_task_runner.cc

 // Copyright 2014 The Chromium 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 "content/child/worker_task_runner.h"
 
 #include "base/callback.h"
 #include "base/lazy_instance.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
@@ skipping 18 matching lines @@
 
 } // namespace
 
 struct WorkerTaskRunner::ThreadLocalState {
   explicit ThreadLocalState(int id) : id_(id) {}
   int id_;
   ObserverList<WorkerTaskRunner::Observer> stop_observers_;
 };
 
 WorkerTaskRunner::WorkerTaskRunner() {
-  // Start worker ids at 1, 0 is reserved for the main thread.
-  int id = id_sequence_.GetNext();
-  DCHECK(!id);
 }
 
 bool WorkerTaskRunner::PostTask(
     int id, const base::Closure& closure) {
   DCHECK(id > 0);
   base::AutoLock locker(loop_map_lock_);
   IDToLoopMap::iterator found = loop_map_.find(id);
   if (found == loop_map_.end())
     return false;
   return found->second.postTask(new RunClosureTask(closure));
@@ skipping 27 matching lines @@
 void WorkerTaskRunner::RemoveStopObserver(Observer* obs) {
   DCHECK(CurrentWorkerId() > 0);
   current_tls_.Get()->stop_observers_.RemoveObserver(obs);
 }
 
 WorkerTaskRunner::~WorkerTaskRunner() {
 }
 
 void WorkerTaskRunner::OnWorkerRunLoopStarted(const WebWorkerRunLoop& loop) {
   DCHECK(!current_tls_.Get());
-  int id = id_sequence_.GetNext();
+  DCHECK(!base::PlatformThread::CurrentRef().is_null());
+  int id = base::PlatformThread::CurrentId();
   current_tls_.Set(new ThreadLocalState(id));
 
   base::AutoLock locker_(loop_map_lock_);
   loop_map_[id] = loop;
 }
 
 void WorkerTaskRunner::OnWorkerRunLoopStopped(const WebWorkerRunLoop& loop) {
   DCHECK(current_tls_.Get());
   FOR_EACH_OBSERVER(Observer, current_tls_.Get()->stop_observers_,
                     OnWorkerRunLoopStopped());
   {
     base::AutoLock locker(loop_map_lock_);
     DCHECK(loop_map_[CurrentWorkerId()] == loop);
     loop_map_.erase(CurrentWorkerId());
   }
   delete current_tls_.Get();
   current_tls_.Set(NULL);
 }
 
 }  // namespace content