X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fcommon%2FThread.cc;fp=src%2Fceph%2Fsrc%2Fcommon%2FThread.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=a58c7ba252ccefb8115cc679e492fdf7a4834af2;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/common/Thread.cc b/src/ceph/src/common/Thread.cc
deleted file mode 100644
index a58c7ba..0000000
--- a/src/ceph/src/common/Thread.cc
+++ /dev/null
@@ -1,200 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2004-2011 New Dream Network
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation.  See file COPYING.
- *
- */
-
-#include "include/compat.h"
-#include "common/Thread.h"
-#include "common/code_environment.h"
-#include "common/debug.h"
-#include "common/signal.h"
-#include "common/io_priority.h"
-
-#ifdef HAVE_SCHED
-#include <sched.h>
-#endif
-
-static int _set_affinity(int id)
-{
-#ifdef HAVE_SCHED
-  if (id >= 0 && id < CPU_SETSIZE) {
-    cpu_set_t cpuset;
-    CPU_ZERO(&cpuset);
-
-    CPU_SET(id, &cpuset);
-
-    if (sched_setaffinity(0, sizeof(cpuset), &cpuset) < 0)
-      return -errno;
-    /* guaranteed to take effect immediately */
-    sched_yield();
-  }
-#endif
-  return 0;
-}
-
-Thread::Thread()
-  : thread_id(0),
-    pid(0),
-    ioprio_class(-1),
-    ioprio_priority(-1),
-    cpuid(-1),
-    thread_name(NULL)
-{
-}
-
-Thread::~Thread()
-{
-}
-
-void *Thread::_entry_func(void *arg) {
-  void *r = ((Thread*)arg)->entry_wrapper();
-  return r;
-}
-
-void *Thread::entry_wrapper()
-{
-  int p = ceph_gettid(); // may return -ENOSYS on other platforms
-  if (p > 0)
-    pid = p;
-  if (pid &&
-      ioprio_class >= 0 &&
-      ioprio_priority >= 0) {
-    ceph_ioprio_set(IOPRIO_WHO_PROCESS,
-		    pid,
-		    IOPRIO_PRIO_VALUE(ioprio_class, ioprio_priority));
-  }
-  if (pid && cpuid >= 0)
-    _set_affinity(cpuid);
-
-  ceph_pthread_setname(pthread_self(), thread_name);
-  return entry();
-}
-
-const pthread_t &Thread::get_thread_id() const
-{
-  return thread_id;
-}
-
-bool Thread::is_started() const
-{
-  return thread_id != 0;
-}
-
-bool Thread::am_self() const
-{
-  return (pthread_self() == thread_id);
-}
-
-int Thread::kill(int signal)
-{
-  if (thread_id)
-    return pthread_kill(thread_id, signal);
-  else
-    return -EINVAL;
-}
-
-int Thread::try_create(size_t stacksize)
-{
-  pthread_attr_t *thread_attr = NULL;
-  pthread_attr_t thread_attr_loc;
-  
-  stacksize &= CEPH_PAGE_MASK;  // must be multiple of page
-  if (stacksize) {
-    thread_attr = &thread_attr_loc;
-    pthread_attr_init(thread_attr);
-    pthread_attr_setstacksize(thread_attr, stacksize);
-  }
-
-  int r;
-
-  // The child thread will inherit our signal mask.  Set our signal mask to
-  // the set of signals we want to block.  (It's ok to block signals more
-  // signals than usual for a little while-- they will just be delivered to
-  // another thread or delieverd to this thread later.)
-  sigset_t old_sigset;
-  if (g_code_env == CODE_ENVIRONMENT_LIBRARY) {
-    block_signals(NULL, &old_sigset);
-  }
-  else {
-    int to_block[] = { SIGPIPE , 0 };
-    block_signals(to_block, &old_sigset);
-  }
-  r = pthread_create(&thread_id, thread_attr, _entry_func, (void*)this);
-  restore_sigset(&old_sigset);
-
-  if (thread_attr) {
-    pthread_attr_destroy(thread_attr);	
-  }
-
-  return r;
-}
-
-void Thread::create(const char *name, size_t stacksize)
-{
-  assert(strlen(name) < 16);
-  thread_name = name;
-
-  int ret = try_create(stacksize);
-  if (ret != 0) {
-    char buf[256];
-    snprintf(buf, sizeof(buf), "Thread::try_create(): pthread_create "
-	     "failed with error %d", ret);
-    dout_emergency(buf);
-    assert(ret == 0);
-  }
-}
-
-int Thread::join(void **prval)
-{
-  if (thread_id == 0) {
-    assert("join on thread that was never started" == 0);
-    return -EINVAL;
-  }
-
-  int status = pthread_join(thread_id, prval);
-  if (status != 0) {
-    char buf[256];
-    snprintf(buf, sizeof(buf), "Thread::join(): pthread_join "
-             "failed with error %d\n", status);
-    dout_emergency(buf);
-    assert(status == 0);
-  }
-
-  thread_id = 0;
-  return status;
-}
-
-int Thread::detach()
-{
-  return pthread_detach(thread_id);
-}
-
-int Thread::set_ioprio(int cls, int prio)
-{
-  // fixme, maybe: this can race with create()
-  ioprio_class = cls;
-  ioprio_priority = prio;
-  if (pid && cls >= 0 && prio >= 0)
-    return ceph_ioprio_set(IOPRIO_WHO_PROCESS,
-			   pid,
-			   IOPRIO_PRIO_VALUE(cls, prio));
-  return 0;
-}
-
-int Thread::set_affinity(int id)
-{
-  int r = 0;
-  cpuid = id;
-  if (pid && ceph_gettid() == pid)
-    r = _set_affinity(id);
-  return r;
-}