Ceph網(wǎng)絡(luò)層代碼之線程的示例分析

小編給大家分享一下Ceph網(wǎng)絡(luò)層代碼之線程的示例分析，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

1. Pipe寫線程是從哪里開始啟動(dòng)的?

Pipe *SimpleMessenger::connect_rank()
---->pipe->start_writer(); //啟動(dòng)Writer線程

2. Pipe讀線程是從哪里開始啟動(dòng)的?

void SimpleMessenger::ready()
----> accepter.start();

Pipe *SimpleMessenger::add_accept_pipe(int sd)
{
p->start_reader();
p->pipe_lock.Unlock();
pipes.insert(p);
accepting_pipes.insert(p);
lock.Unlock();
return p;
}

void Pipe::start_reader()
{
  assert(pipe_lock.is_locked());
  assert(!reader_running);
  if (reader_needs_join) {
    reader_thread.join();
    reader_needs_join = false;
  }
  reader_running = true;
  reader_thread.create(msgr->cct->_conf->ms_rwthread_stack_bytes);
}

void Pipe::reader() //啟動(dòng)reader線程.

3. DispatcherQueue線程是從哪里開始啟動(dòng)的?

void SimpleMessenger::ready()
{
  ldout(cct,10) << "ready " << get_myaddr() << dendl;
  dispatch_queue.start();

  lock.Lock();
  if (did_bind)
    accepter.start();
  lock.Unlock();
}

以上是“Ceph網(wǎng)絡(luò)層代碼之線程的示例分析”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！