main
Bob Mottram 2020-04-16 11:28:56 +01:00
parent 32bce7bfa1
commit 73a2b37696
1 changed files with 5 additions and 12 deletions

View File

@ -866,6 +866,9 @@ class PubServer(BaseHTTPRequestHandler):
self.end_headers() self.end_headers()
self.server.POSTbusy = False self.server.POSTbusy = False
return 0 return 0
self.send_response(503)
self.end_headers()
self.server.POSTbusy = False
return 1 return 1
def _isAuthorized(self) -> bool: def _isAuthorized(self) -> bool:
@ -6967,12 +6970,7 @@ class PubServer(BaseHTTPRequestHandler):
queueStatus = \ queueStatus = \
self._updateInboxQueue(self.postToNickname, self._updateInboxQueue(self.postToNickname,
messageJson, messageBytes) messageJson, messageBytes)
if queueStatus == 0: if queueStatus == 0 or queueStatus == 1:
return
elif queueStatus == 1:
self.send_response(503)
self.end_headers()
self.server.POSTbusy = False
return return
if self.server.debug: if self.server.debug:
print('_updateInboxQueue exited ' + print('_updateInboxQueue exited ' +
@ -6989,12 +6987,7 @@ class PubServer(BaseHTTPRequestHandler):
print('DEBUG: POST to shared inbox') print('DEBUG: POST to shared inbox')
queueStatus = \ queueStatus = \
self._updateInboxQueue('inbox', messageJson, messageBytes) self._updateInboxQueue('inbox', messageJson, messageBytes)
if queueStatus == 0: if queueStatus == 0 or queueStatus == 1:
return
elif queueStatus == 1:
self.send_response(503)
self.end_headers()
self.server.POSTbusy = False
return return
self.send_response(200) self.send_response(200)
self.end_headers() self.end_headers()