Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • 18:04

    mjpt777 on master

    [Java] More in keeping error me… (compare)

  • 17:52

    mjpt777 on master

    [Java] Add more details about c… (compare)

  • 17:52
    mjpt777 closed #1286
  • 17:37
    kwbc opened #1286
  • 06:14
    mikeb01 synchronize #1285
  • 03:49
    mikeb01 opened #1285
  • Jan 26 01:27
    mikeb01 commented #1272
  • Jan 25 18:27

    mjpt777 on master

    [Java] Upgrade to Mockito 4.3.1. (compare)

  • Jan 25 18:25

    mjpt777 on master

    Upgrade to Mockito 4.3.1. (compare)

  • Jan 25 08:51
    vachb commented #1272
  • Jan 25 03:57

    mikeb01 on master

    [C] Simpify structure init. On… (compare)

  • Jan 25 03:42

    mikeb01 on master

    [C] Add recvfrom, recvmsg, recv… (compare)

  • Jan 24 23:04

    mikeb01 on master

    C ping pong raw (#1284) * [C] … (compare)

  • Jan 24 23:04
    mikeb01 closed #1284
  • Jan 24 22:40
    mikeb01 synchronize #1284
  • Jan 24 22:15
    mikeb01 synchronize #1284
  • Jan 24 18:52

    tmontgomery on master

    [Java] add sending of unavailab… (compare)

  • Jan 24 08:11
    SipanVardanyan commented #1263
  • Jan 24 03:45
    mikeb01 opened #1284
  • Jan 23 15:47

    mjpt777 on master

    Support Static Linking (#1261) … (compare)

michaelredman
@michaelredman
Hi, I am trying to persist the egress with aeron cluster, the clustered driver already has an archive and various channels setup, is it a bad idea to use ClusteredMediaDriver.archive().startRecording(my_log) and try connect to it over udp? will the cluster client get confused?
Martin Thompson
@mjpt777
@michaelredman This channel is for contributor discussions only. If you require support we have commercial offerings.
William
@ilove7412369_twitter
I believe i encounter an Aeron Bug.
i publish multidestintaion cast from Host A to HostA and HostB, big message as big as 300k bytes. at rate say 10 times per second.
After 1-2 hours, one of the host , say host B, will get corrupted message. We detect that as it is SBE message with wrong data. While the same message properly processed correctly and successfully.
And then, we will not able to receive any message in host B.
I think bottom line we got exception instead of corrupt message as that make me worry the integrity of the data via aeron.
Martin Thompson
@mjpt777
@ilove7412369_twitter This channel is not for support. If you can create a test that reproduces what you are seeing then raise an issue.
@ilove7412369_twitter When we have investigated issues of data corruption in the past it has almost always been a bug in the application. It is possible it is a bug in Aeron but without a reproducible test we cannot investigate without a support contract.
gorive
@gorive
Just stumbled across Aeron- got a question
1) where does the actual udp transport happen - where it sends the messages to all clients ? Is that in the media driver ?
2) lets say i use it as a fast message broker on the internet and only as unicast - how many clients ( clients connecting to the udp port on the server ) from the outside can Aeron handle without degrading in speed ? Are there any benchmarks on the pure transport level if we want to burst out alot of packets to be distributed to many clients ?
Michael Barker
@mikeb01
1) Yes. 2) This is complicated question and there are numerous tuning options and approaches that can affect this. We can offer consulting in this area: https://real-logic.co.uk/contact.html.
particulitis_julien
@particulitis_twitter
Quick question, I'm a bit confused. The cookbook mentions using ReservedValueSupplier as a checksum. So I'm assuming that Aeron doesn't do a checksum on the receiver messages ? I don't see any official mentions of that except in the wiki
Martin Thompson
@mjpt777
@particulitis_twitter UDP provides its own checksum. The reserved value is for additional data carriage which the application can apply. In future please ask questions on Stackoverflow, this group is for contributor discussions.
particulitis_julien
@particulitis_twitter
Ok, sorry about that, and thanks for the quick reply Martin :)
eduneeraj2019
@eduneeraj2019
morning
eduneeraj2019
@eduneeraj2019
Can aeron connect between multiple switch and multiple subnet? Its works fine on same switch
Martin Thompson
@mjpt777
@eduneeraj2019 This channel is not for support questions.
eduneeraj2019
@eduneeraj2019
Tks @mjpt777 where shud i ask support qn ?
Martin Thompson
@mjpt777
You can approach us for a commercial support contract or try Stackoverflow.
chertar
@chertar
I'm looking to get started with SBE. Is there a tutorial or example to learn from? I've been searching and can't find anything
A "hello world" type example would be perfect
Ronen
@ronenhamias
Hello everyone is there somewhere a simple benchmark for aeron-cluster that i can learn from?
Michael Barker
@mikeb01

Hi @ronenhamias, the focus of this channel is community contribution discussion. Support questions should come through a commercial contract or via stackoverflow.

