Merge pull request #5882 from aiicore/add_thread_names

common: add thread names

Reviewed-by: Sage Weil <sage@redhat.com>

diff --cc src/kv/LevelDBStore.cc
Simple merge

diff --cc src/kv/RocksDBStore.cc
Simple merge

diff --cc src/librbd/ImageCtx.cc
Simple merge

diff --cc src/mds/MDLog.cc
index 3aea9df34e04211defcfda4c428202db6dbf6709,c8817b5eb4a54831c66f9e3aec9a732d8e662f09..2a0c7166409738f643756e9b018ad685ddbc634e
--- 1/src/mds/MDLog.cc
--- 2/src/mds/MDLog.cc
+++ b/src/mds/MDLog.cc
@@@ -176,11 -176,10 +176,11 @@@ void MDLog::open(MDSInternalContextBas
  {
    dout(5) << "open discovering log bounds" << dendl;
  
 +  assert(!recovery_thread.is_started());
    recovery_thread.set_completion(c);
-   recovery_thread.create();
+   recovery_thread.create("md_recov_open");
  
-   submit_thread.create();
+   submit_thread.create("md_submit");
    // either append() or replay() will follow.
  }
  
@@@ -216,13 -215,8 +216,13 @@@ void MDLog::reopen(MDSInternalContextBa
    delete journaler;
    journaler = NULL;
  
 +  // recovery_thread was started at some point in the past.  Although
 +  // it has called it's completion if we made it back here, it might
 +  // still not have been cleaned up: join it.
 +  recovery_thread.join();
 +
    recovery_thread.set_completion(new C_ReopenComplete(this, c));
-   recovery_thread.create();
+   recovery_thread.create("md_recov_reopen");
  }
  
  void MDLog::append()
@@@ -846,14 -840,9 +846,14 @@@ void MDLog::replay(MDSInternalContextBa
           << " to " << journaler->get_write_pos() << dendl;
  
    assert(num_events == 0 || already_replayed);
 +  if (already_replayed) {
 +    // Ensure previous instance of ReplayThread is joined before
 +    // we create another one
 +    replay_thread.join();
 +  }
    already_replayed = true;
  
-   replay_thread.create();
+   replay_thread.create("md_log_replay");
  }
  
  

diff --cc src/mon/MonitorDBStore.h
Simple merge

diff --cc src/msg/simple/Pipe.cc
Simple merge

diff --cc src/os/bluestore/BlockDevice.cc
Simple merge

diff --cc src/os/bluestore/BlueStore.cc
Simple merge

diff --cc src/os/filestore/FileStore.cc
Simple merge

diff --cc src/os/keyvaluestore/KeyValueStore.cc
Simple merge

diff --cc src/os/kstore/KStore.cc
Simple merge

diff --cc src/osd/OSD.cc
Simple merge

diff --cc src/osdc/ObjectCacher.h
Simple merge

diff --cc src/rgw/rgw_bucket.h
Simple merge

diff --cc src/tools/rbd_nbd/rbd-nbd.cc
index 8ce5787dd26a687e433fa808a3585baed42e0c59,a6363d4a62c8792224dd52b0feda39a916bc6ced..07d7edb19c634f47601fd6c3590441495db07945
--- 1/src/tools/rbd_nbd/rbd-nbd.cc
--- 2/src/tools/rbd_nbd/rbd-nbd.cc
+++ b/src/tools/rbd_nbd/rbd-nbd.cc
@@@ -328,12 -260,10 +328,12 @@@ public
    void start()
    {
      if (!started) {
 +      dout(10) << __func__ << ": starting" << dendl;
 +
        started = true;
  
-       reader_thread.create();
-       writer_thread.create();
+       reader_thread.create("rbd_reader");
+       writer_thread.create("rbd_writer");
      }
    }