.disruptor.metadata

@@ -1 +0,0 @@
-6027c6014a49499e4b7b831bfb3df916d7192a3a SOURCES/disruptor-3.4.4.tar.gz

.fmf/version

@@ -0,0 +1 @@
+1

.gitignore

@@ -1 +1,11 @@
-SOURCES/disruptor-3.4.4.tar.gz
+/3.2.1.tar.gz
+/3.3.2.tar.gz
+/disruptor-3.3.2.pom
+/disruptor-3.3.4.pom
+/3.3.4.tar.gz
+/disruptor-3.3.6.tar.gz
+/disruptor-3.3.6.pom
+/disruptor-3.4.2.pom
+/disruptor-3.4.2.tar.gz
+/disruptor-3.4.4.tar.gz
+/disruptor-3.4.4.pom

SOURCES/disruptor-3.4.4.pom

@@ -1,37 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
-    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
-  <modelVersion>4.0.0</modelVersion>
-  <groupId>com.lmax</groupId>
-  <artifactId>disruptor</artifactId>
-  <version>3.4.4</version>
-  <name>Disruptor Framework</name>
-  <description>Disruptor - Concurrent Programming Framework</description>
-  <url>http://lmax-exchange.github.com/disruptor</url>
-  <licenses>
-    <license>
-      <name>The Apache Software License, Version 2.0</name>
-      <url>http://www.apache.org/licenses/LICENSE-2.0.txt</url>
-      <distribution>repo</distribution>
-    </license>
-  </licenses>
-  <developers>
-    <developer>
-      <id>team</id>
-      <name>LMAX Disruptor Development Team</name>
-      <email>lmax-disruptor@googlegroups.com</email>
-    </developer>
-  </developers>
-  <scm>
-    <connection>scm:git@github.com:LMAX-Exchange/disruptor.git</connection>
-    <url>scm:git@github.com:LMAX-Exchange/disruptor.git</url>
-  </scm>
-  <dependencies>
-    <dependency>
-      <groupId>junit</groupId>
-      <artifactId>junit</artifactId>
-      <version>4.12</version>
-      <scope>test</scope>
-    </dependency>
-  </dependencies>
-</project>

disruptor-3.3.2-jmock.patch

@@ -0,0 +1,21 @@
+--- disruptor-3.3.2/src/test/java/com/lmax/disruptor/BatchEventProcessorTest.java	2015-02-25 10:09:57.000000000 +0100
++++ disruptor-3.3.2/src/test/java/com/lmax/disruptor/BatchEventProcessorTest.java.jmock	2015-06-03 15:52:43.997446568 +0200
+@@ -23,6 +23,7 @@
+ import org.jmock.api.Action;
+ import org.jmock.api.Invocation;
+ import org.jmock.integration.junit4.JMock;
++import org.jmock.lib.concurrent.Synchroniser;
+ import org.junit.Test;
+ import org.junit.runner.RunWith;
+ 
+@@ -35,7 +36,9 @@
+ @RunWith(JMock.class)
+ public final class BatchEventProcessorTest
+ {
+-    private final Mockery context = new Mockery();
++    private final Mockery context = new Mockery() {{
++        setThreadingPolicy(new Synchroniser());
++    }};
+     private final Sequence lifecycleSequence = context.sequence("lifecycleSequence");
+     private final CountDownLatch latch = new CountDownLatch(1);
+ 

gating.yaml

@@ -0,0 +1,7 @@
+--- !Policy
+product_versions:
+  - rhel-9
+decision_contexts:
+  - osci_compose_gate
+rules:
+  - !PassingTestCaseRule {test_case_name: osci.brew-build.tier0.functional}

plans/Smoke.java

@@ -0,0 +1,51 @@
+import com.lmax.disruptor.dsl.Disruptor;
+import com.lmax.disruptor.EventFactory;
+import com.lmax.disruptor.RingBuffer;
+import com.lmax.disruptor.util.DaemonThreadFactory;
+import java.nio.ByteBuffer;
+
+class LongEvent
+{
+    private long value;
+
+    public void set(long value)
+    {
+        this.value = value;
+    }
+}
+
+class LongEventFactory implements EventFactory<LongEvent>
+{
+    public LongEvent newInstance()
+    {
+        return new LongEvent();
+    }
+}
+
+public class Smoke
+{
+    public static void main(String[] args) throws Exception
+    {
+	System.out.println("SMOKE TEST START");
+
+        int bufferSize = 1024; 
+
+        Disruptor<LongEvent> disruptor = 
+                new Disruptor<>(LongEvent::new, bufferSize, DaemonThreadFactory.INSTANCE);
+
+        disruptor.handleEventsWith((event, sequence, endOfBatch) ->
+                System.out.println("Event: " + event));
+        disruptor.start();
+
+        RingBuffer<LongEvent> ringBuffer = disruptor.getRingBuffer();
+        ByteBuffer bb = ByteBuffer.allocate(8);
+        for (long l = 0; l < 10; l++)
+        {
+            bb.putLong(0, l);
+            ringBuffer.publishEvent((event, sequence, buffer) -> event.set(buffer.getLong(0)), bb);
+            Thread.sleep(100);
+        }
+
+	System.out.println("SMOKE TEST COMPLETE");
+    }
+}

plans/smoke.fmf

@@ -0,0 +1,8 @@
+summary: Basic smoke test
+prepare:
+  how: install
+  package: java-devel
+execute:
+  script:
+    - javac -cp /usr/share/java/disruptor.jar plans/Smoke.java
+    - java -cp /usr/share/java/disruptor.jar:plans Smoke

sources

@@ -0,0 +1,2 @@
+SHA512 (disruptor-3.4.4.tar.gz) = 871d474ecbc4e09d33b0d099232f2abdf88b755141e00406e4a721e5bd6c5edc99c6c446277e054bd603ae9b158bdb6b438aa6e8532194dca9bce953b748bfde
+SHA512 (disruptor-3.4.4.pom) = 32c4ce4267c8dac44803949e68298fabfc399e1ff170a630b531aca2d87b8ec8fdb9a3f379005c512e94c9cfaa25f15bc421023d211c6c6d8ceb3eee1b61ce0d