Client hangs indefinitely while synchronizing subscriptions #1536
peterfranciscook
started this conversation in
General
Replies: 5 comments 12 replies
-
|
Wireshark capture and thread dumps may help. Can you run this in a debugger and step into the |
Beta Was this translation helpful? Give feedback.
0 replies
-
|
dumped all threads, this one looks like its handling the task at hand - blocking @ |
Beta Was this translation helpful? Give feedback.
7 replies
-
I was using the |
Beta Was this translation helpful? Give feedback.
-
|
Ok, well I think this is something I have to fix in Milo. I wanted to preserve the delivery order of responses up until the OpcUaClient layer and then let the user decide, but this seems like it's not going to work out. Trivially reproducible with the following test: @Test
void deadlockInAsyncCallback() throws Exception {
CompletableFuture<List<DataValue>> future =
client.readValuesAsync(
0.0, TimestampsToReturn.Neither, List.of(NodeIds.Server_ServerStatus_CurrentTime));
var blockingReadComplete = new CountDownLatch(1);
future.whenComplete(
(dataValues, throwable) -> {
try {
client.readValue(
0.0, TimestampsToReturn.Neither, NodeIds.Server_ServerStatus_CurrentTime);
blockingReadComplete.countDown();
} catch (UaException e) {
throw new RuntimeException(e);
}
});
blockingReadComplete.await();
} |
Beta Was this translation helpful? Give feedback.
-
Am I deadlocking myself then? |
Beta Was this translation helpful? Give feedback.
-
You could look at it that way, but IMO this is a Milo bug. |
Beta Was this translation helpful? Give feedback.
-
Beta Was this translation helpful? Give feedback.
-
|
@peterfranciscook this should be fixed if you can build and test against a SNAPSHOT version from the latest commit. |
Beta Was this translation helpful? Give feedback.
2 replies
-
|
@kevinherron whats the snapshot name on sonatype? |
Beta Was this translation helpful? Give feedback.
-
|
I don't think snapshots are being published right now, you'd have to build locally ( |
Beta Was this translation helpful? Give feedback.
-
|
Still hung =/ full thread dump |
Beta Was this translation helpful? Give feedback.
1 reply
-
|
not sure if its relevant but I think maven is shading in netty 4.1.122 from another package for my package instead of the milo version 4.1.121 going to build with bazel and deploy to a different JVM (graal instead of corretto) and see if that changes anything |
Beta Was this translation helpful? Give feedback.
-
|
@kevinherron I refuse to speculate as to reasons why, but the same jarfile built with milo 1.0.3-SNAPSHOT running on graalvm (graalvm-jdk-21.0.8+12.1) doesn't hang here! |
Beta Was this translation helpful? Give feedback.
2 replies
-
|
I think you just needed a Maven refresh or something. This stack trace still shows the task running via |
Beta Was this translation helpful? Give feedback.
-
|
Shit hang on, let me make sure there's not another ExecutionQueue somewhere... edit: doesn't look like it.. |
Beta Was this translation helpful? Give feedback.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
In this service/class, my first call to
OpcUaSubscription::synchronizeMonitoredItemscompletes as expected.But after the service is running, an additional call (via the
subscribeToUdts) method to eitherOpcUaSubscription::synchronizeMonitoredItemsorOpcUaSubscription::createMonitoredItemshangs the client indefinitely.The last few log entries I see when this happens:
I do see a log message with the same PID during my first call to
synchronizeMonitoredItems:DEBUG: id=37182249, createMonitoredItems partition.size(): 80After the client is hung here, I can't perform a graceful shutdown with
OpcUaClient::disconnect(spins indefinitely) orOpcUaClient::disconnectAsync(throws or times out when I try to get or join the thread)I'm not sure what is happening - is this a milo bug or am I doing something wrong?
My subscription service code (method
subscribeToUdtsis where my second synchronization call is made):Beta Was this translation helpful? Give feedback.
All reactions