1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
// -*- 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 "common/Thread.h"
#include "common/code_environment.h"
#include "common/debug.h"
#include "common/signal.h"
#include <dirent.h>
#include <errno.h>
#include <iostream>
#include <pthread.h>
#include <signal.h>
#include <sstream>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
Thread::Thread()
: thread_id(0)
{
}
Thread::~Thread()
{
}
void *Thread::_entry_func(void *arg) {
void *r = ((Thread*)arg)->entry();
return r;
}
const pthread_t &Thread::get_thread_id()
{
return thread_id;
}
bool Thread::is_started()
{
return thread_id != 0;
}
bool Thread::am_self()
{
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;
stacksize &= CEPH_PAGE_MASK; // must be multiple of page
if (stacksize) {
thread_attr = (pthread_attr_t*) malloc(sizeof(pthread_attr_t));
if (!thread_attr)
return -ENOMEM;
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)
free(thread_attr);
return r;
}
void Thread::create(size_t stacksize)
{
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);
assert(status == 0);
thread_id = 0;
return status;
}
int Thread::detach()
{
return pthread_detach(thread_id);
}
|
