Flaky Test: ClientEffectiveStrategyTest #2245

bondolo · 2022-06-08T18:43:03Z

https://github.com/apple/servicetalk/pull/2244/checks?check_run_id=6799736339

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_NEVER_STRATEGY CF=null
java.lang.AssertionError: API=BLOCKING_AGGREGATED, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, apiStrategy=OFFLOAD_EVENT_STRATEGY. Async Errors! See suppressed

java.lang.AssertionError: API=BLOCKING_AGGREGATED, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, apiStrategy=OFFLOAD_EVENT_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:501)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:282)
	at jdk.internal.reflect.GeneratedMethodAccessor15.invoke(Unknown Source)
	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
	at org.junit.jupiter.engine.extension.TimeoutInvocation.proceed(TimeoutInvocation.java:46)
	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
	at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
	at java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:194)
	at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
	at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
	at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
	at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
	at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-3 at Send, but was running on an offloading executor thread: client-executor-3-5. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:490)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1940)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:472)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:462)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
		at java.base/java.lang.Thread.run(Thread.java:833)

The text was updated successfully, but these errors were encountered:

Scottmitch · 2022-06-17T19:34:18Z

https://github.com/apple/servicetalk/pull/2254/checks?check_run_id=6941365663

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NONE_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_SEND_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-2. clientStrategy=OFFLOAD_NONE_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
		at java.base/java.lang.Thread.run(Thread.java:833)

Scottmitch · 2022-07-01T21:09:39Z

https://github.com/apple/servicetalk/runs/7156620156

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_NONE_STRATEGY CF=OFFLOAD_NEVER_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-5. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1877)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
		at java.util.concurrent.FutureTask.run(FutureTask.java:266)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
		at java.lang.Thread.run(Thread.java:750)

Scottmitch · 2022-07-01T23:55:40Z

https://github.com/apple/servicetalk/runs/7158092150

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=null filter=null LB=null CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-3 at Send, but was running on an offloading executor thread: client-executor-5-2. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1932)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
		at java.base/java.lang.Thread.run(Thread.java:829)

Scottmitch · 2022-07-01T23:56:44Z

https://github.com/apple/servicetalk/runs/7158091706

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NEVER_STRATEGY filter=null LB=DEFAULT_HTTP_EXECUTION_STRATEGY CF=OFFLOAD_SEND_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-2. clientStrategy=OFFLOAD_NEVER_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1877)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
		at java.util.concurrent.FutureTask.run(FutureTask.java:266)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
		at java.lang.Thread.run(Thread.java:750)

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NEVER_STRATEGY filter=OFFLOAD_SEND_STRATEGY LB=OFFLOAD_ALL_STRATEGY CF=OFFLOAD_NEVER_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:337)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-2. clientStrategy=OFFLOAD_NEVER_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
		at java.util.concurrent.FutureTask.run(FutureTask.java:266)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
		at java.lang.Thread.run(Thread.java:750)

Scottmitch · 2022-07-02T00:11:19Z

https://github.com/apple/servicetalk/pull/2257/checks?check_run_id=7158336577

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NONE_STRATEGY filter=DEFAULT_HTTP_EXECUTION_STRATEGY LB=OFFLOAD_NEVER_STRATEGY CF=DEFAULT_HTTP_EXECUTION_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-3 at Send, but was running on an offloading executor thread: client-executor-5-1. clientStrategy=OFFLOAD_NONE_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1908)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
		at java.base/java.lang.Thread.run(Thread.java:829)

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=null LB=null CF=OFFLOAD_NEVER_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-4. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1877)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
		at java.util.concurrent.FutureTask.run(FutureTask.java:266)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
		at java.lang.Thread.run(Thread.java:750)

Scottmitch · 2022-08-18T00:21:26Z

https://github.com/apple/servicetalk/runs/7815903522 (snapshot build)

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NONE_STRATEGY LB=OFFLOAD_NONE_STRATEGY CF=OFFLOAD_NEVER_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	

Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-1. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1877)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:263)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
		at java.util.concurrent.FutureTask.run(FutureTask.java:266)
		at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
		at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
		at java.lang.Thread.run(Thread.java:750)

tkountis · 2022-09-12T20:36:27Z

