Я не имею полные права так, может быть, кто-то будет достаточно хорош, чтобы переместить его на феникса нить.
Код:
дифф -Naur феникс 1.6.1 / Miner.py феникс-тест / Miner.py
--- Феникс-1.6.1 / Miner.py 2011-08-15 13: 27: +10,000000000 -0500
+++ Феникс-тест / Miner.py 2011-08-18 10: 34: +50,000000000 -0500
@@ -42,6 +42,7 @@
self.idle = True
self.cores = []
self.backup = False
+ self.backupLife = 0
self.failures = 0
self.lastMetaRate = 0.0
self.lastRateUpdate = время ()
@@ -65,6 +66,25 @@
Защиту onWork (самость, работа):
self.logger.reportDebug ( «Сервер дал новую работу, переходя к WorkQueue»)
self.queue.storeWork (работа)
+ если self.backup:
+ #When жизнь резервного копирования достигает 0, переключиться обратно на основной бассейн
+ если (self.backupLife <= 0):
+ #disconnect и установить соединение ни
+ self.connection.disconnect ()
+ не self.connection = None
+
+ #журнал
+ self.logger.log ("Резервное копирование Lifespan закончена,")
+ self.logger.log ("пытаясь вернуться к основному серверу.")
+
+ Отказ #reset рассчитывать и вернуться к основному серверу
+ self.failures = 0
+ self.backup = False
+ self.connection = self.options.makeConnection (само)
+ self.connection.connect ()
+ еще:
+ self.backupLife - = 1
+
Защиту onLongpoll (я, LP):
self.logger.reportType ( 'RPC' + ( '(+ LP)', если LP еще ''))
Защиту OnPush (я, игнорируется):
@@ -73,9 +93,10 @@
self.logger.log (сообщение)
Защиту onDebug (я, сообщение):
self.logger.reportDebug (сообщение)
-
+
Защиту failoverCheck (самостоятельно):
если self.backup:
+ #The резервный пул должен обязательно 3 раза, прежде чем перейти на резервный пул
если (self.failures >= 1):
#disconnect и установить соединение ни
self.connection.disconnect ()
@@ -106,6 +127,10 @@
#reset количество отказов и подключение к серверу резервного копирования
self.failures = 0
self.backup = True
+ self.backupLife = 20
+ если self.options.backupLife не является None:
+ self.backupLife = self.options.backupLife
+
self.connection = self.options.makeConnection (я, правда)
self.connection.connect ()
еще:
дифф -Naur феникс 1.6.1 / phoenix.py феникс-тест / phoenix.py
--- Феникс-1.6.1 / phoenix.py 2011-08-15 13: 27: +10,000000000 -0500
+++ Феникс-тест / phoenix.py 2011-08-18 10: 31: +29,000000000 -0500
@@ -40,6 +40,7 @@
не self.parsedSettings = None
не self.url = None
не self.url2 = None
+ не self.backupLife = None
не self.logger = None
не self.kernel = None
не self.queue = None
@@ -57,6 +58,9 @@
parser.add_option ("-b", "--backupurl", Приемник ="URL2", По умолчанию = None,
помощь ="URL-адрес резервного горнорудного сервера для работы, если "
"первична вниз [НЕОБЯЗАТЕЛЬНО]")
+ parser.add_option ("-f", "--отступать", Приемник ="backupLife", По умолчанию = None,
+ помощь ="количество getworks, когда на сервере резервного копирования горнорудного "
+ "перед повторной попыткой основного сервера [опционально]")
parser.add_option ("-q", "--queuesize", Приемник ="QUEUESIZE", Тип ="ИНТ",
по умолчанию = 1, помощь ="сколько рабочих единиц держать в очереди в любое время")
parser.add_option ("-a", "--avgsamples", Приемник ="avgsamples", Тип ="ИНТ",
--- Феникс-1.6.1 / Miner.py 2011-08-15 13: 27: +10,000000000 -0500
+++ Феникс-тест / Miner.py 2011-08-18 10: 34: +50,000000000 -0500
@@ -42,6 +42,7 @@
self.idle = True
self.cores = []
self.backup = False
+ self.backupLife = 0
self.failures = 0
self.lastMetaRate = 0.0
self.lastRateUpdate = время ()
@@ -65,6 +66,25 @@
Защиту onWork (самость, работа):
self.logger.reportDebug ( «Сервер дал новую работу, переходя к WorkQueue»)
self.queue.storeWork (работа)
+ если self.backup:
+ #When жизнь резервного копирования достигает 0, переключиться обратно на основной бассейн
+ если (self.backupLife <= 0):
+ #disconnect и установить соединение ни
+ self.connection.disconnect ()
+ не self.connection = None
+
+ #журнал
+ self.logger.log ("Резервное копирование Lifespan закончена,")
+ self.logger.log ("пытаясь вернуться к основному серверу.")
+
+ Отказ #reset рассчитывать и вернуться к основному серверу
+ self.failures = 0
+ self.backup = False
+ self.connection = self.options.makeConnection (само)
+ self.connection.connect ()
+ еще:
+ self.backupLife - = 1
+
Защиту onLongpoll (я, LP):
self.logger.reportType ( 'RPC' + ( '(+ LP)', если LP еще ''))
Защиту OnPush (я, игнорируется):
@@ -73,9 +93,10 @@
self.logger.log (сообщение)
Защиту onDebug (я, сообщение):
self.logger.reportDebug (сообщение)
-
+
Защиту failoverCheck (самостоятельно):
если self.backup:
+ #The резервный пул должен обязательно 3 раза, прежде чем перейти на резервный пул
если (self.failures >= 1):
#disconnect и установить соединение ни
self.connection.disconnect ()
@@ -106,6 +127,10 @@
#reset количество отказов и подключение к серверу резервного копирования
self.failures = 0
self.backup = True
+ self.backupLife = 20
+ если self.options.backupLife не является None:
+ self.backupLife = self.options.backupLife
+
self.connection = self.options.makeConnection (я, правда)
self.connection.connect ()
еще:
дифф -Naur феникс 1.6.1 / phoenix.py феникс-тест / phoenix.py
--- Феникс-1.6.1 / phoenix.py 2011-08-15 13: 27: +10,000000000 -0500
+++ Феникс-тест / phoenix.py 2011-08-18 10: 31: +29,000000000 -0500
@@ -40,6 +40,7 @@
не self.parsedSettings = None
не self.url = None
не self.url2 = None
+ не self.backupLife = None
не self.logger = None
не self.kernel = None
не self.queue = None
@@ -57,6 +58,9 @@
parser.add_option ("-b", "--backupurl", Приемник ="URL2", По умолчанию = None,
помощь ="URL-адрес резервного горнорудного сервера для работы, если "
"первична вниз [НЕОБЯЗАТЕЛЬНО]")
+ parser.add_option ("-f", "--отступать", Приемник ="backupLife", По умолчанию = None,
+ помощь ="количество getworks, когда на сервере резервного копирования горнорудного "
+ "перед повторной попыткой основного сервера [опционально]")
parser.add_option ("-q", "--queuesize", Приемник ="QUEUESIZE", Тип ="ИНТ",
по умолчанию = 1, помощь ="сколько рабочих единиц держать в очереди в любое время")
parser.add_option ("-a", "--avgsamples", Приемник ="avgsamples", Тип ="ИНТ",