304305306307308309310311312313314
log.debug(group+"- duration=" + (end-now) + " size=" + chunks.size()); } } catch (IOException e) { if (t!= null) { t.stopAndLogTracer(); } writeChunkRetries--; log.error(group +"- Could not save the chunk. ", e);
320321322323324325326327328329330
throw new WriterException(e); } } if (t!= null) { t.stopAndLogTracer(); } return COMMIT_OK; }
377378379380381382383384385386387
SequenceFile.CompressionType.NONE, codec); } } catch (Throwable e) { if (t!= null) { t.stopAndLogTracer(); } log.fatal(group+"- Throwable Exception in rotate. Exiting!", e); // Shutting down the collector // Watchdog will re-start it automatically
405406407408409410411412413414415
DaemonWatcher.bailout(-1); } nextRotate = System.currentTimeMillis() + rotateInterval; if (t!= null) { t.stopAndLogTracer(); } } protected void internalClose() { try {
204205206207208209210211212213214
result.setMessage(""+tChunk.getSeqId()); result.setResultCode(ResultCode.TRY_LATER); } if (t!= null) { t.stopAndLogTracer(); } return result; }
169170171172173174175176177178179
closeConnection(); } sendChunk(chunk); if (t!= null) { t.stopAndLogTracer(); } chunkCount++; lineCount += chunk.getLogEventsSize(); Thread.yield();
221222223224225226227228229230231
initConnection(); } result = collector.process(chunk); if (t!= null){ t.stopAndLogTracer(); } if (result.getResultCode() == ResultCode.TRY_LATER) { Counter.increment("honu.client.tryLater");
252253254255256257258259260261262
} catch (Throwable e) { try { log.warn("exception in sendChunk", e); if (t != null) { t.stopAndLogTracer(); } Counter.increment("honu.client.exceptionCount"); exceptionCount++;