| commit | fcbf98cd434c21a4d802c4d840e3b851cc7e3879 | [log] [tgz] |
|---|---|---|
| author | Michael Stroucken <stroucki@apache.org> | Wed Jun 20 19:29:23 2012 +0000 |
| committer | Michael Stroucken <stroucki@apache.org> | Wed Jun 20 19:29:23 2012 +0000 |
| tree | 8cdf0f3ede6c82911e4657ee077f11f2efc756d0 | |
| parent | 99bfa053a3479f1045d689a49a62828671d8bf41 [diff] |
nodemanagerservice: make sure we flush our notification buffers regularly git-svn-id: https://svn.apache.org/repos/asf/incubator/tashi/trunk@1352273 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/src/tashi/nodemanager/nodemanagerservice.py b/src/tashi/nodemanager/nodemanagerservice.py index 1955ecf..3299613 100755 --- a/src/tashi/nodemanager/nodemanagerservice.py +++ b/src/tashi/nodemanager/nodemanagerservice.py
@@ -189,6 +189,11 @@ self.log.exception('Failed to register with the CM') happy = False + # make sure we flush our notification buffers + # if we have good comms with the CM + if happy: + self.__flushNotifyCM() + toSleep = start - time.time() + self.registerFrequency if (toSleep > 0): time.sleep(toSleep)