We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Following snippet sometimes throws TimeoutException on archive.stopRecording(channel, 1); line.
archive.stopRecording(channel, 1);
String aeronDirName = Files.createTempDirectory("md").toString(); try (ArchivingMediaDriver mediaDriver = ArchivingMediaDriver.launch( new MediaDriver.Context() .threadingMode(ThreadingMode.SHARED) .aeronDirectoryName(aeronDirName), new Archive.Context() .aeronDirectoryName(aeronDirName) .threadingMode(ArchiveThreadingMode.SHARED) .archiveDir(Files.createTempDirectory("ar").toFile()) )) { try (Aeron aeron = Aeron.connect(new Aeron.Context() .aeronDirectoryName(mediaDriver.mediaDriver().aeronDirectoryName())); AeronArchive archive = AeronArchive.connect(new AeronArchive.Context() .aeron(aeron))) { String channel = "aeron:udp?endpoint=127.0.0.1:9000"; archive.startRecording(channel, 1, SourceLocation.LOCAL); archive.startRecording(channel, 2, SourceLocation.LOCAL); aeron.addPublication(channel, 1); aeron.addPublication(channel, 2); archive.stopRecording(channel, 1); archive.stopRecording(channel, 2); } }
The text was updated successfully, but these errors were encountered:
The archive should enqueue new recordings.
I'll also update the Aeron client so it detects a reentrant call when current request is active.
Sorry, something went wrong.
[Java] Enqueue actions required on available image handlers in the ar…
b1ced49
…chive so they are run asynchronously and not on the callback to avoid reentrancy issues. Issue #524.
[Java] Ensure the aeron client is not reentered during a callback. Is…
6ed1586
…sue #524.
No branches or pull requests
Following snippet sometimes throws TimeoutException on
archive.stopRecording(channel, 1);
line.The text was updated successfully, but these errors were encountered: