diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-09-01 11:46:02 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2021-09-01 11:46:02 +0200 |
commit | 6b7b870da2a89c37ccc3c2e3d516f6eae9c4648e (patch) | |
tree | 8522328f31ee7d20e53922c705dc0a28bb42609c /node-admin | |
parent | 9c4d1627d06584f5868d563429075da8da51ceb1 (diff) |
Include exception name in error message + split handleFailure
Diffstat (limited to 'node-admin')
-rw-r--r-- | node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/servicedump/VespaServiceDumperImpl.java | 27 |
1 files changed, 14 insertions, 13 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/servicedump/VespaServiceDumperImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/servicedump/VespaServiceDumperImpl.java index 972834293b2..5663dea02d0 100644 --- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/servicedump/VespaServiceDumperImpl.java +++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/servicedump/VespaServiceDumperImpl.java @@ -63,17 +63,17 @@ public class VespaServiceDumperImpl implements VespaServiceDumper { return; } if (isNullTimestamp(request.getCreatedMillisOrNull())) { - handleFailure(context, request, startedAt, null, "'createdMillis' is missing or null"); + handleFailure(context, request, startedAt, "'createdMillis' is missing or null"); return; } String configId = request.configId(); if (configId == null) { - handleFailure(context, request, startedAt, null, "Service config id is missing from request"); + handleFailure(context, request, startedAt, "Service config id is missing from request"); return; } Instant expiry = expireAt(startedAt, request); if (expiry.isBefore(startedAt)) { - handleFailure(context, request, startedAt, null, "Request already expired"); + handleFailure(context, request, startedAt, "Request already expired"); return; } try { @@ -91,20 +91,20 @@ public class VespaServiceDumperImpl implements VespaServiceDumper { context, vespaJvmDumper.toString(), configId, directoryInNode.toString()); context.log(log, Level.FINE, "vespa-jvm-dumper exit code: " + result.getExitCode() + ", output: " + result.getOutput()); if (result.getExitCode() > 0) { - handleFailure(context, request, startedAt, null, "Failed to create dump: " + result.getOutput()); + handleFailure(context, request, startedAt, "Failed to create dump: " + result.getOutput()); return; } URI destination = serviceDumpDestination(nodeSpec, createDumpId(request)); context.log(log, Level.INFO, "Uploading files with destination " + destination + " and expiry " + expiry); List<SyncFileInfo> files = dumpFiles(directoryOnHost, destination, expiry); if (!syncClient.sync(context, files, Integer.MAX_VALUE)) { - handleFailure(context, request, startedAt, null, "Unable to upload all files"); + handleFailure(context, request, startedAt, "Unable to upload all files"); return; } context.log(log, Level.INFO, "Upload complete"); storeReport(context, createSuccessReport(clock, request, startedAt, destination)); } catch (Exception e) { - handleFailure(context, request, startedAt, e, e.getMessage()); + handleFailure(context, request, startedAt, e); } } @@ -120,13 +120,14 @@ public class VespaServiceDumperImpl implements VespaServiceDumper { : Instant.ofEpochMilli(request.expireAt()); } - private void handleFailure(NodeAgentContext context, ServiceDumpReport request, Instant startedAt, - Exception failure, String message) { - if (failure != null) { - context.log(log, Level.WARNING, message, failure); - } else { - context.log(log, Level.WARNING, message); - } + private void handleFailure(NodeAgentContext context, ServiceDumpReport request, Instant startedAt, Exception failure) { + context.log(log, Level.WARNING, failure.toString(), failure); + ServiceDumpReport report = createErrorReport(clock, request, startedAt, failure.toString()); + storeReport(context, report); + } + + private void handleFailure(NodeAgentContext context, ServiceDumpReport request, Instant startedAt, String message) { + context.log(log, Level.WARNING, message); ServiceDumpReport report = createErrorReport(clock, request, startedAt, message); storeReport(context, report); } |