@@ -1130,14 +1130,20 @@ def updateRecordingStatus(self, *args):
1130
1130
if subsystemOut == '' :
1131
1131
break
1132
1132
# logger.error('DE subsystemOut = "{0}"'.format(subsystemOut))
1133
+ if stop ():
1134
+ break
1133
1135
with recording_lock :
1134
1136
tmp = self ._is_accepted_input (subsystemOut )
1135
1137
if not tmp :
1138
+ if stop ():
1139
+ break
1136
1140
continue
1137
1141
subsystemOut = subsystemOut .strip ()
1138
1142
subsystemOut = subsystemOut .replace ('\r ' , '' ).replace ('\n ' , '' )
1139
1143
# logger.error('DE subsystemOut = "{0}"'.format(subsystemOut))
1140
1144
1145
+ if stop ():
1146
+ break
1141
1147
with recording_lock :
1142
1148
tmp = self .oldUserInput ['Input' ]
1143
1149
if tmp != subsystemOut :
@@ -1148,14 +1154,20 @@ def updateRecordingStatus(self, *args):
1148
1154
else :
1149
1155
logger .debug ('Monitor User input: {}' .format (subsystemOut ))
1150
1156
1157
+ if stop ():
1158
+ break
1151
1159
with recording_lock :
1152
1160
self .oldUserInput ['Input' ] = subsystemOut
1153
1161
self_volume_string = self .volume_string
1154
1162
self_player_name = self .PLAYER_NAME
1163
+ if stop ():
1164
+ break
1155
1165
if self_volume_string in subsystemOut :
1156
1166
# disable volume for mpv
1157
1167
if self_player_name != 'mpv' :
1158
1168
# logger.error('***** volume')
1169
+ if stop ():
1170
+ break
1159
1171
with recording_lock :
1160
1172
if self .oldUserInput ['Volume' ] != subsystemOut :
1161
1173
self .oldUserInput ['Volume' ] = subsystemOut
@@ -1178,6 +1190,8 @@ def updateRecordingStatus(self, *args):
1178
1190
if self .show_volume and self .oldUserInput ['Title' ]:
1179
1191
self .outputStream .write (msg = string_to_show , counter = '' )
1180
1192
self .threadUpdateTitle ()
1193
+ if stop ():
1194
+ break
1181
1195
except :
1182
1196
if logger .isEnabledFor (logging .ERROR ):
1183
1197
logger .error ('Error in updateRecordingStatus thread.' , exc_info = True )
0 commit comments