ShaYmez
/
RYSEN
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add 'DNS_TIME' for 'XLXPEER' instances 

Also change client.getHostByName  I tried a couple of times to resolve a hostname with  it but I couldn't, reactor.resolve works.
This commit is contained in:
Christian OA4DOA 2021-09-12 00:58:45 -05:00 committed by GitHub
parent 96e3739590
commit fb1c6ef8c3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hblink.py
View File

@ -40,7 +40,6 @@ from collections import deque
from twisted.internet.protocol import DatagramProtocol, Factory, Protocol from twisted.internet.protocol import DatagramProtocol, Factory, Protocol
from twisted.protocols.basic import NetstringReceiver from twisted.protocols.basic import NetstringReceiver
from twisted.internet import reactor, task from twisted.internet import reactor, task
from twisted.names import client
# Other files we pull from -- this is mostly for readability and segmentation # Other files we pull from -- this is mostly for readability and segmentation
import log import log
@ -314,6 +313,7 @@ class HBSYSTEM(DatagramProtocol):
elif self._config['MODE'] == 'XLXPEER': elif self._config['MODE'] == 'XLXPEER':
self._stats = self._config['XLXSTATS'] self._stats = self._config['XLXSTATS']
self._stats['DNS_TIME'] = time()
self.send_system = self.send_master self.send_system = self.send_master
self.maintenance_loop = self.peer_maintenance_loop self.maintenance_loop = self.peer_maintenance_loop
self.datagramReceived = self.peer_datagramReceived self.datagramReceived = self.peer_datagramReceived
@ -364,7 +364,7 @@ class HBSYSTEM(DatagramProtocol):
self._stats['CONNECTION'] = 'RPTL_SENT' self._stats['CONNECTION'] = 'RPTL_SENT'
if self._stats['DNS_TIME'] < (time() - 600): if self._stats['DNS_TIME'] < (time() - 600):
self._stats['DNS_TIME'] = time() self._stats['DNS_TIME'] = time()
_d = client.getHostByName(self._config['_MASTER_IP']) _d = reactor.resolve(self._config['_MASTER_IP'])
_d.addCallback(self.updateSockaddr) _d.addCallback(self.updateSockaddr)
_d.addErrback(self.updateSockaddr_errback) _d.addErrback(self.updateSockaddr_errback)
self.send_master(b''.join([RPTL, self._config['RADIO_ID']])) self.send_master(b''.join([RPTL, self._config['RADIO_ID']]))