Empty go1 branch.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/e57c2a52 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/e57c2a52 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/e57c2a52 Branch: refs/heads/go1 Commit: e57c2a524872fed0963971acb42b53f25b99d0d7 Parents: 513df7d Author: Alan Conway <[email protected]> Authored: Tue Sep 29 09:36:16 2015 -0400 Committer: Alan Conway <[email protected]> Committed: Tue Sep 29 09:36:16 2015 -0400 ---------------------------------------------------------------------- design/build.xml | 74 - design/src/proton/Accepted.java | 34 - design/src/proton/Connection.java | 78 - design/src/proton/Delivery.java | 65 - design/src/proton/DeliveryBuffer.java | 44 - design/src/proton/DeliveryState.java | 32 - design/src/proton/Endpoint.java | 119 -- design/src/proton/Link.java | 71 - design/src/proton/Modified.java | 34 - design/src/proton/Outcome.java | 34 - design/src/proton/Received.java | 34 - design/src/proton/Receiver.java | 52 - design/src/proton/Rejected.java | 34 - design/src/proton/Released.java | 34 - design/src/proton/Sender.java | 55 - design/src/proton/Session.java | 76 - design/src/proton/Transport.java | 53 - design/src/proton/package.html | 122 -- proton-c/.gitignore | 8 - proton-c/LICENSE | 203 --- proton-c/Makefile | 65 - proton-c/README | 0 proton-c/TODO | 8 - proton-c/include/proton/codec.h | 108 -- proton-c/include/proton/driver.h | 50 - proton-c/include/proton/engine.h | 129 -- proton-c/include/proton/framing.h | 42 - proton-c/include/proton/message.h | 29 - proton-c/include/proton/sasl.h | 47 - proton-c/include/proton/util.h | 31 - proton-c/include/proton/value.h | 240 --- proton-c/mllib/__init__.py | 85 - proton-c/mllib/dom.py | 310 ---- proton-c/mllib/parsers.py | 139 -- proton-c/mllib/transforms.py | 164 -- proton-c/musings.txt | 15 - proton-c/src/codec/codec.c | 529 ------ proton-c/src/codec/encodings.h.py | 41 - proton-c/src/codec/types.xml | 125 -- proton-c/src/dispatcher/dispatcher.c | 198 --- proton-c/src/dispatcher/dispatcher.h | 66 - proton-c/src/driver.c | 526 ------ proton-c/src/engine/engine-internal.h | 202 --- proton-c/src/engine/engine.c | 1541 ------------------ proton-c/src/framing/framing.c | 65 - proton-c/src/message/message.c | 35 - proton-c/src/messaging.xml | 168 -- proton-c/src/protocol.h.py | 46 - proton-c/src/protocol.py | 113 -- proton-c/src/proton.c | 425 ----- proton-c/src/proton.i | 8 - proton-c/src/sasl/sasl-internal.h | 40 - proton-c/src/sasl/sasl.c | 203 --- proton-c/src/security.xml | 76 - proton-c/src/transactions.xml | 73 - proton-c/src/transport.xml | 200 --- proton-c/src/types/array.c | 158 -- proton-c/src/types/binary.c | 88 - proton-c/src/types/decode.c | 272 ---- proton-c/src/types/list.c | 212 --- proton-c/src/types/map.c | 229 --- proton-c/src/types/string.c | 68 - proton-c/src/types/symbol.c | 90 - proton-c/src/types/value-internal.h | 61 - proton-c/src/types/value.c | 838 ---------- proton-c/src/util.c | 121 -- proton-c/src/util.h | 91 -- proton-j/build.xml | 168 -- proton-j/codec/build.xml | 27 - .../org/apache/qpid/proton/codec/AMQPType.java | 36 - .../proton/codec/AbstractPrimitiveType.java | 32 - .../codec/AbstractPrimitiveTypeEncoding.java | 67 - .../org/apache/qpid/proton/codec/ArrayType.java | 1139 ------------- .../apache/qpid/proton/codec/BinaryType.java | 162 -- .../apache/qpid/proton/codec/BooleanType.java | 273 ---- .../qpid/proton/codec/ByteBufferDecoder.java | 28 - .../qpid/proton/codec/ByteBufferEncoder.java | 28 - .../org/apache/qpid/proton/codec/ByteType.java | 129 -- .../apache/qpid/proton/codec/CharacterType.java | 127 -- .../qpid/proton/codec/Decimal128Type.java | 103 -- .../apache/qpid/proton/codec/Decimal32Type.java | 100 -- .../apache/qpid/proton/codec/Decimal64Type.java | 100 -- .../qpid/proton/codec/DecodeException.java | 44 - .../org/apache/qpid/proton/codec/Decoder.java | 141 -- .../apache/qpid/proton/codec/DecoderImpl.java | 972 ----------- .../proton/codec/DescribedTypeConstructor.java | 30 - .../apache/qpid/proton/codec/DoubleType.java | 127 -- .../qpid/proton/codec/DynamicDescribedType.java | 150 -- .../proton/codec/DynamicTypeConstructor.java | 60 - .../qpid/proton/codec/EncodeException.java | 44 - .../org/apache/qpid/proton/codec/Encoder.java | 109 -- .../apache/qpid/proton/codec/EncoderImpl.java | 886 ---------- .../apache/qpid/proton/codec/EncodingCodes.java | 89 - .../codec/FixedSizePrimitiveTypeEncoding.java | 42 - .../org/apache/qpid/proton/codec/FloatType.java | 128 -- .../FloatingSizePrimitiveTypeEncoding.java | 54 - .../apache/qpid/proton/codec/IntegerType.java | 213 --- .../LargeFloatingSizePrimitiveTypeEncoding.java | 42 - .../org/apache/qpid/proton/codec/ListType.java | 235 --- .../org/apache/qpid/proton/codec/LongType.java | 212 --- .../org/apache/qpid/proton/codec/MapType.java | 251 --- .../org/apache/qpid/proton/codec/NullType.java | 111 -- .../apache/qpid/proton/codec/PrimitiveType.java | 35 - .../proton/codec/PrimitiveTypeEncoding.java | 32 - .../org/apache/qpid/proton/codec/ShortType.java | 127 -- .../SmallFloatingSizePrimitiveTypeEncoding.java | 42 - .../apache/qpid/proton/codec/StringType.java | 262 --- .../apache/qpid/proton/codec/SymbolType.java | 201 --- .../apache/qpid/proton/codec/TimestampType.java | 111 -- .../qpid/proton/codec/TypeConstructor.java | 30 - .../apache/qpid/proton/codec/TypeEncoding.java | 40 - .../org/apache/qpid/proton/codec/UUIDType.java | 103 -- .../qpid/proton/codec/UnsignedByteType.java | 100 -- .../qpid/proton/codec/UnsignedIntegerType.java | 209 --- .../qpid/proton/codec/UnsignedLongType.java | 203 --- .../qpid/proton/codec/UnsignedShortType.java | 100 -- .../qpid/proton/framing/TransportFrame.java | 57 - .../qpid/proton/type/AMQPDefinedTypes.java | 95 -- .../src/org/apache/qpid/proton/type/Binary.java | 161 -- .../org/apache/qpid/proton/type/Decimal128.java | 98 -- .../org/apache/qpid/proton/type/Decimal32.java | 82 - .../org/apache/qpid/proton/type/Decimal64.java | 84 - .../apache/qpid/proton/type/DescribedType.java | 27 - .../src/org/apache/qpid/proton/type/Symbol.java | 90 - .../apache/qpid/proton/type/UnsignedByte.java | 134 -- .../qpid/proton/type/UnsignedInteger.java | 149 -- .../apache/qpid/proton/type/UnsignedLong.java | 155 -- .../apache/qpid/proton/type/UnsignedShort.java | 134 -- .../qpid/proton/type/messaging/Accepted.java | 114 -- .../proton/type/messaging/AmqpSequence.java | 87 - .../qpid/proton/type/messaging/AmqpValue.java | 86 - .../type/messaging/ApplicationProperties.java | 87 - .../apache/qpid/proton/type/messaging/Data.java | 86 - .../proton/type/messaging/DeleteOnClose.java | 114 -- .../proton/type/messaging/DeleteOnNoLinks.java | 114 -- .../messaging/DeleteOnNoLinksOrMessages.java | 114 -- .../type/messaging/DeleteOnNoMessages.java | 114 -- .../type/messaging/DeliveryAnnotations.java | 87 - .../qpid/proton/type/messaging/Footer.java | 87 - .../qpid/proton/type/messaging/Header.java | 209 --- .../proton/type/messaging/LifetimePolicy.java | 25 - .../type/messaging/MessageAnnotations.java | 87 - .../qpid/proton/type/messaging/Modified.java | 176 -- .../qpid/proton/type/messaging/Outcome.java | 5 - .../qpid/proton/type/messaging/Properties.java | 346 ---- .../qpid/proton/type/messaging/Received.java | 158 -- .../qpid/proton/type/messaging/Rejected.java | 141 -- .../qpid/proton/type/messaging/Released.java | 114 -- .../qpid/proton/type/messaging/Section.java | 25 - .../qpid/proton/type/messaging/Source.java | 354 ---- .../qpid/proton/type/messaging/StdDistMode.java | 34 - .../qpid/proton/type/messaging/Target.java | 274 ---- .../type/messaging/TerminusDurability.java | 36 - .../type/messaging/TerminusExpiryPolicy.java | 38 - .../apache/qpid/proton/type/package-info.java | 55 - .../proton/type/security/SaslChallenge.java | 149 -- .../qpid/proton/type/security/SaslCode.java | 40 - .../proton/type/security/SaslFrameBody.java | 25 - .../qpid/proton/type/security/SaslInit.java | 183 --- .../proton/type/security/SaslMechanisms.java | 157 -- .../qpid/proton/type/security/SaslOutcome.java | 166 -- .../qpid/proton/type/security/SaslResponse.java | 149 -- .../proton/type/transaction/Coordinator.java | 149 -- .../qpid/proton/type/transaction/Declare.java | 141 -- .../qpid/proton/type/transaction/Declared.java | 149 -- .../qpid/proton/type/transaction/Discharge.java | 166 -- .../proton/type/transaction/GlobalTxId.java | 25 - .../type/transaction/TransactionErrors.java | 36 - .../type/transaction/TransactionalState.java | 166 -- .../proton/type/transaction/TxnCapability.java | 40 - .../qpid/proton/type/transport/AmqpError.java | 56 - .../qpid/proton/type/transport/Attach.java | 423 ----- .../qpid/proton/type/transport/Begin.java | 316 ---- .../qpid/proton/type/transport/Close.java | 154 -- .../proton/type/transport/ConnectionError.java | 36 - .../proton/type/transport/DeliveryState.java | 26 - .../qpid/proton/type/transport/Detach.java | 198 --- .../qpid/proton/type/transport/Disposition.java | 239 --- .../apache/qpid/proton/type/transport/End.java | 154 -- .../qpid/proton/type/transport/Error.java | 184 --- .../apache/qpid/proton/type/transport/Flow.java | 349 ---- .../qpid/proton/type/transport/FrameBody.java | 22 - .../qpid/proton/type/transport/LinkError.java | 40 - .../apache/qpid/proton/type/transport/Open.java | 365 ----- .../type/transport/ReceiverSettleMode.java | 34 - .../apache/qpid/proton/type/transport/Role.java | 32 - .../proton/type/transport/SenderSettleMode.java | 36 - .../proton/type/transport/SessionError.java | 38 - .../qpid/proton/type/transport/Source.java | 5 - .../qpid/proton/type/transport/Target.java | 5 - .../qpid/proton/type/transport/Transfer.java | 346 ---- proton-j/common.xml | 366 ----- proton-j/driver/build.xml | 28 - .../apache/qpid/proton/driver/Application.java | 29 - .../qpid/proton/driver/ApplicationFactory.java | 27 - .../qpid/proton/driver/BytesTransport.java | 29 - .../qpid/proton/driver/ConnectionTransport.java | 168 -- .../qpid/proton/driver/DelegatingTransport.java | 128 -- .../qpid/proton/driver/NIOAcceptingDriver.java | 147 -- .../proton/driver/NoddyBrokerApplication.java | 162 -- proton-j/engine/build.xml | 28 - .../org/apache/qpid/proton/engine/Accepted.java | 43 - .../apache/qpid/proton/engine/Connection.java | 59 - .../org/apache/qpid/proton/engine/Delivery.java | 63 - .../qpid/proton/engine/DeliveryBuffer.java | 44 - .../qpid/proton/engine/DeliveryState.java | 32 - .../org/apache/qpid/proton/engine/Endpoint.java | 72 - .../qpid/proton/engine/EndpointError.java | 34 - .../qpid/proton/engine/EndpointState.java | 11 - .../src/org/apache/qpid/proton/engine/Link.java | 66 - .../org/apache/qpid/proton/engine/Modified.java | 34 - .../org/apache/qpid/proton/engine/Outcome.java | 34 - .../org/apache/qpid/proton/engine/Received.java | 34 - .../org/apache/qpid/proton/engine/Receiver.java | 51 - .../org/apache/qpid/proton/engine/Rejected.java | 34 - .../org/apache/qpid/proton/engine/Released.java | 34 - .../org/apache/qpid/proton/engine/Sender.java | 57 - .../org/apache/qpid/proton/engine/Sequence.java | 27 - .../org/apache/qpid/proton/engine/Session.java | 53 - .../apache/qpid/proton/engine/Transport.java | 53 - .../proton/engine/impl/AmqpErrorException.java | 25 - .../qpid/proton/engine/impl/ArraySequence.java | 46 - .../engine/impl/ConcatenatedSequence.java | 55 - .../qpid/proton/engine/impl/ConnectionImpl.java | 333 ---- .../qpid/proton/engine/impl/DeliveryImpl.java | 295 ---- .../qpid/proton/engine/impl/EndpointImpl.java | 186 --- .../engine/impl/EndpointSelectionSequence.java | 63 - .../qpid/proton/engine/impl/FrameParser.java | 305 ---- .../proton/engine/impl/IteratorSequence.java | 52 - .../qpid/proton/engine/impl/LinkImpl.java | 189 --- .../qpid/proton/engine/impl/ReceiverImpl.java | 93 -- .../proton/engine/impl/SelectiveSequence.java | 64 - .../qpid/proton/engine/impl/SenderImpl.java | 114 -- .../qpid/proton/engine/impl/SessionImpl.java | 113 -- .../proton/engine/impl/TransportDelivery.java | 49 - .../proton/engine/impl/TransportFactory.java | 34 - .../engine/impl/TransportFactoryImpl.java | 33 - .../qpid/proton/engine/impl/TransportImpl.java | 736 --------- .../qpid/proton/engine/impl/TransportLink.java | 126 -- .../proton/engine/impl/TransportReceiver.java | 46 - .../proton/engine/impl/TransportSender.java | 52 - .../proton/engine/impl/TransportSession.java | 255 --- proton-j/module.xml | 886 ---------- .../src/org/apache/qpid/tasks/BaseTask.java | 74 - .../src/org/apache/qpid/tasks/Foreach.java | 84 - .../tasks/src/org/apache/qpid/tasks/Map.java | 99 -- .../org/apache/qpid/tasks/PropertyMapper.java | 50 - .../src/org/apache/qpid/tasks/Require.java | 80 - 248 files changed, 33396 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/build.xml ---------------------------------------------------------------------- diff --git a/design/build.xml b/design/build.xml deleted file mode 100644 index 0b23a6e..0000000 --- a/design/build.xml +++ /dev/null @@ -1,74 +0,0 @@ -<project name="Qpid Proton Design" default="dist" basedir="."> - <description> - simple example build file - </description> - - <!-- global properties for this build --> - <property name="src" location="src"/> - <property name="build" location="build"/> - <property name="dist" location="dist"/> - <property name="classes" location="${build}/classes"/> - <property name="docs" location="${build}/docs"/> - <property name="umlgraph.jar" location="/usr/share/java/umlgraph.jar"/> - - <target name="init"> - <tstamp/> - <mkdir dir="${classes}"/> - </target> - - <target name="compile" depends="init" description="compile the source "> - <javac srcdir="${src}" destdir="${classes}"/> - </target> - - <target name="uml"> - <property name="uml.dir" value="${docs}/uml"/> - <mkdir dir="${uml.dir}"/> - <path id="uml.source.path"> - <pathelement path="${src}/"/> - </path> - <javadoc sourcepathref="uml.source.path" packagenames="*" package="true"> - <doclet name="org.umlgraph.doclet.UmlGraph" path="${umlgraph.jar}"> - <param name="-d" value="${uml.dir}"/> - </doclet> - </javadoc> - <apply executable="dot" dest="${uml.dir}" parallel="false"> - <arg value="-Tpng"/> - <arg value="-o"/> - <targetfile/> - <srcfile/> - <fileset dir="${uml.dir}" includes="*.dot"/> - <mapper type="glob" from="*.dot" to="*.png"/> - </apply> - </target> - - <target name="apidoc"> - <javadoc destdir="${docs}/api" author="true" version="true" use="true" - windowtitle="Qpid Proton API"> - - <fileset dir="src" defaultexcludes="yes"> - <include name="proton/**.java"/> - </fileset> - - <doctitle><![CDATA[<h1>Qpid Proton</h1>]]></doctitle> - <bottom><![CDATA[<i>Copyright © 2011 Rafael Schloming All Rights Reserved.</i>]]></bottom> - <tag name="todo" scope="all" description="To do:"/> - <link offline="true" href="http://download.oracle.com/javase/6/docs/api/"; packagelistLoc="C:\tmp"/> - <link href="http://developer.java.sun.com/developer/products/xml/docs/api/"/> - </javadoc> - </target> - - <target name="doc" depends="uml,apidoc"/> - - <target name="dist" depends="compile,doc" description="generate the distribution"> - <mkdir dir="${dist}/lib"/> - - <jar jarfile="${dist}/lib/qpidproton.jar" basedir="${classes}"/> - <zip destfile="${dist}/docs.zip" basedir="${docs}"/> - <zip destfile="${dist}/srcs.zip" basedir="${basedir}" excludes="build/**,dist/**"/> - </target> - - <target name="clean" description="clean up" > - <delete dir="${build}"/> - <delete dir="${dist}"/> - </target> -</project> http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Accepted.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Accepted.java b/design/src/proton/Accepted.java deleted file mode 100644 index 246eb6c..0000000 --- a/design/src/proton/Accepted.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Accepted - * - * @hidden - * - */ - -public interface Accepted extends Outcome -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Connection.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Connection.java b/design/src/proton/Connection.java deleted file mode 100644 index a7f4af7..0000000 --- a/design/src/proton/Connection.java +++ /dev/null @@ -1,78 +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 proton; - -import java.util.Iterator; - - -/** - * Connection - * - * @opt operations - * @opt types - * - * @composed 1 - "0..n" Session - * @composed 1 - "0..?" Transport - * - */ - -public interface Connection extends Endpoint -{ - - /** - * transition local state to ACTIVE - */ - public void open(); - - /** - * transition local state to CLOSED - */ - public void close(); - - /** - * @return a newly created session - */ - public Session session(); - - /** - * @return a newly created transport - */ - public Transport transport(); - - /** - * @return iterator for endpoints matching the specified local and - * remote states - */ - public Iterator<Endpoint> endpoints(Endpoint.State local, Endpoint.State remote); - - /** - * @return iterator for incoming link endpoints with pending - * transfers - */ - public Iterator<Receiver> incoming(); - - /** - * @return iterator for unblocked outgoing link endpoints with - * offered credits - */ - public Iterator<Sender> outgoing(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Delivery.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Delivery.java b/design/src/proton/Delivery.java deleted file mode 100644 index f68b020..0000000 --- a/design/src/proton/Delivery.java +++ /dev/null @@ -1,65 +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 proton; - - -/** - * Delivery - * - * @opt operations - * @opt types - * - * @assoc - local 0..1 DeliveryState - * @assoc - remote 0..1 DeliveryState - * - * @todo deliveries need to track important link state (source and - * targets) at the point that they were created - * - */ - -public interface Delivery -{ - - public byte[] getTag(); - - public Link getLink(); - - public DeliveryState getLocalState(); - - public DeliveryState getRemoteState(); - - public boolean remoteSettled(); - - public int getMessageFormat(); - - /** - * updates the state of the delivery - * - * @param state the new delivery state - */ - public void disposition(DeliveryState state); - - /** - * settle the delivery - */ - public void settle(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/DeliveryBuffer.java ---------------------------------------------------------------------- diff --git a/design/src/proton/DeliveryBuffer.java b/design/src/proton/DeliveryBuffer.java deleted file mode 100644 index bdd592e..0000000 --- a/design/src/proton/DeliveryBuffer.java +++ /dev/null @@ -1,44 +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 proton; - - -/** - * DeliveryBuffer - * - * @opt operations - * @opt attributes - * @opt types - * - * @composed 1 - "0..n" Delivery - * - */ - -public interface DeliveryBuffer -{ - - int next = 0; - - public int getCapacity(); - - public int getSize(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/DeliveryState.java ---------------------------------------------------------------------- diff --git a/design/src/proton/DeliveryState.java b/design/src/proton/DeliveryState.java deleted file mode 100644 index 50d23e3..0000000 --- a/design/src/proton/DeliveryState.java +++ /dev/null @@ -1,32 +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 proton; - - -/** - * DeliveryState - * - */ - -public interface DeliveryState -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Endpoint.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Endpoint.java b/design/src/proton/Endpoint.java deleted file mode 100644 index a9febe3..0000000 --- a/design/src/proton/Endpoint.java +++ /dev/null @@ -1,119 +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 proton; - - -/** - * Endpoint - * - * @opt operations - * @opt types - * - * @assoc - local 1 Endpoint.State - * @assoc - remote 1 Endpoint.State - * @assoc - local 0..1 Endpoint.Error - * @assoc - remote 0..1 Endpoint.Error - */ - -public interface Endpoint -{ - - /** - * Represents the state of a communication endpoint. - */ - public static final class State { - - private String name; - - private State(String name) - { - this.name = name; - } - - public String toString() - { - return name; - } - - }; - - public static final State UNINIT = new State("UNINIT"); - public static final State ACTIVE = new State("ACTIVE"); - public static final State CLOSED = new State("CLOSED"); - - /** - * Holds information about an endpoint error. - */ - public static final class Error { - - private String name; - private String description; - - public Error(String name, String description) - { - this.name = name; - this.description = description; - } - - public Error(String name) - { - this(name, null); - } - - public String toString() - { - if (description == null) - { - return name; - } - else - { - return String.format("%s -- %s", name, description); - } - } - } - - /** - * @return the local endpoint state - */ - public State getLocalState(); - - /** - * @return the remote endpoint state (as last communicated) - */ - public State getRemoteState(); - - /** - * @return the local endpoint error, or null if there is none - */ - public Error getLocalError(); - - /** - * @return the remote endpoint error, or null if there is none - */ - public Error getRemoteError(); - - /** - * free the endpoint and any associated resources - */ - public void destroy(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Link.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Link.java b/design/src/proton/Link.java deleted file mode 100644 index ec80b62..0000000 --- a/design/src/proton/Link.java +++ /dev/null @@ -1,71 +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 proton; - -import java.util.Iterator; - - -/** - * Link - * - * @opt operations - * @opt types - * - * @assoc 1 - n Delivery - * - * @todo make links able to exist independently from - * sessions/connections and allow to migrate - * - */ - -public interface Link extends Endpoint -{ - - /** - * transition local state to ACTIVE - */ - public void attach(); - - /** - * transition local state to CLOSED - */ - public void detach(); - - /** - * @param tag a tag for the delivery - * - * @return a Delivery object - */ - public Delivery delivery(byte[] tag); - - /** - * @return the unsettled deliveries for this link - */ - public Iterator<Delivery> unsettled(); - - /** - * Advances the current delivery to the next delivery on the link. - * - * @return the next delivery or null if there is none - */ - public Delivery next(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Modified.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Modified.java b/design/src/proton/Modified.java deleted file mode 100644 index 1f07cb0..0000000 --- a/design/src/proton/Modified.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Modified - * - * @hidden - * - */ - -public interface Modified extends Outcome -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Outcome.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Outcome.java b/design/src/proton/Outcome.java deleted file mode 100644 index d0a4064..0000000 --- a/design/src/proton/Outcome.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Outcome - * - * @hidden - * - */ - -public interface Outcome extends DeliveryState -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Received.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Received.java b/design/src/proton/Received.java deleted file mode 100644 index 37856bf..0000000 --- a/design/src/proton/Received.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Received - * - * @hidden - * - */ - -public interface Received extends DeliveryState -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Receiver.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Receiver.java b/design/src/proton/Receiver.java deleted file mode 100644 index f46bfa4..0000000 --- a/design/src/proton/Receiver.java +++ /dev/null @@ -1,52 +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 proton; - - -/** - * Receiver - * - * @opt operations - * @opt types - * - */ - -public interface Receiver extends Link -{ - - /** - * issue the specified number of credits - */ - public void flow(int credits); - - /** - * Receive message data for the current delivery. - * - * @param bytes the destination array where the message data is written - * @param offset the index to begin writing into the array - * @param size the maximum number of bytes to write - * - * @return the number of bytes written or -1 if there is no more - * message data for the current delivery - */ - public int recv(byte[] bytes, int offset, int size); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Rejected.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Rejected.java b/design/src/proton/Rejected.java deleted file mode 100644 index 92f1ec4..0000000 --- a/design/src/proton/Rejected.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Rejected - * - * @hidden - * - */ - -public interface Rejected extends Outcome -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Released.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Released.java b/design/src/proton/Released.java deleted file mode 100644 index e480ef7..0000000 --- a/design/src/proton/Released.java +++ /dev/null @@ -1,34 +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 proton; - - -/** - * Released - * - * @hidden - * - */ - -public interface Released extends Outcome -{ - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Sender.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Sender.java b/design/src/proton/Sender.java deleted file mode 100644 index 36bd68d..0000000 --- a/design/src/proton/Sender.java +++ /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. - * - */ -package proton; - - -/** - * Sender - * - * @opt operations - * @opt types - * - */ - -public interface Sender extends Link -{ - - /** - * indicates pending deliveries - * - * @param credits the number of pending deliveries - * @todo is this absolute or cumulative? - */ - public void offer(int credits); - - /** - * Sends message data for the current delivery. - * - * @param bytes the message data - */ - public void send(byte[] bytes); - - /** - * Abort the current delivery. - */ - public void abort(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Session.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Session.java b/design/src/proton/Session.java deleted file mode 100644 index b6ae6f9..0000000 --- a/design/src/proton/Session.java +++ /dev/null @@ -1,76 +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 proton; - -import java.util.Iterator; - - -/** - * Session - * - * @opt operations - * @opt types - * - * @composed 1 - "0..n" Link - * @composed 1 incoming 1 DeliveryBuffer - * @composed 1 outgoing 1 DeliveryBuffer - * - */ - -public interface Session extends Endpoint -{ - - /** - * transition local state to ACTIVE - */ - public void begin(); - - /** - * transition local state to CLOSED - */ - public void end(); - - /** - * @return a newly created outgoing link - */ - public Sender sender(); - - /** - * @return a newly created incoming link - */ - public Receiver receiver(); - - /** - * @see Connection#endpoints(Endpoint.State, Endpoint.State) - */ - public Iterator<Endpoint> endpoints(Endpoint.State local, Endpoint.State remote); - - /** - * @see Connection#incoming() - */ - public Iterator<Receiver> incoming(); - - /** - * @see Connection#outgoing() - */ - public Iterator<Sender> outgoing(); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/Transport.java ---------------------------------------------------------------------- diff --git a/design/src/proton/Transport.java b/design/src/proton/Transport.java deleted file mode 100644 index 0ff89ac..0000000 --- a/design/src/proton/Transport.java +++ /dev/null @@ -1,53 +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 proton; - - -/** - * Transport - * - * @opt operations - * @opt types - * - */ - -public interface Transport extends Endpoint -{ - - /** - * @param bytes input bytes for consumption - * @param offset the offset within bytes where input begins - * @param size the number of bytes available for input - * - * @return the number of bytes consumed - */ - public int input(byte[] bytes, int offset, int size); - - /** - * @param bytes array for output bytes - * @param offset the offset within bytes where output begins - * @param size the number of bytes available for output - * - * @return the number of bytes written - */ - public int output(byte[] bytes, int offset, int size); - -} http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/design/src/proton/package.html ---------------------------------------------------------------------- diff --git a/design/src/proton/package.html b/design/src/proton/package.html deleted file mode 100644 index f327ddb..0000000 --- a/design/src/proton/package.html +++ /dev/null @@ -1,122 +0,0 @@ -<html> - <body> - <p> - Connections are the primary unit of resource management. - Sessions and Links are components of connections. When the - Connection is destroyed/discarded, any resources associated with - the Sessions and Links are automatically destroyed or discarded - as well. - </p> - - <p> - Each of the Connection, Session, and Link endpoints share a - common state model. Note that although this follows the same - pattern as the protocol state model for open/close, begin/end, - and attach/detach, this does not necessarily correspond one to - one to the protocol state model for endpoints. For example the - engine implementation may detach/reattach a link endpoint - without visibly changing the external state. - </p> - - <p> - The state of each endpoint is divided into two parts, one - reflecting the state of the local endpoint, and the other - reflecting the state of the remote endpoint as last - communicated. - </p> - - <pre> - LOCAL: - UNINIT - ACTIVE - CLOSED - - REMOTE: - UNINIT - ACTIVE - CLOSED - </pre> - - <p>In total there are 9 possible states:</p> - - <pre> - LOCAL REMOTE Example - ------------------------------------------------------------------------- - UNINIT UNINIT A newly created connection. - - UNINIT ACTIVE A remotely initiated connection - prior to full establishment. - - UNINIT CLOSED A remotely initiated connection that - has been closed prior to full - establishment. - - ACTIVE UNINIT A locally initiated connection prior - to full establishment. - - ACTIVE ACTIVE A fully established connection. - - ACTIVE CLOSED A remotely terminated connection. - - CLOSED UNINIT A locally initiated connection that - has been closed prior to full - establishment. - - CLOSED ACTIVE A locally terminated connection. - - CLOSED CLOSED A fully terminated connection. - </pre> - - <p> - Additionally each endpoint has a local and remote error slot which - may be filled with additional information regarding why the - endpoint was transitioned to CLOSED. - </p> - - <h3>Questions:</h3> - - <ul> - <li>The transfer buffer class may not necessarily be explicitly part - of the external interface, e.g. it could be absorbed into the - session interface.</li> - <li>how do we confirm acheiving active/active without iterating - over all active/active endpoints? - <ul> - <li>add an ignore/interest flag as part of generic endpoint state?</li> - <li>add pending state to local state?</li> - </ul> - </li> - <li>what are credits exactly? - <ul> - <li>how does synchronous get work? - <ul><li>implies credit unit needs to be messages?</li></ul> - <li>credits may not correspond exactly with on-the-wire credits due - to local buffering</li> - </ul> - </li> - <li>how would 0-x impls work given that we're passing bytes directly to send? - <ul> - <li>have a generic property get/set API? - <ul><li>this could address per transfer flags as well</li></ul> - </li> - </ul> - </li> - <li>how do large messages work? - <ul><li>does send need a done flag for multiple transfers?</li></ul> - </li> - <li>how does resume work?</li> - <li>how does abort work?</li> - <li>how do we send settled? - <ul> - <li>just call settle on the returned transfer, the engine MUST optimize</li> - </ul> - </li> - <li> - how do we deal with send and receive modes on individual transfers? - <ul><li>could just twiddle the link ones and set them on the - transfer frame if they differ from what they were when the - attach was made</li></ul> - </li> - </ul> - </body> -</html> http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/.gitignore ---------------------------------------------------------------------- diff --git a/proton-c/.gitignore b/proton-c/.gitignore deleted file mode 100644 index 223c5c6..0000000 --- a/proton-c/.gitignore +++ /dev/null @@ -1,8 +0,0 @@ -*.pyc -*.o -*.d -src/codec/encodings.h -src/protocol.h -src/proton -src/test -src/libqpidproton.so http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/LICENSE ---------------------------------------------------------------------- diff --git a/proton-c/LICENSE b/proton-c/LICENSE deleted file mode 100644 index 6b0b127..0000000 --- a/proton-c/LICENSE +++ /dev/null @@ -1,203 +0,0 @@ - - Apache License - Version 2.0, January 2004 - http://www.apache.org/licenses/ - - TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION - - 1. Definitions. - - "License" shall mean the terms and conditions for use, reproduction, - and distribution as defined by Sections 1 through 9 of this document. - - "Licensor" shall mean the copyright owner or entity authorized by - the copyright owner that is granting the License. - - "Legal Entity" shall mean the union of the acting entity and all - other entities that control, are controlled by, or are under common - control with that entity. For the purposes of this definition, - "control" means (i) the power, direct or indirect, to cause the - direction or management of such entity, whether by contract or - otherwise, or (ii) ownership of fifty percent (50%) or more of the - outstanding shares, or (iii) beneficial ownership of such entity. - - "You" (or "Your") shall mean an individual or Legal Entity - exercising permissions granted by this License. - - "Source" form shall mean the preferred form for making modifications, - including but not limited to software source code, documentation - source, and configuration files. - - "Object" form shall mean any form resulting from mechanical - transformation or translation of a Source form, including but - not limited to compiled object code, generated documentation, - and conversions to other media types. - - "Work" shall mean the work of authorship, whether in Source or - Object form, made available under the License, as indicated by a - copyright notice that is included in or attached to the work - (an example is provided in the Appendix below). - - "Derivative Works" shall mean any work, whether in Source or Object - form, that is based on (or derived from) the Work and for which the - editorial revisions, annotations, elaborations, or other modifications - represent, as a whole, an original work of authorship. For the purposes - of this License, Derivative Works shall not include works that remain - separable from, or merely link (or bind by name) to the interfaces of, - the Work and Derivative Works thereof. - - "Contribution" shall mean any work of authorship, including - the original version of the Work and any modifications or additions - to that Work or Derivative Works thereof, that is intentionally - submitted to Licensor for inclusion in the Work by the copyright owner - or by an individual or Legal Entity authorized to submit on behalf of - the copyright owner. For the purposes of this definition, "submitted" - means any form of electronic, verbal, or written communication sent - to the Licensor or its representatives, including but not limited to - communication on electronic mailing lists, source code control systems, - and issue tracking systems that are managed by, or on behalf of, the - Licensor for the purpose of discussing and improving the Work, but - excluding communication that is conspicuously marked or otherwise - designated in writing by the copyright owner as "Not a Contribution." - - "Contributor" shall mean Licensor and any individual or Legal Entity - on behalf of whom a Contribution has been received by Licensor and - subsequently incorporated within the Work. - - 2. Grant of Copyright License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - copyright license to reproduce, prepare Derivative Works of, - publicly display, publicly perform, sublicense, and distribute the - Work and such Derivative Works in Source or Object form. - - 3. Grant of Patent License. Subject to the terms and conditions of - this License, each Contributor hereby grants to You a perpetual, - worldwide, non-exclusive, no-charge, royalty-free, irrevocable - (except as stated in this section) patent license to make, have made, - use, offer to sell, sell, import, and otherwise transfer the Work, - where such license applies only to those patent claims licensable - by such Contributor that are necessarily infringed by their - Contribution(s) alone or by combination of their Contribution(s) - with the Work to which such Contribution(s) was submitted. If You - institute patent litigation against any entity (including a - cross-claim or counterclaim in a lawsuit) alleging that the Work - or a Contribution incorporated within the Work constitutes direct - or contributory patent infringement, then any patent licenses - granted to You under this License for that Work shall terminate - as of the date such litigation is filed. - - 4. Redistribution. You may reproduce and distribute copies of the - Work or Derivative Works thereof in any medium, with or without - modifications, and in Source or Object form, provided that You - meet the following conditions: - - (a) You must give any other recipients of the Work or - Derivative Works a copy of this License; and - - (b) You must cause any modified files to carry prominent notices - stating that You changed the files; and - - (c) You must retain, in the Source form of any Derivative Works - that You distribute, all copyright, patent, trademark, and - attribution notices from the Source form of the Work, - excluding those notices that do not pertain to any part of - the Derivative Works; and - - (d) If the Work includes a "NOTICE" text file as part of its - distribution, then any Derivative Works that You distribute must - include a readable copy of the attribution notices contained - within such NOTICE file, excluding those notices that do not - pertain to any part of the Derivative Works, in at least one - of the following places: within a NOTICE text file distributed - as part of the Derivative Works; within the Source form or - documentation, if provided along with the Derivative Works; or, - within a display generated by the Derivative Works, if and - wherever such third-party notices normally appear. The contents - of the NOTICE file are for informational purposes only and - do not modify the License. You may add Your own attribution - notices within Derivative Works that You distribute, alongside - or as an addendum to the NOTICE text from the Work, provided - that such additional attribution notices cannot be construed - as modifying the License. - - You may add Your own copyright statement to Your modifications and - may provide additional or different license terms and conditions - for use, reproduction, or distribution of Your modifications, or - for any such Derivative Works as a whole, provided Your use, - reproduction, and distribution of the Work otherwise complies with - the conditions stated in this License. - - 5. Submission of Contributions. Unless You explicitly state otherwise, - any Contribution intentionally submitted for inclusion in the Work - by You to the Licensor shall be under the terms and conditions of - this License, without any additional terms or conditions. - Notwithstanding the above, nothing herein shall supersede or modify - the terms of any separate license agreement you may have executed - with Licensor regarding such Contributions. - - 6. Trademarks. This License does not grant permission to use the trade - names, trademarks, service marks, or product names of the Licensor, - except as required for reasonable and customary use in describing the - origin of the Work and reproducing the content of the NOTICE file. - - 7. Disclaimer of Warranty. Unless required by applicable law or - agreed to in writing, Licensor provides the Work (and each - Contributor provides its Contributions) on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - implied, including, without limitation, any warranties or conditions - of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A - PARTICULAR PURPOSE. You are solely responsible for determining the - appropriateness of using or redistributing the Work and assume any - risks associated with Your exercise of permissions under this License. - - 8. Limitation of Liability. In no event and under no legal theory, - whether in tort (including negligence), contract, or otherwise, - unless required by applicable law (such as deliberate and grossly - negligent acts) or agreed to in writing, shall any Contributor be - liable to You for damages, including any direct, indirect, special, - incidental, or consequential damages of any character arising as a - result of this License or out of the use or inability to use the - Work (including but not limited to damages for loss of goodwill, - work stoppage, computer failure or malfunction, or any and all - other commercial damages or losses), even if such Contributor - has been advised of the possibility of such damages. - - 9. Accepting Warranty or Additional Liability. While redistributing - the Work or Derivative Works thereof, You may choose to offer, - and charge a fee for, acceptance of support, warranty, indemnity, - or other liability obligations and/or rights consistent with this - License. However, in accepting such obligations, You may act only - on Your own behalf and on Your sole responsibility, not on behalf - of any other Contributor, and only if You agree to indemnify, - defend, and hold each Contributor harmless for any liability - incurred by, or claims asserted against, such Contributor by reason - of your accepting any such warranty or additional liability. - - END OF TERMS AND CONDITIONS - - APPENDIX: How to apply the Apache License to your work. - - To apply the Apache License to your work, attach the following - boilerplate notice, with the fields enclosed by brackets "[]" - replaced with your own identifying information. (Don't include - the brackets!) The text should be enclosed in the appropriate - comment syntax for the file format. We also recommend that a - file or class name and description of purpose be included on the - same "printed page" as the copyright notice for easier - identification within third-party archives. - - Copyright [yyyy] [name of copyright owner] - - Licensed 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. - http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/Makefile ---------------------------------------------------------------------- diff --git a/proton-c/Makefile b/proton-c/Makefile deleted file mode 100644 index 17dae2a..0000000 --- a/proton-c/Makefile +++ /dev/null @@ -1,65 +0,0 @@ -CFLAGS := -Wall -Werror -pedantic-errors -std=c99 -g -Iinclude -fPIC -PYTHON := python -PYTHONPATH := ${realpath .} -UTIL_SRC := src/util.c -CODEC_SRC := src/codec/codec.c -FRAMING_SRC := src/framing/framing.c -VALUE_SRC := src/types/value.c src/types/array.c src/types/list.c \ - src/types/map.c src/types/string.c src/types/binary.c \ - src/types/symbol.c src/types/decode.c -UTIL_HDR := include/proton/util.h -VALUE_HDR := include/proton/value.h -DISPATCHER_SRC := src/dispatcher/dispatcher.c -ENGINE_SRC := src/engine/engine.c -SASL_SRC := src/sasl/sasl.c -MESSAGE_SRC := src/message/message.c -DRIVER_SRC := src/driver.c - -SRCS := ${UTIL_SRC} ${VALUE_SRC} ${FRAMING_SRC} ${CODEC_SRC} ${PROTOCOL_SRC} \ - ${DISPATCHER_SRC} ${ENGINE_SRC} ${SASL_SRC} ${MESSAGE_SRC} ${DRIVER_SRC} -OBJS := ${SRCS:.c=.o} -DEPS := ${OBJS:.o=.d} -HDRS := ${UTIL_HDR} ${VALUE_HDR} \ - ${FRAMING_SRC:src/framing/%.c=include/proton/%.h} \ - ${CODEC_SRC:src/codec/%.c=include/proton/%.h} \ - src/protocol.h \ - include/proton/engine.h \ - include/proton/sasl.h \ - include/proton/message.h \ - src/codec/encodings.h - -PROGRAMS := src/proton -LIBRARY := src/libqpidproton.so - -MODULE := src/proton.py -SWIG_INT := src/proton.i - -all: ${PROGRAMS} ${LIBRARY} ${MODULE} - -# pull in dependency info for *existing* .o files --include ${DEPS} - -${PROGRAMS}: ${OBJS} - -${LIBRARY}: ${OBJS} - $(CC) $(CCFLAGS) -shared -o $@ $^ - -${MODULE}: ${SWIG_INT} ${HDRS} ${LIBRARY} - swig -python -Iinclude ${SWIG_INT} - $(CC) $(CCFLAGS) -fPIC -Iinclude -I/usr/include/python2.7 -Lsrc \ - -lqpidproton -shared -o src/_proton.so src/proton_wrap.c - -${OBJS}: ${HDRS} -${OBJS}: %.o: %.c - gcc -c -MMD -MP $(CFLAGS) $*.c -o $*.o - -%.h: %.h.py - PYTHONPATH=${PYTHONPATH} ${PYTHON} $< > $@ - -%.c: %.c.py - PYTHONPATH=${PYTHONPATH} ${PYTHON} $< > $@ - -clean: - rm -f ${PROGRAMS} ${LIBRARY} ${MODULE} ${OBJS} ${DEPS} src/protocol.c \ - src/protocol.h src/codec/encodings.h src/*.pyc \ - src/proton_wrap.c src/_proton.so http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/README ---------------------------------------------------------------------- diff --git a/proton-c/README b/proton-c/README deleted file mode 100644 index e69de29..0000000 http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/TODO ---------------------------------------------------------------------- diff --git a/proton-c/TODO b/proton-c/TODO deleted file mode 100644 index 9a9a750..0000000 --- a/proton-c/TODO +++ /dev/null @@ -1,8 +0,0 @@ - - fill in fake codecs - - uuid, timestamp - - tests: swig/python? mains? - - eliminate exported structs - - bug in driver when selectable set is modified from handler? - - temporary failure in name reslution? - - eliminate useless codegen in favor of a single reused arg list - + finish this by adding stack thingy to engine for nested structures http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/codec.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/codec.h b/proton-c/include/proton/codec.h deleted file mode 100644 index b784664..0000000 --- a/proton-c/include/proton/codec.h +++ /dev/null @@ -1,108 +0,0 @@ -#ifndef _PROTON_CODEC_H -#define _PROTON_CODEC_H 1 - -/* - * - * 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. - * - */ - -#include <stdbool.h> -#include <stdint.h> -#include <unistd.h> -#include <wchar.h> - -int pn_write_descriptor(char **pos, char *limit); -int pn_write_null(char **pos, char *limit); -int pn_write_boolean(char **pos, char *limit, bool v); -int pn_write_ubyte(char **pos, char *limit, uint8_t v); -int pn_write_byte(char **pos, char *limit, int8_t v); -int pn_write_ushort(char **pos, char *limit, uint16_t v); -int pn_write_short(char **pos, char *limit, int16_t v); -int pn_write_uint(char **pos, char *limit, uint32_t v); -int pn_write_int(char **pos, char *limit, int32_t v); -int pn_write_char(char **pos, char *limit, wchar_t v); -int pn_write_float(char **pos, char *limit, float v); -int pn_write_ulong(char **pos, char *limit, uint64_t v); -int pn_write_long(char **pos, char *limit, int64_t v); -int pn_write_double(char **pos, char *limit, double v); -int pn_write_binary(char **pos, char *limit, size_t size, char *src); -int pn_write_utf8(char **pos, char *limit, size_t size, char *utf8); -int pn_write_symbol(char **pos, char *limit, size_t size, const char *symbol); -int pn_write_start(char **pos, char *limit, char **start); -int pn_write_list(char **pos, char *limit, char *start, size_t count); -int pn_write_map(char **pos, char *limit, char *start, size_t count); - -typedef struct { - void (*on_null)(void *ctx); - void (*on_bool)(void *ctx, bool v); - void (*on_ubyte)(void *ctx, uint8_t v); - void (*on_byte)(void *ctx, int8_t v); - void (*on_ushort)(void *ctx, uint16_t v); - void (*on_short)(void *ctx, int16_t v); - void (*on_uint)(void *ctx, uint32_t v); - void (*on_int)(void *ctx, int32_t v); - void (*on_float)(void *ctx, float v); - void (*on_ulong)(void *ctx, uint64_t v); - void (*on_long)(void *ctx, int64_t v); - void (*on_double)(void *ctx, double v); - void (*on_binary)(void *ctx, size_t size, char *bytes); - void (*on_utf8)(void *ctx, size_t size, char *utf8); - void (*on_symbol)(void *ctx, size_t size, char *str); - void (*start_descriptor)(void *ctx); - void (*stop_descriptor)(void *ctx); - void (*start_array)(void *ctx, size_t count, uint8_t code); - void (*stop_array)(void *ctx, size_t count, uint8_t code); - void (*start_list)(void *ctx, size_t count); - void (*stop_list)(void *ctx, size_t count); - void (*start_map)(void *ctx, size_t count); - void (*stop_map)(void *ctx, size_t count); -} pn_data_callbacks_t; - -ssize_t pn_read_datum(char *bytes, size_t n, pn_data_callbacks_t *cb, void *ctx); - -#define PN_DATA_CALLBACKS(STEM) ((pn_data_callbacks_t) { \ - .on_null = & STEM ## _null, \ - .on_bool = & STEM ## _bool, \ - .on_ubyte = & STEM ## _ubyte, \ - .on_byte = & STEM ## _byte, \ - .on_ushort = & STEM ## _ushort, \ - .on_short = & STEM ## _short, \ - .on_uint = & STEM ## _uint, \ - .on_int = & STEM ## _int, \ - .on_float = & STEM ## _float, \ - .on_ulong = & STEM ## _ulong, \ - .on_long = & STEM ## _long, \ - .on_double = & STEM ## _double, \ - .on_binary = & STEM ## _binary, \ - .on_utf8 = & STEM ## _utf8, \ - .on_symbol = & STEM ## _symbol, \ - .start_descriptor = & STEM ## _start_descriptor, \ - .stop_descriptor = & STEM ## _stop_descriptor, \ - .start_array = & STEM ## _start_array, \ - .stop_array = & STEM ## _stop_array, \ - .start_list = & STEM ## _start_list, \ - .stop_list = & STEM ## _stop_list, \ - .start_map = & STEM ## _start_map, \ - .stop_map = & STEM ## _stop_map, \ -}) - -extern pn_data_callbacks_t *noop; -extern pn_data_callbacks_t *printer; - -#endif /* codec.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/driver.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/driver.h b/proton-c/include/proton/driver.h deleted file mode 100644 index 5f75752..0000000 --- a/proton-c/include/proton/driver.h +++ /dev/null @@ -1,50 +0,0 @@ -#ifndef _PROTON_DRIVER_H -#define _PROTON_DRIVER_H 1 - -/* - * - * 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. - * - */ - -#include <proton/engine.h> -#include <proton/sasl.h> -#include <stdlib.h> - -typedef struct pn_driver_t pn_driver_t; -typedef struct pn_selectable_t pn_selectable_t; -typedef void (pn_callback_t)(pn_selectable_t *); - -#define PN_SEL_RD (0x0001) -#define PN_SEL_WR (0x0002) - -pn_driver_t *pn_driver(void); -void pn_driver_trace(pn_driver_t *d, pn_trace_t trace); -void pn_driver_run(pn_driver_t *d); -void pn_driver_stop(pn_driver_t *d); -void pn_driver_destroy(pn_driver_t *d); - -pn_selectable_t *pn_acceptor(pn_driver_t *driver, char *host, char *port, pn_callback_t *callback, void* context); -pn_selectable_t *pn_connector(pn_driver_t *driver, char *host, char *port, pn_callback_t *callback, void* context); -void pn_selectable_trace(pn_selectable_t *sel, pn_trace_t trace); -pn_sasl_t *pn_selectable_sasl(pn_selectable_t *sel); -pn_connection_t *pn_selectable_connection(pn_selectable_t *sel); -void *pn_selectable_context(pn_selectable_t *sel); -void pn_selectable_destroy(pn_selectable_t *sel); - -#endif /* driver.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/engine.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/engine.h b/proton-c/include/proton/engine.h deleted file mode 100644 index af4ce30..0000000 --- a/proton-c/include/proton/engine.h +++ /dev/null @@ -1,129 +0,0 @@ -#ifndef _PROTON_ENGINE_H -#define _PROTON_ENGINE_H 1 - -/* - * - * 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. - * - */ - -#include <stdbool.h> -#include <stddef.h> -#include <sys/types.h> -#include <proton/value.h> - -typedef struct pn_error_t pn_error_t; -typedef struct pn_endpoint_t pn_endpoint_t; -typedef struct pn_transport_t pn_transport_t; -typedef struct pn_connection_t pn_connection_t; -typedef struct pn_session_t pn_session_t; -typedef struct pn_link_t pn_link_t; -typedef struct pn_sender_t pn_sender_t; -typedef struct pn_receiver_t pn_receiver_t; -typedef struct pn_delivery_t pn_delivery_t; - -typedef enum pn_endpoint_state_t {UNINIT=1, ACTIVE=2, CLOSED=4} pn_endpoint_state_t; -typedef enum pn_endpoint_type_t {CONNECTION=1, TRANSPORT=2, SESSION=3, SENDER=4, RECEIVER=5} pn_endpoint_type_t; -typedef enum pn_disposition_t {PN_RECEIVED=1, PN_ACCEPTED=2, PN_REJECTED=3, PN_RELEASED=4, PN_MODIFIED=5} pn_disposition_t; - -typedef enum pn_trace_t {PN_TRACE_OFF=0, PN_TRACE_RAW=1, PN_TRACE_FRM=2} pn_trace_t; - -/* Currently the way inheritence is done it is safe to "upcast" from - pn_{transport,connection,session,link,sender,or receiver}_t to - pn_endpoint_t and to "downcast" based on the endpoint type. I'm - not sure if this should be part of the ABI or not. */ - -// endpoint -pn_endpoint_type_t pn_endpoint_type(pn_endpoint_t *endpoint); -pn_endpoint_state_t pn_local_state(pn_endpoint_t *endpoint); -pn_endpoint_state_t pn_remote_state(pn_endpoint_t *endpoint); -pn_error_t *pn_local_error(pn_endpoint_t *endpoint); -pn_error_t *pn_remote_error(pn_endpoint_t *endpoint); -void pn_destroy(pn_endpoint_t *endpoint); -void pn_open(pn_endpoint_t *endpoint); -void pn_close(pn_endpoint_t *endpoint); - -// connection -pn_connection_t *pn_connection(); -void pn_connection_set_container(pn_connection_t *connection, const wchar_t *container); -void pn_connection_set_hostname(pn_connection_t *connection, const wchar_t *hostname); -pn_delivery_t *pn_work_head(pn_connection_t *connection); -pn_delivery_t *pn_work_next(pn_delivery_t *delivery); - -pn_session_t *pn_session(pn_connection_t *connection); -pn_transport_t *pn_transport(pn_connection_t *connection); - -pn_endpoint_t *pn_endpoint_head(pn_connection_t *connection, - pn_endpoint_state_t local, - pn_endpoint_state_t remote); -pn_endpoint_t *pn_endpoint_next(pn_endpoint_t *endpoint, - pn_endpoint_state_t local, - pn_endpoint_state_t remote); - -// transport -#define PN_EOS (-1) -#define PN_ERR (-2) -ssize_t pn_input(pn_transport_t *transport, char *bytes, size_t available); -ssize_t pn_output(pn_transport_t *transport, char *bytes, size_t size); -time_t pn_tick(pn_transport_t *transport, time_t now); -void pn_trace(pn_transport_t *transport, pn_trace_t trace); - -// session -pn_sender_t *pn_sender(pn_session_t *session, const wchar_t *name); -pn_receiver_t *pn_receiver(pn_session_t *session, const wchar_t *name); - -// link -pn_session_t *pn_get_session(pn_link_t *link); -void pn_set_source(pn_link_t *link, const wchar_t *source); -void pn_set_target(pn_link_t *link, const wchar_t *target); -wchar_t *pn_remote_source(pn_link_t *link); -wchar_t *pn_remote_target(pn_link_t *link); -pn_delivery_t *pn_delivery(pn_link_t *link, pn_binary_t *tag); -pn_delivery_t *pn_current(pn_link_t *link); -bool pn_advance(pn_link_t *link); - -pn_delivery_t *pn_unsettled_head(pn_link_t *link); -pn_delivery_t *pn_unsettled_next(pn_delivery_t *delivery); - -// sender -//void pn_offer(pn_sender_t *sender, int credits); -ssize_t pn_send(pn_sender_t *sender, const char *bytes, size_t n); -//void pn_abort(pn_sender_t *sender); - -// receiver -#define PN_EOM (-1) -void pn_flow(pn_receiver_t *receiver, int credits); -ssize_t pn_recv(pn_receiver_t *receiver, char *bytes, size_t n); - -// delivery -pn_binary_t *pn_delivery_tag(pn_delivery_t *delivery); -pn_link_t *pn_link(pn_delivery_t *delivery); -// how do we do delivery state? -int pn_local_disp(pn_delivery_t *delivery); -int pn_remote_disp(pn_delivery_t *delivery); -size_t pn_pending(pn_delivery_t *delivery); -bool pn_writable(pn_delivery_t *delivery); -bool pn_readable(pn_delivery_t *delivery); -bool pn_dirty(pn_delivery_t *delivery); -void pn_clean(pn_delivery_t *delivery); -void pn_disposition(pn_delivery_t *delivery, pn_disposition_t disposition); -//int pn_format(pn_delivery_t *delivery); -void pn_settle(pn_delivery_t *delivery); -void pn_delivery_dump(pn_delivery_t *delivery); - -#endif /* engine.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/framing.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/framing.h b/proton-c/include/proton/framing.h deleted file mode 100644 index 9f8a182..0000000 --- a/proton-c/include/proton/framing.h +++ /dev/null @@ -1,42 +0,0 @@ -#ifndef _PROTON_FRAMING_H -#define _PROTON_FRAMING_H 1 - -/* - * - * 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. - * - */ - -#include <stdint.h> -#include <sys/types.h> - -#define AMQP_HEADER_SIZE (8) - -typedef struct { - uint8_t type; - uint16_t channel; - size_t ex_size; - char *extended; - size_t size; - char *payload; -} pn_frame_t; - -size_t pn_read_frame(pn_frame_t *frame, char *bytes, size_t available); -size_t pn_write_frame(char *bytes, size_t size, pn_frame_t frame); - -#endif /* framing.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/message.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/message.h b/proton-c/include/proton/message.h deleted file mode 100644 index c3e64cb..0000000 --- a/proton-c/include/proton/message.h +++ /dev/null @@ -1,29 +0,0 @@ -#ifndef _PROTON_MESSAGE_H -#define _PROTON_MESSAGE_H 1 - -/* - * - * 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. - * - */ - -#include <sys/types.h> - -ssize_t pn_message_data(char *dst, size_t available, char *src, size_t size); - -#endif /* message.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/sasl.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/sasl.h b/proton-c/include/proton/sasl.h deleted file mode 100644 index 6470b3b..0000000 --- a/proton-c/include/proton/sasl.h +++ /dev/null @@ -1,47 +0,0 @@ -#ifndef _PROTON_SASL_H -#define _PROTON_SASL_H 1 - -/* - * - * 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. - * - */ - -#include <sys/types.h> -#include <stdbool.h> - -typedef struct pn_sasl_t pn_sasl_t; - -typedef enum {SASL_NONE=-1, SASL_OK=0, SASL_AUTH=1, SASL_SYS=2, SASL_PERM=3, - SASL_TEMP=4} pn_sasl_outcome_t; - -pn_sasl_t *pn_sasl(); -void pn_sasl_client(pn_sasl_t *sasl, const char *mechanism, const char *username, const char *password); -void pn_sasl_server(pn_sasl_t *sasl); -void pn_sasl_auth(pn_sasl_t *sasl, pn_sasl_outcome_t outcome); -bool pn_sasl_init(pn_sasl_t *sasl); -const char *pn_sasl_mechanism(pn_sasl_t *sasl); -pn_binary_t *pn_sasl_challenge(pn_sasl_t *sasl); -pn_binary_t *pn_sasl_response(pn_sasl_t *sasl); -pn_sasl_outcome_t pn_sasl_outcome(pn_sasl_t *sasl); -ssize_t pn_sasl_input(pn_sasl_t *sasl, char *bytes, size_t available); -ssize_t pn_sasl_output(pn_sasl_t *sasl, char *bytes, size_t size); -void pn_sasl_trace(pn_sasl_t *sasl, pn_trace_t trace); -void pn_sasl_destroy(pn_sasl_t *sasl); - -#endif /* sasl.h */ http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/e57c2a52/proton-c/include/proton/util.h ---------------------------------------------------------------------- diff --git a/proton-c/include/proton/util.h b/proton-c/include/proton/util.h deleted file mode 100644 index 3d24b61..0000000 --- a/proton-c/include/proton/util.h +++ /dev/null @@ -1,31 +0,0 @@ -#ifndef _PROTON_UTIL_H -#define _PROTON_UTIL_H 1 - -/* - * - * 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. - * - */ - -#include <stdarg.h> - -void parse_url(char *url, char **user, char **pass, char **host, char **port); -void pn_fatal(char *fmt, ...); -void pn_vfatal(char *fmt, va_list ap); - -#endif /* util.h */ --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
