Commit ⋅ uber/tchannel-java

Showing 1 of 2 files from the diff.

...ava/com/uber/tchannel/handlers/ResponseRouter.java changed.

Other files ignored by Codecov

...com/uber/tchannel/handlers/ResponseRouterTest.java is new.

@@ -22,6 +22,7 @@

Loading


package com.uber.tchannel.handlers;

import com.google.common.annotations.VisibleForTesting;
import com.uber.tchannel.api.TChannel;
import com.uber.tchannel.api.errors.TChannelConnectionReset;
import com.uber.tchannel.channels.PeerManager;

@@ -71,6 +72,14 @@

Loading

        this.maxPendingRequests = topChannel.getClientMaxPendingRequests();
    }

    @VisibleForTesting
    ResponseRouter(@NotNull TChannel topChannel, @NotNull PeerManager peerManager, @NotNull HashedWheelTimer timer) {
        this.peerManager = peerManager;
        this.resetOnTimeoutLimit = topChannel.getResetOnTimeoutLimit();
        this.timer = timer;
        this.maxPendingRequests = topChannel.getClientMaxPendingRequests();
    }

    @Override
    public void channelActive(@NotNull ChannelHandlerContext ctx) throws Exception {
        super.channelActive(ctx);

@@ -183,6 +192,11 @@

Loading

        }

        if (response != null) {
            // Reset timeout counter if we receive a non-timeout response.
            if (!(response.isError() &&
                    ErrorType.Timeout.equals(((ErrorResponse) response).getErrorType()))) {
                timeouts.set(0);
            }
            response.touch("ResponseRouter.handleResponse(...)");
        }


Files		•	•	•	Complexity	Coverage
tchannel-core/src/main/java/com/uber/tchannel	2,839	2,158	219	462	0	76.01%
tchannel-hyperbahn/src/main/java/com/uber/tchannel/hyperbahn	101	60	7	34	64.71%	59.41%
Project Totals (88 files)	2,940	2,218	226	496	64.71%	75.44%

openjdk7=
TRAVIS_OS_NAME=linux

View CI Build Download

1	coverage:
2	range: 50..99
3	round: nearest

Read the docs

Interact now

The inner-most circle is the entire project, moving away from the center are folders then, finally, a single file. The size and color of each slice is representing the number of statements and the coverage, respectively.

SVG

The top section represents the entire project. Proceeding with folders and finally individual files. The size and color of each slice is representing the number of statements and the coverage, respectively.

SVG

Each block represents a single file in the project. The size and color of each block is represented by the number of statements and the coverage, respectively.

SVG

Learn more about the coverage sunburst graph

183	192		}
184	193
185	194		if (response != null) {
	195	+	// Reset timeout counter if we receive a non-timeout response.
	196	+	if (!(response.isError() &&
	197	+	ErrorType.Timeout.equals(((ErrorResponse) response).getErrorType()))) {
	198	+	timeouts.set(0);
	199	+	}
186	200		response.touch("ResponseRouter.handleResponse(...)");
187	201		}
188	202

Navigation	Overlay
`t` Navigate files	`h` Toggle hits
`y` Change url to tip of branch	`m` Toggle misses
`b / v` Jump to prev/next hit line	`p` Toggle partial
`z / x` Jump to prev/next missed or partial line	`1..9` Toggle flags
`shift + o` Open current page in GitHub	`a` Toggle all on
`/ or ?` Show keyboard shortcuts dialog	`c` Toggle context lines or commits

22	22
23	23		package com.uber.tchannel.handlers;
24	24
	25	+	import com.google.common.annotations.VisibleForTesting;
25	26		import com.uber.tchannel.api.TChannel;
26	27		import com.uber.tchannel.api.errors.TChannelConnectionReset;
27	28		import com.uber.tchannel.channels.PeerManager;

71	72		this.maxPendingRequests = topChannel.getClientMaxPendingRequests();
72	73		}
73	74
	75	+	@VisibleForTesting
	76	+	ResponseRouter(@NotNull TChannel topChannel, @NotNull PeerManager peerManager, @NotNull HashedWheelTimer timer) {
	77	+	this.peerManager = peerManager;
	78	+	this.resetOnTimeoutLimit = topChannel.getResetOnTimeoutLimit();
	79	+	this.timer = timer;
	80	+	this.maxPendingRequests = topChannel.getClientMaxPendingRequests();
	81	+	}
	82	+
74	83		@Override
75	84		public void channelActive(@NotNull ChannelHandlerContext ctx) throws Exception {
76	85		super.channelActive(ctx);

Updating our web app