This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// 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 |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from ctypes import * | |
import base64 | |
import gzip, zlib | |
class HDR_COMPRESSED(BigEndianStructure): | |
_pack_ = 1 | |
_fields_ = [ | |
("cookie", c_int), | |
("length", c_int) | |
] |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
RingBuffer<ValueEvent<String>> ringBuffer = new RingBuffer<>(...); | |
String data = "ABC"; | |
ringBuffer.publishEvent((event, seq, arg) -> event.set(arg), data); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
RingBuffer<ValueEvent<String>> ringBuffer = new RingBuffer<>(...); | |
String data = "ABC"; | |
long next = ringBuffer.next(); | |
try | |
{ | |
ValueEvent<String> event = ringBuffer.get(next); | |
event.set(data); | |
} | |
finally |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/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 \ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?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> |
NewerOlder