Extra debug

main2
Bob Mottram 2019-10-16 15:46:29 +01:00
parent 45c7896627
commit 3b0d441e5b
1 changed files with 4 additions and 0 deletions

View File

@ -1134,8 +1134,10 @@ def sendPost(projectVersion: str, \
# Keep the number of threads being used small # Keep the number of threads being used small
while len(sendThreads)>20: while len(sendThreads)>20:
print('WARN: Maximum threads reached - killing send thread')
sendThreads[0].kill() sendThreads[0].kill()
sendThreads.pop(0) sendThreads.pop(0)
print('WARN: thread killed')
thr = threadWithTrace(target=threadSendPost,args=(session, \ thr = threadWithTrace(target=threadSendPost,args=(session, \
postJsonStr, \ postJsonStr, \
federationList, \ federationList, \
@ -1409,6 +1411,8 @@ def sendSignedJson(postJsonObject: {},session,baseDir: str, \
toDomain,toPort, \ toDomain,toPort, \
postPath,httpPrefix,withDigest,postJsonStr) postPath,httpPrefix,withDigest,postJsonStr)
removeDormantThreads(sendThreads,debug)
# Keep the number of threads being used small # Keep the number of threads being used small
while len(sendThreads)>20: while len(sendThreads)>20:
print('WARN: Maximum threads reached - killing send thread') print('WARN: Maximum threads reached - killing send thread')