mirror of
https://github.com/ElvishArtisan/rivendell.git
synced 2026-01-11 23:25:57 +01:00
2019-01-08 Fred Gleason <fredg@paravelsystems.com>
* Renamed the 'pypad.Receiver::setCallback()' method to 'pypad.Receiver::setPadCallback()'.
This commit is contained in:
@@ -735,13 +735,13 @@ class Update(object):
|
||||
|
||||
class Receiver(object):
|
||||
def __init__(self):
|
||||
self.__callback=None
|
||||
self.__pad_callback=None
|
||||
self.__timer_callback=None
|
||||
self.__timer_interval=None
|
||||
self.__config_parser=None
|
||||
|
||||
def __pypad_Process(self,pad):
|
||||
self.__callback(pad)
|
||||
self.__pad_callback(pad)
|
||||
|
||||
def __pypad_TimerProcess(self,config):
|
||||
self.__timer_callback(config)
|
||||
@@ -756,11 +756,11 @@ class Receiver(object):
|
||||
creds=self.__getDbCredentials()
|
||||
return MySQLdb.connect(creds[2],creds[0],creds[1],creds[3])
|
||||
|
||||
def setCallback(self,callback):
|
||||
def setPadCallback(self,callback):
|
||||
"""
|
||||
Set the processing callback.
|
||||
"""
|
||||
self.__callback=callback
|
||||
self.__pad_callback=callback
|
||||
|
||||
def setTimerCallback(self,interval,callback):
|
||||
"""
|
||||
|
||||
@@ -83,6 +83,6 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_ando.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.setTimerCallback(30,ProcessTimer)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -54,5 +54,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_filewrite.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -92,7 +92,7 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_icecast2: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
iprint('Started')
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
iprint('Stopped')
|
||||
|
||||
@@ -95,5 +95,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_inno713.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -68,5 +68,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_liqcomp.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -72,5 +72,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_live365.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -65,5 +65,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_serial.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -79,5 +79,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_shoutcast1.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -124,5 +124,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_spinitron.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -67,5 +67,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_spottrap.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -98,7 +98,7 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_tunein.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
iprint('Started')
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
iprint('Stopped')
|
||||
|
||||
@@ -54,5 +54,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_udp.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -65,5 +65,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_urlwrite.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -65,5 +65,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_walltime.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -100,5 +100,5 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_xds.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -179,6 +179,6 @@ try:
|
||||
except IndexError:
|
||||
eprint('pypad_xmpad.py: USAGE: cmd <hostname> <port> <config>')
|
||||
sys.exit(1)
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
rcvr.setTimerCallback(30,ProcessTimer)
|
||||
rcvr.start(sys.argv[1],int(sys.argv[2]))
|
||||
|
||||
@@ -68,7 +68,7 @@ rcvr=pypad.Receiver()
|
||||
#
|
||||
# Tell it to use the callback
|
||||
#
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
|
||||
#
|
||||
# Start the receiver, giving it the hostname or IP address and TCP port of
|
||||
|
||||
@@ -52,14 +52,14 @@ def ProcessPad(update):
|
||||
print("%03d:xxxx NEXT: [none]" % update.machine())
|
||||
|
||||
#
|
||||
# Create an instance of 'pypadReceiver'
|
||||
# Create an instance of 'pypad.Receiver'
|
||||
#
|
||||
rcvr=pypad.Receiver()
|
||||
|
||||
#
|
||||
# Tell it to use the callback
|
||||
#
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
|
||||
#
|
||||
# Start the receiver, giving it the hostname or IP address and TCP port of
|
||||
|
||||
@@ -141,7 +141,7 @@ rcvr=pypad.Receiver()
|
||||
#
|
||||
# Tell it to use the callback
|
||||
#
|
||||
rcvr.setCallback(ProcessPad)
|
||||
rcvr.setPadCallback(ProcessPad)
|
||||
|
||||
#
|
||||
# Start the receiver, giving it the hostname or IP address and TCP port of
|
||||
|
||||
Reference in New Issue
Block a user