From 88c0425a4fbf5ce7d297ff8ccd75c2e0f8866116 Mon Sep 17 00:00:00 2001
From: Bert Hubert <bert.hubert@netherlabs.nl>
Date: Sat, 17 Nov 2007 21:30:56 +0000
Subject: [PATCH] 64-bit fix for the slave cycle interval, which might lead to
 locked up systems!

git-svn-id: svn://svn.powerdns.com/pdns/trunk/pdns@1105 d19b8d6e-7fed-0310-83ef-9ca221ded41b
---
 pdns/communicator.cc | 8 +++++---
 pdns/communicator.hh | 4 ++--
 2 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/pdns/communicator.cc b/pdns/communicator.cc
index 0a1e7dda8..1a9f00d90 100644
--- a/pdns/communicator.cc
+++ b/pdns/communicator.cc
@@ -55,6 +55,7 @@ void CommunicatorClass::addSuckRequest(const string &domain, const string &maste
 
 void CommunicatorClass::suck(const string &domain,const string &remote)
 {
+  L<<Logger::Error<<"Initiating transfer of '"<<domain<<"' from remote '"<<remote<<"'"<<endl;
   uint32_t domain_id;
   PacketHandler P;
 
@@ -288,7 +289,7 @@ void CommunicatorClass::slaveRefresh(PacketHandler *P)
   }
 }  
 
-int CommunicatorClass::doNotifications()
+time_t CommunicatorClass::doNotifications()
 {
   ComboAddress from;
   Utility::socklen_t fromlen=sizeof(from);
@@ -423,7 +424,7 @@ void CommunicatorClass::mainloop(void)
     int rc;
     time_t next;
 
-    int tick;
+    time_t tick;
 
     for(;;) {
       slaveRefresh(&P);
@@ -432,9 +433,10 @@ void CommunicatorClass::mainloop(void)
       tick=min(doNotifications(),
 	       d_tickinterval);
 
+      L<<Logger::Error<<"tick = "<<tick<<", d_tickinterval = "<<d_tickinterval<<endl;
       next=time(0)+tick;
 
-      while(time(0)<next) {
+      while(time(0) < next) {
 	rc=d_any_sem.tryWait();
 
 	if(rc)
diff --git a/pdns/communicator.hh b/pdns/communicator.hh
index 9c5de66dd..934193e7e 100644
--- a/pdns/communicator.hh
+++ b/pdns/communicator.hh
@@ -131,7 +131,7 @@ public:
     d_tickinterval=60;
     d_masterschanged=d_slaveschanged=true;
   }
-  int doNotifications();    
+  time_t doNotifications();    
   void go()
   {
     pthread_t tid;
@@ -163,7 +163,7 @@ private:
   bool d_havepriosuckrequest;
   Semaphore d_suck_sem;
   Semaphore d_any_sem;
-  int d_tickinterval;
+  time_t d_tickinterval;
   NotificationQueue d_nq;
   bool d_masterschanged, d_slaveschanged;
 };
-- 
2.40.0