ClientEffectiveStrategyTest.Type=MULTI_BUILDER builder=OFFLOAD_ALL_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=null CF=OFFLOAD_NEVER_STRATEGY
java.lang.AssertionError: API=BLOCKING_STREAMING, apiStrategy=OFFLOAD_ALL_STRATEGY, clientStrategy=OFFLOAD_ALL_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY. Async Errors! See suppressed


java.lang.AssertionError: API=BLOCKING_STREAMING, apiStrategy=OFFLOAD_ALL_STRATEGY, clientStrategy=OFFLOAD_ALL_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:337)

https://github.com/apple/servicetalk/pull/2348/checks?check_run_id=8310753563

Scottmitch · 2022-11-23T23:11:43Z

https://github.com/apple/servicetalk/pull/2440/checks?check_run_id=9676646223

ClientEffectiveStrategyTest.Type=MULTI_BUILDER builder=null filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_NEVER_STRATEGY CF=OFFLOAD_NONE_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-4. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1940)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2022-11-24T00:21:53Z

https://github.com/apple/servicetalk/pull/2444/checks?check_run_id=9677905936

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=null filter=null LB=OFFLOAD_NEVER_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	
	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-5. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1877)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$null$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

idelpivnitskiy · 2023-02-27T18:28:24Z

https://github.com/apple/servicetalk/pull/2520/checks?check_run_id=11633533654

ClientEffectiveStrategyTest.Type=MULTI_BUILDER builder=null filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_NONE_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	at jdk.internal.reflect.GeneratedMethodAccessor42.invoke(Unknown Source)
	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-3 at Send, but was running on an offloading executor thread: client-executor-5-1. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1908)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
		at java.base/java.lang.Thread.run(Thread.java:829)

Scottmitch · 2023-04-21T01:45:00Z

https://github.com/apple/servicetalk/pull/2555/checks?check_run_id=12913256561

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_ALL_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=DEFAULT_HTTP_EXECUTION_STRATEGY CF=DEFAULT_HTTP_EXECUTION_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	at jdk.internal.reflect.GeneratedMethodAccessor46.invoke(Unknown Source)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-3. clientStrategy=OFFLOAD_ALL_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
		at java.base/java.lang.Thread.run(Thread.java:833)

idelpivnitskiy · 2023-05-31T20:50:26Z

https://github.com/apple/servicetalk/pull/2614/checks?check_run_id=13905833089

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NONE_STRATEGY filter=DEFAULT_HTTP_EXECUTION_STRATEGY LB=OFFLOAD_SEND_STRATEGY CF=OFFLOAD_ALL_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:104)
	at java.base/java.lang.reflect.Method.invoke(Method.java:578)
...
	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-5. clientStrategy=OFFLOAD_NONE_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1940)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:112)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)
		at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577)
		at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
		at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
		at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
		at java.base/java.lang.Thread.run(Thread.java:1623)

Scottmitch · 2023-07-05T16:02:18Z

https://github.com/apple/servicetalk/pull/2640/checks?check_run_id=14783343570

ClientEffectiveStrategyTest.Type=MULTI_BUILDER builder=null filter=null LB=null CF=OFFLOAD_NEVER_STRATEGY
java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:337)
	

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-5-2. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:116)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2023-08-20T15:47:46Z

https://github.com/apple/servicetalk/runs/16047242078

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NONE_STRATEGY LB=OFFLOAD_NONE_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-7-4. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1940)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:117)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2023-08-21T16:21:36Z

https://github.com/apple/servicetalk/pull/2678/checks?check_run_id=16074782218

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=null filter=null LB=OFFLOAD_NEVER_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-7-5. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:117)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2023-08-31T09:38:33Z

https://github.com/apple/servicetalk/pull/2684/checks?check_run_id=16351475169

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=null LB=OFFLOAD_NEVER_STRATEGY CF=OFFLOAD_NONE_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)


	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-7-3. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:117)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2023-09-12T01:56:00Z

https://github.com/apple/servicetalk/pull/2690/checks?check_run_id=16697253580

ClientEffectiveStrategyTest.Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NONE_STRATEGY filter=null LB=DEFAULT_HTTP_EXECUTION_STRATEGY CF=null

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)

	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-3 at Send, but was running on an offloading executor thread: client-executor-7-5. clientStrategy=OFFLOAD_NONE_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=OFFLOAD_ALL_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1932)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:117)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

