You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2017/01/09 15:24:40 UTC
[04/34] qpid-proton git commit: PROTON-1385: remove proton-j from the
existing repo, it now has its own repo at:
https://git-wip-us.apache.org/repos/asf/qpid-proton-j.git
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/InteropTest.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/InteropTest.java b/tests/java/org/apache/qpid/proton/InteropTest.java
deleted file mode 100644
index e9b8c58..0000000
--- a/tests/java/org/apache/qpid/proton/InteropTest.java
+++ /dev/null
@@ -1,219 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.qpid.proton;
-
-import org.apache.qpid.proton.amqp.Binary;
-import org.apache.qpid.proton.amqp.DescribedType;
-import org.apache.qpid.proton.amqp.Symbol;
-import org.apache.qpid.proton.amqp.messaging.AmqpValue;
-import org.apache.qpid.proton.codec.AMQPDefinedTypes;
-import org.apache.qpid.proton.codec.Decoder;
-import org.apache.qpid.proton.codec.DecoderImpl;
-import org.apache.qpid.proton.codec.EncoderImpl;
-import org.apache.qpid.proton.message.Message;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertArrayEquals;
-import org.junit.Test;
-import java.lang.System;
-import java.nio.ByteBuffer;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.util.Vector;
-import java.util.List;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.HashMap;
-
-public class InteropTest
-{
-
- static private File findTestsInteropDir()
- {
- File f = new File(System.getProperty("user.dir"));
- while (f != null && !f.getName().equals("tests"))
- f = f.getParentFile();
- if (f != null && f.isDirectory())
- return new File(f, "interop");
- else
- throw new Error("Cannot find tests/interop directory");
- }
-
- static File testsInteropDir = findTestsInteropDir();
-
- byte[] getBytes(String name) throws IOException
- {
- File f = new File(testsInteropDir, name + ".amqp");
- byte[] data = new byte[(int) f.length()];
- FileInputStream fi = new FileInputStream(f);
- assertEquals(f.length(), fi.read(data));
- fi.close();
- return data;
- }
-
- Message decodeMessage(String name) throws IOException
- {
- byte[] data = getBytes(name);
- Message m = Proton.message();
- m.decode(data, 0, data.length);
- return m;
- }
-
- Decoder createDecoder(byte[] data)
- {
- DecoderImpl decoder = new DecoderImpl();
- AMQPDefinedTypes.registerAllTypes(decoder, new EncoderImpl(decoder));
- ByteBuffer buffer = ByteBuffer.allocate(data.length);
- buffer.put(data);
- buffer.rewind();
- decoder.setByteBuffer(buffer);
-
- return decoder;
- }
-
- @Test
- public void testMessage() throws IOException
- {
- Message m = decodeMessage("message");
- Binary b = (Binary) (((AmqpValue) m.getBody()).getValue());
- String s = createDecoder(b.getArray()).readString();
- assertEquals("hello", s);
- }
-
- @Test
- public void testPrimitives() throws IOException
- {
- Decoder d = createDecoder(getBytes("primitives"));
- assertEquals(true, d.readBoolean());
- assertEquals(false, d.readBoolean());
- assertEquals(d.readUnsignedByte().intValue(), 42);
- assertEquals(42, d.readUnsignedShort().intValue());
- assertEquals(-42, d.readShort().intValue());
- assertEquals(12345, d.readUnsignedInteger().intValue());
- assertEquals(-12345, d.readInteger().intValue());
- assertEquals(12345, d.readUnsignedLong().longValue());
- assertEquals(-12345, d.readLong().longValue());
- assertEquals(0.125, d.readFloat().floatValue(), 0e-10);
- assertEquals(0.125, d.readDouble().doubleValue(), 0e-10);
- }
-
- @Test
- public void testStrings() throws IOException
- {
- Decoder d = createDecoder(getBytes("strings"));
- assertEquals(new Binary("abc\0defg".getBytes("UTF-8")), d.readBinary());
- assertEquals("abcdefg", d.readString());
- assertEquals(Symbol.valueOf("abcdefg"), d.readSymbol());
- assertEquals(new Binary(new byte[0]), d.readBinary());
- assertEquals("", d.readString());
- assertEquals(Symbol.valueOf(""), d.readSymbol());
- }
-
- @Test
- public void testDescribed() throws IOException
- {
- Decoder d = createDecoder(getBytes("described"));
- DescribedType dt = (DescribedType) (d.readObject());
- assertEquals(Symbol.valueOf("foo-descriptor"), dt.getDescriptor());
- assertEquals("foo-value", dt.getDescribed());
-
- dt = (DescribedType) (d.readObject());
- assertEquals(12, dt.getDescriptor());
- assertEquals(13, dt.getDescribed());
- }
-
- @Test
- public void testDescribedArray() throws IOException
- {
- Decoder d = createDecoder(getBytes("described_array"));
- DescribedType a[] = (DescribedType[]) (d.readArray());
- for (int i = 0; i < 10; ++i)
- {
- assertEquals(Symbol.valueOf("int-array"), a[i].getDescriptor());
- assertEquals(i, a[i].getDescribed());
- }
- }
-
- @Test
- public void testArrays() throws IOException
- {
- Decoder d = createDecoder(getBytes("arrays"));
-
- // int array
- Vector<Integer> ints = new Vector<Integer>();
- for (int i = 0; i < 100; ++i)
- ints.add(new Integer(i));
- assertArrayEquals(ints.toArray(), d.readArray());
-
- // String array
- String strings[] =
- { "a", "b", "c" };
- assertArrayEquals(strings, d.readArray());
-
- // Empty array
- assertArrayEquals(new Integer[0], d.readArray());
- }
-
- @Test
- public void testLists() throws IOException
- {
- Decoder d = createDecoder(getBytes("lists"));
- List<Object> l = new ArrayList<Object>()
- {
- {
- add(new Integer(32));
- add("foo");
- add(new Boolean(true));
- }
- };
- assertEquals(l, d.readList());
- l.clear();
- assertEquals(l, d.readList());
- }
-
- @SuppressWarnings({ "rawtypes", "unchecked" })
- @Test
- public void testMaps() throws IOException
- {
- Decoder d = createDecoder(getBytes("maps"));
- Map map = new HashMap()
- {
- {
- put("one", 1);
- put("two", 2);
- put("three", 3);
- }
- };
- assertEquals(map, d.readMap());
-
- map = new HashMap()
- {
- {
- put(1, "one");
- put(2, "two");
- put(3, "three");
- }
- };
- assertEquals(map, d.readMap());
-
- map = new HashMap();
- assertEquals(map, d.readMap());
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/JythonTest.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/JythonTest.java b/tests/java/org/apache/qpid/proton/JythonTest.java
deleted file mode 100644
index 23eceab..0000000
--- a/tests/java/org/apache/qpid/proton/JythonTest.java
+++ /dev/null
@@ -1,283 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-package org.apache.qpid.proton;
-
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.junit.Test;
-import org.python.core.PyException;
-import org.python.core.PyString;
-import org.python.core.PySystemState;
-import org.python.util.PythonInterpreter;
-
-/**
- * Runs all the python tests, or just those that match the system property {@value #TEST_PATTERN_SYSTEM_PROPERTY}
- * if it exists.
- * Use {@value #TEST_INVOCATIONS_SYSTEM_PROPERTY} to specify the number of repetitions, or use 0
- * for unlimited repetitions.
- */
-public class JythonTest
-{
- public interface PathBuilder {
- public PathBuilder append(String path);
- }
- private static final Logger LOGGER = Logger.getLogger(JythonTest.class.getName());
-
- /* System properties expected to be defined in test/pom.xml */
- private static final String PROTON_JYTHON_BINDING = "protonJythonBinding";
- private static final String PROTON_JYTHON_SHIM = "protonJythonShim";
- private static final String PROTON_JYTHON_TEST_ROOT = "protonJythonTestRoot";
- private static final String PROTON_JYTHON_TEST_SCRIPT = "protonJythonTestScript";
- private static final String PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY = "protonJythonTestXmlOutputDirectory";
- private static final String PROTON_JYTHON_IGNORE_FILE = "protonJythonIgnoreFile";
-
- /** Name of the junit style xml report to be written by the python test script */
- private static final String XML_REPORT_NAME = "TEST-jython-test-results.xml";
-
- public static final String TEST_PATTERN_SYSTEM_PROPERTY = "proton.pythontest.pattern";
- public static final String IGNORE_FILE_SYSTEM_PROPERTY = "proton.pythontest.ignore_file";
-
- /** The number of times to run the test, or forever if zero */
- public static final String TEST_INVOCATIONS_SYSTEM_PROPERTY = "proton.pythontest.invocations";
-
- public static final String ALWAYS_COLORIZE_SYSTEM_PROPERTY = "proton.pythontest.always_colorize";
-
- @Test
- public void test() throws Exception
- {
- String testScript = getJythonTestScript();
- String testRoot = getJythonTestRoot();
- String xmlReportFile = getOptionalXmlReportFilename();
- String ignoreFile = getOptionalIgnoreFile();
-
- final PythonInterpreter interp = createInterpreterWithArgs(xmlReportFile, ignoreFile);
- PathBuilder pathBuilder = new PathBuilder() {
- @Override
- public PathBuilder append(String path) {
- interp.getSystemState().path.insert(0, new PyString(path));
- return this;
- }
- };
- extendPath(pathBuilder);
-
- LOGGER.info("About to call Jython test script: '" + testScript
- + "' with '" + testRoot + "' added to Jython path");
-
- int maxInvocations = Integer.getInteger(TEST_INVOCATIONS_SYSTEM_PROPERTY, 1);
- assertTrue("Number of invocations should be non-negative", maxInvocations >= 0);
- boolean loopForever = maxInvocations == 0;
- if(maxInvocations > 1)
- {
- LOGGER.info("Will invoke Python test " + maxInvocations + " times");
- }
- if(loopForever)
- {
- LOGGER.info("Will repeatedly invoke Python test forever");
- }
- int invocations = 1;
- while(loopForever || invocations++ <= maxInvocations)
- {
- runTestOnce(testScript, interp, invocations);
- }
- }
-
- protected void extendPath(PathBuilder pathBuilder) throws Exception {
- String binding = getJythonBinding();
- String shim = getJythonShim();
- String testRoot = getJythonTestRoot();
- pathBuilder.append(binding).append(shim).append(testRoot);
-
- }
-
- private void runTestOnce(String testScript, PythonInterpreter interp, int invocationsSoFar)
- {
- try
- {
- interp.execfile(testScript);
- }
- catch (PyException e)
- {
- if( e.type.toString().equals("<type 'exceptions.SystemExit'>") && e.value.toString().equals("0") )
- {
- // Build succeeded.
- }
- else
- {
- if (LOGGER.isLoggable(Level.FINE))
- {
- LOGGER.log(Level.FINE, "Jython interpreter failed. Test failures?", e);
- }
-
- // This unusual code is necessary because PyException toString() contains the useful Python traceback
- // and getMessage() is usually null
- fail("Caught PyException on invocation number " + invocationsSoFar + ": " + e.toString() + " with message: " + e.getMessage());
- }
- }
- }
-
- private PythonInterpreter createInterpreterWithArgs(String xmlReportFile, String ignoreFile)
- {
- PySystemState systemState = new PySystemState();
-
- if (xmlReportFile != null)
- {
- systemState.argv.append(new PyString("--xml"));
- systemState.argv.append(new PyString(xmlReportFile));
- }
-
- if(ignoreFile == null)
- {
- ignoreFile = System.getProperty(IGNORE_FILE_SYSTEM_PROPERTY);
- }
-
- if(ignoreFile != null)
- {
- systemState.argv.append(new PyString("-I"));
- systemState.argv.append(new PyString(ignoreFile));
- }
-
- String testPattern = System.getProperty(TEST_PATTERN_SYSTEM_PROPERTY);
- if(testPattern != null)
- {
- systemState.argv.append(new PyString(testPattern));
- }
-
- if(Boolean.getBoolean(ALWAYS_COLORIZE_SYSTEM_PROPERTY))
- {
- systemState.argv.append(new PyString("--always-colorize"));
- }
-
- PythonInterpreter interp = new PythonInterpreter(null, systemState);
- return interp;
- }
-
- private String getJythonTestScript() throws FileNotFoundException
- {
- String testScriptString = getNonNullSystemProperty(PROTON_JYTHON_TEST_SCRIPT, "System property '%s' must provide the location of the python test script");
- File testScript = new File(testScriptString);
- if (!testScript.canRead())
- {
- throw new FileNotFoundException("Can't read python test script " + testScript);
- }
- return testScript.getAbsolutePath();
- }
-
- private String getJythonBinding() throws FileNotFoundException
- {
- String str = getNonNullSystemProperty(PROTON_JYTHON_BINDING, "System property '%s' must provide the location of the proton python binding");
- File file = new File(str);
- if (!file.isDirectory())
- {
- throw new FileNotFoundException("Binding location '" + file + "' should be a directory.");
- }
- return file.getAbsolutePath();
- }
-
- private String getJythonShim() throws FileNotFoundException
- {
- String str = getNonNullSystemProperty(PROTON_JYTHON_SHIM, "System property '%s' must provide the location of the proton jython shim");
- File file = new File(str);
- if (!file.isDirectory())
- {
- throw new FileNotFoundException("Shim location '" + file + "' should be a directory.");
- }
- return file.getAbsolutePath();
- }
-
-
- private String getJythonTestRoot() throws FileNotFoundException
- {
- String testRootString = getNonNullSystemProperty(PROTON_JYTHON_TEST_ROOT, "System property '%s' must provide the location of the python test root");
- File testRoot = new File(testRootString);
- if (!testRoot.isDirectory())
- {
- throw new FileNotFoundException("Test root '" + testRoot + "' should be a directory.");
- }
- return testRoot.getAbsolutePath();
- }
-
- private String getOptionalIgnoreFile()
- {
- String ignoreFile = System.getProperty(PROTON_JYTHON_IGNORE_FILE);
-
- if(ignoreFile != null)
- {
- File f = new File(ignoreFile);
- if(f.exists() && f.canRead())
- {
- return ignoreFile;
- }
- else
- {
- LOGGER.info(PROTON_JYTHON_IGNORE_FILE + " system property set to " + ignoreFile + " but this cannot be read.");
- }
- }
- return null;
-
- }
-
- private String getOptionalXmlReportFilename()
- {
- String xmlOutputDirString = System.getProperty(PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY);
- if (xmlOutputDirString == null)
- {
- LOGGER.info(PROTON_JYTHON_TESTS_XML_OUTPUT_DIRECTORY + " system property not set; xml output will not be written");
- }
-
- File xmlOutputDir = new File(xmlOutputDirString);
- createXmlOutputDirectoryIfNecessary(xmlOutputDirString, xmlOutputDir);
- return new File(xmlOutputDir, XML_REPORT_NAME).getAbsolutePath();
- }
-
- private void createXmlOutputDirectoryIfNecessary(String xmlOutputDirString, File xmlOutputDir)
- {
- if (!xmlOutputDir.isDirectory())
- {
- boolean success = xmlOutputDir.mkdirs();
- if (!success)
- {
- LOGGER.warning("Failed to create directory " + xmlOutputDir + " Thread name :" + Thread.currentThread().getName());
- }
-
- if (!xmlOutputDir.isDirectory())
- {
- throw new RuntimeException("Failed to create one or more directories with path " + xmlOutputDirString);
- }
- }
- }
-
- protected String getNonNullSystemProperty(String systemProperty, String messageWithStringFormatToken)
- {
- String testScriptString = System.getProperty(systemProperty);
- if (testScriptString == null)
- {
- String message = messageWithStringFormatToken;
- throw new IllegalStateException(String.format(message, systemProperty));
- }
- return testScriptString;
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/org/apache/qpid/proton/ProtonJInterop.java
----------------------------------------------------------------------
diff --git a/tests/java/org/apache/qpid/proton/ProtonJInterop.java b/tests/java/org/apache/qpid/proton/ProtonJInterop.java
deleted file mode 100644
index 58a9c31..0000000
--- a/tests/java/org/apache/qpid/proton/ProtonJInterop.java
+++ /dev/null
@@ -1,205 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.proton;
-
-import java.io.IOException;
-import java.nio.BufferOverflowException;
-
-import org.apache.qpid.proton.amqp.messaging.AmqpValue;
-import org.apache.qpid.proton.amqp.transport.ErrorCondition;
-import org.apache.qpid.proton.engine.BaseHandler;
-import org.apache.qpid.proton.engine.Connection;
-import org.apache.qpid.proton.engine.Delivery;
-import org.apache.qpid.proton.engine.EndpointState;
-import org.apache.qpid.proton.engine.Event;
-import org.apache.qpid.proton.engine.Receiver;
-import org.apache.qpid.proton.engine.Sender;
-import org.apache.qpid.proton.engine.Session;
-import org.apache.qpid.proton.message.Message;
-import org.apache.qpid.proton.reactor.Acceptor;
-import org.apache.qpid.proton.reactor.FlowController;
-import org.apache.qpid.proton.reactor.Handshaker;
-import org.apache.qpid.proton.reactor.Reactor;
-
-public class ProtonJInterop {
-
- private static class SendHandler extends BaseHandler {
-
- private int numMsgs;
- private int count = 0;
- private boolean result = false;
-
- private SendHandler(int numMsgs) {
- this.numMsgs = numMsgs;
- add(new Handshaker());
- }
-
- @Override
- public void onConnectionInit(Event event) {
- Connection conn = event.getConnection();
- Session ssn = conn.session();
- Sender snd = ssn.sender("sender");
- conn.open();
- ssn.open();
- snd.open();
- }
-
- @Override
- public void onLinkFlow(Event event) {
- Sender snd = (Sender)event.getLink();
- if (snd.getCredit() > 0 && snd.getLocalState() != EndpointState.CLOSED) {
- Message message = Proton.message();
- ++count;
- message.setBody(new AmqpValue("message-"+count));
- byte[] msgData = new byte[1024];
- int length;
- while(true) {
- try {
- length = message.encode(msgData, 0, msgData.length);
- break;
- } catch(BufferOverflowException e) {
- msgData = new byte[msgData.length * 2];
- }
- }
- byte[] tag = String.valueOf(count).getBytes();
- Delivery dlv = snd.delivery(tag);
- snd.send(msgData, 0, length);
- dlv.settle();
- snd.advance();
- if (count == numMsgs) {
- snd.close();
- snd.getSession().close();
- snd.getSession().getConnection().close();
- result = true;
- }
- }
- }
-
- @Override
- public void onTransportError(Event event) {
- result = false;
- ErrorCondition condition = event.getTransport().getCondition();
- if (condition != null) {
- System.err.println("Error: " + condition.getDescription());
- } else {
- System.err.println("Error (no description returned).");
- }
- }
- }
-
- private static class Send extends BaseHandler {
- private final SendHandler sendHandler;
- private final String host;
- private final int port;
-
- private Send(String host, int port, int numMsgs) {
- this.host = host;
- this.port = port;
- sendHandler = new SendHandler(numMsgs);
- }
-
- @Override
- public void onReactorInit(Event event) {
- Reactor r = event.getReactor();
- r.connectionToHost(host, port, sendHandler);
- }
-
- public boolean getResult() {
- return sendHandler.result;
- }
- }
-
- private static class Recv extends BaseHandler {
- private final int port;
- private final int numMsgs;
- private int count = 0;
- private Acceptor acceptor = null;
-
- private Recv(int port, int numMsgs) {
- this.port = port;
- this.numMsgs = numMsgs;
- add(new Handshaker());
- add(new FlowController());
- }
-
- @Override
- public void onReactorInit(Event event) {
- try {
- acceptor = event.getReactor().acceptor("localhost", port);
- } catch(IOException ioException) {
- throw new RuntimeException(ioException);
- }
- }
-
- @Override
- public void onDelivery(Event event) {
- Receiver recv = (Receiver)event.getLink();
- Delivery delivery = recv.current();
- if (delivery.isReadable() && !delivery.isPartial()) {
- int size = delivery.pending();
- byte[] buffer = new byte[size];
- int read = recv.recv(buffer, 0, buffer.length);
- recv.advance();
-
- Message msg = Proton.message();
- msg.decode(buffer, 0, read);
-
- ++count;
- String msgBody = ((AmqpValue)msg.getBody()).getValue().toString();
- String expected = "message-" + count;
- if (!expected.equals(msgBody)) {
- throw new RuntimeException("Received message body '" + msgBody + "', expected: '" + expected + "'");
- }
-
- if (count == numMsgs) {
- recv.close();
- recv.getSession().close();
- recv.getSession().getConnection().close();
- acceptor.close();
- }
- }
- }
- }
-
- public static void main(String[] args) throws IOException {
- try {
- int port = Integer.valueOf(args[1]);
- int numMsgs = Integer.valueOf(args[2]);
- boolean result = false;
-
- if ("send".equalsIgnoreCase(args[0])) {
- Send send = new Send("localhost", port, numMsgs);
- Reactor r = Proton.reactor(send);
- r.run();
- result = send.getResult();
- } else {
- Reactor r = Proton.reactor(new Recv(port, numMsgs));
- r.run();
- result = true;
- }
- System.exit(result ? 0 : 1);
- } catch(Throwable t) {
- t.printStackTrace();
- System.exit(1);
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/pythonTests.ignore
----------------------------------------------------------------------
diff --git a/tests/java/pythonTests.ignore b/tests/java/pythonTests.ignore
deleted file mode 100644
index 7911176..0000000
--- a/tests/java/pythonTests.ignore
+++ /dev/null
@@ -1,4 +0,0 @@
-proton_tests.reactor_interop.*
-proton_tests.soak.*
-proton_tests.ssl.SslTest.test_defaults_messenger_app
-proton_tests.ssl.SslTest.test_server_authentication_messenger_app
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/ccodec.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/ccodec.py b/tests/java/shim/ccodec.py
deleted file mode 100644
index 0aa9499..0000000
--- a/tests/java/shim/ccodec.py
+++ /dev/null
@@ -1,356 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp import Symbol, UnsignedByte, UnsignedInteger, \
- UnsignedShort, UnsignedLong, Decimal32, Decimal64, Decimal128
-from org.apache.qpid.proton.codec.Data import DataType
-from cerror import *
-
-from java.util import UUID as JUUID, Date as JDate
-from java.nio import ByteBuffer
-from compat import array, zeros
-
-# from proton/codec.h
-PN_NULL = 1
-PN_BOOL = 2
-PN_UBYTE = 3
-PN_BYTE = 4
-PN_USHORT = 5
-PN_SHORT = 6
-PN_UINT = 7
-PN_INT = 8
-PN_CHAR = 9
-PN_ULONG = 10
-PN_LONG = 11
-PN_TIMESTAMP = 12
-PN_FLOAT = 13
-PN_DOUBLE = 14
-PN_DECIMAL32 = 15
-PN_DECIMAL64 = 16
-PN_DECIMAL128 = 17
-PN_UUID = 18
-PN_BINARY = 19
-PN_STRING = 20
-PN_SYMBOL = 21
-PN_DESCRIBED = 22
-PN_ARRAY = 23
-PN_LIST = 24
-PN_MAP = 25
-
-DATA_TYPES_J2P = {}
-DATA_TYPES_P2J = {}
-
-def DATA_TYPES(jtype, ptype):
- DATA_TYPES_J2P[jtype] = ptype
- DATA_TYPES_P2J[ptype] = jtype
-
-DATA_TYPES(DataType.NULL, PN_NULL)
-DATA_TYPES(DataType.BOOL, PN_BOOL)
-DATA_TYPES(DataType.BYTE, PN_BYTE)
-DATA_TYPES(DataType.UBYTE, PN_UBYTE)
-DATA_TYPES(DataType.USHORT, PN_USHORT)
-DATA_TYPES(DataType.UINT, PN_UINT)
-DATA_TYPES(DataType.ULONG, PN_ULONG)
-DATA_TYPES(DataType.SHORT, PN_SHORT)
-DATA_TYPES(DataType.INT, PN_INT)
-DATA_TYPES(DataType.LONG, PN_LONG)
-DATA_TYPES(DataType.CHAR, PN_CHAR)
-DATA_TYPES(DataType.TIMESTAMP, PN_TIMESTAMP)
-DATA_TYPES(DataType.FLOAT, PN_FLOAT)
-DATA_TYPES(DataType.DOUBLE, PN_DOUBLE)
-DATA_TYPES(DataType.DECIMAL32, PN_DECIMAL32)
-DATA_TYPES(DataType.DECIMAL64, PN_DECIMAL64)
-DATA_TYPES(DataType.DECIMAL128, PN_DECIMAL128)
-DATA_TYPES(DataType.BINARY, PN_BINARY)
-DATA_TYPES(DataType.STRING, PN_STRING)
-DATA_TYPES(DataType.SYMBOL, PN_SYMBOL)
-DATA_TYPES(DataType.UUID, PN_UUID)
-DATA_TYPES(DataType.LIST, PN_LIST)
-DATA_TYPES(DataType.MAP, PN_MAP)
-DATA_TYPES(DataType.ARRAY, PN_ARRAY)
-DATA_TYPES(DataType.DESCRIBED, PN_DESCRIBED)
-
-def pn_data(capacity):
- return Proton.data(capacity)
-
-def pn_data_put_null(data):
- data.putNull()
- return 0
-
-def pn_data_put_bool(data, b):
- data.putBoolean(b)
- return 0
-
-def pn_data_get_bool(data):
- return data.getBoolean()
-
-def pn_data_get_byte(data):
- return data.getByte()
-
-def pn_data_put_byte(data, u):
- data.putByte(u)
- return 0
-
-def pn_data_get_ubyte(data):
- return data.getUnsignedByte().longValue()
-
-def pn_data_put_ubyte(data, u):
- data.putUnsignedByte(UnsignedByte.valueOf(u))
- return 0
-
-def pn_data_get_ushort(data):
- return data.getUnsignedShort().longValue()
-
-def pn_data_put_ushort(data, u):
- data.putUnsignedShort(UnsignedShort.valueOf(u))
- return 0
-
-def pn_data_get_uint(data):
- return data.getUnsignedInteger().longValue()
-
-def pn_data_put_uint(data, u):
- data.putUnsignedInteger(UnsignedInteger.valueOf(u))
- return 0
-
-def pn_data_put_ulong(data, u):
- data.putUnsignedLong(UnsignedLong.valueOf(u))
- return 0
-
-BITS_64 = 2**64 - 1;
-
-def pn_data_get_ulong(data):
- value = data.getUnsignedLong().longValue()
- if value < 0:
- return value & BITS_64;
- return value
-
-def pn_data_get_short(data):
- return data.getShort()
-
-def pn_data_put_short(data, s):
- data.putShort(s)
- return 0
-
-def pn_data_put_int(data, i):
- data.putInt(i)
- return 0
-
-def pn_data_get_int(data):
- return data.getInt()
-
-def pn_data_put_long(data, l):
- data.putLong(l)
- return 0
-
-def pn_data_get_long(data):
- return data.getLong()
-
-def pn_data_put_char(data, c):
- data.putChar(c)
- return 0
-
-def pn_data_get_char(data):
- return data.getChar()
-
-def pn_data_put_timestamp(data, t):
- data.putTimestamp(JDate(t))
- return 0
-
-def pn_data_get_timestamp(data):
- return data.getTimestamp().getTime()
-
-def pn_data_put_float(data, f):
- data.putFloat(f)
- return 0
-
-def pn_data_get_float(data):
- return data.getFloat()
-
-def pn_data_put_double(data, d):
- data.putDouble(d)
- return 0
-
-def pn_data_get_double(data):
- return data.getDouble()
-
-def pn_data_put_decimal32(data, d):
- data.putDecimal32(Decimal32(d))
- return 0
-
-def pn_data_get_decimal32(data):
- return data.getDecimal32().getBits()
-
-def pn_data_put_decimal64(data, d):
- data.putDecimal64(Decimal64(d))
- return 0
-
-def pn_data_get_decimal64(data):
- return data.getDecimal64().getBits()
-
-def pn_data_put_decimal128(data, d):
- data.putDecimal128(Decimal128(array(d, 'b')))
- return 0
-
-def pn_data_get_decimal128(data):
- return data.getDecimal128().asBytes().tostring()
-
-def pn_data_put_binary(data, b):
- data.putBinary(array(b, 'b'))
- return 0
-
-def pn_data_get_binary(data):
- return data.getBinary().getArray().tostring()
-
-def pn_data_put_string(data, s):
- data.putString(s)
- return 0
-
-def pn_data_get_string(data):
- return data.getString()
-
-def pn_data_put_symbol(data, s):
- data.putSymbol(Symbol.valueOf(s))
- return 0
-
-def pn_data_get_symbol(data):
- return data.getSymbol().toString()
-
-def pn_data_put_uuid(data, u):
- bb = ByteBuffer.wrap(array(u, 'b'))
- first = bb.getLong()
- second = bb.getLong()
- data.putUUID(JUUID(first, second))
- return 0
-
-def pn_data_get_uuid(data):
- u = data.getUUID()
- ba = zeros(16, 'b')
- bb = ByteBuffer.wrap(ba)
- bb.putLong(u.getMostSignificantBits())
- bb.putLong(u.getLeastSignificantBits())
- return ba.tostring()
-
-def pn_data_put_list(data):
- data.putList()
- return 0
-
-def pn_data_get_list(data):
- return data.getList()
-
-def pn_data_put_map(data):
- data.putMap()
- return 0
-
-def pn_data_put_array(data, described, type):
- data.putArray(described, DATA_TYPES_P2J[type])
- return 0
-
-def pn_data_get_array(data):
- return data.getArray()
-
-def pn_data_is_array_described(data):
- return data.isArrayDescribed()
-
-def pn_data_get_array_type(data):
- return DATA_TYPES_J2P[data.getArrayType()]
-
-def pn_data_put_described(data):
- data.putDescribed()
- return 0
-
-def pn_data_rewind(data):
- data.rewind()
-
-def pn_data_next(data):
- t = data.next()
- return t != None
-
-def pn_data_enter(data):
- return data.enter()
-
-def pn_data_exit(data):
- return data.exit()
-
-def pn_data_type(data):
- t = data.type()
- if t is None:
- return -1
- else:
- return DATA_TYPES_J2P[t]
-
-def pn_data_encode(data, size):
- enc = data.encode().getArray().tostring()
- if len(enc) > size:
- return PN_OVERFLOW, None
- else:
- return len(enc), enc
-
-def pn_data_encoded_size(data):
- return data.encodedSize()
-
-def pn_data_decode(data, encoded):
- return data.decode(ByteBuffer.wrap(array(encoded, 'b')))
-
-def pn_data_narrow(data):
- data.narrow()
-
-def pn_data_widen(data):
- data.widen()
-
-def pn_data_copy(data, src):
- data.copy(src)
-
-def pn_data_format(data, n):
- return 0, data.format()
-
-def pn_data_clear(data):
- data.clear()
-
-def pn_data_free(data):
- pass
-
-def dat2obj(dat):
- dat.rewind()
- if dat.next():
- return dat.getObject()
- else:
- return None
-
-def obj2dat(obj, dat=None):
- if dat is None:
- dat = pn_data(0)
- else:
- dat.clear()
- if obj:
- dat.putObject(obj)
- dat.rewind()
- return dat
-
-def array2dat(ary, atype, dat=None):
- if dat is None:
- dat = pn_data(0)
- else:
- dat.clear()
- if ary:
- pn_data_put_array(dat, False, atype)
- pn_data_enter(dat)
- for o in ary:
- dat.putObject(o)
- dat.rewind()
- return dat
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cengine.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cengine.py b/tests/java/shim/cengine.py
deleted file mode 100644
index 141c482..0000000
--- a/tests/java/shim/cengine.py
+++ /dev/null
@@ -1,1139 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp import Symbol
-from org.apache.qpid.proton.amqp.messaging import Source, Target, \
- TerminusDurability, TerminusExpiryPolicy, Received, Accepted, \
- Rejected, Released, Modified
-from org.apache.qpid.proton.amqp.transaction import Coordinator
-from org.apache.qpid.proton.amqp.transport import ErrorCondition, \
- SenderSettleMode, ReceiverSettleMode
-from org.apache.qpid.proton.engine import EndpointState, Sender, \
- Receiver, Transport as _Transport, TransportException, EventType
-
-from java.util import EnumSet
-from compat import array, zeros
-
-from cerror import *
-from ccodec import *
-
-# from proton/engine.h
-PN_LOCAL_UNINIT = 1
-PN_LOCAL_ACTIVE = 2
-PN_LOCAL_CLOSED = 4
-PN_REMOTE_UNINIT = 8
-PN_REMOTE_ACTIVE = 16
-PN_REMOTE_CLOSED = 32
-
-PN_SND_UNSETTLED = 0
-PN_SND_SETTLED = 1
-PN_SND_MIXED = 2
-
-PN_RCV_FIRST = 0
-PN_RCV_SECOND = 1
-
-PN_UNSPECIFIED = 0
-PN_SOURCE = 1
-PN_TARGET = 2
-PN_COORDINATOR = 3
-
-PN_NONDURABLE = 0
-PN_CONFIGURATION = 1
-PN_DELIVERIES = 2
-
-PN_EXPIRE_WITH_LINK = 0
-PN_EXPIRE_WITH_SESSION = 1
-PN_EXPIRE_WITH_CONNECTION = 2
-PN_EXPIRE_NEVER = 3
-
-PN_DIST_MODE_UNSPECIFIED = 0
-PN_DIST_MODE_COPY = 1
-PN_DIST_MODE_MOVE = 2
-
-PN_RECEIVED = (0x0000000000000023)
-PN_ACCEPTED = (0x0000000000000024)
-PN_REJECTED = (0x0000000000000025)
-PN_RELEASED = (0x0000000000000026)
-PN_MODIFIED = (0x0000000000000027)
-
-PN_TRACE_OFF = _Transport.TRACE_OFF
-PN_TRACE_RAW = _Transport.TRACE_RAW
-PN_TRACE_FRM = _Transport.TRACE_FRM
-PN_TRACE_DRV = _Transport.TRACE_DRV
-
-def wrap(obj, wrapper):
- if obj:
- ctx = obj.getContext()
- if not ctx:
- ctx = wrapper(obj)
- obj.setContext(ctx)
- return ctx
-
-class pn_condition:
-
- def __init__(self):
- self.name = None
- self.description = None
- self.info = pn_data(0)
-
- def decode(self, impl):
- if impl is None:
- self.name = None
- self.description = None
- self.info.clear()
- else:
- cond = impl.getCondition()
- if cond is None:
- self.name = None
- else:
- self.name = cond.toString()
- self.description = impl.getDescription()
- obj2dat(impl.getInfo(), self.info)
-
- def encode(self):
- if self.name is None:
- return None
- else:
- impl = ErrorCondition()
- impl.setCondition(Symbol.valueOf(self.name))
- impl.setDescription(self.description)
- impl.setInfo(dat2obj(self.info))
- return impl
-
-def pn_condition_is_set(cond):
- return bool(cond.name)
-
-def pn_condition_get_name(cond):
- return cond.name
-
-def pn_condition_set_name(cond, name):
- cond.name = name
-
-def pn_condition_get_description(cond):
- return cond.description
-
-def pn_condition_set_description(cond, description):
- cond.description = description
-
-def pn_condition_clear(cond):
- cond.name = None
- cond.description = None
- cond.info.clear()
-
-def pn_condition_info(cond):
- return cond.info
-
-class endpoint_wrapper:
-
- def __init__(self, impl):
- self.impl = impl
- self.condition = pn_condition()
- self.remote_condition = pn_condition()
-
- def on_close(self):
- cond = self.condition.encode()
- if cond:
- self.impl.setCondition(cond)
-
-def remote_condition(self):
- self.remote_condition.decode(self.impl.getRemoteCondition())
- return self.remote_condition
-
-class pn_connection_wrapper(endpoint_wrapper):
-
- def __init__(self, impl):
- endpoint_wrapper.__init__(self, impl)
- self.properties = pn_data(0)
- self.offered_capabilities = pn_data(0)
- self.desired_capabilities = pn_data(0)
-
-def pn_connection():
- return wrap(Proton.connection(), pn_connection_wrapper)
-
-def set2mask(local, remote):
- mask = 0
- if local.contains(EndpointState.UNINITIALIZED):
- mask |= PN_LOCAL_UNINIT
- if local.contains(EndpointState.ACTIVE):
- mask |= PN_LOCAL_ACTIVE
- if local.contains(EndpointState.CLOSED):
- mask |= PN_LOCAL_CLOSED
- if remote.contains(EndpointState.UNINITIALIZED):
- mask |= PN_REMOTE_UNINIT
- if remote.contains(EndpointState.ACTIVE):
- mask |= PN_REMOTE_ACTIVE
- if remote.contains(EndpointState.CLOSED):
- mask |= PN_REMOTE_CLOSED
- return mask
-
-def endpoint_state(impl):
- return set2mask(EnumSet.of(impl.getLocalState()),
- EnumSet.of(impl.getRemoteState()))
-
-def pn_connection_state(conn):
- return endpoint_state(conn.impl)
-
-def pn_connection_condition(conn):
- return conn.condition
-
-def pn_connection_remote_condition(conn):
- return remote_condition(conn)
-
-def pn_connection_properties(conn):
- return conn.properties
-
-def pn_connection_remote_properties(conn):
- return obj2dat(conn.impl.getRemoteProperties())
-
-def pn_connection_offered_capabilities(conn):
- return conn.offered_capabilities
-
-def pn_connection_remote_offered_capabilities(conn):
- return array2dat(conn.impl.getRemoteOfferedCapabilities(), PN_SYMBOL)
-
-def pn_connection_desired_capabilities(conn):
- return conn.desired_capabilities
-
-def pn_connection_remote_desired_capabilities(conn):
- return array2dat(conn.impl.getRemoteDesiredCapabilities(), PN_SYMBOL)
-
-def pn_connection_attachments(conn):
- return conn.impl.attachments()
-
-def pn_connection_set_container(conn, name):
- conn.impl.setContainer(name)
-
-def pn_connection_get_container(conn):
- return conn.impl.getContainer()
-
-def pn_connection_remote_container(conn):
- return conn.impl.getRemoteContainer()
-
-def pn_connection_get_hostname(conn):
- return conn.impl.getHostname()
-
-def pn_connection_set_hostname(conn, name):
- conn.impl.setHostname(name)
-
-def pn_connection_remote_hostname(conn):
- return conn.impl.getRemoteHostname()
-
-def pn_connection_open(conn):
- props = dat2obj(conn.properties)
- offered = dat2obj(conn.offered_capabilities)
- desired = dat2obj(conn.desired_capabilities)
- if props:
- conn.impl.setProperties(props)
- if offered:
- conn.impl.setOfferedCapabilities(array(list(offered), Symbol))
- if desired:
- conn.impl.setDesiredCapabilities(array(list(desired), Symbol))
- conn.impl.open()
-
-def pn_connection_close(conn):
- conn.on_close()
- conn.impl.close()
-
-def pn_connection_release(conn):
- conn.impl.free()
-
-def pn_connection_transport(conn):
- return wrap(conn.impl.getTransport(), pn_transport_wrapper)
-
-class pn_session_wrapper(endpoint_wrapper):
- pass
-
-def pn_session(conn):
- return wrap(conn.impl.session(), pn_session_wrapper)
-
-def pn_session_attachments(ssn):
- return ssn.impl.attachments()
-
-def pn_session_state(ssn):
- return endpoint_state(ssn.impl)
-
-def pn_session_get_incoming_capacity(ssn):
- return ssn.impl.getIncomingCapacity()
-
-def pn_session_set_incoming_capacity(ssn, capacity):
- ssn.impl.setIncomingCapacity(capacity)
-
-def pn_session_incoming_bytes(ssn):
- return ssn.impl.getIncomingBytes()
-
-def pn_session_outgoing_bytes(ssn):
- return ssn.impl.getOutgoingBytes()
-
-def pn_session_get_outgoing_window(ssn):
- return ssn.impl.getOutgoingWindow()
-
-def pn_session_set_outgoing_window(ssn, window):
- ssn.impl.setOutgoingWindow(window)
-
-def pn_session_condition(ssn):
- return ssn.condition
-
-def pn_session_remote_condition(ssn):
- return remote_condition(ssn)
-
-def pn_session_open(ssn):
- ssn.impl.open()
-
-def pn_session_close(ssn):
- ssn.on_close()
- ssn.impl.close()
-
-def mask2set(mask):
- local = []
- remote = []
- if PN_LOCAL_UNINIT & mask:
- local.append(EndpointState.UNINITIALIZED)
- if PN_LOCAL_ACTIVE & mask:
- local.append(EndpointState.ACTIVE)
- if PN_LOCAL_CLOSED & mask:
- local.append(EndpointState.CLOSED)
- if PN_REMOTE_UNINIT & mask:
- remote.append(EndpointState.UNINITIALIZED)
- if PN_REMOTE_ACTIVE & mask:
- remote.append(EndpointState.ACTIVE)
- if PN_REMOTE_CLOSED & mask:
- remote.append(EndpointState.CLOSED)
-
- if local:
- local = EnumSet.of(*local)
- else:
- local = None
- if remote:
- remote = EnumSet.of(*remote)
- else:
- remote = None
-
- return local, remote
-
-def pn_session_head(conn, mask):
- local, remote = mask2set(mask)
- return wrap(conn.impl.sessionHead(local, remote), pn_session_wrapper)
-
-def pn_session_connection(ssn):
- return wrap(ssn.impl.getConnection(), pn_connection_wrapper)
-
-def pn_sender(ssn, name):
- return wrap(ssn.impl.sender(name), pn_link_wrapper)
-
-def pn_receiver(ssn, name):
- return wrap(ssn.impl.receiver(name), pn_link_wrapper)
-
-def pn_session_free(ssn):
- ssn.impl.free()
-
-TERMINUS_TYPES_J2P = {
- Source: PN_SOURCE,
- Target: PN_TARGET,
- Coordinator: PN_COORDINATOR,
- None.__class__: PN_UNSPECIFIED
-}
-
-TERMINUS_TYPES_P2J = {
- PN_SOURCE: Source,
- PN_TARGET: Target,
- PN_COORDINATOR: Coordinator,
- PN_UNSPECIFIED: lambda: None
-}
-
-DURABILITY_P2J = {
- PN_NONDURABLE: TerminusDurability.NONE,
- PN_CONFIGURATION: TerminusDurability.CONFIGURATION,
- PN_DELIVERIES: TerminusDurability.UNSETTLED_STATE
-}
-
-DURABILITY_J2P = {
- TerminusDurability.NONE: PN_NONDURABLE,
- TerminusDurability.CONFIGURATION: PN_CONFIGURATION,
- TerminusDurability.UNSETTLED_STATE: PN_DELIVERIES
-}
-
-EXPIRY_POLICY_P2J = {
- PN_EXPIRE_WITH_LINK: TerminusExpiryPolicy.LINK_DETACH,
- PN_EXPIRE_WITH_SESSION: TerminusExpiryPolicy.SESSION_END,
- PN_EXPIRE_WITH_CONNECTION: TerminusExpiryPolicy.CONNECTION_CLOSE,
- PN_EXPIRE_NEVER: TerminusExpiryPolicy.NEVER
-}
-
-EXPIRY_POLICY_J2P = {
- TerminusExpiryPolicy.LINK_DETACH: PN_EXPIRE_WITH_LINK,
- TerminusExpiryPolicy.SESSION_END: PN_EXPIRE_WITH_SESSION,
- TerminusExpiryPolicy.CONNECTION_CLOSE: PN_EXPIRE_WITH_CONNECTION,
- TerminusExpiryPolicy.NEVER: PN_EXPIRE_NEVER
-}
-
-DISTRIBUTION_MODE_P2J = {
- PN_DIST_MODE_UNSPECIFIED: None,
- PN_DIST_MODE_COPY: Symbol.valueOf("copy"),
- PN_DIST_MODE_MOVE: Symbol.valueOf("move")
-}
-
-DISTRIBUTION_MODE_J2P = {
- None: PN_DIST_MODE_UNSPECIFIED,
- Symbol.valueOf("copy"): PN_DIST_MODE_COPY,
- Symbol.valueOf("move"): PN_DIST_MODE_MOVE
-}
-
-class pn_terminus:
-
- def __init__(self, type):
- self.type = type
- self.address = None
- self.durability = PN_NONDURABLE
- self.expiry_policy = PN_EXPIRE_WITH_SESSION
- self.distribution_mode = PN_DIST_MODE_UNSPECIFIED
- self.timeout = 0
- self.dynamic = False
- self.properties = pn_data(0)
- self.capabilities = pn_data(0)
- self.outcomes = pn_data(0)
- self.filter = pn_data(0)
-
- def copy(self, src):
- self.type = src.type
- self.address = src.address
- self.durability = src.durability
- self.expiry_policy = src.expiry_policy
- self.timeout = src.timeout
- self.dynamic = src.dynamic
- self.properties = src.properties
- self.capabilities = src.capabilities
- self.outcomes = src.outcomes
- self.filter = src.filter
-
- def decode(self, impl):
- if impl is not None:
- self.type = TERMINUS_TYPES_J2P[impl.__class__]
- if self.type in (PN_SOURCE, PN_TARGET):
- self.address = impl.getAddress()
- self.durability = DURABILITY_J2P[impl.getDurable()]
- self.expiry_policy = EXPIRY_POLICY_J2P[impl.getExpiryPolicy()]
- self.timeout = impl.getTimeout().longValue()
- self.dynamic = impl.getDynamic()
- obj2dat(impl.getDynamicNodeProperties(), self.properties)
- array2dat(impl.getCapabilities(), PN_SYMBOL, self.capabilities)
- if self.type == PN_SOURCE:
- self.distribution_mode = DISTRIBUTION_MODE_J2P[impl.getDistributionMode()]
- array2dat(impl.getOutcomes(), PN_SYMBOL, self.outcomes)
- obj2dat(impl.getFilter(), self.filter)
-
- def encode(self):
- impl = TERMINUS_TYPES_P2J[self.type]()
- if self.type in (PN_SOURCE, PN_TARGET):
- impl.setAddress(self.address)
- impl.setDurable(DURABILITY_P2J[self.durability])
- impl.setExpiryPolicy(EXPIRY_POLICY_P2J[self.expiry_policy])
- impl.setTimeout(UnsignedInteger.valueOf(self.timeout))
- impl.setDynamic(self.dynamic)
- props = dat2obj(self.properties)
- caps = dat2obj(self.capabilities)
- if props: impl.setDynamicNodeProperties(props)
- if caps:
- impl.setCapabilities(*array(list(caps), Symbol))
- if self.type == PN_SOURCE:
- impl.setDistributionMode(DISTRIBUTION_MODE_P2J[self.distribution_mode])
- outcomes = dat2obj(self.outcomes)
- filter = dat2obj(self.filter)
- if outcomes: impl.setOutcomes(outcomes)
- if filter: impl.setFilter(filter)
- return impl
-
-def pn_terminus_get_type(terminus):
- return terminus.type
-
-def pn_terminus_set_type(terminus, type):
- terminus.type = type
- return 0
-
-def pn_terminus_get_address(terminus):
- return terminus.address
-
-def pn_terminus_set_address(terminus, address):
- terminus.address = address
- return 0
-
-def pn_terminus_get_durability(terminus):
- return terminus.durability
-
-def pn_terminus_get_expiry_policy(terminus):
- return terminus.expiry_policy
-
-def pn_terminus_set_timeout(terminus, timeout):
- terminus.timeout = timeout
- return 0
-
-def pn_terminus_get_timeout(terminus):
- return terminus.timeout
-
-def pn_terminus_get_distribution_mode(terminus):
- return terminus.distribution_mode
-
-def pn_terminus_set_distribution_mode(terminus, mode):
- terminus.distribution_mode = mode
- return 0
-
-def pn_terminus_is_dynamic(terminus):
- return terminus.dynamic
-
-def pn_terminus_set_dynamic(terminus, dynamic):
- terminus.dynamic = dynamic
- return 0
-
-def pn_terminus_properties(terminus):
- return terminus.properties
-
-def pn_terminus_capabilities(terminus):
- return terminus.capabilities
-
-def pn_terminus_outcomes(terminus):
- return terminus.outcomes
-
-def pn_terminus_filter(terminus):
- return terminus.filter
-
-def pn_terminus_copy(terminus, src):
- terminus.copy(src)
- return 0
-
-class pn_link_wrapper(endpoint_wrapper):
-
- def __init__(self, impl):
- endpoint_wrapper.__init__(self, impl)
- self.source = pn_terminus(PN_SOURCE)
- self.remote_source = pn_terminus(PN_UNSPECIFIED)
- self.target = pn_terminus(PN_TARGET)
- self.remote_target = pn_terminus(PN_UNSPECIFIED)
-
- def on_open(self):
- self.impl.setSource(self.source.encode())
- self.impl.setTarget(self.target.encode())
-
-def pn_link_attachments(link):
- return link.impl.attachments()
-
-def pn_link_source(link):
- link.source.decode(link.impl.getSource())
- return link.source
-
-def pn_link_remote_source(link):
- link.remote_source.decode(link.impl.getRemoteSource())
- return link.remote_source
-
-def pn_link_target(link):
- link.target.decode(link.impl.getTarget())
- return link.target
-
-def pn_link_remote_target(link):
- link.remote_target.decode(link.impl.getRemoteTarget())
- return link.remote_target
-
-def pn_link_condition(link):
- return link.condition
-
-def pn_link_remote_condition(link):
- return remote_condition(link)
-
-SND_SETTLE_MODE_P2J = {
- PN_SND_UNSETTLED: SenderSettleMode.UNSETTLED,
- PN_SND_SETTLED: SenderSettleMode.SETTLED,
- PN_SND_MIXED: SenderSettleMode.MIXED,
- None: None
-}
-
-SND_SETTLE_MODE_J2P = {
- SenderSettleMode.UNSETTLED: PN_SND_UNSETTLED,
- SenderSettleMode.SETTLED: PN_SND_SETTLED,
- SenderSettleMode.MIXED: PN_SND_MIXED,
- None: None
-}
-
-def pn_link_set_snd_settle_mode(link, mode):
- link.impl.setSenderSettleMode(SND_SETTLE_MODE_P2J[mode])
-
-def pn_link_snd_settle_mode(link):
- return SND_SETTLE_MODE_J2P[link.impl.getSenderSettleMode()]
-
-def pn_link_remote_snd_settle_mode(link):
- return SND_SETTLE_MODE_J2P[link.impl.getRemoteSenderSettleMode()]
-
-RCV_SETTLE_MODE_P2J = {
- PN_RCV_FIRST: ReceiverSettleMode.FIRST,
- PN_RCV_SECOND: ReceiverSettleMode.SECOND,
- None: None
-}
-
-RCV_SETTLE_MODE_J2P = {
- ReceiverSettleMode.FIRST: PN_RCV_FIRST,
- ReceiverSettleMode.SECOND: PN_RCV_SECOND,
- None: None
-}
-
-def pn_link_set_rcv_settle_mode(link, mode):
- link.impl.setReceiverSettleMode(RCV_SETTLE_MODE_P2J[mode])
-
-def pn_link_rcv_settle_mode(link):
- return RCV_SETTLE_MODE_J2P[link.impl.getReceiverSettleMode()]
-
-def pn_link_remote_rcv_settle_mode(link):
- return RCV_SETTLE_MODE_J2P[link.impl.getRemoteReceiverSettleMode()]
-
-def pn_link_is_sender(link):
- return isinstance(link.impl, Sender)
-
-def pn_link_is_receiver(link):
- return isinstance(link.impl, Receiver)
-
-def pn_link_head(conn, mask):
- local, remote = mask2set(mask)
- return wrap(conn.impl.linkHead(local, remote), pn_link_wrapper)
-
-def pn_link_next(link, mask):
- local, remote = mask2set(mask)
- return wrap(link.impl.next(local, remote), pn_link_wrapper)
-
-def pn_link_session(link):
- return wrap(link.impl.getSession(), pn_session_wrapper)
-
-def pn_link_state(link):
- return endpoint_state(link.impl)
-
-def pn_link_name(link):
- return link.impl.getName()
-
-def pn_link_open(link):
- link.on_open()
- link.impl.open()
-
-def pn_link_close(link):
- link.on_close()
- link.impl.close()
-
-def pn_link_detach(link):
- link.on_close()
- link.impl.detach()
-
-def pn_link_flow(link, n):
- link.impl.flow(n)
-
-def pn_link_drain(link, n):
- link.impl.drain(n)
-
-def pn_link_drained(link):
- return link.impl.drained()
-
-def pn_link_draining(link):
- return link.impl.draining()
-
-def pn_link_credit(link):
- return link.impl.getCredit()
-
-def pn_link_queued(link):
- return link.impl.getQueued()
-
-def pn_link_get_drain(link):
- return link.impl.getDrain();
-
-def pn_link_set_drain(link, drain):
- return link.impl.setDrain(drain);
-
-def pn_link_unsettled(link):
- return link.impl.getUnsettled()
-
-def pn_link_send(link, bytes):
- return link.impl.send(array(bytes, 'b'), 0, len(bytes))
-
-def pn_link_recv(link, limit):
- ary = zeros(limit, 'b')
- n = link.impl.recv(ary, 0, limit)
- if n >= 0:
- bytes = ary[:n].tostring()
- else:
- bytes = None
- return n, bytes
-
-def pn_link_advance(link):
- return link.impl.advance()
-
-def pn_link_current(link):
- return wrap(link.impl.current(), pn_delivery_wrapper)
-
-def pn_link_free(link):
- link.impl.free()
-
-def pn_work_head(conn):
- return wrap(conn.impl.getWorkHead(), pn_delivery_wrapper)
-
-def pn_work_next(dlv):
- return wrap(dlv.impl.getWorkNext(), pn_delivery_wrapper)
-
-DELIVERY_STATES = {
- Received: PN_RECEIVED,
- Accepted: PN_ACCEPTED,
- Rejected: PN_REJECTED,
- Released: PN_RELEASED,
- Modified: PN_MODIFIED,
- None.__class__: 0
- }
-
-DISPOSITIONS = {
- PN_RECEIVED: Received,
- PN_ACCEPTED: Accepted,
- PN_REJECTED: Rejected,
- PN_RELEASED: Released,
- PN_MODIFIED: Modified,
- 0: lambda: None
-}
-
-class pn_disposition:
-
- def __init__(self):
- self.type = 0
- self.data = pn_data(0)
- self.failed = False
- self.undeliverable = False
- self.annotations = pn_data(0)
- self.condition = pn_condition()
- self.section_number = 0
- self.section_offset = 0
-
- def decode(self, impl):
- self.type = DELIVERY_STATES[impl.__class__]
-
- if self.type == PN_REJECTED:
- self.condition.decode(impl.getError())
- else:
- pn_condition_clear(self.condition)
-
- if self.type == PN_MODIFIED:
- self.failed = impl.getDeliveryFailed()
- self.undeliverable = impl.getUndeliverableHere()
- obj2dat(impl.getMessageAnnotations(), self.annotations)
- else:
- self.failed = False
- self.undeliverable = False
- pn_data_clear(self.annotations)
-
- if self.type == PN_RECEIVED:
- self.section_number = impl.getSectionNumber().longValue()
- self.section_offset = impl.getSectionOffset().longValue()
- else:
- self.section_number = 0
- self.section_offset = 0
-
- self.data.clear()
- if impl:
- # XXX
- #self.data.putObject(impl)
- pass
- self.data.rewind()
-
- def encode(self):
- if self.type not in DISPOSITIONS:
- raise Skipped()
- impl = DISPOSITIONS[self.type]()
-
- if impl is None:
- return impl
-
- if self.type == PN_REJECTED:
- impl.setError(self.condition.encode())
-
- if self.type == PN_MODIFIED:
- impl.setDeliveryFailed(self.failed)
- impl.setUndeliverableHere(self.undeliverable)
- ann = dat2obj(self.annotations)
- if ann: impl.setMessageAnnotations(ann)
-
- if self.type == PN_RECEIVED:
- if self.section_number:
- impl.setSectionNumber(UnsignedInteger.valueOf(self.section_number))
- if self.section_offset:
- impl.setSectionOffset(UnsignedLong.valueOf(self.section_offset))
-
- return impl
-
-def pn_disposition_type(dsp):
- return dsp.type
-
-def pn_disposition_is_failed(dsp):
- return dsp.failed
-
-def pn_disposition_set_failed(dsp, failed):
- dsp.failed = failed
-
-def pn_disposition_is_undeliverable(dsp):
- return dsp.undeliverable
-
-def pn_disposition_set_undeliverable(dsp, undeliverable):
- dsp.undeliverable = undeliverable
-
-def pn_disposition_data(dsp):
- return dsp.data
-
-def pn_disposition_annotations(dsp):
- return dsp.annotations
-
-def pn_disposition_condition(dsp):
- return dsp.condition
-
-def pn_disposition_get_section_number(dsp):
- return dsp.section_number
-
-def pn_disposition_set_section_number(dsp, number):
- dsp.section_number = number
-
-def pn_disposition_get_section_offset(dsp):
- return dsp.section_offset
-
-def pn_disposition_set_section_offset(dsp, offset):
- dsp.section_offset = offset
-
-class pn_delivery_wrapper:
-
- def __init__(self, impl):
- self.impl = impl
- self.local = pn_disposition()
- self.remote = pn_disposition()
-
-def pn_delivery(link, tag):
- return wrap(link.impl.delivery(array(tag, 'b')), pn_delivery_wrapper)
-
-def pn_delivery_tag(dlv):
- return dlv.impl.getTag().tostring()
-
-def pn_delivery_attachments(dlv):
- return dlv.impl.attachments()
-
-def pn_delivery_partial(dlv):
- return dlv.impl.isPartial()
-
-def pn_delivery_pending(dlv):
- return dlv.impl.pending()
-
-def pn_delivery_writable(dlv):
- return dlv.impl.isWritable()
-
-def pn_delivery_readable(dlv):
- return dlv.impl.isReadable()
-
-def pn_delivery_updated(dlv):
- return dlv.impl.isUpdated()
-
-def pn_delivery_settled(dlv):
- return dlv.impl.remotelySettled()
-
-def pn_delivery_local(dlv):
- dlv.local.decode(dlv.impl.getLocalState())
- return dlv.local
-
-def pn_delivery_local_state(dlv):
- dlv.local.decode(dlv.impl.getLocalState())
- return dlv.local.type
-
-def pn_delivery_remote(dlv):
- dlv.remote.decode(dlv.impl.getRemoteState())
- return dlv.remote
-
-def pn_delivery_remote_state(dlv):
- dlv.remote.decode(dlv.impl.getRemoteState())
- return dlv.remote.type
-
-def pn_delivery_update(dlv, state):
- dlv.local.type = state
- dlv.impl.disposition(dlv.local.encode())
-
-def pn_delivery_link(dlv):
- return wrap(dlv.impl.getLink(), pn_link_wrapper)
-
-def pn_delivery_settle(dlv):
- dlv.impl.settle()
-
-class pn_transport_wrapper:
- def __init__(self, impl):
- self.impl = impl
- self.server = False
- self.condition = pn_condition()
-
-def pn_transport():
- return wrap(Proton.transport(), pn_transport_wrapper)
-
-def pn_transport_get_pytracer(trans):
- raise Skipped()
-
-def pn_transport_attachments(trans):
- return trans.impl.attachments()
-
-def pn_transport_set_server(trans):
- trans.server = True;
-
-def pn_transport_get_max_frame(trans):
- return trans.impl.getMaxFrameSize()
-
-def pn_transport_set_max_frame(trans, value):
- trans.impl.setMaxFrameSize(value)
-
-def pn_transport_get_remote_max_frame(trans):
- return trans.impl.getRemoteMaxFrameSize()
-
-def pn_transport_set_idle_timeout(trans, value):
- trans.impl.setIdleTimeout(value);
-
-def pn_transport_get_idle_timeout(trans):
- return trans.impl.getIdleTimeout()
-
-def pn_transport_get_remote_idle_timeout(trans):
- return trans.impl.getRemoteIdleTimeout()
-
-def pn_transport_get_frames_input(trans):
- return trans.impl.getFramesInput()
-
-def pn_transport_get_frames_output(trans):
- return trans.impl.getFramesOutput()
-
-def pn_transport_set_channel_max(trans, n):
- trans.impl.setChannelMax(n)
-
-def pn_transport_get_channel_max(trans):
- return trans.impl.getChannelMax()
-
-def pn_transport_remote_channel_max(trans):
- return trans.impl.getRemoteChannelMax()
-
-def pn_transport_tick(trans, now):
- return trans.impl.tick(now);
-
-def pn_transport_bind(trans, conn):
- trans.impl.bind(conn.impl)
- return 0
-
-def pn_transport_unbind(trans):
- trans.impl.unbind()
- return 0
-
-def pn_transport_set_pytracer(trans, tracer):
- import warnings
- warnings.warn("TODO pn_transport_set_tracer", stacklevel=2)
-
-def pn_transport_trace(trans, n):
- trans.impl.trace(n)
-
-def pn_transport_pending(trans):
- return trans.impl.pending()
-
-def pn_transport_peek(trans, size):
- size = min(trans.impl.pending(), size)
- ba = zeros(size, 'b')
- if size:
- bb = trans.impl.head()
- bb.get(ba)
- bb.position(0)
- return 0, ba.tostring()
-
-def pn_transport_pop(trans, size):
- trans.impl.pop(size)
-
-def pn_transport_capacity(trans):
- return trans.impl.capacity()
-
-def pn_transport_push(trans, input):
- result = 0
- while input:
- cap = pn_transport_capacity(trans)
- if cap < 0:
- return cap
- elif len(input) > cap:
- trimmed = input[:cap]
- else:
- trimmed = input
-
- bb = trans.impl.tail()
- bb.put(array(trimmed, 'b'))
- trans.impl.process()
- input = input[cap:]
- result += len(trimmed)
- return result
-
-def pn_transport_close_head(trans):
- trans.impl.close_head()
- return 0
-
-def pn_transport_close_tail(trans):
- trans.impl.close_tail()
- return 0
-
-def pn_transport_closed(trans):
- return trans.impl.isClosed()
-
-def pn_transport_condition(trans):
- trans.condition.decode(trans.impl.getCondition())
- return trans.condition
-
-from org.apache.qpid.proton.engine import Event
-
-PN_REACTOR_INIT = Event.Type.REACTOR_INIT
-PN_REACTOR_QUIESCED = Event.Type.REACTOR_QUIESCED
-PN_REACTOR_FINAL = Event.Type.REACTOR_FINAL
-
-PN_TIMER_TASK = Event.Type.TIMER_TASK
-
-PN_CONNECTION_INIT = Event.Type.CONNECTION_INIT
-PN_CONNECTION_BOUND = Event.Type.CONNECTION_BOUND
-PN_CONNECTION_UNBOUND = Event.Type.CONNECTION_UNBOUND
-PN_CONNECTION_LOCAL_OPEN = Event.Type.CONNECTION_LOCAL_OPEN
-PN_CONNECTION_REMOTE_OPEN = Event.Type.CONNECTION_REMOTE_OPEN
-PN_CONNECTION_LOCAL_CLOSE = Event.Type.CONNECTION_LOCAL_CLOSE
-PN_CONNECTION_REMOTE_CLOSE = Event.Type.CONNECTION_REMOTE_CLOSE
-PN_CONNECTION_FINAL = Event.Type.CONNECTION_FINAL
-PN_SESSION_INIT = Event.Type.SESSION_INIT
-PN_SESSION_LOCAL_OPEN = Event.Type.SESSION_LOCAL_OPEN
-PN_SESSION_REMOTE_OPEN = Event.Type.SESSION_REMOTE_OPEN
-PN_SESSION_LOCAL_CLOSE = Event.Type.SESSION_LOCAL_CLOSE
-PN_SESSION_REMOTE_CLOSE = Event.Type.SESSION_REMOTE_CLOSE
-PN_SESSION_FINAL = Event.Type.SESSION_FINAL
-PN_LINK_INIT = Event.Type.LINK_INIT
-PN_LINK_LOCAL_OPEN = Event.Type.LINK_LOCAL_OPEN
-PN_LINK_REMOTE_OPEN = Event.Type.LINK_REMOTE_OPEN
-PN_LINK_LOCAL_CLOSE = Event.Type.LINK_LOCAL_CLOSE
-PN_LINK_REMOTE_CLOSE = Event.Type.LINK_REMOTE_CLOSE
-PN_LINK_LOCAL_DETACH = Event.Type.LINK_LOCAL_DETACH
-PN_LINK_REMOTE_DETACH = Event.Type.LINK_REMOTE_DETACH
-PN_LINK_FLOW = Event.Type.LINK_FLOW
-PN_LINK_FINAL = Event.Type.LINK_FINAL
-PN_DELIVERY = Event.Type.DELIVERY
-PN_TRANSPORT = Event.Type.TRANSPORT
-PN_TRANSPORT_ERROR = Event.Type.TRANSPORT_ERROR
-PN_TRANSPORT_HEAD_CLOSED = Event.Type.TRANSPORT_HEAD_CLOSED
-PN_TRANSPORT_TAIL_CLOSED = Event.Type.TRANSPORT_TAIL_CLOSED
-PN_TRANSPORT_CLOSED = Event.Type.TRANSPORT_CLOSED
-PN_SELECTABLE_INIT = Event.Type.SELECTABLE_INIT
-PN_SELECTABLE_UPDATED = Event.Type.SELECTABLE_UPDATED
-PN_SELECTABLE_READABLE = Event.Type.SELECTABLE_READABLE
-PN_SELECTABLE_WRITABLE = Event.Type.SELECTABLE_WRITABLE
-PN_SELECTABLE_EXPIRED = Event.Type.SELECTABLE_EXPIRED
-PN_SELECTABLE_ERROR = Event.Type.SELECTABLE_ERROR
-PN_SELECTABLE_FINAL = Event.Type.SELECTABLE_FINAL
-
-def pn_collector():
- return Proton.collector()
-
-def pn_connection_collect(conn, coll):
- conn.impl.collect(coll)
-
-class pn_event:
-
- def __init__(self, impl):
- self.impl = impl
-
- def copy(self):
- return pn_event(self.impl.copy())
-
-def pn_collector_peek(coll):
- ev = coll.peek()
- if ev:
- return pn_event(ev.copy())
- else:
- return None
-
-def pn_collector_pop(coll):
- coll.pop()
-
-def pn_collector_free(coll):
- pass
-
-def pn_event_reactor(event):
- return event.impl.getReactor()
-
-def pn_event_connection(event):
- return wrap(event.impl.getConnection(), pn_connection_wrapper)
-
-def pn_event_session(event):
- return wrap(event.impl.getSession(), pn_session_wrapper)
-
-def pn_event_link(event):
- return wrap(event.impl.getLink(), pn_link_wrapper)
-
-def pn_event_delivery(event):
- return wrap(event.impl.getDelivery(), pn_delivery_wrapper)
-
-def pn_event_transport(event):
- return wrap(event.impl.getTransport(), pn_transport_wrapper)
-
-from org.apache.qpid.proton.engine.impl import ConnectionImpl, SessionImpl, \
- SenderImpl, ReceiverImpl, DeliveryImpl, TransportImpl
-from org.apache.qpid.proton.reactor.impl import TaskImpl, SelectableImpl
-
-J2C = {
- ConnectionImpl: "pn_connection",
- SessionImpl: "pn_session",
- SenderImpl: "pn_link",
- ReceiverImpl: "pn_link",
- DeliveryImpl: "pn_delivery",
- TransportImpl: "pn_transport",
- TaskImpl: "pn_task",
- SelectableImpl: "pn_selectable"
-}
-
-wrappers = {
- "pn_connection": lambda x: wrap(x, pn_connection_wrapper),
- "pn_session": lambda x: wrap(x, pn_session_wrapper),
- "pn_link": lambda x: wrap(x, pn_link_wrapper),
- "pn_delivery": lambda x: wrap(x, pn_delivery_wrapper),
- "pn_transport": lambda x: wrap(x, pn_transport_wrapper),
- "pn_task": lambda x: x,
- "pn_selectable": lambda x: x,
- "pn_void": lambda x: x
-}
-
-def pn_event_class(event):
- ctx = event.impl.getContext()
- return J2C.get(ctx.getClass(), "pn_void")
-
-def pn_event_context(event):
- return wrappers[pn_event_class(event)](event.impl.getContext())
-
-def pn_event_type(event):
- return event.impl.getEventType()
-
-def pn_event_root(event):
- return event.impl.getRootHandler()
-
-def pn_event_type_name(etype):
- return str(etype)
-
-def pn_event_category(event):
- return event.impl.getCategory()
-
-def pn_event_attachments(event):
- return event.impl.attachments()
-
-def pn_event_copy(event):
- return event.copy()
-
-class TypeExtender:
- def __init__(self, number):
- pass
- def next(self):
- class CustomEvent(EventType):
- def isValid(self):
- return True
- return CustomEvent()
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cerror.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cerror.py b/tests/java/shim/cerror.py
deleted file mode 100644
index c87681c..0000000
--- a/tests/java/shim/cerror.py
+++ /dev/null
@@ -1,48 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-
-# from proton/error.h
-PN_EOS = -1
-PN_ERR = -2
-PN_OVERFLOW = -3
-PN_UNDERFLOW = -4
-PN_STATE_ERR = -5
-PN_ARG_ERR = -6
-PN_TIMEOUT =-7
-PN_INTR = -8
-PN_INPROGRESS =-9
-
-class pn_error:
-
- def __init__(self, code, text):
- self.code = code
- self.text = text
-
- def set(self, code, text):
- self.code = code
- self.text = text
- return self.code
-
-def pn_error_code(err):
- return err.code
-
-def pn_error_text(err):
- return err.text
-
-from unittest import SkipTest as Skipped
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/chandlers.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/chandlers.py b/tests/java/shim/chandlers.py
deleted file mode 100644
index 272990f..0000000
--- a/tests/java/shim/chandlers.py
+++ /dev/null
@@ -1,55 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-
-import sys
-from cerror import Skipped
-from org.apache.qpid.proton.reactor import FlowController, Handshaker
-from org.apache.qpid.proton.engine import BaseHandler, HandlerException
-
-# from proton/handlers.h
-def pn_flowcontroller(window):
- return FlowController(window)
-
-def pn_handshaker():
- return Handshaker()
-
-def pn_iohandler():
- raise Skipped()
-
-from cengine import pn_event, pn_event_type
-
-class pn_pyhandler(BaseHandler):
-
- def __init__(self, pyobj):
- self.pyobj = pyobj
-
- def onUnhandled(self, event):
- ev = pn_event(event)
- try:
- self.pyobj.dispatch(ev, pn_event_type(ev))
- except HandlerException:
- ex = sys.exc_info();
- cause = ex[1].cause
- if hasattr(cause, "value"):
- cause = cause.value
- t = type(cause)
- self.pyobj.exception(t, cause, ex[2])
- except:
- ex = sys.exc_info()
- self.pyobj.exception(*ex)
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cmessage.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cmessage.py b/tests/java/shim/cmessage.py
deleted file mode 100644
index d406bea..0000000
--- a/tests/java/shim/cmessage.py
+++ /dev/null
@@ -1,250 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.amqp.messaging import AmqpValue, AmqpSequence, \
- Data as DataSection, ApplicationProperties, MessageAnnotations, DeliveryAnnotations
-
-from ccodec import *
-from cerror import *
-from org.apache.qpid.proton.amqp import Binary
-
-# from proton/message.h
-PN_DATA = 0
-PN_TEXT = 1
-PN_AMQP = 2
-PN_JSON = 3
-
-PN_DEFAULT_PRIORITY = 4
-
-class pn_message_wrapper:
-
- def __init__(self):
- self.inferred = False
- self.impl = Proton.message()
- self.id = pn_data(0)
- self.correlation_id = pn_data(0)
- self.instructions = pn_data(0)
- self.annotations = pn_data(0)
- self.properties = pn_data(0)
- self.body = pn_data(0)
-
- def decode(self, impl):
- self.impl = impl
- self.post_decode()
-
- def post_decode(self):
- obj2dat(self.impl.getMessageId(), self.id)
- self.id.next()
- obj2dat(self.impl.getCorrelationId(), self.correlation_id)
- self.correlation_id.next()
- def peel(x):
- if x is not None:
- return x.getValue()
- return None
- obj2dat(peel(self.impl.getDeliveryAnnotations()), self.instructions)
- obj2dat(peel(self.impl.getMessageAnnotations()), self.annotations)
- obj2dat(peel(self.impl.getApplicationProperties()), self.properties)
- bod = self.impl.getBody()
- if bod is not None: bod = bod.getValue()
- obj2dat(bod, self.body)
-
- def pre_encode(self):
- self.impl.setMessageId(dat2obj(self.id))
- self.impl.setCorrelationId(dat2obj(self.correlation_id))
- def wrap(x, wrapper):
- if x is not None:
- return wrapper(x)
- return None
- self.impl.setDeliveryAnnotations(wrap(dat2obj(self.instructions), DeliveryAnnotations))
- self.impl.setMessageAnnotations(wrap(dat2obj(self.annotations), MessageAnnotations))
- self.impl.setApplicationProperties(wrap(dat2obj(self.properties), ApplicationProperties))
- bod = dat2obj(self.body)
- if self.inferred:
- if isinstance(bod, bytes):
- bod = DataSection(Binary(array(bod, 'b')))
- elif isinstance(bod, list):
- bod = AmqpSequence(bod)
- else:
- bod = AmqpValue(bod)
- else:
- bod = AmqpValue(bod)
- self.impl.setBody(bod)
-
- def __repr__(self):
- return self.impl.toString()
-
-def pn_message():
- return pn_message_wrapper()
-
-def pn_message_id(msg):
- return msg.id
-
-def pn_message_correlation_id(msg):
- return msg.correlation_id
-
-def pn_message_get_address(msg):
- return msg.impl.getAddress()
-
-def pn_message_set_address(msg, address):
- msg.impl.setAddress(address)
- return 0
-
-def pn_message_get_reply_to(msg):
- return msg.impl.getReplyTo()
-
-def pn_message_set_reply_to(msg, address):
- msg.impl.setReplyTo(address)
- return 0
-
-def pn_message_get_reply_to_group_id(msg):
- return msg.impl.getReplyToGroupId()
-
-def pn_message_set_reply_to_group_id(msg, id):
- msg.impl.setReplyToGroupId(id)
- return 0
-
-def pn_message_get_group_sequence(msg):
- return msg.impl.getGroupSequence()
-
-def pn_message_set_group_sequence(msg, seq):
- msg.impl.setGroupSequence(seq)
- return 0
-
-def pn_message_get_group_id(msg):
- return msg.impl.getGroupId()
-
-def pn_message_set_group_id(msg, id):
- msg.impl.setGroupId(id)
- return 0
-
-def pn_message_is_first_acquirer(msg):
- return msg.impl.isFirstAcquirer()
-
-def pn_message_set_first_acquirer(msg, b):
- msg.impl.setFirstAcquirer(b)
- return 0
-
-def pn_message_is_durable(msg):
- return msg.impl.isDurable()
-
-def pn_message_set_durable(msg, b):
- msg.impl.setDurable(b)
- return 0
-
-def pn_message_get_delivery_count(msg):
- return msg.impl.getDeliveryCount()
-
-def pn_message_set_delivery_count(msg, c):
- msg.impl.setDeliveryCount(c)
- return 0
-
-def pn_message_get_creation_time(msg):
- return msg.impl.getCreationTime()
-
-def pn_message_set_creation_time(msg, t):
- msg.impl.setCreationTime(t)
- return 0
-
-def pn_message_get_expiry_time(msg):
- return msg.impl.getExpiryTime()
-
-def pn_message_set_expiry_time(msg, t):
- msg.impl.setExpiryTime(t)
- return 0
-
-def pn_message_get_content_type(msg):
- return msg.impl.getContentType()
-
-def pn_message_set_content_type(msg, ct):
- msg.impl.setContentType(ct)
- return 0
-
-def pn_message_get_content_encoding(msg):
- return msg.impl.getContentEncoding()
-
-def pn_message_set_content_encoding(msg, ct):
- msg.impl.setContentEncoding(ct)
- return 0
-
-def pn_message_get_subject(msg):
- return msg.impl.getSubject()
-
-def pn_message_set_subject(msg, value):
- msg.impl.setSubject(value)
- return 0
-
-def pn_message_get_priority(msg):
- return msg.impl.getPriority()
-
-def pn_message_set_priority(msg, p):
- msg.impl.setPriority(p)
- return 0
-
-def pn_message_get_ttl(msg):
- return msg.impl.getTtl()
-
-def pn_message_set_ttl(msg, ttl):
- msg.impl.setTtl(ttl)
- return 0
-
-def pn_message_get_user_id(msg):
- uid = msg.impl.getUserId()
- if uid is None:
- return ""
- else:
- return uid.tostring()
-
-def pn_message_set_user_id(msg, uid):
- msg.impl.setUserId(uid)
- return 0
-
-def pn_message_instructions(msg):
- return msg.instructions
-
-def pn_message_annotations(msg):
- return msg.annotations
-
-def pn_message_properties(msg):
- return msg.properties
-
-def pn_message_body(msg):
- return msg.body
-
-def pn_message_decode(msg, data):
- n = msg.impl.decode(array(data, 'b'), 0, len(data))
- msg.post_decode()
- return n
-
-from java.nio import BufferOverflowException
-
-def pn_message_encode(msg, size):
- msg.pre_encode()
- ba = zeros(size, 'b')
- # XXX: shouldn't have to use the try/catch
- try:
- n = msg.impl.encode(ba, 0, size)
- if n >= 0:
- return n, ba[:n].tostring()
- else:
- return n
- except BufferOverflowException, e:
- return PN_OVERFLOW, None
-
-def pn_message_clear(msg):
- msg.impl.clear()
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cmessenger.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cmessenger.py b/tests/java/shim/cmessenger.py
deleted file mode 100644
index 249e0dc..0000000
--- a/tests/java/shim/cmessenger.py
+++ /dev/null
@@ -1,225 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-from org.apache.qpid.proton import Proton
-from org.apache.qpid.proton.messenger import Messenger, Status
-from org.apache.qpid.proton import InterruptException, TimeoutException
-
-from cerror import *
-
-# from proton/messenger.h
-PN_STATUS_UNKNOWN = 0
-PN_STATUS_PENDING = 1
-PN_STATUS_ACCEPTED = 2
-PN_STATUS_REJECTED = 3
-PN_STATUS_RELEASED = 4
-PN_STATUS_MODIFIED = 5
-PN_STATUS_ABORTED = 6
-PN_STATUS_SETTLED = 7
-
-PN_CUMULATIVE = 1
-
-class pn_messenger_wrapper:
-
- def __init__(self, impl):
- self.impl = impl
- self.error = pn_error(0, None)
-
-def pn_messenger(name):
- if name is None:
- return pn_messenger_wrapper(Proton.messenger())
- else:
- return pn_messenger_wrapper(Proton.messenger(name))
-
-def pn_messenger_error(m):
- return m.error
-
-def pn_messenger_set_timeout(m, t):
- m.impl.setTimeout(t)
- return 0
-
-def pn_messenger_set_blocking(m, b):
- m.impl.setBlocking(b)
- return 0
-
-def pn_messenger_set_certificate(m, c):
- m.impl.setCertificate(c)
- return 0
-
-def pn_messenger_set_private_key(m, p):
- m.impl.setPrivateKey(p)
- return 0
-
-def pn_messenger_set_password(m, p):
- m.impl.setPassword(p)
- return 0
-
-def pn_messenger_set_trusted_certificates(m, t):
- m.impl.setTrustedCertificates(t)
- return 0
-
-def pn_messenger_set_incoming_window(m, w):
- m.impl.setIncomingWindow(w)
- return 0
-
-def pn_messenger_set_outgoing_window(m, w):
- m.impl.setOutgoingWindow(w)
- return 0
-
-def pn_messenger_start(m):
- m.impl.start()
- return 0
-
-# XXX: ???
-def pn_messenger_work(m, t):
- try:
- if m.impl.work(t):
- return 1
- else:
- return PN_TIMEOUT
- except InterruptException, e:
- return PN_INTR
-
-class pn_subscription:
-
- def __init__(self):
- pass
-
-def pn_messenger_subscribe(m, source):
- m.impl.subscribe(source)
- return pn_subscription()
-
-def pn_messenger_route(m, pattern, address):
- m.impl.route(pattern, address)
- return 0
-
-def pn_messenger_rewrite(m, pattern, address):
- m.impl.rewrite(pattern, address)
- return 0
-
-def pn_messenger_interrupt(m):
- m.impl.interrupt()
- return 0
-
-def pn_messenger_buffered(m, t):
- raise Skipped()
-
-from org.apache.qpid.proton.engine import TransportException
-
-def pn_messenger_stop(m):
- m.impl.stop()
- return 0
-
-def pn_messenger_stopped(m):
- return m.impl.stopped()
-
-def pn_messenger_put(m, msg):
- msg.pre_encode()
- m.impl.put(msg.impl)
- return 0
-
-def pn_messenger_outgoing_tracker(m):
- return m.impl.outgoingTracker()
-
-def pn_messenger_send(m, n):
- try:
- m.impl.send(n)
- return 0
- except InterruptException, e:
- return PN_INTR
- except TimeoutException, e:
- return PN_TIMEOUT
-
-def pn_messenger_recv(m, n):
- try:
- m.impl.recv(n)
- return 0
- except InterruptException, e:
- return PN_INTR
- except TimeoutException, e:
- return PN_TIMEOUT
-
-def pn_messenger_receiving(m):
- return m.impl.receiving()
-
-def pn_messenger_incoming(m):
- return m.impl.incoming()
-
-def pn_messenger_outgoing(m):
- return m.impl.outgoing()
-
-def pn_messenger_get(m, msg):
- mimpl = m.impl.get()
- if msg:
- msg.decode(mimpl)
- return 0
-
-def pn_messenger_incoming_tracker(m):
- return m.impl.incomingTracker()
-
-def pn_messenger_accept(m, tracker, flags):
- if flags:
- m.impl.accept(tracker, Messenger.CUMULATIVE)
- else:
- m.impl.accept(tracker, 0)
- return 0
-
-def pn_messenger_reject(m, tracker, flags):
- if flags:
- m.impl.reject(tracker, Messenger.CUMULATIVE)
- else:
- m.impl.reject(tracker, 0)
- return 0
-
-def pn_messenger_settle(m, tracker, flags):
- if flags:
- m.impl.settle(tracker, Messenger.CUMULATIVE)
- else:
- m.impl.settle(tracker, 0)
- return 0
-
-STATUS_P2J = {
- PN_STATUS_UNKNOWN: Status.UNKNOWN,
- PN_STATUS_PENDING: Status.PENDING,
- PN_STATUS_ACCEPTED: Status.ACCEPTED,
- PN_STATUS_REJECTED: Status.REJECTED,
- PN_STATUS_RELEASED: Status.RELEASED,
- PN_STATUS_MODIFIED: Status.MODIFIED,
- PN_STATUS_ABORTED: Status.ABORTED,
- PN_STATUS_SETTLED: Status.SETTLED
-}
-
-STATUS_J2P = {
- Status.UNKNOWN: PN_STATUS_UNKNOWN,
- Status.PENDING: PN_STATUS_PENDING,
- Status.ACCEPTED: PN_STATUS_ACCEPTED,
- Status.REJECTED: PN_STATUS_REJECTED,
- Status.RELEASED: PN_STATUS_RELEASED,
- Status.MODIFIED: PN_STATUS_MODIFIED,
- Status.ABORTED: PN_STATUS_ABORTED,
- Status.SETTLED: PN_STATUS_SETTLED
-}
-
-def pn_messenger_status(m, tracker):
- return STATUS_J2P[m.impl.getStatus(tracker)]
-
-def pn_messenger_set_passive(m, passive):
- raise Skipped()
-
-def pn_messenger_selectable(m):
- raise Skipped()
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cobject.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cobject.py b/tests/java/shim/cobject.py
deleted file mode 100644
index 33ab438..0000000
--- a/tests/java/shim/cobject.py
+++ /dev/null
@@ -1,91 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-
-def pn_class_name(cls):
- return cls
-
-def pn_void2py(obj):
- return obj
-
-def pn_py2void(obj):
- return obj
-
-def pn_cast_pn_connection(obj):
- return obj
-
-def pn_cast_pn_session(obj):
- return obj
-
-def pn_cast_pn_link(obj):
- return obj
-
-def pn_cast_pn_delivery(obj):
- return obj
-
-def pn_cast_pn_transport(obj):
- return obj
-
-def pn_cast_pn_reactor(obj):
- return obj
-
-def pn_cast_pn_task(obj):
- return obj
-
-def pn_cast_pn_selectable(obj):
- return obj
-
-PN_PYREF = None
-
-def pn_record_def(record, key, clazz):
- pass
-
-from java.lang import Object
-
-def pn_record_get(record, key):
- return record.get(key, Object)
-
-def pn_record_set(record, key, value):
- record.set(key, Object, value)
-
-def pn_incref(obj):
- pass
-
-def pn_decref(obj):
- pass
-
-def pn_free(obj):
- pass
-
-from java.lang import StringBuilder
-
-def pn_string(st):
- sb = StringBuilder()
- if st:
- sb.append(st)
- return sb
-
-def pn_string_get(sb):
- return sb.toString()
-
-def pn_inspect(obj, st):
- if obj is None:
- st.append("null")
- else:
- st.append(repr(obj))
- return 0
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/compat.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/compat.py b/tests/java/shim/compat.py
deleted file mode 100644
index 7bff3ba..0000000
--- a/tests/java/shim/compat.py
+++ /dev/null
@@ -1,26 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-import sys
-from jarray import zeros, array as _array
-
-if (sys.version_info[0] == 2 and sys.version_info[1] == 5):
- array = _array
-else:
- def array(obj, code):
- return obj
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/ccdcf329/tests/java/shim/cproton.py
----------------------------------------------------------------------
diff --git a/tests/java/shim/cproton.py b/tests/java/shim/cproton.py
deleted file mode 100644
index d5ed574..0000000
--- a/tests/java/shim/cproton.py
+++ /dev/null
@@ -1,42 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements. See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership. The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License. You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied. See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-
-"""
-The cproton module defines a java implementation of the C interface as
-exposed to python via swig. This allows tests defined in python to run
-against both the C and Java protocol implementations.
-"""
-
-# @todo(kgiusti) dynamically set these via filters in the pom.xml file
-PN_VERSION_MAJOR = 0
-PN_VERSION_MINOR = 0
-PN_VERSION_POINT = 0
-
-from ctypes import *
-from cobject import *
-from cerror import *
-from ccodec import *
-from cengine import *
-from csasl import *
-from cssl import *
-from cmessenger import *
-from cmessage import *
-from curl import *
-from creactor import *
-from chandlers import *
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org