Skip to content

Instantly share code, notes, and snippets.

aeron:udp?endpoint=224.20.30.39:24326|fc=min,g:/3,t:5000ms // timeout 5s
aeron:udp?endpoint=224.20.30.39:24326|fc=tagged,g:1001/3,t:5s // timeout 5s
aeron:udp?endpoint=224.20.30.39:24326|fc=min,g:/3 // group min size 3
aeron:udp?endpoint=224.20.30.39:24326|fc=tagged,g:1001/3 // group min size 3
// Publisher
aeron:udp?endpoint=224.20.30.39:24326|fc=max // max strategy
aeron:udp?endpoint=224.20.30.39:24326|fc=min // min strategy
aeron:udp?endpoint=224.20.30.39:24326|fc=tagged,g:1001 // tagged strategy, group 1001
// Subscriber
aeron:udp?endpoint=224.20.30.39:24326|gtag=1001 // tagged subscription
from ctypes import *
import base64
import gzip, zlib
class HDR_COMPRESSED(BigEndianStructure):
_pack_ = 1
_fields_ = [
("cookie", c_int),
("length", c_int)
]
RingBuffer<ValueEvent<String>> ringBuffer = new RingBuffer<>(...);
String data = "ABC";
ringBuffer.publishEvent((event, seq, arg) -> event.set(arg), data);
RingBuffer<ValueEvent<String>> ringBuffer = new RingBuffer<>(...);
String data = "ABC";
long next = ringBuffer.next();
try
{
ValueEvent<String> event = ringBuffer.get(next);
event.set(data);
}
finally
diff --git a/aeron-driver/src/test/java/uk/co/real_logic/aeron/driver/UdpChannelTest.java b/aeron-driver/src/test/java/uk/co/real_logic/aeron/driver/UdpChannelTest.java
index 32e3814..fb28e8b 100644
--- a/aeron-driver/src/test/java/uk/co/real_logic/aeron/driver/UdpChannelTest.java
+++ b/aeron-driver/src/test/java/uk/co/real_logic/aeron/driver/UdpChannelTest.java
@@ -22,15 +22,17 @@ import static org.hamcrest.MatcherAssert.assertThat;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.NetworkInterface;
+import java.net.SocketException;
import java.net.UnknownHostException;
package org.openjdk.jmh.samples;
import org.openjdk.jmh.annotations.Benchmark;
import org.openjdk.jmh.annotations.Scope;
import org.openjdk.jmh.annotations.Setup;
import org.openjdk.jmh.annotations.State;
import org.openjdk.jmh.infra.Blackhole;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;
#!/bin/bash
LINKDIR=/usr/bin
JHOME=/usr/java/latest
JREDIR=$JHOME/jre/bin
JDKDIR=$JHOME/bin
sudo alternatives --install $LINKDIR/java java $JREDIR/java 20000 \
--slave $LINKDIR/keytool keytool $JREDIR/keytool \
--slave $LINKDIR/orbd orbd $JREDIR/orbd \
<?xml version="1.0"?>
<!DOCTYPE fontconfig SYSTEM "fonts.dtd">
<fontconfig>
<match target="font">
<edit name="autohint" mode="assign">
<bool>true</bool>
</edit>
<edit name="hinting" mode="assign">
<bool>true</bool>
</edit>