3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-01-21 23:19:31 +08:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1107 from jlauenercern/master

Browse Source 
Allow change of pthread priority
This commit is contained in:
Pieter Hintjens 2014-06-25 11:29:07 +02:00
commit 859b43f1eb
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/thread.cpp
View File

@ -62,6 +62,7 @@ void zmq::thread_t::stop ()
#else #else
#include <signal.h> #include <signal.h>
#include <sstream>
extern "C" extern "C"
{ {
@ -83,12 +84,36 @@ extern "C"
} }
} }
bool getenvi(const char *env_, int &result_)
{
char *str = getenv(env_);
if(str == NULL)
{
return false;
}
std::stringstream ss(str);
return ss >> result_;
}
void zmq::thread_t::start (thread_fn *tfn_, void *arg_) void zmq::thread_t::start (thread_fn *tfn_, void *arg_)
{ {
tfn = tfn_; tfn = tfn_;
arg = arg_; arg = arg_;
int rc = pthread_create (&descriptor, NULL, thread_routine, this); int rc = pthread_create (&descriptor, NULL, thread_routine, this);
posix_assert (rc); posix_assert (rc);
int prio;
if(getenvi("ZMQ_THREAD_PRIO", prio))
{
int policy = SCHED_RR;
getenvi("ZMQ_THREAD_POLICY", policy);
struct sched_param param;
param.sched_priority = prio;
rc = pthread_setschedparam(descriptor, policy, &param);
posix_assert (rc);
}
} }
void zmq::thread_t::stop () void zmq::thread_t::stop ()