We have a cluster benchmark here: https://github.com/real-logic/benchmarks/blob/master/benchmarks-aeron/src/test/java/uk/co/real_logic/benchmarks/aeron/remote/ClusterTest.java.

Ronen
@ronenhamias
@mikeb01 thank you very much!
Bill Segall
@billsegall
@mjpt777 I'm probably being blind and not seeing it but is there any documentation on the aeron-archive security model. I'm looking to implement this in aeron-go and I've been looking at the java code. I'm not sure I really comprehend the model for either connection establishment and/or message delivery.
Todd L. Montgomery
@tmontgomery
@billsegall the archive uses the cluster model for Authenticator, etc.
Bill Segall
@billsegall
Lovely! So this is connection auth. Am I right there is no mechanism for selective delivery of messages so this is all I need to worry about?
Todd L. Montgomery
@tmontgomery
yes, it is on the connection.
Bill Segall
@billsegall
Thanks!
Todd L. Montgomery
@tmontgomery
no worries
supergaga
@supergaga
Can I subscribe 2 different UDP channel in one aeronCluster Client?
Michael Barker
@mikeb01
Hi @supergaga we are using this chat room is for public contributor discussions. For support queries you can post your question to stack overflow (https://stackoverflow.com/questions/tagged/aeron) or contact Real Logic for a commercial support contract.
supergaga
@supergaga
@mikeb01 okay . thanks reply
William
@ilove7412369_twitter

@keithwong1 ConcurrentPublication is thread safe; ExclusivePublication is not thread safe. ConcurrentPublication is returned from Aeron.addPublication. ThreadingMode for the driver is an independent feature for configuring thread usage by the driver.

But is ConcurrentPublication safe to use when multiple "processes" publish to same endpoint?

Martin Thompson
@mjpt777
@ilove7412369_twitter We do not offer support in this channel. Please ask questions on Stackoverflow.
William
@ilove7412369_twitter
I thought my level of question is the same level as Keithwong1, so is that Keithwong1 has paid support so can ask it here?
Martin Thompson
@mjpt777
We have a support mailing list for those on commercial support.
Historically we have given support on this channel and people have taken advantage.
KabDeveloper
@KabDeveloper

Caused by: java.lang.IllegalStateException: Missing file for cnc: c:\datapath\cnc

Someone can help with this error?

Michael Barker
@mikeb01
@KabDeveloper We have switched to using this channel for public contribution discussion. For support queries you can post your question to stack overflow (https://stackoverflow.com/questions/tagged/aeron) or contact Real Logic for a commercial support contract.
Welly Tambunan
@welly87

hi all, i try posting on stackoverflow but seems it not the appropriate place for this questions it's getting closed :D

Previously i read in docs that C Media Driver currently still on going development but doesn't support clustering like Java does. Is this still the case today? I try to look at source code but seems it's no clustering related code there. Not sure if i'm looking at right branch.

Is it a goal for C Media Driver to be in par with Java Media Driver? And which direction it will go?

thanks a lot

Martin Thompson
@mjpt777
@welly87 If Stackoverflow will not accept your question the you should take that up with them. No reason they should deny it.
This channel is for contributor discussions. You can consider a support subscription - sales@real-logic.co.uk.
Welly Tambunan
@welly87:matrix.org
[m]
thanks @mjpt777 . will reopen the questions as per your edit review.
Nikita
@NikitaMishin
Hi everyone, have several small questions:
1) https://github.com/real-logic/aeron/wiki/Channel-Configuration :
term-length: is it defined in bytes i.e can i pass number of bytes 65536 or is it should be passed in kbytes? Given some threshold on messages is it better to changes this property to some specific value, eg 10 times bigger then max length of message
2) can subscriber detect that he slowly process data so he can skip all old messages and start to process the last one (also can he notify publisher that it can skip old messages too)? Is this refers to property "reliable"?
Martin Thompson
@mjpt777
We do not answer support questions or give free consultancy in this channel. Please ask specific questions on Stackoverflow or sign up for commercial support at sales@real-logic.co.uk.
Nikita
@NikitaMishin
ok, C++ exception with description "no response from driver in 10000 ms" thrown in the test body. when running test with embedded cmedia driver. should i do smth apart from what written in docs?
Michael Barker
@mikeb01
@NikitaMishin As mentioned, if you could ask support questions on Stack Overflow and tag it with "aeron". You are more likely to get a response there.
Vitaly
@rvit34
ratcash
@ratcashdev
Hello gents, could you please help with the following scenario regarding cluster election? Assuming a leader dies with appendPositionL and commitPositionL. Next one of the members becomes a candidate while having commitPositionM1 < commitPositionL < appendPositionM1 < appendPositionL. So i was wondering what happens when he gets (eventually) elected?
a) he truncates his log to commitPositionM1 (just like all the followers do onNewLeadershipTerm ),
b) he keeps the messages in his log (beyond the commit position) and eventually distributes these to members and form a consensus
c) nothing is guaranteed during elections, and he may or may not retain those log entries beyond the commit position.
thanks in advance.