bryce-anderson · 2023-10-25T22:06:04Z

https://github.com/apple/servicetalk/pull/2737/checks?check_run_id=18060199944
Essentially identical as the last.

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=null filter=OFFLOAD_NONE_STRATEGY LB=null CF=OFFLOAD_NEVER_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:337)
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
	at java.base/java.lang.reflect.Method.invoke(Method.java:580)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
...

Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-7-3. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1916)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)

daschl · 2023-10-27T05:15:03Z

@bryce-anderson thanks - good to understand that the last flaky test fixes did not help with this. looking.

bryce-anderson · 2023-11-28T17:21:40Z

Another failure
https://github.com/apple/servicetalk/actions/runs/7008105255/job/19063661335#step:7:1036

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=SINGLE_BUILDER builder=OFFLOAD_SEND_STRATEGY filter=null LB=OFFLOAD_ALL_STRATEGY CF=OFFLOAD_NEVER_STRATEGY FAILED
    java.lang.AssertionError: API=ASYNC_STREAMING, apiStrategy=OFFLOAD_ALL_STRATEGY, clientStrategy=OFFLOAD_ALL_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:337)

The output didn't seem to contain a suppressed exception.

Scottmitch · 2023-11-30T15:47:27Z

https://github.com/apple/servicetalk/pull/2769/checks?check_run_id=19163365328

ClientEffectiveStrategyTest.Type=SINGLE_BUILDER builder=null filter=null LB=OFFLOAD_NONE_STRATEGY CF=OFFLOAD_NONE_STRATEGY

java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
	at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:562)
	at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:328)
...
	Suppressed: java.lang.AssertionError: Expected IoThread or ForkJoinPool-1-worker-1 at Send, but was running on an offloading executor thread: client-executor-7-5. clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY, requestStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.lambda$recordThread$0(ClientEffectiveStrategyTest.java:550)
		at java.base/java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1940)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.recordThread(ClientEffectiveStrategyTest.java:532)
		at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder$1.lambda$request$0(ClientEffectiveStrategyTest.java:522)
		at io.servicetalk.concurrent.api.PublisherDoOnUtils$5.request(PublisherDoOnUtils.java:141)
		at io.servicetalk.concurrent.api.WhenSubscriptionPublisher$DoSubscriptionPublisherSubscriber$BeforeSubscription.request(WhenSubscriptionPublisher.java:83)
		at io.servicetalk.concurrent.api.ContextPreservingSubscription.request(ContextPreservingSubscription.java:48)
		at io.servicetalk.concurrent.internal.DelayedSubscription.request(DelayedSubscription.java:77)
		at io.servicetalk.concurrent.api.DelayedCancellableThenSubscription.request(DelayedCancellableThenSubscription.java:46)
		at io.servicetalk.concurrent.api.SingleConcatWithPublisher$ConcatDeferNextSubscriber.request(SingleConcatWithPublisher.java:366)
		at io.servicetalk.concurrent.api.ScanWithPublisher$ScanWithSubscriber$1.request(ScanWithPublisher.java:117)
		at io.servicetalk.concurrent.api.TaskBasedAsyncPublisherOperator$OffloadedSubscription.executeTask(TaskBasedAsyncPublisherOperator.java:436)
		at io.servicetalk.concurrent.api.ContextPreservingRunnable.run(ContextPreservingRunnable.java:46)

Scottmitch · 2024-09-20T14:38:08Z

https://github.com/apple/servicetalk/actions/runs/10959243976/job/30431175672?pr=3061#step:8:1437

> Task :servicetalk-http-netty:test

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=null filter=OFFLOAD_NONE_STRATEGY LB=null CF=OFFLOAD_NEVER_STRATEGY FAILED
    java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:566)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:331)

bryce-anderson · 2024-09-23T15:13:14Z

https://github.com/apple/servicetalk/actions/runs/10966985327/job/30455933910?pr=3062#step:8:1051

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=null LB=null CF=OFFLOAD_NONE_STRATEGY FAILED
    java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:566)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:340)

idelpivnitskiy · 2024-10-02T09:41:29Z

Failed multiple times in a row for a single PR: https://github.com/apple/servicetalk/actions/runs/11127685633/job/30931918614?pr=3071

