summaryrefslogtreecommitdiffstats
path: root/jdisc_http_service/src/main/java/com/yahoo/jdisc/http
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2021-01-15 19:09:53 +0100
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2021-01-15 19:15:38 +0100
commit539cfec43fae5c1ee702b9d0bb119aea82b47804 (patch)
tree343cdc644d67b797090e8f5f8e223fa9e1cc2703 /jdisc_http_service/src/main/java/com/yahoo/jdisc/http
parent280ea168d3ab169a79fd409548001c48010d2422 (diff)
Only include counters if initialized. Rename 'bytes' fields
Diffstat (limited to 'jdisc_http_service/src/main/java/com/yahoo/jdisc/http')
-rw-r--r--jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/JettyConnectionLogger.java30
1 files changed, 19 insertions, 11 deletions
diff --git a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/JettyConnectionLogger.java b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/JettyConnectionLogger.java
index 0dfedb3154f..67efae63b0a 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/JettyConnectionLogger.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/JettyConnectionLogger.java
@@ -204,10 +204,10 @@ class JettyConnectionLogger extends AbstractLifeCycle implements Connection.List
private final InetSocketAddress localAddress;
private final InetSocketAddress peerAddress;
- private long bytesReceived;
- private long bytesSent;
- private long requests;
- private long responses;
+ private long httpBytesReceived = -1;
+ private long httpBytesSent = -1;
+ private long requests = -1;
+ private long responses = -1;
private byte[] sslSessionId;
private String sslProtocol;
private String sslCipherSuite;
@@ -234,8 +234,8 @@ class JettyConnectionLogger extends AbstractLifeCycle implements Connection.List
synchronized UUID uuid() { return uuid; }
synchronized ConnectionInfo setHttpBytes(long received, long sent) {
- this.bytesReceived = received;
- this.bytesSent = sent;
+ this.httpBytesReceived = received;
+ this.httpBytesSent = sent;
return this;
}
@@ -264,11 +264,19 @@ class JettyConnectionLogger extends AbstractLifeCycle implements Connection.List
}
synchronized ConnectionLogEntry toLogEntry() {
- ConnectionLogEntry.Builder builder = ConnectionLogEntry.builder(uuid, Instant.ofEpochMilli(createdAt))
- .withBytesReceived(bytesReceived)
- .withBytesSent(bytesSent)
- .withRequests(requests)
- .withResponses(responses);
+ ConnectionLogEntry.Builder builder = ConnectionLogEntry.builder(uuid, Instant.ofEpochMilli(createdAt));
+ if (httpBytesReceived >= 0) {
+ builder.withHttpBytesReceived(httpBytesReceived);
+ }
+ if (httpBytesSent >= 0) {
+ builder.withHttpBytesSent(httpBytesSent);
+ }
+ if (requests >= 0) {
+ builder.withRequests(requests);
+ }
+ if (responses >= 0) {
+ builder.withResponses(responses);
+ }
if (peerAddress != null) {
builder.withPeerAddress(peerAddress.getHostString())
.withPeerPort(peerAddress.getPort());