Changeset 1105
- Timestamp:
- 11/17/07 22:30:56 (3 years ago)
- Location:
- trunk/pdns/pdns
- Files:
-
- 2 modified
-
communicator.cc (modified) (4 diffs)
-
communicator.hh (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/pdns/pdns/communicator.cc
r1085 r1105 56 56 void CommunicatorClass::suck(const string &domain,const string &remote) 57 57 { 58 L<<Logger::Error<<"Initiating transfer of '"<<domain<<"' from remote '"<<remote<<"'"<<endl; 58 59 uint32_t domain_id; 59 60 PacketHandler P; … … 289 290 } 290 291 291 int CommunicatorClass::doNotifications()292 time_t CommunicatorClass::doNotifications() 292 293 { 293 294 ComboAddress from; … … 424 425 time_t next; 425 426 426 int tick;427 time_t tick; 427 428 428 429 for(;;) { … … 433 434 d_tickinterval); 434 435 436 L<<Logger::Error<<"tick = "<<tick<<", d_tickinterval = "<<d_tickinterval<<endl; 435 437 next=time(0)+tick; 436 438 437 while(time(0) <next) {439 while(time(0) < next) { 438 440 rc=d_any_sem.tryWait(); 439 441 -
trunk/pdns/pdns/communicator.hh
r1052 r1105 132 132 d_masterschanged=d_slaveschanged=true; 133 133 } 134 int doNotifications();134 time_t doNotifications(); 135 135 void go() 136 136 { … … 164 164 Semaphore d_suck_sem; 165 165 Semaphore d_any_sem; 166 int d_tickinterval;166 time_t d_tickinterval; 167 167 NotificationQueue d_nq; 168 168 bool d_masterschanged, d_slaveschanged;