From 030594a033fda4c40023dd6bc2f451b1e35abbf7 Mon Sep 17 00:00:00 2001 From: Eric Klatzco Date: Tue, 13 Apr 2021 14:10:32 -0600 Subject: [PATCH 1/5] Fine level logging for total and partial failure exceptions --- .../usgs/earthquake/eids/EIDSInputWedge.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java index aaae2490..b4214a27 100644 --- a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java +++ b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java @@ -652,6 +652,15 @@ else if (poll) { totalFailures++; LOGGER.severe("Total failure sending product " + sentId.toString()); + + //Iterator for specific Product Senders + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } else { // output built product id because it was sent at least // once @@ -663,6 +672,14 @@ else if (poll) { partialFailures++; LOGGER.warning("Partial failure sending product " + sentId.toString()); + + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } } } From f49f8d141e9c59c9de6d1524e07a32fe0791dfbb Mon Sep 17 00:00:00 2001 From: Eric Klatzco Date: Tue, 13 Apr 2021 14:10:32 -0600 Subject: [PATCH 2/5] Fine level logging for total and partial failure exceptions --- .../usgs/earthquake/eids/EIDSInputWedge.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java index aaae2490..b4214a27 100644 --- a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java +++ b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java @@ -652,6 +652,15 @@ else if (poll) { totalFailures++; LOGGER.severe("Total failure sending product " + sentId.toString()); + + //Iterator for specific Product Senders + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } else { // output built product id because it was sent at least // once @@ -663,6 +672,14 @@ else if (poll) { partialFailures++; LOGGER.warning("Partial failure sending product " + sentId.toString()); + + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } } } From b563fbabf21c594af29dc325aaa8dbb6ac83abfa Mon Sep 17 00:00:00 2001 From: Eric Klatzco Date: Tue, 13 Apr 2021 14:10:32 -0600 Subject: [PATCH 3/5] Fine level logging for total and partial failure exceptions --- .../usgs/earthquake/eids/EIDSInputWedge.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java index aaae2490..b4214a27 100644 --- a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java +++ b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java @@ -652,6 +652,15 @@ else if (poll) { totalFailures++; LOGGER.severe("Total failure sending product " + sentId.toString()); + + //Iterator for specific Product Senders + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } else { // output built product id because it was sent at least // once @@ -663,6 +672,14 @@ else if (poll) { partialFailures++; LOGGER.warning("Partial failure sending product " + sentId.toString()); + + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } } } From a9d20e339ac7419e52b4117567962bee3ec1fd99 Mon Sep 17 00:00:00 2001 From: Eric Klatzco Date: Tue, 13 Apr 2021 14:10:32 -0600 Subject: [PATCH 4/5] Fine level logging for total and partial failure exceptions --- .../usgs/earthquake/eids/EIDSInputWedge.java | 17 +++++++++++++++++ 1 file changed, 17 insertions(+) diff --git a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java index 61ff4aaf..c2d6a286 100644 --- a/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java +++ b/src/main/java/gov/usgs/earthquake/eids/EIDSInputWedge.java @@ -740,6 +740,15 @@ else if (poll) { totalFailures++; LOGGER.severe("Total failure sending product " + sentId.toString()); + + //Iterator for specific Product Senders + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } else { // output built product id because it was sent at least // once @@ -751,6 +760,14 @@ else if (poll) { partialFailures++; LOGGER.warning("Partial failure sending product " + sentId.toString()); + + Iterator productSenders = sendExceptions.get(sentId) + .keySet().iterator(); + while(productSenders.hasNext()) { + ProductSender productSender = productSenders.next(); + LOGGER.fine("Total failure exception " + + sendExceptions.get(sentId).get(productSender).toString()); + } } } } From 078deda9be7748ff090ad63dc50e7ea11f6c1c13 Mon Sep 17 00:00:00 2001 From: Eric Klatzco Date: Tue, 4 May 2021 13:57:32 -0600 Subject: [PATCH 5/5] Removed exception loggin in EIDSInputWedge. Added to parallelSendProducts --- .../earthquake/distribution/ProductBuilder.java | 7 ++++++- .../usgs/earthquake/eids/EIDSInputWedge.java | 17 ----------------- 2 files changed, 6 insertions(+), 18 deletions(-) diff --git a/src/main/java/gov/usgs/earthquake/distribution/ProductBuilder.java b/src/main/java/gov/usgs/earthquake/distribution/ProductBuilder.java index c3e307f2..0eb9673b 100644 --- a/src/main/java/gov/usgs/earthquake/distribution/ProductBuilder.java +++ b/src/main/java/gov/usgs/earthquake/distribution/ProductBuilder.java @@ -295,7 +295,12 @@ public static Map parallelSendProduct(final List productSenders = sendExceptions.get(sentId) - .keySet().iterator(); - while(productSenders.hasNext()) { - ProductSender productSender = productSenders.next(); - LOGGER.fine("Total failure exception " - + sendExceptions.get(sentId).get(productSender).toString()); - } } else { // output built product id because it was sent at least // once @@ -760,14 +751,6 @@ else if (poll) { partialFailures++; LOGGER.warning("Partial failure sending product " + sentId.toString()); - - Iterator productSenders = sendExceptions.get(sentId) - .keySet().iterator(); - while(productSenders.hasNext()) { - ProductSender productSender = productSenders.next(); - LOGGER.fine("Total failure exception " - + sendExceptions.get(sentId).get(productSender).toString()); - } } } }