Revision 0888ae48 src/raft/ReplicaThread.cc
src/raft/ReplicaThread.cc | ||
---|---|---|
38 | 38 |
{ |
39 | 39 |
ReplicaThread * rt; |
40 | 40 |
|
41 |
int oldstate; |
|
42 |
|
|
41 | 43 |
if ( arg == 0 ) |
42 | 44 |
{ |
43 | 45 |
return 0; |
... | ... | |
47 | 49 |
|
48 | 50 |
rt->_thread_id = pthread_self(); |
49 | 51 |
|
52 |
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &oldstate); |
|
53 |
|
|
54 |
pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, &oldstate); |
|
55 |
|
|
50 | 56 |
rt->do_replication(); |
51 | 57 |
|
52 | 58 |
return 0; |
Also available in: Unified diff