Merge branch 'master' into rajith-codec Keeping the codec branch upto date with master.
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/a8ed0f35 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/a8ed0f35 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/a8ed0f35 Branch: refs/heads/rajith-codec Commit: a8ed0f357c8a8e5d6514f5c7dabbbf1b4303610f Parents: 2877fa3 d5bd60d Author: Rajith Attapattu <[email protected]> Authored: Wed May 13 17:55:04 2015 -0400 Committer: Rajith Attapattu <[email protected]> Committed: Wed May 13 17:55:04 2015 -0400 ---------------------------------------------------------------------- .gitattributes | 2 + .gitignore | 6 + .travis.yml | 6 + CMakeLists.txt | 93 +- DEVELOPERS | 36 - DEVELOPERS.md | 86 + INSTALL.md | 168 ++ NOTICE | 5 + README | 259 --- README.md | 42 + appveyor.yml | 16 + bin/export.sh | 50 +- bin/jenkins-proton-c-build.sh | 46 + bin/release.sh | 23 +- bin/version.sh | 4 +- contrib/proton-hawtdispatch/pom.xml | 2 +- .../proton/hawtdispatch/impl/AmqpTransport.java | 1 - contrib/proton-jms/pom.xml | 2 +- .../jms/AMQPNativeOutboundTransformer.java | 6 + examples/CMakeLists.txt | 2 +- examples/README.txt | 7 - examples/c/messenger/CMakeLists.txt | 32 + examples/c/messenger/recv-async.c | 193 +++ examples/c/messenger/recv.c | 154 ++ examples/c/messenger/send-async.c | 170 ++ examples/c/messenger/send.c | 111 ++ examples/engine/java/drain | 2 +- examples/engine/java/pom.xml | 2 +- examples/engine/java/server | 2 +- examples/engine/java/spout | 2 +- examples/engine/py/README | 155 -- examples/engine/py/abstract_server.py | 35 - examples/engine/py/client.py | 64 - examples/engine/py/client_http.py | 110 -- examples/engine/py/common.py | 699 -------- examples/engine/py/db_common.py | 114 -- examples/engine/py/db_ctrl.py | 46 - examples/engine/py/db_recv.py | 79 - examples/engine/py/db_send.py | 105 -- examples/engine/py/helloworld.py | 45 - examples/engine/py/helloworld_blocking.py | 35 - examples/engine/py/helloworld_direct.py | 47 - examples/engine/py/helloworld_direct_tornado.py | 52 - examples/engine/py/helloworld_tornado.py | 49 - examples/engine/py/proton_server.py | 61 - examples/engine/py/proton_tornado.py | 70 - examples/engine/py/recurring_timer.py | 43 - examples/engine/py/recurring_timer_tornado.py | 44 - examples/engine/py/selected_recv.py | 40 - examples/engine/py/server.py | 56 - examples/engine/py/server_direct.py | 60 - examples/engine/py/server_tx.py | 77 - examples/engine/py/simple_recv.py | 54 - examples/engine/py/simple_send.py | 62 - examples/engine/py/sync_client.py | 88 - examples/engine/py/test_examples.py | 106 -- examples/engine/py/tx_recv.py | 79 - examples/engine/py/tx_recv_interactive.py | 83 - examples/engine/py/tx_send.py | 87 - examples/go/README.md | 69 + examples/go/event/broker.go | 255 +++ examples/go/receive.go | 176 ++ examples/go/send.go | 158 ++ examples/include/pncompat/misc_defs.h | 8 +- examples/java/messenger/README.txt | 22 + examples/java/messenger/pom.xml | 41 + examples/java/messenger/recv | 12 + examples/java/messenger/send | 10 + .../org/apache/qpid/proton/example/Recv.java | 131 ++ .../org/apache/qpid/proton/example/Send.java | 102 ++ examples/javascript/messenger/client.js | 103 ++ examples/javascript/messenger/drain.js | 70 + examples/javascript/messenger/proxy.js | 105 ++ examples/javascript/messenger/qpid-config.js | 1511 ++++++++++++++++++ examples/javascript/messenger/recv.js | 69 + examples/javascript/messenger/send.html | 122 ++ examples/javascript/messenger/send.js | 105 ++ examples/javascript/messenger/server.js | 81 + examples/javascript/messenger/spout.js | 71 + examples/javascript/messenger/ws2tcp.js | 166 ++ examples/messenger/c/CMakeLists.txt | 32 - examples/messenger/c/recv-async.c | 193 --- examples/messenger/c/recv.c | 154 -- examples/messenger/c/send-async.c | 169 -- examples/messenger/c/send.c | 111 -- examples/messenger/java/README.txt | 22 - examples/messenger/java/pom.xml | 41 - examples/messenger/java/recv | 12 - examples/messenger/java/send | 10 - .../org/apache/qpid/proton/example/Recv.java | 131 -- .../org/apache/qpid/proton/example/Send.java | 102 -- examples/messenger/javascript/client.js | 103 -- examples/messenger/javascript/drain.js | 70 - examples/messenger/javascript/proxy.js | 105 -- examples/messenger/javascript/qpid-config.js | 1511 ------------------ examples/messenger/javascript/recv.js | 69 - examples/messenger/javascript/send.html | 122 -- examples/messenger/javascript/send.js | 105 -- examples/messenger/javascript/server.js | 81 - examples/messenger/javascript/spout.js | 71 - examples/messenger/javascript/ws2tcp.js | 166 -- examples/messenger/perl/async.pm | 120 -- examples/messenger/perl/client.pl | 105 -- examples/messenger/perl/recv.pl | 99 -- examples/messenger/perl/recv_async.pl | 84 - examples/messenger/perl/send.pl | 88 - examples/messenger/perl/send_async.pl | 97 -- examples/messenger/perl/server.pl | 123 -- examples/messenger/php/recv.php | 49 - examples/messenger/php/send.php | 41 - examples/messenger/py/README.txt | 20 - examples/messenger/py/async.py | 81 - examples/messenger/py/client.py | 55 - examples/messenger/py/recv.py | 54 - examples/messenger/py/recv_async.py | 55 - examples/messenger/py/send.py | 44 - examples/messenger/py/send_async.py | 63 - examples/messenger/py/server.py | 61 - examples/messenger/ruby/client.rb | 92 -- examples/messenger/ruby/mailserver.rb | 85 - examples/messenger/ruby/passive_recv.rb | 140 -- examples/messenger/ruby/recv.rb | 82 - examples/messenger/ruby/send.rb | 74 - examples/perl/messenger/async.pm | 120 ++ examples/perl/messenger/client.pl | 105 ++ examples/perl/messenger/recv.pl | 99 ++ examples/perl/messenger/recv_async.pl | 84 + examples/perl/messenger/send.pl | 88 + examples/perl/messenger/send_async.pl | 97 ++ examples/perl/messenger/server.pl | 123 ++ examples/php/messenger/recv.php | 49 + examples/php/messenger/send.php | 41 + examples/python/README | 173 ++ examples/python/abstract_server.py | 35 + examples/python/broker.py | 124 ++ examples/python/client.py | 64 + examples/python/client_http.py | 113 ++ examples/python/db_common.py | 114 ++ examples/python/db_ctrl.py | 46 + examples/python/db_recv.py | 79 + examples/python/db_send.py | 105 ++ examples/python/direct_recv.py | 59 + examples/python/direct_send.py | 63 + examples/python/helloworld.py | 44 + examples/python/helloworld_blocking.py | 33 + examples/python/helloworld_direct.py | 47 + examples/python/helloworld_direct_tornado.py | 47 + examples/python/helloworld_tornado.py | 44 + examples/python/messenger/README.txt | 20 + examples/python/messenger/async.py | 81 + examples/python/messenger/client.py | 55 + examples/python/messenger/recv.py | 54 + examples/python/messenger/recv_async.py | 55 + examples/python/messenger/send.py | 44 + examples/python/messenger/send_async.py | 63 + examples/python/messenger/server.py | 61 + examples/python/proton_server.py | 61 + examples/python/proton_tornado.py | 114 ++ examples/python/queue_browser.py | 42 + examples/python/reactor/README.md | 34 + examples/python/reactor/cat.py | 56 + examples/python/reactor/count-randomly.py | 77 + examples/python/reactor/counter.py | 60 + examples/python/reactor/delegates.py | 48 + examples/python/reactor/echo.py | 61 + examples/python/reactor/global-logger.py | 58 + examples/python/reactor/goodbye-world.py | 46 + examples/python/reactor/handlers.py | 48 + examples/python/reactor/hello-world.py | 42 + examples/python/reactor/reactor-logger.py | 54 + examples/python/reactor/recv.py | 48 + examples/python/reactor/scheduling.py | 51 + examples/python/reactor/send.py | 90 ++ examples/python/reactor/tornado-hello-world.py | 41 + examples/python/reactor/tornado-send.py | 82 + examples/python/reactor/tornado_app.py | 93 ++ examples/python/reactor/unhandled.py | 34 + examples/python/recurring_timer.py | 42 + examples/python/recurring_timer_tornado.py | 44 + examples/python/selected_recv.py | 40 + examples/python/server.py | 57 + examples/python/server_direct.py | 63 + examples/python/server_tx.py | 78 + examples/python/simple_recv.py | 58 + examples/python/simple_send.py | 62 + examples/python/sync_client.py | 54 + examples/python/test_examples.py | 130 ++ examples/python/tx_recv.py | 79 + examples/python/tx_recv_interactive.py | 83 + examples/python/tx_send.py | 88 + examples/ruby/messenger/client.rb | 92 ++ examples/ruby/messenger/mailserver.rb | 85 + examples/ruby/messenger/passive_recv.rb | 140 ++ examples/ruby/messenger/recv.rb | 82 + examples/ruby/messenger/send.rb | 74 + pom.xml | 4 +- proton-c/CMakeLists.txt | 185 ++- proton-c/bindings/CMakeLists.txt | 12 + proton-c/bindings/go/README.md | 5 + proton-c/bindings/javascript/CMakeLists.txt | 49 +- proton-c/bindings/javascript/README | 4 +- proton-c/bindings/javascript/data.js | 13 +- proton-c/bindings/javascript/message.js | 29 +- .../javascript/qpid-proton-messenger/LICENSE | 203 +++ .../javascript/qpid-proton-messenger/README.md | 94 ++ .../qpid-proton-messenger/lib/.gitignore | 21 + .../qpid-proton-messenger/package.json | 18 + .../bindings/javascript/qpid-proton/LICENSE | 203 --- .../bindings/javascript/qpid-proton/README.md | 4 - .../javascript/qpid-proton/lib/.gitignore | 21 - .../javascript/qpid-proton/package.json | 11 - proton-c/bindings/node/CMakeLists.txt | 71 + proton-c/bindings/node/binding.gyp.in | 31 + proton-c/bindings/node/javascript.i | 42 + proton-c/bindings/perl/CMakeLists.txt | 9 +- proton-c/bindings/perl/lib/qpid/proton/Data.pm | 4 +- .../bindings/perl/lib/qpid/proton/Message.pm | 16 +- proton-c/bindings/perl/lib/qpid/proton/utils.pm | 7 + proton-c/bindings/perl/perl.i | 48 +- proton-c/bindings/php/CMakeLists.txt | 1 + proton-c/bindings/php/examples/client.php | 188 --- proton-c/bindings/php/examples/server.php | 218 --- proton-c/bindings/php/php.i | 124 +- proton-c/bindings/php/proton.php | 36 +- proton-c/bindings/python/CMakeLists.txt | 8 +- proton-c/bindings/python/cproton.i | 128 +- proton-c/bindings/python/docs/Makefile | 153 ++ proton-c/bindings/python/docs/README | 5 + proton-c/bindings/python/docs/make.bat | 190 +++ proton-c/bindings/python/docs/source/conf.py | 242 +++ proton-c/bindings/python/docs/source/index.rst | 24 + .../bindings/python/docs/source/overview.rst | 161 ++ .../bindings/python/docs/source/reference.rst | 44 + .../bindings/python/docs/source/tutorial.rst | 301 ++++ proton-c/bindings/python/proton/__init__.py | 839 +++++----- proton-c/bindings/python/proton/handlers.py | 248 ++- proton-c/bindings/python/proton/reactor.py | 753 +++++++++ proton-c/bindings/python/proton/reactors.py | 962 ----------- proton-c/bindings/python/proton/utils.py | 167 +- proton-c/bindings/python/setup.py | 10 +- proton-c/bindings/ruby/CMakeLists.txt | 1 + proton-c/bindings/ruby/ext/cproton/extconf.rb | 1 - proton-c/bindings/ruby/lib/qpid_proton.rb | 1 - .../ruby/lib/qpid_proton/exception_handling.rb | 3 + .../bindings/ruby/lib/qpid_proton/exceptions.rb | 6 + .../bindings/ruby/lib/qpid_proton/mapping.rb | 12 +- .../bindings/ruby/lib/qpid_proton/message.rb | 37 +- .../ruby/lib/qpid_proton/message_format.rb | 75 - proton-c/bindings/ruby/qpid_proton.gemspec | 3 +- proton-c/bindings/ruby/ruby.i | 52 +- .../ruby/spec/qpid/proton/message_spec.rb | 47 - .../ruby/spec/qpid/proton/messenger_spec.rb | 2 +- proton-c/docs/man/CMakeLists.txt | 2 +- proton-c/docs/man/proton-dump.1 | 7 - proton-c/docs/man/proton.1 | 36 - proton-c/env.py | 5 + proton-c/include/proton/codec.h | 1085 ++++++++++++- proton-c/include/proton/condition.h | 1 - proton-c/include/proton/connection.h | 40 +- proton-c/include/proton/cproton.i | 357 +---- proton-c/include/proton/delivery.h | 12 +- proton-c/include/proton/disposition.h | 1 - proton-c/include/proton/driver.h | 378 ----- proton-c/include/proton/driver_extras.h | 68 - proton-c/include/proton/event.h | 19 +- proton-c/include/proton/io.h | 2 +- proton-c/include/proton/link.h | 1 - proton-c/include/proton/message.h | 75 +- proton-c/include/proton/object.h | 9 +- proton-c/include/proton/reactor.h | 25 +- proton-c/include/proton/sasl.h | 153 +- proton-c/include/proton/scanner.h | 2 +- proton-c/include/proton/session.h | 5 +- proton-c/include/proton/ssl.h | 1 - proton-c/include/proton/terminus.h | 1 - proton-c/include/proton/transport.h | 68 +- proton-c/include/proton/type_compat.h | 11 +- proton-c/include/proton/types.h | 2 +- proton-c/include/proton/version.h.in | 1 + proton-c/src/buffer.c | 34 +- proton-c/src/codec/codec.c | 17 +- proton-c/src/codec/decoder.c | 11 +- proton-c/src/codec/encoder.c | 199 ++- proton-c/src/codec/encoder.h | 1 + proton-c/src/config.h | 26 + proton-c/src/dispatcher/dispatcher.h | 1 - proton-c/src/engine/engine-internal.h | 14 +- proton-c/src/engine/engine.c | 65 +- proton-c/src/error.c | 8 +- proton-c/src/events/event.c | 19 +- proton-c/src/framing/framing.h | 1 - proton-c/src/handlers/flowcontroller.c | 11 +- proton-c/src/handlers/handshaker.c | 4 +- proton-c/src/handlers/iohandler.c | 17 +- proton-c/src/message/message.c | 303 +--- proton-c/src/messenger/messenger.c | 26 +- proton-c/src/messenger/store.c | 22 +- proton-c/src/object/map.c | 74 +- proton-c/src/object/object.c | 9 +- proton-c/src/parser.c | 10 +- proton-c/src/platform.h | 3 - proton-c/src/posix/driver.c | 795 --------- proton-c/src/posix/io.c | 12 +- proton-c/src/posix/selector.c | 5 +- proton-c/src/proton.c | 540 ------- proton-c/src/reactor/acceptor.c | 8 +- proton-c/src/reactor/connection.c | 64 +- proton-c/src/reactor/handler.c | 22 +- proton-c/src/reactor/reactor.c | 142 +- proton-c/src/sasl/cyrus_sasl.c | 370 +++++ proton-c/src/sasl/none_sasl.c | 132 ++ proton-c/src/sasl/sasl-internal.h | 57 +- proton-c/src/sasl/sasl.c | 753 +++++---- proton-c/src/scanner.c | 2 +- proton-c/src/ssl/openssl.c | 50 +- proton-c/src/ssl/ssl-internal.h | 2 + proton-c/src/tests/CMakeLists.txt | 10 +- proton-c/src/tests/object.c | 142 +- proton-c/src/tests/reactor.c | 44 +- proton-c/src/tests/refcount.c | 101 ++ proton-c/src/transport/transport.c | 237 ++- proton-c/src/util.c | 32 +- proton-c/src/util.h | 11 +- proton-c/src/windows/driver.c | 819 ---------- proton-c/src/windows/iocp.c | 14 +- proton-c/src/windows/iocp.h | 3 +- proton-c/src/windows/schannel.c | 11 +- proton-c/src/windows/selector.c | 8 +- proton-j/pom.xml | 2 +- .../java/org/apache/qpid/proton/codec/Data.java | 1 + .../apache/qpid/proton/codec/EncoderImpl.java | 7 +- .../apache/qpid/proton/codec/StringType.java | 8 +- .../apache/qpid/proton/codec/impl/DataImpl.java | 10 +- .../apache/qpid/proton/engine/Connection.java | 2 + .../apache/qpid/proton/engine/Transport.java | 9 + .../qpid/proton/engine/impl/ConnectionImpl.java | 14 +- .../qpid/proton/engine/impl/FrameParser.java | 18 +- .../qpid/proton/engine/impl/FrameWriter.java | 9 +- .../engine/impl/PlainTransportWrapper.java | 6 + .../qpid/proton/engine/impl/SaslImpl.java | 33 +- .../qpid/proton/engine/impl/SessionImpl.java | 52 +- .../qpid/proton/engine/impl/TransportImpl.java | 185 ++- .../qpid/proton/engine/impl/TransportInput.java | 5 +- .../qpid/proton/engine/impl/TransportLink.java | 19 +- .../proton/engine/impl/TransportSession.java | 64 +- .../impl/ssl/SimpleSslTransportWrapper.java | 9 +- .../SslHandshakeSniffingTransportWrapper.java | 14 + .../qpid/proton/engine/impl/ssl/SslImpl.java | 13 +- proton-j/src/main/resources/ccodec.py | 18 +- proton-j/src/main/resources/cengine.py | 33 +- proton-j/src/main/resources/chandlers.py | 13 +- proton-j/src/main/resources/cproton.py | 15 + proton-j/src/main/resources/creactor.py | 26 + proton-j/src/main/resources/csasl.py | 42 +- .../qpid/proton/codec/StringTypeTest.java | 56 +- .../proton/engine/impl/TransportImplTest.java | 99 ++ .../impl/ssl/RememberingTransportInput.java | 8 +- tests/interop/described.amqp | Bin 39 -> 33 bytes tests/interop/lists.amqp | Bin 29 -> 26 bytes tests/interop/maps.amqp | Bin 91 -> 73 bytes tests/javascript/codec.js | 2 +- tests/javascript/message.js | 2 +- tests/javascript/msgr-recv.js | 2 +- tests/javascript/msgr-send-common.js | 4 +- tests/javascript/msgr-send.html | 2 +- tests/javascript/msgr-send.js | 2 +- tests/javascript/soak.js | 2 +- tests/pom.xml | 2 +- tests/python/proton-test | 22 +- tests/python/proton_tests/__init__.py | 1 + tests/python/proton_tests/codec.py | 64 +- tests/python/proton_tests/common.py | 229 +-- tests/python/proton_tests/engine.py | 294 ++-- tests/python/proton_tests/interop.py | 8 +- tests/python/proton_tests/message.py | 50 - tests/python/proton_tests/messenger.py | 87 +- tests/python/proton_tests/reactor.py | 172 ++ tests/python/proton_tests/sasl.py | 117 +- tests/python/proton_tests/soak.py | 9 + tests/python/proton_tests/transport.py | 41 + tests/python/proton_tests/utils.py | 25 +- tests/ruby/proton_tests/interop.rb | 2 +- tests/tools/apps/c/CMakeLists.txt | 8 +- tests/tools/apps/c/reactor-recv.c | 451 ++++++ tests/tools/apps/c/reactor-send.c | 389 +++++ tests/tools/apps/python/msgr-send.py | 2 +- tools/cmake/Modules/FindNodePackages.cmake | 7 +- version.txt | 2 +- 388 files changed, 18644 insertions(+), 15592 deletions(-) ---------------------------------------------------------------------- --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
