This is an automated email from the ASF dual-hosted git repository.
tabish121 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
from 4be6231f PROTON-2941 Update to latest slf4j
new 6b8c0b2e Various codec correctness and performance improvements
new 1694e03a PROTON-2923 Update to Netty 4.2.17.Final release
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 2 +-
.../apache/qpid/protonj2/client/DecodeOptions.java | 100 ++
.../org/apache/qpid/protonj2/client/Delivery.java | 55 +
.../qpid/protonj2/client/StreamDecodeOptions.java | 251 +++++
.../qpid/protonj2/client/StreamDelivery.java | 50 +
.../protonj2/client/impl/ClientConnection.java | 2 +-
.../client/impl/ClientConversionSupport.java | 67 +-
.../qpid/protonj2/client/impl/ClientDelivery.java | 32 +
.../protonj2/client/impl/ClientMessageSupport.java | 31 +-
.../protonj2/client/impl/ClientStreamDelivery.java | 19 +-
.../client/impl/ClientStreamReceiverMessage.java | 13 +-
.../qpid/protonj2/client/impl/ReceiverTest.java | 199 ++++
.../protonj2/client/impl/StreamReceiverTest.java | 258 +++++
.../protonj2/client/impl/TransactionsTest.java | 2 +-
.../client/test/ImperativeClientTestCase.java | 47 +
.../protonj2/codec/ProtonEncoderBenchmark.java | 115 ++
.../protonj2/engine/util/MapBenchmarkBase.java | 10 +-
.../engine/util/UnsettledMapBenchmark.java | 385 +++++++
.../buffer/ProtonBufferComponentAccessor.java | 57 +-
.../qpid/protonj2/buffer/ProtonBufferUtils.java | 2 +-
.../buffer/impl/ProtonByteArrayBuffer.java | 8 +-
.../buffer/impl/ProtonCompositeBufferImpl.java | 15 +
.../buffer/netty/Netty4ToProtonBufferAdapter.java | 2 +-
.../apache/qpid/protonj2/codec/DecoderState.java | 78 ++
.../qpid/protonj2/codec/StreamDecoderState.java | 223 ++++
.../qpid/protonj2/codec/StreamTypeDecoder.java | 8 +-
.../apache/qpid/protonj2/codec/TypeDecoder.java | 8 +-
.../decoders/AbstractDescribedListTypeDecoder.java | 217 +++-
.../decoders/AbstractDescribedMapTypeDecoder.java | 216 +++-
.../decoders/AbstractDescribedTypeDecoder.java | 8 +-
.../decoders/AbstractPrimitiveTypeDecoder.java | 12 +-
.../codec/decoders/PrimitiveArrayTypeDecoder.java | 99 ++
.../codec/decoders/PrimitiveTypeDecoder.java | 54 +-
.../protonj2/codec/decoders/ProtonDecoder.java | 237 +++--
.../codec/decoders/ProtonDecoderFactory.java | 91 +-
.../codec/decoders/ProtonDecoderState.java | 155 +--
.../codec/decoders/ProtonStreamDecoder.java | 204 ++--
.../codec/decoders/ProtonStreamDecoderFactory.java | 83 +-
.../codec/decoders/ProtonStreamDecoderState.java | 199 +++-
.../decoders/UnknownDescribedTypeDecoder.java | 76 +-
.../decoders/messaging/AcceptedTypeDecoder.java | 81 +-
.../messaging/AmqpSequenceTypeDecoder.java | 18 +-
.../decoders/messaging/AmqpValueTypeDecoder.java | 44 +-
.../ApplicationPropertiesTypeDecoder.java | 104 +-
.../codec/decoders/messaging/DataTypeDecoder.java | 38 +-
.../messaging/DeleteOnCloseTypeDecoder.java | 60 +-
.../DeleteOnNoLinksOrMessagesTypeDecoder.java | 60 +-
.../messaging/DeleteOnNoLinksTypeDecoder.java | 60 +-
.../messaging/DeleteOnNoMessagesTypeDecoder.java | 60 +-
.../messaging/DeliveryAnnotationsTypeDecoder.java | 108 +-
.../decoders/messaging/FooterTypeDecoder.java | 80 +-
.../decoders/messaging/HeaderTypeDecoder.java | 95 +-
.../messaging/MessageAnnotationsTypeDecoder.java | 110 +-
.../decoders/messaging/ModifiedTypeDecoder.java | 87 +-
.../decoders/messaging/PropertiesTypeDecoder.java | 135 +--
.../decoders/messaging/ReceivedTypeDecoder.java | 73 +-
.../decoders/messaging/RejectedTypeDecoder.java | 87 +-
.../decoders/messaging/ReleasedTypeDecoder.java | 79 +-
.../decoders/messaging/SourceTypeDecoder.java | 134 +--
.../decoders/messaging/TargetTypeDecoder.java | 112 +-
.../primitives/AbstractArrayTypeDecoder.java | 408 ++------
.../primitives/AbstractBinaryTypeDecoder.java | 56 +-
.../primitives/AbstractListTypeDecoder.java | 120 ++-
.../primitives/AbstractMapTypeDecoder.java | 189 +++-
.../primitives/AbstractStringTypeDecoder.java | 34 +-
.../primitives/AbstractSymbolTypeDecoder.java | 59 +-
.../decoders/primitives/Array32TypeDecoder.java | 2 +
.../decoders/primitives/Array8TypeDecoder.java | 2 +
.../decoders/primitives/Binary32TypeDecoder.java | 2 +
.../decoders/primitives/Binary8TypeDecoder.java | 2 +
.../decoders/primitives/BinaryTypeDecoder.java | 64 ++
.../primitives/BooleanFalseTypeDecoder.java | 53 +
.../primitives/BooleanTrueTypeDecoder.java | 53 +
.../decoders/primitives/BooleanTypeDecoder.java | 30 +
.../codec/decoders/primitives/ByteTypeDecoder.java | 30 +
.../decoders/primitives/CharacterTypeDecoder.java | 30 +
.../decoders/primitives/Decimal128TypeDecoder.java | 2 +
.../decoders/primitives/Decimal32TypeDecoder.java | 2 +
.../decoders/primitives/Decimal64TypeDecoder.java | 2 +
.../decoders/primitives/DoubleTypeDecoder.java | 30 +
.../decoders/primitives/FloatTypeDecoder.java | 30 +
.../decoders/primitives/Integer32TypeDecoder.java | 30 +
.../decoders/primitives/Integer8TypeDecoder.java | 30 +
.../decoders/primitives/List0TypeDecoder.java | 34 +-
.../decoders/primitives/List32TypeDecoder.java | 2 +
.../decoders/primitives/List8TypeDecoder.java | 6 +-
.../decoders/primitives/Long8TypeDecoder.java | 79 +-
.../codec/decoders/primitives/LongTypeDecoder.java | 30 +
.../decoders/primitives/Map32TypeDecoder.java | 2 +
.../codec/decoders/primitives/Map8TypeDecoder.java | 6 +-
.../codec/decoders/primitives/NullTypeDecoder.java | 7 +
...peDecoder.java => SaslSymbol32TypeDecoder.java} | 15 +-
...ypeDecoder.java => SaslSymbol8TypeDecoder.java} | 15 +-
.../decoders/primitives/ShortTypeDecoder.java | 30 +
.../decoders/primitives/String32TypeDecoder.java | 2 +
.../decoders/primitives/String8TypeDecoder.java | 4 +-
.../decoders/primitives/Symbol32TypeDecoder.java | 2 +
.../decoders/primitives/Symbol8TypeDecoder.java | 2 +
.../decoders/primitives/TimestampTypeDecoder.java | 2 +
.../codec/decoders/primitives/UUIDTypeDecoder.java | 2 +
.../primitives/UnsignedByteTypeDecoder.java | 2 +
.../primitives/UnsignedInteger0TypeDecoder.java | 7 +
.../primitives/UnsignedInteger32TypeDecoder.java | 2 +
.../primitives/UnsignedInteger8TypeDecoder.java | 2 +
.../primitives/UnsignedLong0TypeDecoder.java | 7 +
.../primitives/UnsignedLong64TypeDecoder.java | 2 +
.../primitives/UnsignedLong8TypeDecoder.java | 2 +
.../primitives/UnsignedShortTypeDecoder.java | 2 +
.../security/SaslChallengeTypeDecoder.java | 73 +-
.../decoders/security/SaslInitTypeDecoder.java | 101 +-
.../security/SaslMechanismsTypeDecoder.java | 73 +-
.../decoders/security/SaslOutcomeTypeDecoder.java | 90 +-
.../decoders/security/SaslResponseTypeDecoder.java | 73 +-
.../transactions/CoordinatorTypeDecoder.java | 69 +-
.../decoders/transactions/DeclareTypeDecoder.java | 69 +-
.../decoders/transactions/DeclaredTypeDecoder.java | 96 +-
.../transactions/DischargeTypeDecoder.java | 103 +-
.../transactions/TransactionStateTypeDecoder.java | 103 +-
.../decoders/transport/AttachTypeDecoder.java | 69 +-
.../codec/decoders/transport/BeginTypeDecoder.java | 69 +-
.../codec/decoders/transport/CloseTypeDecoder.java | 67 +-
.../decoders/transport/DetachTypeDecoder.java | 69 +-
.../decoders/transport/DispositionTypeDecoder.java | 69 +-
.../codec/decoders/transport/EndTypeDecoder.java | 67 +-
.../transport/ErrorConditionTypeDecoder.java | 91 +-
.../codec/decoders/transport/FlowTypeDecoder.java | 71 +-
.../codec/decoders/transport/OpenTypeDecoder.java | 69 +-
.../decoders/transport/TransferTypeDecoder.java | 71 +-
.../encoders/AbstractDescribedListTypeEncoder.java | 68 +-
.../encoders/AbstractDescribedMapTypeEncoder.java | 55 +-
.../encoders/AbstractPrimitiveTypeEncoder.java | 3 +-
.../codec/encoders/DeliveryTagEncoder.java | 15 +-
.../protonj2/codec/encoders/ProtonEncoder.java | 74 +-
.../codec/encoders/ProtonEncoderFactory.java | 85 +-
.../codec/encoders/ProtonEncoderState.java | 4 +-
.../protonj2/codec/encoders/ProtonEncodings.java | 273 +++++
.../encoders/UnknownDescribedTypeEncoder.java | 2 +
.../encoders/messaging/AcceptedTypeEncoder.java | 20 +-
.../messaging/AmqpSequenceTypeEncoder.java | 8 +-
.../encoders/messaging/AmqpValueTypeEncoder.java | 8 +-
.../ApplicationPropertiesTypeEncoder.java | 14 +-
.../codec/encoders/messaging/DataTypeEncoder.java | 10 +-
.../messaging/DeleteOnCloseTypeEncoder.java | 14 +-
.../DeleteOnNoLinksOrMessagesTypeEncoder.java | 14 +-
.../messaging/DeleteOnNoLinksTypeEncoder.java | 14 +-
.../messaging/DeleteOnNoMessagesTypeEncoder.java | 14 +-
.../messaging/DeliveryAnnotationsTypeEncoder.java | 13 +-
.../encoders/messaging/FooterTypeEncoder.java | 13 +-
.../encoders/messaging/HeaderTypeEncoder.java | 100 +-
.../messaging/MessageAnnotationsTypeEncoder.java | 14 +-
.../encoders/messaging/ModifiedTypeEncoder.java | 41 +-
.../encoders/messaging/PropertiesTypeEncoder.java | 123 +--
.../encoders/messaging/ReceivedTypeEncoder.java | 40 +-
.../encoders/messaging/RejectedTypeEncoder.java | 25 +-
.../encoders/messaging/ReleasedTypeEncoder.java | 18 +-
.../encoders/messaging/SourceTypeEncoder.java | 120 +--
.../encoders/messaging/TargetTypeEncoder.java | 88 +-
.../encoders/primitives/ArrayTypeEncoder.java | 5 +-
.../encoders/primitives/BinaryTypeEncoder.java | 18 +-
.../encoders/primitives/BooleanTypeEncoder.java | 8 +-
.../codec/encoders/primitives/ByteTypeEncoder.java | 8 +-
.../encoders/primitives/CharacterTypeEncoder.java | 9 +-
.../encoders/primitives/Decimal128TypeEncoder.java | 2 +
.../encoders/primitives/Decimal32TypeEncoder.java | 2 +
.../encoders/primitives/Decimal64TypeEncoder.java | 2 +
.../encoders/primitives/DoubleTypeEncoder.java | 8 +-
.../encoders/primitives/FloatTypeEncoder.java | 8 +-
.../encoders/primitives/IntegerTypeEncoder.java | 8 +-
.../codec/encoders/primitives/ListTypeEncoder.java | 26 +-
.../codec/encoders/primitives/LongTypeEncoder.java | 8 +-
.../codec/encoders/primitives/MapTypeEncoder.java | 21 +-
.../codec/encoders/primitives/NullTypeEncoder.java | 2 +
.../encoders/primitives/ShortTypeEncoder.java | 8 +-
.../encoders/primitives/StringTypeEncoder.java | 45 +-
.../encoders/primitives/SymbolTypeEncoder.java | 15 +-
.../encoders/primitives/TimestampTypeEncoder.java | 2 +
.../codec/encoders/primitives/UUIDTypeEncoder.java | 2 +
.../primitives/UnsignedByteTypeEncoder.java | 2 +
.../primitives/UnsignedIntegerTypeEncoder.java | 44 +-
.../primitives/UnsignedLongTypeEncoder.java | 22 +-
.../primitives/UnsignedShortTypeEncoder.java | 2 +
.../security/SaslChallengeTypeEncoder.java | 37 +-
.../encoders/security/SaslInitTypeEncoder.java | 45 +-
.../security/SaslMechanismsTypeEncoder.java | 26 +-
.../encoders/security/SaslOutcomeTypeEncoder.java | 38 +-
.../encoders/security/SaslResponseTypeEncoder.java | 43 +-
.../transactions/CoordinatorTypeEncoder.java | 23 +-
.../encoders/transactions/DeclareTypeEncoder.java | 23 +-
.../encoders/transactions/DeclaredTypeEncoder.java | 39 +-
.../transactions/DischargeTypeEncoder.java | 44 +-
.../transactions/TransactionStateTypeEncoder.java | 46 +-
.../encoders/transport/AttachTypeEncoder.java | 91 +-
.../codec/encoders/transport/BeginTypeEncoder.java | 93 +-
.../codec/encoders/transport/CloseTypeEncoder.java | 17 +-
.../encoders/transport/DetachTypeEncoder.java | 54 +-
.../encoders/transport/DispositionTypeEncoder.java | 75 +-
.../codec/encoders/transport/EndTypeEncoder.java | 17 +-
.../transport/ErrorConditionTypeEncoder.java | 50 +-
.../codec/encoders/transport/FlowTypeEncoder.java | 113 +-
.../codec/encoders/transport/OpenTypeEncoder.java | 72 +-
.../encoders/transport/TransferTypeEncoder.java | 121 ++-
.../qpid/protonj2/engine/EngineConfiguration.java | 27 +-
.../exceptions/ProtocolViolationException.java | 3 +-
.../engine/impl/ProtonEngineConfiguration.java | 19 +
.../engine/impl/ProtonFrameDecodingHandler.java | 24 +-
.../engine/impl/ProtonIncomingDelivery.java | 14 +-
.../qpid/protonj2/engine/impl/ProtonReceiver.java | 12 +-
.../engine/impl/ProtonSessionIncomingWindow.java | 19 +-
.../engine/impl/ProtonTransactionManager.java | 3 +-
.../engine/impl/sasl/ProtonSaslClientContext.java | 2 +-
.../engine/impl/sasl/ProtonSaslServerContext.java | 2 +-
.../protonj2/engine/sasl/SaslClientContext.java | 2 +-
.../protonj2/engine/sasl/SaslServerContext.java | 2 +-
.../engine/sasl/client/AnonymousMechanism.java | 2 +-
.../engine/sasl/client/CramMD5Mechanism.java | 2 +-
.../engine/sasl/client/ExternalMechanism.java | 2 +-
.../engine/sasl/client/OauthBearerMechanism.java | 2 +-
.../engine/sasl/client/PlainMechanism.java | 2 +-
.../engine/sasl/client/ScramSHA1Mechanism.java | 2 +-
.../engine/sasl/client/ScramSHA256Mechanism.java | 2 +-
.../engine/sasl/client/ScramSHA512Mechanism.java | 2 +-
.../engine/sasl/client/XOauth2Mechanism.java | 2 +-
.../qpid/protonj2/engine/util/StringUtils.java | 100 +-
.../qpid/protonj2/engine/util/UnsettledMap.java | 1045 ++++++++++++-------
.../org/apache/qpid/protonj2/types/Symbol.java | 232 ++++-
.../org/apache/qpid/protonj2/types/Symbols.java | 14 +
.../apache/qpid/protonj2/types/UnsignedByte.java | 2 +
.../qpid/protonj2/types/messaging/Header.java | 5 +
.../qpid/protonj2/types/messaging/Modified.java | 56 +-
.../qpid/protonj2/types/messaging/Properties.java | 9 +-
.../qpid/protonj2/types/messaging/Received.java | 38 +
.../qpid/protonj2/types/messaging/Source.java | 141 +++
.../qpid/protonj2/types/messaging/Target.java | 97 ++
.../protonj2/types/security/SaslChallenge.java | 2 +-
.../qpid/protonj2/types/security/SaslInit.java | 2 +-
.../protonj2/types/security/SaslMechanisms.java | 2 +-
.../qpid/protonj2/types/security/SaslOutcome.java | 2 +-
.../qpid/protonj2/types/security/SaslResponse.java | 2 +-
.../qpid/protonj2/types/transport/Attach.java | 2 +-
.../qpid/protonj2/types/transport/Begin.java | 2 +-
.../qpid/protonj2/types/transport/Detach.java | 2 +-
.../protonj2/types/transport/ErrorCondition.java | 38 +
.../apache/qpid/protonj2/types/transport/Open.java | 2 +-
.../qpid/protonj2/types/transport/Transfer.java | 2 +-
.../protonj2/buffer/ProtonAbstractBufferTest.java | 122 +++
.../buffer/impl/ProtonCompositeBufferImplTest.java | 14 +-
.../qpid/protonj2/codec/CodecTestSupport.java | 12 +
.../codec/UnknownDescribedTypeCodecTest.java | 432 ++++++++
.../qpid/protonj2/codec/benchmark/Benchmark.java | 954 ++++++++++++++---
.../protonj2/codec/decoders/ProtonDecoderTest.java | 187 +++-
.../codec/decoders/ProtonDecodersErrorTest.java | 1096 ++++++++++++++++++++
.../codec/decoders/ProtonStreamDecoderTest.java | 207 +++-
.../protonj2/codec/legacy/CodecToLegacyType.java | 103 ++
.../codec/messaging/AcceptedTypeCodecTest.java | 143 +++
.../codec/messaging/AmqpSequenceTypeCodecTest.java | 67 ++
.../codec/messaging/AmqpValueTypeCodecTest.java | 256 +++++
.../ApplicationPropertiesTypeCodecTest.java | 573 +++++++++-
.../codec/messaging/DataTypeCodecTest.java | 22 +
.../messaging/DeleteOnCloseTypeCodecTest.java | 143 +++
.../DeleteOnNoLinksOrMessagesCodecTest.java | 143 +++
.../messaging/DeleteOnNoLinksTypeCodecTest.java | 143 +++
.../messaging/DeleteOnNoMessagesTypeCodecTest.java | 143 +++
.../DeliveryAnnotationsTypeCodecTest.java | 235 ++++-
.../codec/messaging/FlowTypeCodecTest.java | 267 -----
.../codec/messaging/FooterTypeCodecTest.java | 238 ++++-
.../codec/messaging/HeaderTypeCodecTest.java | 194 ++++
.../messaging/MessageAnnotationsTypeCodecTest.java | 235 ++++-
.../codec/messaging/ModifiedTypeCodecTest.java | 4 +-
.../codec/messaging/RejectedTypeCodecTest.java | 4 +-
.../codec/primitives/ArrayTypeCodecTest.java | 490 ++++++++-
.../codec/primitives/BinaryTypeCodecTest.java | 67 +-
.../codec/primitives/BooleanTypeCodecTest.java | 308 +++++-
.../codec/primitives/ByteTypeCodecTest.java | 129 +++
.../codec/primitives/CharacterTypeCodecTest.java | 89 ++
.../codec/primitives/DoubleTypeCodecTest.java | 89 ++
.../codec/primitives/FloatTypeCodecTest.java | 88 ++
.../codec/primitives/IntegerTypeCodecTest.java | 227 +++-
.../codec/primitives/ListTypeCodecTest.java | 382 ++++++-
.../codec/primitives/LongTypeCodecTest.java | 180 +++-
.../codec/primitives/MapTypeCodecTest.java | 378 +++++++
.../codec/primitives/NullTypeCodecTest.java | 191 ++++
.../codec/primitives/ShortTypeCodecTest.java | 91 ++
.../codec/primitives/StringTypeCodecTest.java | 102 ++
.../codec/primitives/SymbolTypeCodecTest.java | 116 ++-
.../primitives/UnsignedIntegerTypeCodecTest.java | 156 +++
.../primitives/UnsignedLongTypeCodecTest.java | 165 ++-
.../codec/security/SaslChallengeTypeCodecTest.java | 93 ++
.../codec/security/SaslInitTypeCodecTest.java | 129 ++-
.../security/SaslMechanismsTypeCodecTest.java | 170 ++-
.../codec/security/SaslOutcomeTypeCodecTest.java | 93 ++
.../codec/security/SaslResponseTypeCodecTest.java | 93 ++
.../codec/transport/BeginTypeCodecTest.java | 153 ++-
.../codec/transport/DispositionTypeCodecTest.java | 75 +-
.../transport/ErrorConditionTypeCodecTest.java | 58 +-
.../codec/transport/FlowTypeCodecTest.java | 90 ++
.../protonj2/engine/impl/ProtonConnectionTest.java | 31 +
.../engine/impl/ProtonDecodeErrorTest.java | 37 +-
.../protonj2/engine/impl/ProtonReceiverTest.java | 258 ++++-
.../protonj2/engine/impl/ProtonSenderTest.java | 65 ++
.../impl/ProtonSessionIncomingWindowTest.java | 44 +
.../protonj2/engine/impl/ProtonSessionTest.java | 128 ++-
.../engine/impl/sasl/ProtonSaslHandlerTest.java | 26 +-
.../engine/impl/sasl/ProtonSaslServerTest.java | 8 +-
.../engine/sasl/client/AbstractMechanismTest.java | 2 +-
.../engine/sasl/client/SaslMechanismsTest.java | 2 +-
.../protonj2/engine/util/UnsettledMapTest.java | 1053 ++++++++++++++++++-
.../org/apache/qpid/protonj2/types/SymbolTest.java | 184 +++-
.../qpid/protonj2/types/security/SaslInitTest.java | 4 +-
.../types/security/SaslMechanismsTest.java | 4 +-
.../types/transport/ErrorConditionTest.java | 6 +-
310 files changed, 19330 insertions(+), 5642 deletions(-)
create mode 100644
protonj2-client/src/main/java/org/apache/qpid/protonj2/client/DecodeOptions.java
create mode 100644
protonj2-client/src/main/java/org/apache/qpid/protonj2/client/StreamDecodeOptions.java
create mode 100644
protonj2-performance-tests/src/main/java/org/apache/qpid/protonj2/codec/ProtonEncoderBenchmark.java
create mode 100644
protonj2-performance-tests/src/main/java/org/apache/qpid/protonj2/engine/util/UnsettledMapBenchmark.java
copy
protonj2/src/main/java/org/apache/qpid/protonj2/codec/decoders/primitives/{Symbol32TypeDecoder.java
=> SaslSymbol32TypeDecoder.java} (69%)
copy
protonj2/src/main/java/org/apache/qpid/protonj2/codec/decoders/primitives/{Symbol8TypeDecoder.java
=> SaslSymbol8TypeDecoder.java} (70%)
create mode 100644
protonj2/src/main/java/org/apache/qpid/protonj2/codec/encoders/ProtonEncodings.java
create mode 100644
protonj2/src/test/java/org/apache/qpid/protonj2/codec/decoders/ProtonDecodersErrorTest.java
delete mode 100644
protonj2/src/test/java/org/apache/qpid/protonj2/codec/messaging/FlowTypeCodecTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
