christoph/fail
1
Fork 0
Code Actions Packages Releases Activity

bounded job queue (configurable, unbounded by default)

Browse Source 
git-svn-id: https://www4.informatik.uni-erlangen.de/i4svn/danceos/trunk/devel/fail@1945 8c4709b5-6ec9-48aa-a5cd-a96041d1645a
This commit is contained in:
hsc
2012-11-20 15:01:58 +00:00
parent a26a155f0c
commit 127161ef5a
3 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/core/config/CMakeLists.txt
View File

@ -23,6 +23,7 @@ OPTION(CONFIG_FAST_BREAKPOINTS "Enable fast breakpoints (requires break
OPTION(CONFIG_FAST_WATCHPOINTS "Enable fast watchpoints (requires memory access events to be enabled)" OFF) OPTION(CONFIG_FAST_WATCHPOINTS "Enable fast watchpoints (requires memory access events to be enabled)" OFF)
SET(SERVER_COMM_HOSTNAME "localhost" CACHE STRING "Job-server hostname or IP") SET(SERVER_COMM_HOSTNAME "localhost" CACHE STRING "Job-server hostname or IP")
SET(SERVER_COMM_TCP_PORT "1111" CACHE STRING "Job-server TCP port") SET(SERVER_COMM_TCP_PORT "1111" CACHE STRING "Job-server TCP port")
SET(SERVER_OUT_QUEUE_SIZE "0" CACHE STRING "Queue size for outbound jobs (0 = unlimited)")
SET(SERVER_PERF_LOG_PATH "perf.log" CACHE STRING "A file name for storing the server's performance log (CSV)") SET(SERVER_PERF_LOG_PATH "perf.log" CACHE STRING "A file name for storing the server's performance log (CSV)")
SET(SERVER_PERF_STEPPING_SEC "1" CACHE STRING "Stepping of performance measurements in seconds") SET(SERVER_PERF_STEPPING_SEC "1" CACHE STRING "Stepping of performance measurements in seconds")
SET(CLIENT_RAND_BACKOFF_TSTART "3" CACHE STRING "Lower limit of client's backoff phase in seconds") SET(CLIENT_RAND_BACKOFF_TSTART "3" CACHE STRING "Lower limit of client's backoff phase in seconds")

1
src/core/config/FailConfig.hpp.in
View File

@ -33,6 +33,7 @@
#cmakedefine SERVER_PERFORMANCE_MEASURE #cmakedefine SERVER_PERFORMANCE_MEASURE
#define SERVER_COMM_HOSTNAME "@SERVER_COMM_HOSTNAME@" #define SERVER_COMM_HOSTNAME "@SERVER_COMM_HOSTNAME@"
#define SERVER_COMM_TCP_PORT @SERVER_COMM_TCP_PORT@ #define SERVER_COMM_TCP_PORT @SERVER_COMM_TCP_PORT@
#define SERVER_OUT_QUEUE_SIZE @SERVER_OUT_QUEUE_SIZE@
#define SERVER_PERF_LOG_PATH "@SERVER_PERF_LOG_PATH@" #define SERVER_PERF_LOG_PATH "@SERVER_PERF_LOG_PATH@"
#define SERVER_PERF_STEPPING_SEC @SERVER_PERF_STEPPING_SEC@ #define SERVER_PERF_STEPPING_SEC @SERVER_PERF_STEPPING_SEC@
#define CLIENT_RAND_BACKOFF_TSTART @CLIENT_RAND_BACKOFF_TSTART@ #define CLIENT_RAND_BACKOFF_TSTART @CLIENT_RAND_BACKOFF_TSTART@

2
src/core/cpn/JobServer.hpp
View File

@ -78,7 +78,7 @@ private:
public: public:
JobServer(int port = SERVER_COMM_TCP_PORT) : m_port(port), m_finish(false), m_noMoreExps(false), JobServer(int port = SERVER_COMM_TCP_PORT) : m_port(port), m_finish(false), m_noMoreExps(false),
m_maxThreads(128), m_threadtimeout(0) m_maxThreads(128), m_threadtimeout(0), m_undoneJobs(SERVER_OUT_QUEUE_SIZE)
{ {
m_runid = std::time(0); m_runid = std::time(0);
#ifndef __puma #ifndef __puma