Skip to content

Commit bc8de5a

Browse files
committed
rename shutdownError to toException
1 parent 538deba commit bc8de5a

File tree

6 files changed

+21
-21
lines changed

6 files changed

+21
-21
lines changed

Diff for: core/src/main/java/com/linecorp/armeria/server/DefaultGracefulShutdown.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -28,13 +28,13 @@ final class DefaultGracefulShutdown implements GracefulShutdown {
2828

2929
private final Duration quietPeriod;
3030
private final Duration timeout;
31-
private final BiFunction<ServiceRequestContext, HttpRequest, Throwable> errorFunction;
31+
private final BiFunction<ServiceRequestContext, HttpRequest, Throwable> toExceptionFunction;
3232

3333
DefaultGracefulShutdown(Duration quietPeriod, Duration timeout,
34-
BiFunction<ServiceRequestContext, HttpRequest, Throwable> errorFunction) {
34+
BiFunction<ServiceRequestContext, HttpRequest, Throwable> toExceptionFunction) {
3535
this.quietPeriod = quietPeriod;
3636
this.timeout = timeout;
37-
this.errorFunction = errorFunction;
37+
this.toExceptionFunction = toExceptionFunction;
3838
}
3939

4040
@Override
@@ -48,8 +48,8 @@ public Duration timeout() {
4848
}
4949

5050
@Override
51-
public Throwable shutdownError(ServiceRequestContext ctx, HttpRequest request) {
52-
return errorFunction.apply(ctx, request);
51+
public Throwable toException(ServiceRequestContext ctx, HttpRequest request) {
52+
return toExceptionFunction.apply(ctx, request);
5353
}
5454

5555
@Override
@@ -63,20 +63,20 @@ public boolean equals(Object o) {
6363
final DefaultGracefulShutdown that = (DefaultGracefulShutdown) o;
6464
return quietPeriod.equals(that.quietPeriod) &&
6565
timeout.equals(that.timeout) &&
66-
errorFunction.equals(that.errorFunction);
66+
toExceptionFunction.equals(that.toExceptionFunction);
6767
}
6868

6969
@Override
7070
public int hashCode() {
71-
return Objects.hash(quietPeriod, timeout, errorFunction);
71+
return Objects.hash(quietPeriod, timeout, toExceptionFunction);
7272
}
7373

7474
@Override
7575
public String toString() {
7676
return MoreObjects.toStringHelper(this)
7777
.add("quietPeriod", quietPeriod)
7878
.add("timeout", timeout)
79-
.add("errorFunction", errorFunction)
79+
.add("toExceptionFunction", toExceptionFunction)
8080
.toString();
8181
}
8282
}

Diff for: core/src/main/java/com/linecorp/armeria/server/GracefulShutdown.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -64,5 +64,5 @@ static GracefulShutdown disabled() {
6464
* <p>If null is returned, the request will be terminated with {@link ShuttingDownException} that will be
6565
* converted to an {@link HttpStatus#SERVICE_UNAVAILABLE} response.
6666
*/
67-
Throwable shutdownError(ServiceRequestContext ctx, HttpRequest request);
67+
Throwable toException(ServiceRequestContext ctx, HttpRequest request);
6868
}

Diff for: core/src/main/java/com/linecorp/armeria/server/GracefulShutdownBuilder.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public final class GracefulShutdownBuilder {
4444

4545
private Duration quietPeriod = DEFAULT_GRACEFUL_SHUTDOWN_QUIET_PERIOD;
4646
private Duration timeout = DEFAULT_GRACEFUL_SHUTDOWN_TIMEOUT;
47-
private BiFunction<ServiceRequestContext, HttpRequest, Throwable> errorFunction = DEFAULT_ERROR_FUNCTION;
47+
private BiFunction<ServiceRequestContext, HttpRequest, Throwable> toException = DEFAULT_ERROR_FUNCTION;
4848

4949
GracefulShutdownBuilder() {}
5050

@@ -99,11 +99,11 @@ public GracefulShutdownBuilder timeoutMillis(long timeoutMillis) {
9999
* shutting down. If unspecified, the request will be terminated with {@link ShuttingDownException} that
100100
* will be converted to an {@link HttpStatus#SERVICE_UNAVAILABLE} response.
101101
*/
102-
public GracefulShutdownBuilder shutdownErrorFunction(
103-
BiFunction<? super ServiceRequestContext, ? super HttpRequest, ? extends Throwable> errorFunction) {
104-
requireNonNull(errorFunction, "errorFunction");
102+
public GracefulShutdownBuilder toExceptionFunction(
103+
BiFunction<? super ServiceRequestContext, ? super HttpRequest, ? extends Throwable> toException) {
104+
requireNonNull(toException, "toException");
105105
//noinspection unchecked
106-
this.errorFunction = (BiFunction<ServiceRequestContext, HttpRequest, Throwable>) errorFunction;
106+
this.toException = (BiFunction<ServiceRequestContext, HttpRequest, Throwable>) toException;
107107
return this;
108108
}
109109

@@ -112,6 +112,6 @@ public GracefulShutdownBuilder shutdownErrorFunction(
112112
*/
113113
public GracefulShutdown build() {
114114
validateGreaterThanOrEqual(timeout, "timeout", quietPeriod, "quietPeriod");
115-
return new DefaultGracefulShutdown(quietPeriod, timeout, errorFunction);
115+
return new DefaultGracefulShutdown(quietPeriod, timeout, toException);
116116
}
117117
}

Diff for: core/src/main/java/com/linecorp/armeria/server/HttpServerHandler.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -322,9 +322,9 @@ private Throwable shutdownError(DecodedHttpRequest req) {
322322
return null;
323323
}
324324
try {
325-
return config.gracefulShutdown().shutdownError(ctx, req);
325+
return config.gracefulShutdown().toException(ctx, req);
326326
} catch (Exception e) {
327-
logger.warn("{} Unexpected exception from gracefulShutdown.shutdownError(): {}",
327+
logger.warn("{} Unexpected exception from gracefulShutdown.toException(): {}",
328328
ctx, config.gracefulShutdown(), e);
329329
return null;
330330
}

Diff for: core/src/test/java/com/linecorp/armeria/GracefulShutdownBuilderTest.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ void testDefault() {
5454
final GracefulShutdown gracefulShutdown = GracefulShutdown.builder().build();
5555
assertThat(gracefulShutdown.quietPeriod()).isZero();
5656
assertThat(gracefulShutdown.timeout()).isZero();
57-
assertThat(gracefulShutdown.shutdownError(null, null))
57+
assertThat(gracefulShutdown.toException(null, null))
5858
.isInstanceOf(ShuttingDownException.class);
5959
}
6060

@@ -64,11 +64,11 @@ void testCustomValues() {
6464
GracefulShutdown.builder()
6565
.quietPeriod(Duration.ofSeconds(1))
6666
.timeout(Duration.ofSeconds(2))
67-
.shutdownErrorFunction((ctx, req) -> new AnticipatedException("test"))
67+
.toExceptionFunction((ctx, req) -> new AnticipatedException("test"))
6868
.build();
6969
assertThat(gracefulShutdown.quietPeriod()).isEqualTo(Duration.ofSeconds(1));
7070
assertThat(gracefulShutdown.timeout()).isEqualTo(Duration.ofSeconds(2));
71-
assertThat(gracefulShutdown.shutdownError(null, null))
71+
assertThat(gracefulShutdown.toException(null, null))
7272
.isInstanceOf(AnticipatedException.class);
7373
}
7474
}

Diff for: core/src/test/java/com/linecorp/armeria/server/CustomGracefulShutDownTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ public Stream<? extends Arguments> provideArguments(ExtensionContext context) {
7878
GracefulShutdown.builder()
7979
.quietPeriod(Duration.ofMillis(500))
8080
.timeout(Duration.ofMillis(500))
81-
.shutdownErrorFunction(
81+
.toExceptionFunction(
8282
(ctx, req) -> new AnticipatedException())
8383
.build();
8484

0 commit comments

Comments
 (0)