CC-2607: handling comment
- each line read is trimed now - xtra bug fixed: - bug on merging with 1.9.3 - state_change_restart array is filled with info for displaying purpose
This commit is contained in:
parent
56ad8c6b3d
commit
d992457bd5
|
@ -12,7 +12,7 @@ INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_host', '1
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_port', '8000', 'integer');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_port', '8000', 'integer');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_user', '', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_user', '', 'string');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_pass', 'hackme', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_pass', 'hackme', 'string');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_mount', 'airtime_128.ogg', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_mount', 'airtime_128', 'string');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_url', 'http://airtime.sourcefabric.org', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_url', 'http://airtime.sourcefabric.org', 'string');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_description', 'Airtime Radio! Stream #1', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_description', 'Airtime Radio! Stream #1', 'string');
|
||||||
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_genre', 'genre', 'string');
|
INSERT INTO cc_stream_setting ("keyname", "value", "type") VALUES ('s1_genre', 'genre', 'string');
|
||||||
|
|
|
@ -116,6 +116,7 @@ class PypoFetch(Thread):
|
||||||
# read existing conf file and build dict
|
# read existing conf file and build dict
|
||||||
while 1:
|
while 1:
|
||||||
line = fh.readline()
|
line = fh.readline()
|
||||||
|
line = line.strip()
|
||||||
if not line:
|
if not line:
|
||||||
break
|
break
|
||||||
if line.find('#') == 0:
|
if line.find('#') == 0:
|
||||||
|
@ -152,8 +153,11 @@ class PypoFetch(Thread):
|
||||||
if (existing[s[u'keyname']] != s[u'value']):
|
if (existing[s[u'keyname']] != s[u'value']):
|
||||||
logger.info("'Need-to-restart' state detected for %s...", s[u'keyname'])
|
logger.info("'Need-to-restart' state detected for %s...", s[u'keyname'])
|
||||||
restart = True;
|
restart = True;
|
||||||
|
state_change_restart[stream] = True
|
||||||
elif ( s[u'value'] != 'disabled'):
|
elif ( s[u'value'] != 'disabled'):
|
||||||
state_change_restart[stream] = True
|
state_change_restart[stream] = True
|
||||||
|
else:
|
||||||
|
state_change_restart[stream] = False
|
||||||
else:
|
else:
|
||||||
# setting inital value
|
# setting inital value
|
||||||
if stream not in change:
|
if stream not in change:
|
||||||
|
@ -477,8 +481,8 @@ class PypoFetch(Thread):
|
||||||
# most recent schedule. After that we can just wait for updates.
|
# most recent schedule. After that we can just wait for updates.
|
||||||
status, self.schedule_data = self.api_client.get_schedule()
|
status, self.schedule_data = self.api_client.get_schedule()
|
||||||
if status == 1:
|
if status == 1:
|
||||||
logger.info("Bootstrap schedule received: %s", schedule_data)
|
logger.info("Bootstrap schedule received: %s", self.schedule_data)
|
||||||
self.process_schedule(schedule_data, "scheduler", True)
|
self.process_schedule(self.schedule_data, "scheduler", True)
|
||||||
logger.info("Bootstrap complete: got initial copy of the schedule")
|
logger.info("Bootstrap complete: got initial copy of the schedule")
|
||||||
|
|
||||||
loops = 1
|
loops = 1
|
||||||
|
|
Loading…
Reference in New Issue