/ - Diff - OpenNebula - OpenNebula Development pages

include/ReplicaThread.h
32	32	{
33	33	public:
34	34	ReplicaThread(int _follower_id):follower_id(_follower_id), _finalize(false),
35		_pending_requests(false), retry_timeout(2)
	35	_pending_requests(false), retry_timeout(1e8)
36	36	{
37	37	pthread_mutex_init(&mutex, 0);
38	38

             return -1;
+        }
         if ( zservers.size() == 0 )
+        {
             error = "No servers defined in the zone";
             return -1;
+        }
         // -------------------------------------------------------------------------
         // Get parameters to call append entries on follower
         // -------------------------------------------------------------------------

src/raft/ReplicaThread.cc
29	29	// -----------------------------------------------------------------------------
30	30	// -----------------------------------------------------------------------------
31	31
32		const time_t ReplicaThread::max_retry_timeout = 300;
	32	const time_t ReplicaThread::max_retry_timeout = 2.5e9;
33	33
34	34	// -----------------------------------------------------------------------------
35	35	// -----------------------------------------------------------------------------
...	...
79	79	{
80	80	struct timespec timeout;
81	81
82		timeout.tv_sec = time(NULL) + retry_timeout;
83		timeout.tv_nsec = 0;
	82	timeout.tv_sec = time(NULL);
	83	timeout.tv_nsec = retry_timeout;
84	84
85	85	if ( pthread_cond_timedwait(&cond, &mutex, &timeout) == ETIMEDOUT )
86	86	{
...	...
110	110	}
111	111	else
112	112	{
113		retry_timeout = 2;
	113	retry_timeout = 1e8;
114	114	retry_request = false;
115	115	}
116	116	}

OpenNebula