|
|
|
@@ -379,29 +379,14 @@ public class PostBack |
|
|
|
myLogger.debug(myName + ": postQueue size: " + postQueue.size()); |
|
|
|
synchronized(postQueue) |
|
|
|
{ |
|
|
|
for (;;) |
|
|
|
{ |
|
|
|
if (postQueue.size() < maxQueueSize) |
|
|
|
{ |
|
|
|
postQueue.add(report); |
|
|
|
postQueue.notify(); |
|
|
|
return true; |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
myLogger.debug("Waiting for space in postQueue to queue report"); |
|
|
|
try |
|
|
|
{ |
|
|
|
postQueue.wait(QUEUE_WAIT * 1000); |
|
|
|
} |
|
|
|
catch (InterruptedException e) |
|
|
|
{ |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|
if (postQueue.size() < maxQueueSize) |
|
|
|
{ |
|
|
|
postQueue.add(report); |
|
|
|
postQueue.notify(); |
|
|
|
return true; |
|
|
|
} |
|
|
|
} |
|
|
|
myLogger.error("Interrupted while waiting for space to queue report"); |
|
|
|
CommonLogger.alarm.warn(myName + ".queueReport failed to send report: " + report); |
|
|
|
return false; |
|
|
|
} |
|
|
|
|
|
|
|
|