> Task :servicetalk-http-netty:test

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=null CF=null FAILED
    java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:566)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:340)

idelpivnitskiy · 2024-10-02T10:43:26Z

Another PR:
https://github.com/apple/servicetalk/actions/runs/11142084075/job/30964294843?pr=3072

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=MULTI_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=OFFLOAD_NEVER_STRATEGY LB=OFFLOAD_NONE_STRATEGY CF=null FAILED
    java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:566)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:331)

bryce-anderson · 2024-10-08T17:26:40Z

Another in the nightly runs:
https://github.com/apple/servicetalk/actions/runs/11238258274/job/31242591590#step:9:1151

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=MULTI_DEFAULT_STRATEGY_SINGLE_BUILDER builder=OFFLOAD_NEVER_STRATEGY filter=null LB=DEFAULT_HTTP_EXECUTION_STRATEGY CF=OFFLOAD_ALL_STRATEGY FAILED
    java.lang.AssertionError: API=BLOCKING_AGGREGATED, apiStrategy=OFFLOAD_EVENT_STRATEGY, clientStrategy=DEFAULT_HTTP_EXECUTION_STRATEGY, expectedStrategy=OFFLOAD_NONE_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:566)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:331)

bryce-anderson · 2024-10-08T17:35:51Z

I'm concerned that this test is surfacing some of the inherent race behaviors in our async streams. This is a general idea, but we tend to queue events in our async-streams when another thread has 'taken the lock' so to speak, and that causes events to end up being run by threads that didn't submit them. This is tangentially what's happening in #1894. If that's the case, fixing it will be really involved (we'd need to re-think the queue system). In the meantime, I think we should consider disabling this test unless someone has some better ideas for how to debug/de-flake it.

Motivation: We had previously disabled the clientStrategy test because it's flaky. According to the notes in the issue (apple#2245) it is only in one part, and that is in the Send stage which appears to be offloaded when it shouldn't be. Modifications: Re-enable the test and prune those errors, and log them.

…3105) Motivation: We had previously disabled the clientStrategy test because it's flaky. According to the notes in the issue (#2245) it is only in one part, and that is in the Send stage which appears to be offloaded when it shouldn't be. Modifications: Re-enable the test and prune those errors, and log them.

bryce-anderson · 2024-12-06T21:17:58Z

Another pop: https://github.com/apple/servicetalk/actions/runs/12204191501/job/34048759889?pr=3131#step:8:963

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=null LB=DEFAULT_HTTP_EXECUTION_STRATEGY CF=DEFAULT_HTTP_EXECUTION_STRATEGY FAILED
    java.lang.AssertionError: API=ASYNC_STREAMING, apiStrategy=OFFLOAD_ALL_STRATEGY, clientStrategy=OFFLOAD_ALL_STRATEGY, expectedStrategy=OFFLOAD_ALL_STRATEGY. Async Errors! See suppressed
        at io.servicetalk.test.resources.TestUtils.assertNoAsyncErrors(TestUtils.java:58)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:596)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.flakyVerifyOffloads(ClientEffectiveStrategyTest.java:592)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:345)

idelpivnitskiy · 2024-12-20T22:42:16Z

https://github.com/apple/servicetalk/actions/runs/12438687624/job/34731061698?pr=3152

ClientEffectiveStrategyTest > clientStrategy(BuilderType, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy, HttpExecutionStrategy) > Type=SINGLE_BUILDER builder=DEFAULT_HTTP_EXECUTION_STRATEGY filter=DEFAULT_HTTP_EXECUTION_STRATEGY LB=OFFLOAD_ALL_STRATEGY CF=DEFAULT_HTTP_EXECUTION_STRATEGY FAILED
    java.lang.AssertionError: Unexpected offload points recorded. {Send=offloaded, ReceiveMeta=offloaded, ReceiveData=offloaded}
    Expected: is <3>
         but: was <2>
        at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:20)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.verifyOffloads(ClientEffectiveStrategyTest.java:599)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest$ClientInvokingThreadRecorder.flakyVerifyOffloads(ClientEffectiveStrategyTest.java:592)
        at io.servicetalk.http.netty.ClientEffectiveStrategyTest.clientStrategy(ClientEffectiveStrategyTest.java:345)

