Scale Stack 0.3 Developer Documentation

scalestack/threading/pthreads/thread_provider.cc

Go to the documentation of this file.

/*
 * Scale Stack
 *
 * Copyright 2010 Eric Day
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "config.h"

#include <cstring>

#include <scalestack/kernel/module.h>
#include <scalestack/kernel/option.h>
#include <scalestack/threading/pthreads/thread_provider.h>

namespace scalestack
{
namespace threading
{
namespace pthreads
{

/*
 * Public functions.
 */

extern "C" void* thread_run(void* context)
{
  thread_provider* thread_provider =
    static_cast<pthreads::thread_provider*>(context);
  thread_provider->run();
  return NULL;
}

/*
 * Public methods.
 */

thread_provider::thread_provider(kernel::module& module, thread& thread):
  threading::thread_provider(module, thread),
  _thread_id()
{
}

void thread_provider::start(void)
{
  pthread_attr_t thread_attribute;

  int return_code = pthread_attr_init(&thread_attribute);
  if (return_code != 0)
  {
    _module.log_fatal(_("Failed pthread_attr_init: %s:%d"),
                      strerror(return_code), return_code);
  }

  size_t stack_size = _module.get_option("thread_stack_size").get_size_value();
  if (stack_size != 0)
  {
    return_code = pthread_attr_setstacksize(&thread_attribute, stack_size);
    if (return_code != 0)
    {
      (void) pthread_attr_destroy(&thread_attribute);
      _module.log_fatal(_("Failed pthread_attr_setstacksize: %s:%d"),
                        strerror(return_code), return_code);
    }
  }

  return_code = pthread_attr_setscope(&thread_attribute, PTHREAD_SCOPE_SYSTEM);
  if (return_code != 0)
  {
    (void) pthread_attr_destroy(&thread_attribute);
    _module.log_fatal(_("Failed pthread_attr_setscope: %s:%d"),
                      strerror(return_code), return_code);
  }

  return_code = pthread_create(&_thread_id, &thread_attribute, thread_run,
                               this);
  if (return_code != 0)
  {
    (void) pthread_attr_destroy(&thread_attribute);
    _module.log_fatal(_("Failed pthread_create: %s:%d"),
                      strerror(return_code), return_code);
  }

  return_code = pthread_attr_destroy(&thread_attribute);
  if (return_code != 0)
  {
    _module.log_error(_("Failed pthread_attr_destroy: %s:%d"),
                      strerror(return_code), return_code);
  }

  _module.log_info("[Thread %u] Started", get_id());
}

void thread_provider::stop(void)
{
  int return_code = pthread_join(_thread_id, NULL);
  if (return_code != 0)
  {
    _module.log_error(_("Failed pthread_join: %s:%d"),
                      strerror(return_code), return_code);
  }

  _module.log_info("[Thread %u] Stopped", get_id());
}

size_t thread_provider::get_id()
{
  return static_cast<size_t>(_thread_id);
}

} /* namespace pthreads */
} /* namespace threading */
} /* namespace scalestack */

---