path # lines of code c/include/proton/connection_driver.h 46 c/include/proton/transport.h 74 c/include/proton/terminus.h 57 c/include/proton/reactor.h 83 c/include/proton/codec.h 153 c/include/proton/annotations.h 79 c/include/proton/session.h 39 c/include/proton/connection.h 58 c/include/proton/raw_connection.h 41 c/include/proton/cid.h 37 c/include/proton/listener.h 24 c/include/proton/message.h 71 c/include/proton/netaddr.h 27 c/include/proton/tls.h 101 c/include/proton/object.h 39 c/include/proton/link.h 76 c/include/proton/delivery.h 43 c/include/proton/import_export.h 47 c/include/proton/types.h 62 c/include/proton/logger.h 48 c/include/proton/error.h 41 c/include/proton/ssl.h 74 c/include/proton/sasl.h 33 c/include/proton/event.h 101 c/include/proton/proactor.h 39 c/include/proton/type_compat.h 86 c/include/proton/selectable.h 51 c/include/proton/cproton.i 804 c/include/proton/version.h.in 26 c/include/proton/engine.h 11 c/include/proton/condition.h 31 c/include/proton/sasl_plugin.h 68 c/include/proton/disposition.h 60 c/include/proton/messenger.h 173 c/include/proton/handlers.h 18 c/include/proton/url.h 45 c/include/proton/log.h 14 c/tools/msgr-recv.c 218 c/tools/include/pncompat/misc_funcs.inc 15 c/tools/include/pncompat/misc_defs.h 15 c/tools/include/pncompat/internal/getopt.c 146 c/tools/include/pncompat/internal/getopt.h 14 c/tools/msgr-common.c 134 c/tools/msgr-send.c 249 c/tools/reactor-send.c 347 c/tools/codec-generator/find_specs.py 81 c/tools/codec-generator/generate.py 460 c/tools/msgr-common.h 35 c/tools/reactor-recv.c 353 c/benchmarks/message-encoding_map.cpp 116 c/benchmarks/benchmarks_main.cpp 2 c/benchmarks/message-encoding_list.cpp 96 c/benchmarks/message-encoding.cpp 25 c/benchmarks/connection-driver.cpp 367 c/src/ssl/openssl.c 1380 c/src/ssl/ssl_stub.c 117 c/src/ssl/ssl-internal.h 11 c/src/ssl/schannel.cpp 1871 c/src/transport.xml 167 c/src/encodings.h.py 20 c/src/libqpid-proton-core.pc.in 28 c/src/messenger/transform.c 206 c/src/messenger/store.c 367 c/src/messenger/messenger.c 2095 c/src/messenger/subscription.h 12 c/src/messenger/store.h 26 c/src/messenger/subscription.c 102 c/src/messenger/messenger.h 6 c/src/messenger/transform.h 14 c/src/messaging.xml 135 c/src/protocol.h.py 118 c/src/platform/platform_fmt.h 22 c/src/platform/platform.h 24 c/src/platform/platform.c 79 c/src/security.xml 43 c/src/types.xml 92 c/src/handlers/handshaker.c 66 c/src/handlers/flowcontroller.c 42 c/src/handlers/iohandler.c 86 c/src/libqpid-proton.pc.in 28 c/src/libqpid-proton-proactor.pc.in 29 c/src/tls/openssl.c 1878 c/src/core/framing.c 122 c/src/core/autodetect.c 49 c/src/core/transport.h 8 c/src/core/buffer.h 25 c/src/core/connection_driver.c 139 c/src/core/log.c 42 c/src/core/memory.h 14 c/src/core/data.h 46 c/src/core/decoder.h 12 c/src/core/dispatcher.c 95 c/src/core/encoder.h 14 c/src/core/fixed_string.h 61 c/src/core/config.h 6 c/src/core/consumers.h 672 c/src/core/autodetect.h 21 c/src/core/object/map.c 366 c/src/core/object/list.c 210 c/src/core/object/object.c 394 c/src/core/object/iterator.c 51 c/src/core/object/record.c 118 c/src/core/object/string.c 214 c/src/core/framing.h 26 c/src/core/engine-internal.h 354 c/src/core/decoder.c 462 c/src/core/message-internal.h 12 c/src/core/dispatch_actions.h 18 c/src/core/logger_private.h 43 c/src/core/memory.c 202 c/src/core/types.c 5 c/src/core/message.c 948 c/src/core/logger.c 233 c/src/core/encoder.c 354 c/src/core/util.c 114 c/src/core/buffer.c 198 c/src/core/codec.c 2049 c/src/core/value_dump.h 13 c/src/core/event.c 311 c/src/core/error.c 112 c/src/core/object_private.h 157 c/src/core/util_str.h 14 c/src/core/engine.c 2450 c/src/core/value_dump.c 547 c/src/core/init.h 5 c/src/core/log_private.h 21 c/src/core/emitters.h 612 c/src/core/transport.c 2590 c/src/core/util.h 206 c/src/core/dispatcher.h 11 c/src/core/max_align.h 21 c/src/core/init.c 12 c/src/protocol.py 87 c/src/reactor/io/windows/selector.c 312 c/src/reactor/io/windows/iocp.h 97 c/src/reactor/io/windows/iocp.c 953 c/src/reactor/io/windows/io.c 366 c/src/reactor/io/windows/write_pipeline.c 242 c/src/reactor/io/posix/selector.c 167 c/src/reactor/io/posix/io.c 260 c/src/reactor/selectable.c 235 c/src/reactor/handler.c 78 c/src/reactor/reactor.h 10 c/src/reactor/selector.h 18 c/src/reactor/timer.c 127 c/src/reactor/connection.c 303 c/src/reactor/acceptor.c 85 c/src/reactor/selectable.h 14 c/src/reactor/io.h 23 c/src/reactor/reactor.c 425 c/src/sasl/cyrus_sasl.c 511 c/src/sasl/sasl-internal.h 36 c/src/sasl/default_sasl.c 175 c/src/sasl/cyrus_stub.c 14 c/src/sasl/sasl.c 827 c/src/libqpid-proton-tls.pc.in 28 c/src/transactions.xml 40 c/src/extra/url.c 209 c/src/ProtonConfig.cmake.in 30 c/src/proactor/epoll.c 2312 c/src/proactor/win_iocp.cpp 2775 c/src/proactor/netaddr-internal.h 33 c/src/proactor/raw_connection-internal.h 103 c/src/proactor/epoll_raw_connection.c 422 c/src/proactor/libuv.c 1090 c/src/proactor/raw_connection.c 677 c/src/proactor/epoll-internal.h 321 c/src/proactor/epoll_timer.c 269 c/src/proactor/proactor-internal.h 28 c/src/proactor/proactor-internal.c 63 c/src/proactor/netaddr-internal.c 56 c/src/compiler/msvc/start.c 20 c/src/compiler/gcc/start.c 11 c/experimental/raw_plus_tls2.c 511 c/experimental/raw_plus_tls.c 1 c/versions.cmake 16 tools/cmake/config/ProtonCppConfig.cmake 34 tools/cmake/config/ProtonConfig.cmake 53 tools/cmake/Modules/FindJsonCpp.cmake 61 tools/cmake/Modules/FindLibuv.cmake 61 tools/cmake/Modules/FindCyrusSASL.cmake 66 tools/cmake/Modules/CheckPythonModule.cmake 54 tools/check-abi/cpp_abi.cpp 10 tools/check-abi/expand_types.cpp 32 scripts/softhsm2.conf.in 11 scripts/env.py 33 python/cproton_ext.c 66 python/ext_build.py 72 python/ext_build_unbundled.py 14 python/MANIFEST.in 27 python/pyproject.toml 55 python/setup.py 7 python/ext_build_devtree.py 19 python/cproton.h 658 python/proton/_data.py 647 python/proton/_io.py 117 python/proton/__init__.py 89 python/proton/_transport.py 391 python/proton/tracing.py 7 python/proton/reactor.py 23 python/proton/_tracing.py 103 python/proton/_common.py 10 python/proton/_condition.py 42 python/proton/_delivery.py 400 python/proton/_events.py 260 python/proton/_handler.py 20 python/proton/_url.py 156 python/proton/_handlers.py 687 python/proton/_exceptions.py 27 python/proton/_selectable.py 72 python/proton/_reactor.py 912 python/proton/_endpoints.py 548 python/proton/_message.py 294 python/proton/_wrapper.py 69 python/proton/utils.py 11 python/proton/_utils.py 348 python/proton/handlers.py 18 python/setup.cfg 2 python/cproton.py 500 misc/config.sh.in 52 misc/config.bat.in 40 ruby/spec/message_spec.rb 478 ruby/spec/hash_spec.rb 20 ruby/spec/array_spec.rb 43 ruby/spec/data_spec.rb 395 ruby/spec/spec_helper.rb 77 ruby/spec/exception_handling_spec.rb 59 ruby/qpid_proton.gemspec.in 35 ruby/ext/cproton/extconf.rb 20 ruby/lib/qpid_proton.rb 54 ruby/lib/handler/reactor_messaging_adapter.rb 118 ruby/lib/handler/adapter.rb 44 ruby/lib/handler/messaging_adapter.rb 107 ruby/lib/handler/messaging_handler.rb 21 ruby/lib/types/hash.rb 10 ruby/lib/types/type.rb 42 ruby/lib/types/array.rb 59 ruby/lib/types/described.rb 3 ruby/lib/types/strings.rb 21 ruby/lib/util/deprecation.rb 24 ruby/lib/util/schedule.rb 28 ruby/lib/util/error_handler.rb 54 ruby/lib/util/version.rb 4 ruby/lib/util/wrapper.rb 71 ruby/lib/core/url.rb 49 ruby/lib/core/uri.rb 47 ruby/lib/core/link.rb 92 ruby/lib/core/sender.rb 41 ruby/lib/core/delivery.rb 41 ruby/lib/core/event.rb 90 ruby/lib/core/message.rb 233 ruby/lib/core/work_queue.rb 33 ruby/lib/core/transfer.rb 46 ruby/lib/core/tracker.rb 17 ruby/lib/core/connection_driver.rb 108 ruby/lib/core/endpoint.rb 43 ruby/lib/core/connection.rb 151 ruby/lib/core/ssl_details.rb 8 ruby/lib/core/terminus.rb 79 ruby/lib/core/disposition.rb 66 ruby/lib/core/receiver.rb 30 ruby/lib/core/ssl_domain.rb 33 ruby/lib/core/session.rb 68 ruby/lib/core/transport.rb 109 ruby/lib/core/listener.rb 29 ruby/lib/core/container.rb 291 ruby/lib/core/exceptions.rb 56 ruby/lib/core/condition.rb 45 ruby/lib/core/sasl.rb 36 ruby/lib/core/ssl.rb 55 ruby/lib/core/messaging_handler.rb 5 ruby/lib/reactor/container.rb 46 ruby/lib/codec/mapping.rb 125 ruby/lib/codec/data.rb 321 ruby/cproton.i 539 go/genwrap.go 398 go/pkg/amqp/unmarshal.go 508 go/pkg/amqp/url.go 66 go/pkg/amqp/version.go 2 go/pkg/amqp/doc.go 2 go/pkg/amqp/types.go 171 go/pkg/amqp/error.go 63 go/pkg/amqp/message.go 427 go/pkg/amqp/marshal.go 222 go/pkg/proton/wrappers.go 277 go/pkg/proton/engine.go 233 go/pkg/proton/uuid.go 27 go/pkg/proton/wrappers_gen.go 856 go/pkg/proton/doc.go 2 go/pkg/proton/handlers.go 267 go/pkg/proton/error.go 51 go/pkg/proton/message.go 64 go/pkg/electron/endpoint.go 87 go/pkg/electron/handler.go 159 go/pkg/electron/time.go 36 go/pkg/electron/container.go 50 go/pkg/electron/receiver.go 157 go/pkg/electron/doc.go 2 go/pkg/electron/sender.go 202 go/pkg/electron/session.go 89 go/pkg/electron/link.go 194 go/pkg/electron/connection.go 277 cpp/include/proton/io/connection_driver.hpp 55 cpp/include/proton/connection_options.hpp 58 cpp/include/proton/ssl.hpp 78 cpp/include/proton/symbol.hpp 12 cpp/include/proton/sender.hpp 42 cpp/include/proton/map.hpp 63 cpp/include/proton/fwd.hpp 43 cpp/include/proton/duration.hpp 32 cpp/include/proton/function.hpp 10 cpp/include/proton/session_options.hpp 21 cpp/include/proton/default_container.hpp 7 cpp/include/proton/connect_config.hpp 13 cpp/include/proton/byte_array.hpp 48 cpp/include/proton/listener.hpp 23 cpp/include/proton/listen_handler.hpp 16 cpp/include/proton/error.hpp 23 cpp/include/proton/work_queue.hpp 216 cpp/include/proton/receiver_options.hpp 36 cpp/include/proton/value.hpp 73 cpp/include/proton/delivery_mode.hpp 17 cpp/include/proton/binary.hpp 27 cpp/include/proton/returned.hpp 24 cpp/include/proton/type_id.hpp 56 cpp/include/proton/types.hpp 20 cpp/include/proton/target.hpp 27 cpp/include/proton/thread_safe.hpp 3 cpp/include/proton/message.hpp 89 cpp/include/proton/reconnect_options.hpp 29 cpp/include/proton/terminus.hpp 50 cpp/include/proton/delivery.hpp 23 cpp/include/proton/source.hpp 36 cpp/include/proton/connection.hpp 64 cpp/include/proton/namespaces.hpp 11 cpp/include/proton/transfer.hpp 36 cpp/include/proton/tracker.hpp 17 cpp/include/proton/source_options.hpp 36 cpp/include/proton/annotation_key.hpp 23 cpp/include/proton/scalar_base.hpp 159 cpp/include/proton/types_fwd.hpp 16 cpp/include/proton/decimal.hpp 15 cpp/include/proton/endpoint.hpp 48 cpp/include/proton/tracing.hpp 7 cpp/include/proton/link.hpp 38 cpp/include/proton/timestamp.hpp 24 cpp/include/proton/codec/map.hpp 14 cpp/include/proton/codec/common.hpp 22 cpp/include/proton/codec/deque.hpp 23 cpp/include/proton/codec/list.hpp 23 cpp/include/proton/codec/unordered_map.hpp 14 cpp/include/proton/codec/decoder.hpp 120 cpp/include/proton/codec/encoder.hpp 118 cpp/include/proton/codec/vector.hpp 20 cpp/include/proton/codec/forward_list.hpp 23 cpp/include/proton/sasl.hpp 28 cpp/include/proton/sender_options.hpp 34 cpp/include/proton/container.hpp 71 cpp/include/proton/url.hpp 42 cpp/include/proton/target_options.hpp 34 cpp/include/proton/null.hpp 16 cpp/include/proton/uuid.hpp 24 cpp/include/proton/scalar.hpp 18 cpp/include/proton/messaging_handler.hpp 43 cpp/include/proton/session.hpp 49 cpp/include/proton/internal/type_traits.hpp 69 cpp/include/proton/internal/object.hpp 55 cpp/include/proton/internal/export.hpp 39 cpp/include/proton/internal/comparable.hpp 13 cpp/include/proton/internal/data.hpp 40 cpp/include/proton/error_condition.hpp 36 cpp/include/proton/message_id.hpp 45 cpp/include/proton/transport.hpp 19 cpp/include/proton/receiver.hpp 39 cpp/libqpid-proton-cpp.pc.in 29 cpp/benchmarks/benchmarks_main.cpp 2 cpp/benchmarks/container.cpp 26 cpp/ProtonCppConfig.cmake.in 44 cpp/src/receiver.cpp 63 cpp/src/sasl.cpp 12 cpp/src/duration.cpp 12 cpp/src/tracing_stub.cpp 20 cpp/src/ssl.cpp 28 cpp/src/proactor_container_impl.hpp 123 cpp/src/source.cpp 32 cpp/src/connection_driver.cpp 113 cpp/src/tracing_private.hpp 20 cpp/src/message.cpp 256 cpp/src/link.cpp 71 cpp/src/timestamp.cpp 29 cpp/src/proactor_container_impl.cpp 619 cpp/src/connect_config.hpp 8 cpp/src/uuid.cpp 70 cpp/src/value.cpp 144 cpp/src/link_namer.cpp 10 cpp/src/reconnect_options_impl.hpp 21 cpp/src/error_condition.cpp 61 cpp/src/ssl_options.cpp 158 cpp/src/proactor_work_queue_impl.hpp 15 cpp/src/cpp-test.cpp 2 cpp/src/proton_bits.cpp 47 cpp/src/error.cpp 9 cpp/src/scalar_base.cpp 129 cpp/src/messaging_adapter.hpp 12 cpp/src/node_options.cpp 154 cpp/src/binary.cpp 19 cpp/src/map.cpp 174 cpp/src/decimal.cpp 13 cpp/src/sender_options.cpp 92 cpp/src/session_options.cpp 37 cpp/src/sender.cpp 70 cpp/src/null.cpp 9 cpp/src/delivery.cpp 22 cpp/src/link_namer.hpp 16 cpp/src/target.cpp 15 cpp/src/messaging_adapter.cpp 277 cpp/src/connect_config.cpp 227 cpp/src/encoder.cpp 124 cpp/src/object.cpp 18 cpp/src/decoder.cpp 274 cpp/src/listener.cpp 47 cpp/src/reconnect_options.cpp 18 cpp/src/url.cpp 222 cpp/src/msg.hpp 19 cpp/src/receiver_options.cpp 103 cpp/src/work_queue.cpp 44 cpp/src/transfer.cpp 28 cpp/src/connection.cpp 171 cpp/src/container.cpp 82 cpp/src/tracker.cpp 11 cpp/src/endpoint.cpp 38 cpp/src/handler.cpp 63 cpp/src/ssl_options_impl.hpp 23 cpp/src/contexts.cpp 55 cpp/src/types_internal.hpp 38 cpp/src/connect_config_dummy.cpp 14 cpp/src/data.cpp 32 cpp/src/session.cpp 104 cpp/src/contexts.hpp 106 cpp/src/returned.cpp 16 cpp/src/transport.cpp 24 cpp/src/tracing_opentelemetry.cpp 149 cpp/src/proton_bits.hpp 123 cpp/src/connection_options.cpp 205 cpp/src/terminus.cpp 40 cpp/src/init_tracer_stub.cpp 4 cpp/src/type_id.cpp 46 cpp/src/byte_array.cpp 14 cpp/tests.cmake 108 cpp/versions.cmake 4