bondolo added the flaky tests Unit tests are flaky label Jun 8, 2022

Scottmitch mentioned this issue Jun 17, 2022

BufferDecoderGroupBuilder#add method w/out advertised #2254

Merged

Scottmitch mentioned this issue Jul 1, 2022

Update JCTools 3.3.0 -> 3.3.1-ea, use unpadded queues #2257

Merged

bondolo self-assigned this Jul 18, 2022

tkountis mentioned this issue Sep 12, 2022

Publisher#flatMapMerge allow terminal propagation after invalid demand #2348

Merged

Scottmitch mentioned this issue Nov 23, 2022

Update mockito 4.8.1 -> 4.9.0 #2440

Merged

Scottmitch mentioned this issue Nov 24, 2022

H2PriorKnowledgeFeatureParityTest.serverGracefulClose ConnectionAcceptor disable offloading #2444

Merged

bondolo removed their assignment Jan 9, 2023

Scottmitch mentioned this issue Apr 21, 2023

Publisher#timeout always propagate TimeoutException #2555

Merged

daschl self-assigned this Oct 3, 2023

daschl mentioned this issue Jan 15, 2024

ClientEffectiveStrategyTest: Attempt at fixing flakyness #2804

Merged

bryce-anderson mentioned this issue Oct 8, 2024

http-netty: Disable the ClientEffectiveStrategyTest suite #3075

Merged

bryce-anderson mentioned this issue Nov 14, 2024

http-netty: Re-enable ClientEfectivenessStrategyTest.clientStrategy #3105

Merged

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Flaky Test: ClientEffectiveStrategyTest #2245

Flaky Test: ClientEffectiveStrategyTest #2245

bondolo commented Jun 8, 2022

Scottmitch commented Jun 17, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 2, 2022

Scottmitch commented Aug 18, 2022

tkountis commented Sep 12, 2022

Scottmitch commented Nov 23, 2022

Scottmitch commented Nov 24, 2022

idelpivnitskiy commented Feb 27, 2023

Scottmitch commented Apr 21, 2023

idelpivnitskiy commented May 31, 2023

Scottmitch commented Jul 5, 2023

Scottmitch commented Aug 20, 2023

Scottmitch commented Aug 21, 2023

Scottmitch commented Aug 31, 2023

Scottmitch commented Sep 12, 2023

bryce-anderson commented Oct 25, 2023

daschl commented Oct 27, 2023

bryce-anderson commented Nov 28, 2023

Scottmitch commented Nov 30, 2023

Scottmitch commented Sep 20, 2024

bryce-anderson commented Sep 23, 2024

idelpivnitskiy commented Oct 2, 2024

idelpivnitskiy commented Oct 2, 2024

bryce-anderson commented Oct 8, 2024

bryce-anderson commented Oct 8, 2024

bryce-anderson commented Dec 6, 2024

idelpivnitskiy commented Dec 20, 2024

Flaky Test: ClientEffectiveStrategyTest #2245

Flaky Test: ClientEffectiveStrategyTest #2245

Comments

bondolo commented Jun 8, 2022

Scottmitch commented Jun 17, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 1, 2022

Scottmitch commented Jul 2, 2022

Scottmitch commented Aug 18, 2022

tkountis commented Sep 12, 2022

Scottmitch commented Nov 23, 2022

Scottmitch commented Nov 24, 2022

idelpivnitskiy commented Feb 27, 2023

Scottmitch commented Apr 21, 2023

idelpivnitskiy commented May 31, 2023

Scottmitch commented Jul 5, 2023

Scottmitch commented Aug 20, 2023

Scottmitch commented Aug 21, 2023

Scottmitch commented Aug 31, 2023

Scottmitch commented Sep 12, 2023

bryce-anderson commented Oct 25, 2023

daschl commented Oct 27, 2023

bryce-anderson commented Nov 28, 2023

Scottmitch commented Nov 30, 2023

Scottmitch commented Sep 20, 2024

bryce-anderson commented Sep 23, 2024

idelpivnitskiy commented Oct 2, 2024

idelpivnitskiy commented Oct 2, 2024

bryce-anderson commented Oct 8, 2024

bryce-anderson commented Oct 8, 2024

bryce-anderson commented Dec 6, 2024

idelpivnitskiy commented Dec 20, 2024