path # lines of code packaging/winsdk/bld-winsdk.ps1 451 packaging/windows/INSTALL_NOTES.html 87 packaging/windows/qpidc.wxs 197 packaging/windows/installer.proj 172 cmake_uninstall.cmake.in 39 CTestConfig.cmake 30 CTestCustom.cmake 1 include/qpid/ImportExport.h 29 include/qpid/types/ImportExport.h 13 include/qpid/types/Uuid.h 50 include/qpid/types/Exception.h 17 include/qpid/types/Variant.h 139 include/qpid/swig_perl_typemaps.i 296 include/qpid/qpid.i 89 include/qpid/sys/posix/IntegerTypes.h 6 include/qpid/sys/IntegerTypes.h 9 include/qpid/sys/windows/IntegerTypes.h 23 include/qpid/swig_python_typemaps.i 405 include/qpid/messaging/Connection.h 43 include/qpid/messaging/ImportExport.h 13 include/qpid/messaging/Duration.h 26 include/qpid/messaging/exceptions.h 118 include/qpid/messaging/Address.h 41 include/qpid/messaging/Message.h 77 include/qpid/messaging/Sender.h 38 include/qpid/messaging/FailoverUpdates.h 19 include/qpid/messaging/Session.h 54 include/qpid/messaging/Handle.h 24 include/qpid/messaging/Message_io.h 9 include/qpid/messaging/Receiver.h 42 include/qpid/messaging/Logger.h 28 include/qpid/swig_ruby_typemaps.i 313 include/qmf/posix/EventNotifier.h 34 include/qmf/SchemaTypes.h 33 include/qmf/ImportExport.h 13 include/qmf/ConsoleSession.h 45 include/qmf/Query.h 47 include/qmf/AgentSession.h 58 include/qmf/Data.h 46 include/qmf/exceptions.h 29 include/qmf/Schema.h 47 include/qmf/SchemaProperty.h 48 include/qmf/qmf2.i 58 include/qmf/Agent.h 57 include/qmf/Handle.h 26 include/qmf/Subscription.h 36 include/qmf/BrokerImportExport.h 21 include/qmf/AgentEvent.h 49 include/qmf/SchemaMethod.h 38 include/qmf/DataAddr.h 39 include/qmf/ConsoleEvent.h 62 include/qmf/SchemaId.h 36 etc/fedora/qpidd.in 147 etc/fedora/qpidd-primary.in 97 etc/fedora/cluster.conf-example.xml 43 etc/emacs/qpid-c++-mode.el 196 management/python/MANIFEST.in 1 management/python/setup.py 39 management/python/lib/qpidtoollibs/config.py 13 management/python/lib/qpidtoollibs/__init__.py 2 management/python/lib/qpidtoollibs/broker.py 342 management/python/lib/qpidtoollibs/disp.py 213 management/python/lib/qmf/console.py 2887 management/python/lib/qmf/client.py 343 management/python/lib/qmf/__init__.py 1 management/python/lib/qlslibs/jrnl.py 342 management/python/lib/qlslibs/efp.py 275 management/python/lib/qlslibs/__init__.py 1 management/python/lib/qlslibs/utils.py 139 management/python/lib/qlslibs/err.py 172 management/python/lib/qlslibs/analyze.py 543 management/python/lib/qpidstore/jrnl.py 482 management/python/lib/qpidstore/__init__.py 1 management/python/lib/qpidstore/jerr.py 108 management/python/lib/qpidstore/janal.py 424 rubygen/cppgen.rb 362 rubygen/MethodBodyDefaultVisitor.rb 27 rubygen/framing.0-10/frame_body_lists.rb 21 rubygen/framing.0-10/OperationsInvoker.rb 83 rubygen/framing.0-10/MethodBodyDefaultVisitor.rb 29 rubygen/framing.0-10/Operations.rb 75 rubygen/framing.0-10/structs.rb 530 rubygen/framing.0-10/Session.rb 341 rubygen/framing.0-10/MethodBodyFactory.rb 36 rubygen/framing.0-10/Proxy.rb 75 rubygen/framing.0-10/constants.rb 161 rubygen/framing.0-10/all_method_bodies.rb 15 rubygen/framing.0-10/MethodBodyConstVisitor.rb 21 rubygen/amqpgen.rb 383 appveyor.yml 13 BuildInstallSettings.cmake 169 managementgen/qmfgen/generate.py 413 managementgen/qmfgen/__init__.py 1 managementgen/qmfgen/management-types.xml 48 managementgen/qmfgen/templates/V2Package.h 15 managementgen/qmfgen/templates/Event.h 30 managementgen/qmfgen/templates/V2Package.cpp 11 managementgen/qmfgen/templates/Package.h 13 managementgen/qmfgen/templates/Args.h 11 managementgen/qmfgen/templates/Class.h 72 managementgen/qmfgen/templates/CMakeLists.cmake 35 managementgen/qmfgen/templates/Class.cpp 225 managementgen/qmfgen/templates/Event.cpp 64 managementgen/qmfgen/templates/Package.cpp 5 managementgen/qmfgen/schema.py 1491 bindings/qpid/python/qpid_messaging.i 487 bindings/qpid/perl/t/Duration.t 63 bindings/qpid/perl/t/Address.t 47 bindings/qpid/perl/t/Message.t 149 bindings/qpid/perl/t/utils.pm 16 bindings/qpid/perl/Makefile.PL.in 15 bindings/qpid/perl/lib/qpid/messaging.pm 27 bindings/qpid/perl/lib/qpid/messaging/Address.pm 88 bindings/qpid/perl/lib/qpid/messaging/Sender.pm 61 bindings/qpid/perl/lib/qpid/messaging/Duration.pm 55 bindings/qpid/perl/lib/qpid/messaging/Message.pm 195 bindings/qpid/perl/lib/qpid/messaging/Session.pm 124 bindings/qpid/perl/lib/qpid/messaging/Receiver.pm 85 bindings/qpid/perl/lib/qpid/messaging/Connection.pm 66 bindings/qpid/perl/lib/qpid_messaging.pm 15 bindings/qpid/perl/lib/qpid.pm 3 bindings/qpid/perl/perl.i 31 bindings/qpid/dotnet/msvcx/org.apache.qpid.messaging.sessionreceiver.sln.in 75 bindings/qpid/dotnet/msvcx/org.apache.qpid.messaging.sln.in 342 bindings/qpid/dotnet/msvc9/org.apache.qpid.messaging.sessionreceiver.sln.in 75 bindings/qpid/dotnet/msvc9/org.apache.qpid.messaging.sln.in 344 bindings/qpid/dotnet/configure-windows.ps1 626 bindings/qpid/dotnet/winsdk_sources/msvcx/winsdk_dotnet_examples.sln.in 179 bindings/qpid/dotnet/winsdk_sources/msvc9/winsdk_dotnet_examples.sln.in 176 bindings/qpid/dotnet/src/Connection.h 98 bindings/qpid/dotnet/src/Sender.cpp 174 bindings/qpid/dotnet/src/msvcx/org.apache.qpid.messaging.vcxproj.in 340 bindings/qpid/dotnet/src/msvcx/org.apache.qpid.messaging.vcxproj.filters.in 114 bindings/qpid/dotnet/src/Duration.h 72 bindings/qpid/dotnet/src/TypeTranslator.cpp 292 bindings/qpid/dotnet/src/Message.cpp 531 bindings/qpid/dotnet/src/resource1.h 8 bindings/qpid/dotnet/src/AssemblyInfo-template.cpp 18 bindings/qpid/dotnet/src/Address.h 142 bindings/qpid/dotnet/src/Message.h 299 bindings/qpid/dotnet/src/QpidMarshal.h 41 bindings/qpid/dotnet/src/Sender.h 123 bindings/qpid/dotnet/src/QpidTypeCheck.h 48 bindings/qpid/dotnet/src/FailoverUpdates.h 37 bindings/qpid/dotnet/src/Receiver.cpp 302 bindings/qpid/dotnet/src/Session.h 132 bindings/qpid/dotnet/src/Session.cpp 565 bindings/qpid/dotnet/src/msvc9/org.apache.qpid.messaging.vcproj.in 648 bindings/qpid/dotnet/src/Address.cpp 201 bindings/qpid/dotnet/src/QpidException.h 16 bindings/qpid/dotnet/src/Receiver.h 140 bindings/qpid/dotnet/src/sessionreceiver/msvcx/org.apache.qpid.messaging.sessionreceiver.csproj.in 142 bindings/qpid/dotnet/src/sessionreceiver/msvc9/org.apache.qpid.messaging.sessionreceiver.csproj.in 131 bindings/qpid/dotnet/src/sessionreceiver/Properties/sessionreceiver-AssemblyInfo-template.cs 15 bindings/qpid/dotnet/src/sessionreceiver/sessionreceiver.cs 65 bindings/qpid/dotnet/src/Logger.cpp 145 bindings/qpid/dotnet/src/TypeTranslator.h 36 bindings/qpid/dotnet/src/Logger.h 57 bindings/qpid/dotnet/src/Connection.cpp 345 bindings/qpid/dotnet/src/FailoverUpdates.cpp 53 bindings/qpid/ruby/qpid_messaging.gemspec 23 bindings/qpid/ruby/ext/cqpid/extconf.rb 42 bindings/qpid/ruby/features/support/env.rb 2 bindings/qpid/ruby/features/step_definitions/sender_steps.rb 13 bindings/qpid/ruby/features/step_definitions/session_steps.rb 68 bindings/qpid/ruby/features/step_definitions/address_steps.rb 3 bindings/qpid/ruby/features/step_definitions/connection_steps.rb 60 bindings/qpid/ruby/features/step_definitions/receiver_steps.rb 40 bindings/qpid/ruby/spec/spec_helper.rb 4 bindings/qpid/ruby/spec/qpid_messaging/sender_spec.rb 80 bindings/qpid/ruby/spec/qpid_messaging/session_spec.rb 228 bindings/qpid/ruby/spec/qpid_messaging/encoding_spec.rb 27 bindings/qpid/ruby/spec/qpid_messaging/receiver_spec.rb 102 bindings/qpid/ruby/spec/qpid_messaging/message_spec.rb 210 bindings/qpid/ruby/spec/qpid_messaging/connection_spec.rb 115 bindings/qpid/ruby/spec/qpid_messaging/duration_spec.rb 44 bindings/qpid/ruby/spec/qpid_messaging/address_spec.rb 45 bindings/qpid/ruby/lib/qpid_messaging/connection.rb 46 bindings/qpid/ruby/lib/qpid_messaging/message.rb 85 bindings/qpid/ruby/lib/qpid_messaging/receiver.rb 33 bindings/qpid/ruby/lib/qpid_messaging/session.rb 72 bindings/qpid/ruby/lib/qpid_messaging/duration.rb 31 bindings/qpid/ruby/lib/qpid_messaging/encoding.rb 35 bindings/qpid/ruby/lib/qpid_messaging/address.rb 29 bindings/qpid/ruby/lib/qpid_messaging/sender.rb 27 bindings/qpid/ruby/lib/qpid_messaging.rb 12 bindings/qpid/ruby/ruby.i 119 CMakeModules/CheckSizetDistinct.cmake 52 CMakeModules/FindSWIG.cmake 37 CMakeModules/FindProton.cmake 62 src/CMakeWinVersions.cmake 54 src/posix/QpiddBroker.cpp 189 src/QpidConfig.cmake.in 26 src/QpidConfigVersion.cmake.in 17 src/qpid/NullSaslClient.cpp 41 src/qpid/SessionId.cpp 19 src/qpid/UrlArray.h 10 src/qpid/AclHost.cpp 100 src/qpid/pointer_to_other.h 30 src/qpid/BufferRef.h 29 src/qpid/Version.h 14 src/qpid/SaslFactory.h 22 src/qpid/types/Exception.cpp 7 src/qpid/types/encodings.h 11 src/qpid/types/Uuid.cpp 155 src/qpid/types/Variant.cpp 887 src/qpid/Sasl.h 24 src/qpid/broker/Connection.h 29 src/qpid/broker/TxAccept.cpp 65 src/qpid/broker/QueueFactory.h 33 src/qpid/broker/TransactionObserver.h 36 src/qpid/broker/Protocol.h 57 src/qpid/broker/DtxBuffer.cpp 58 src/qpid/broker/Lvq.cpp 42 src/qpid/broker/ExchangeRegistry.cpp 138 src/qpid/broker/posix/BrokerDefaults.cpp 17 src/qpid/broker/posix/SocketFDPlugin.cpp 56 src/qpid/broker/PagedQueue.cpp 385 src/qpid/broker/LinkRegistry.cpp 348 src/qpid/broker/Selector.h 28 src/qpid/broker/TopicExchange.cpp 270 src/qpid/broker/IndexedDeque.h 158 src/qpid/broker/ConnectionObservers.h 24 src/qpid/broker/PersistableMessage.h 46 src/qpid/broker/RecoverableExchange.h 19 src/qpid/broker/DeliveryRecord.h 99 src/qpid/broker/NullMessageStore.cpp 109 src/qpid/broker/RetryList.h 21 src/qpid/broker/SaslAuthenticator.cpp 396 src/qpid/broker/FedOps.h 10 src/qpid/broker/LossyQueue.cpp 57 src/qpid/broker/QueuedMessage.cpp 10 src/qpid/broker/QueueDepth.cpp 95 src/qpid/broker/Bridge.h 110 src/qpid/broker/Messages.h 29 src/qpid/broker/QueueFlowLimit.h 71 src/qpid/broker/SelectorToken.cpp 269 src/qpid/broker/TxBuffer.h 39 src/qpid/broker/QueueFlowLimit.cpp 225 src/qpid/broker/MessageGroupManager.cpp 226 src/qpid/broker/SelectorToken.h 88 src/qpid/broker/LossyLvq.cpp 7 src/qpid/broker/AclModule.h 33 src/qpid/broker/QueueBindings.h 37 src/qpid/broker/RecoveredDequeue.cpp 19 src/qpid/broker/PersistableQueue.h 32 src/qpid/broker/PriorityQueue.cpp 187 src/qpid/broker/DtxManager.h 45 src/qpid/broker/Message.cpp 328 src/qpid/broker/HandlerImpl.h 19 src/qpid/broker/DtxBuffer.h 33 src/qpid/broker/Daemon.h 30 src/qpid/broker/amqp_0_10/Connection.h 157 src/qpid/broker/amqp_0_10/MessageTransfer.h 97 src/qpid/broker/amqp_0_10/MessageTransfer.cpp 406 src/qpid/broker/amqp_0_10/Connection.cpp 454 src/qpid/broker/QueueCleaner.cpp 66 src/qpid/broker/MessageMap.h 37 src/qpid/broker/RetryList.cpp 30 src/qpid/broker/QueueObservers.h 37 src/qpid/broker/PersistableObject.cpp 65 src/qpid/broker/SelfDestructQueue.cpp 23 src/qpid/broker/MessageAdapter.cpp 48 src/qpid/broker/TopicExchange.h 78 src/qpid/broker/MessageBuilder.h 32 src/qpid/broker/RecoverableMessage.h 23 src/qpid/broker/BrokerObservers.h 43 src/qpid/broker/DtxWorkRecord.h 50 src/qpid/broker/Observers.h 53 src/qpid/broker/HeadersExchange.cpp 329 src/qpid/broker/DtxWorkRecord.cpp 143 src/qpid/broker/PersistableObject.h 43 src/qpid/broker/SignalHandler.cpp 25 src/qpid/broker/OwnershipToken.h 11 src/qpid/broker/IngressCompletion.h 23 src/qpid/broker/MessageDistributor.h 15 src/qpid/broker/AsyncCommandCallback.h 21 src/qpid/broker/RecoveryManagerImpl.h 37 src/qpid/broker/RecoveredDequeue.h 27 src/qpid/broker/SemanticState.h 205 src/qpid/broker/DtxManager.cpp 171 src/qpid/broker/ObjectFactory.h 35 src/qpid/broker/SessionHandlerObserver.h 20 src/qpid/broker/ExchangeRegistry.h 70 src/qpid/broker/Message.h 185 src/qpid/broker/SessionOutputException.h 12 src/qpid/broker/Credit.cpp 126 src/qpid/broker/SecureConnection.h 28 src/qpid/broker/LossyLvq.h 21 src/qpid/broker/amqp/Connection.h 75 src/qpid/broker/amqp/NodeProperties.cpp 323 src/qpid/broker/amqp/Interconnect.h 37 src/qpid/broker/amqp/Topic.cpp 169 src/qpid/broker/amqp/Interconnect.cpp 122 src/qpid/broker/amqp/ManagedConnection.cpp 170 src/qpid/broker/amqp/Sasl.h 40 src/qpid/broker/amqp/ManagedConnection.h 52 src/qpid/broker/amqp/Authorise.cpp 124 src/qpid/broker/amqp/NodePolicy.cpp 272 src/qpid/broker/amqp/Header.h 22 src/qpid/broker/amqp/Message.cpp 486 src/qpid/broker/amqp/Exception.cpp 9 src/qpid/broker/amqp/Authorise.h 32 src/qpid/broker/amqp/NodeProperties.h 65 src/qpid/broker/amqp/NodePolicy.h 84 src/qpid/broker/amqp/Header.cpp 35 src/qpid/broker/amqp/Sasl.cpp 138 src/qpid/broker/amqp/ManagedSession.h 41 src/qpid/broker/amqp/BrokerContext.cpp 12 src/qpid/broker/amqp/Message.h 115 src/qpid/broker/amqp/Domain.h 58 src/qpid/broker/amqp/Translation.h 24 src/qpid/broker/amqp/Relay.h 96 src/qpid/broker/amqp/Filter.cpp 360 src/qpid/broker/amqp/Outgoing.cpp 307 src/qpid/broker/amqp/ManagedOutgoingLink.cpp 42 src/qpid/broker/amqp/ProtocolPlugin.cpp 131 src/qpid/broker/amqp/BrokerContext.h 29 src/qpid/broker/amqp/Session.h 101 src/qpid/broker/amqp/Session.cpp 933 src/qpid/broker/amqp/ManagedSession.cpp 119 src/qpid/broker/amqp/ManagedIncomingLink.h 26 src/qpid/broker/amqp/Incoming.h 60 src/qpid/broker/amqp/Interconnects.cpp 147 src/qpid/broker/amqp/ManagedIncomingLink.cpp 33 src/qpid/broker/amqp/DataReader.cpp 164 src/qpid/broker/amqp/ManagedOutgoingLink.h 28 src/qpid/broker/amqp/SaslClient.cpp 148 src/qpid/broker/amqp/SaslClient.h 52 src/qpid/broker/amqp/Interconnects.h 38 src/qpid/broker/amqp/Translation.cpp 297 src/qpid/broker/amqp/Connection.cpp 587 src/qpid/broker/amqp/Exception.h 20 src/qpid/broker/amqp/Domain.cpp 261 src/qpid/broker/amqp/Topic.h 57 src/qpid/broker/amqp/Filter.h 87 src/qpid/broker/amqp/Outgoing.h 117 src/qpid/broker/amqp/Relay.cpp 248 src/qpid/broker/amqp/DataReader.h 30 src/qpid/broker/amqp/Incoming.cpp 132 src/qpid/broker/ObjectFactory.cpp 49 src/qpid/broker/Vhost.cpp 29 src/qpid/broker/TxDequeue.h 27 src/qpid/broker/NameGenerator.h 16 src/qpid/broker/QueueCursor.cpp 20 src/qpid/broker/NullMessageStore.h 64 src/qpid/broker/AsyncCompletion.h 83 src/qpid/broker/TxBuffer.cpp 67 src/qpid/broker/RecoverableConfig.h 14 src/qpid/broker/FanOutExchange.cpp 93 src/qpid/broker/SelectorValue.cpp 156 src/qpid/broker/Vhost.h 22 src/qpid/broker/DeliveryRecord.cpp 128 src/qpid/broker/ConnectionObserver.h 17 src/qpid/broker/SessionHandler.cpp 115 src/qpid/broker/Fairshare.h 29 src/qpid/broker/Consumer.h 44 src/qpid/broker/DeliveryId.h 10 src/qpid/broker/Fairshare.cpp 89 src/qpid/broker/SessionHandler.h 64 src/qpid/broker/ThresholdAlerts.cpp 76 src/qpid/broker/RecoveredEnqueue.cpp 16 src/qpid/broker/SaslAuthenticator.h 34 src/qpid/broker/DirectExchange.h 44 src/qpid/broker/SelectorExpression.cpp 851 src/qpid/broker/QueueSettings.cpp 295 src/qpid/broker/NameGenerator.cpp 9 src/qpid/broker/QueuedMessage.h 26 src/qpid/broker/ThresholdAlerts.h 48 src/qpid/broker/QueueSettings.h 71 src/qpid/broker/MessageDeque.cpp 55 src/qpid/broker/TxOp.h 18 src/qpid/broker/Daemon.cpp 128 src/qpid/broker/QueueBindings.cpp 28 src/qpid/broker/DeliverableMessage.cpp 13 src/qpid/broker/FifoDistributor.h 17 src/qpid/broker/Lvq.h 16 src/qpid/broker/QueueListeners.cpp 62 src/qpid/broker/PriorityQueue.h 68 src/qpid/broker/SecureConnection.cpp 55 src/qpid/broker/SelectorValue.h 78 src/qpid/broker/Credit.h 67 src/qpid/broker/Bridge.cpp 377 src/qpid/broker/TopicKeyNode.h 249 src/qpid/broker/BrokerOptions.h 59 src/qpid/broker/DtxTimeout.h 21 src/qpid/broker/QueueObserver.h 20 src/qpid/broker/TransactionalStore.h 29 src/qpid/broker/MessageInterceptor.h 24 src/qpid/broker/IngressCompletion.cpp 25 src/qpid/broker/SelectorExpression.h 16 src/qpid/broker/SelfDestructQueue.h 16 src/qpid/broker/Queue.cpp 1498 src/qpid/broker/System.cpp 60 src/qpid/broker/Persistable.h 18 src/qpid/broker/RecoveredEnqueue.h 27 src/qpid/broker/LinkRegistry.h 100 src/qpid/broker/Broker.h 254 src/qpid/broker/DtxAck.cpp 48 src/qpid/broker/ConnectionHandler.h 78 src/qpid/broker/QueueCursor.h 40 src/qpid/broker/MessageAdapter.h 32 src/qpid/broker/TxAccept.h 28 src/qpid/broker/PersistableMessage.cpp 22 src/qpid/broker/QueueListeners.h 44 src/qpid/broker/ConnectionHandler.cpp 360 src/qpid/broker/RecoverableQueue.h 25 src/qpid/broker/Broker.cpp 1437 src/qpid/broker/MessageBuilder.cpp 89 src/qpid/broker/MessageStore.h 47 src/qpid/broker/ConsumerFactory.h 27 src/qpid/broker/HeadersExchange.h 75 src/qpid/broker/Protocol.cpp 110 src/qpid/broker/QueueDepth.h 43 src/qpid/broker/RecoveryManager.h 29 src/qpid/broker/MessageGroupManager.h 79 src/qpid/broker/System.h 31 src/qpid/broker/QueueRegistry.h 51 src/qpid/broker/PagedQueue.h 72 src/qpid/broker/Exchange.cpp 419 src/qpid/broker/FanOutExchange.h 40 src/qpid/broker/RecoveryManagerImpl.cpp 222 src/qpid/broker/management-schema.xml 404 src/qpid/broker/BrokerImportExport.h 21 src/qpid/broker/DeliverableMessage.h 21 src/qpid/broker/windows/SaslAuthenticator.cpp 155 src/qpid/broker/windows/BrokerDefaults.cpp 24 src/qpid/broker/windows/SslProtocolFactory.cpp 244 src/qpid/broker/DtxTimeout.cpp 14 src/qpid/broker/SignalHandler.h 16 src/qpid/broker/LossyQueue.h 14 src/qpid/broker/TxDequeue.cpp 41 src/qpid/broker/Link.h 139 src/qpid/broker/PersistableConfig.h 14 src/qpid/broker/BrokerObserver.h 34 src/qpid/broker/MessageMap.cpp 123 src/qpid/broker/QueueFactory.cpp 103 src/qpid/broker/SessionAdapter.cpp 551 src/qpid/broker/MessageDeque.h 25 src/qpid/broker/Exchange.h 172 src/qpid/broker/SessionManager.cpp 67 src/qpid/broker/SemanticState.cpp 727 src/qpid/broker/SessionState.h 195 src/qpid/broker/Link.cpp 635 src/qpid/broker/MessageStoreModule.h 51 src/qpid/broker/SessionState.cpp 379 src/qpid/broker/QueueCleaner.h 36 src/qpid/broker/SessionContext.h 29 src/qpid/broker/Selector.cpp 207 src/qpid/broker/DirectExchange.cpp 161 src/qpid/broker/MessageStoreModule.cpp 121 src/qpid/broker/Queue.h 312 src/qpid/broker/Deliverable.h 20 src/qpid/broker/PersistableExchange.h 14 src/qpid/broker/RecoverableMessageImpl.h 26 src/qpid/broker/DtxAck.h 24 src/qpid/broker/FifoDistributor.cpp 17 src/qpid/broker/AsyncCommandCallback.cpp 39 src/qpid/broker/QueueRegistry.cpp 142 src/qpid/broker/RecoverableTransaction.h 17 src/qpid/broker/SessionManager.h 38 src/qpid/broker/SessionAdapter.h 187 src/qpid/Plugin.h 34 src/qpid/DataDir.cpp 22 src/qpid/DisableExceptionLogging.h 11 src/qpid/SaslServer.h 22 src/qpid/amqp_0_10/Connection.h 48 src/qpid/amqp_0_10/CodecsInternal.h 18 src/qpid/amqp_0_10/SessionHandler.cpp 266 src/qpid/amqp_0_10/SessionHandler.h 65 src/qpid/amqp_0_10/Codecs.h 44 src/qpid/amqp_0_10/Connection.cpp 111 src/qpid/amqp_0_10/Codecs.cpp 483 src/qpid/Exception.cpp 32 src/qpid/AclHost.h 51 src/qpid/RangeSet.h 224 src/qpid/OptionsTemplates.h 25 src/qpid/StringUtils.h 10 src/qpid/Address.h 26 src/qpid/Url.cpp 204 src/qpid/ptr_map.h 18 src/qpid/assert.cpp 22 src/qpid/management/Mutex.cpp 8 src/qpid/management/ManagementObject.cpp 282 src/qpid/management/Manageable.cpp 27 src/qpid/management/ManagementAgent.h 282 src/qpid/management/ConnectionSettings.cpp 17 src/qpid/management/ConnectionSettings.h 29 src/qpid/management/Buffer.cpp 77 src/qpid/management/Manageable.h 31 src/qpid/management/Args.h 15 src/qpid/management/Buffer.h 66 src/qpid/management/ManagementTopicExchange.h 28 src/qpid/management/ManagementTopicExchange.cpp 40 src/qpid/management/ManagementObject.h 178 src/qpid/management/Mutex.h 36 src/qpid/management/ManagementDirectExchange.h 25 src/qpid/management/ManagementDirectExchange.cpp 34 src/qpid/management/ManagementEvent.h 23 src/qpid/management/ManagementAgent.cpp 2205 src/qpid/StringUtils.cpp 24 src/qpid/InlineAllocator.h 57 src/qpid/amqp/MapSizeCalculator.cpp 109 src/qpid/amqp/Descriptor.cpp 109 src/qpid/amqp/SaslServer.cpp 149 src/qpid/amqp/Reader.h 42 src/qpid/amqp/MapReader.h 68 src/qpid/amqp/ListBuilder.h 14 src/qpid/amqp/Sasl.h 27 src/qpid/amqp/MapSizeCalculator.h 35 src/qpid/amqp/CharSequence.cpp 37 src/qpid/amqp/SaslServer.h 20 src/qpid/amqp/MapEncoder.cpp 102 src/qpid/amqp/ListReader.h 74 src/qpid/amqp/descriptors.h 102 src/qpid/amqp/Sasl.cpp 104 src/qpid/amqp/MapBuilder.cpp 9 src/qpid/amqp/MessageReader.cpp 624 src/qpid/amqp/Descriptor.h 30 src/qpid/amqp/Decoder.h 68 src/qpid/amqp/MessageEncoder.h 80 src/qpid/amqp/CharSequence.h 21 src/qpid/amqp/Constructor.h 14 src/qpid/amqp/MessageId.cpp 56 src/qpid/amqp/typecodes.h 73 src/qpid/amqp/Codec.h 50 src/qpid/amqp/MapHandler.h 27 src/qpid/amqp/Encoder.h 122 src/qpid/amqp/DataBuilder.cpp 168 src/qpid/amqp/Decoder.cpp 382 src/qpid/amqp/ListBuilder.cpp 9 src/qpid/amqp/SaslClient.cpp 122 src/qpid/amqp/SaslClient.h 23 src/qpid/amqp/LoggingReader.h 38 src/qpid/amqp/MessageId.h 30 src/qpid/amqp/DataBuilder.h 48 src/qpid/amqp/MessageEncoder.cpp 233 src/qpid/amqp/MessageReader.h 113 src/qpid/amqp/MapBuilder.h 14 src/qpid/amqp/Encoder.cpp 449 src/qpid/amqp/MapEncoder.h 31 src/qpid/amqp/MapReader.cpp 262 src/qpid/Options.cpp 256 src/qpid/Modules.cpp 56 src/qpid/Options.h 87 src/qpid/SessionId.h 20 src/qpid/NullSaslClient.h 21 src/qpid/xml/XmlExchange.cpp 346 src/qpid/xml/XmlExchangePlugin.cpp 38 src/qpid/xml/XmlExchange.h 67 src/qpid/NullSaslServer.h 20 src/qpid/Modules.h 17 src/qpid/Msg.h 36 src/qpid/SharedObject.h 16 src/qpid/Plugin.cpp 51 src/qpid/Serializer.h 101 src/qpid/sys/Time.h 66 src/qpid/sys/ConnectionInputHandlerFactory.h 18 src/qpid/sys/Semaphore.h 49 src/qpid/sys/AsynchIOHandler.h 45 src/qpid/sys/TransportFactory.h 34 src/qpid/sys/DispatchHandle.h 67 src/qpid/sys/Runnable.cpp 10 src/qpid/sys/LockPtr.h 20 src/qpid/sys/RdmaIOPlugin.cpp 285 src/qpid/sys/unordered_map.h 18 src/qpid/sys/posix/Time.h 8 src/qpid/sys/posix/Condition.cpp 17 src/qpid/sys/posix/BSDSocket.h 50 src/qpid/sys/posix/PosixPoller.cpp 573 src/qpid/sys/posix/PidFile.h 19 src/qpid/sys/posix/Mutex.cpp 16 src/qpid/sys/posix/Thread.cpp 47 src/qpid/sys/posix/Fork.cpp 92 src/qpid/sys/posix/Condition.h 46 src/qpid/sys/posix/AsynchIO.cpp 461 src/qpid/sys/posix/Shlib.cpp 34 src/qpid/sys/posix/PipeHandle.cpp 33 src/qpid/sys/posix/LockFile.cpp 72 src/qpid/sys/posix/PrivatePosix.h 28 src/qpid/sys/posix/SystemInfo.cpp 150 src/qpid/sys/posix/MemoryMappedFile.cpp 89 src/qpid/sys/posix/check.h 21 src/qpid/sys/posix/Fork.h 27 src/qpid/sys/posix/StrError.cpp 14 src/qpid/sys/posix/PollableCondition.cpp 77 src/qpid/sys/posix/Path.cpp 30 src/qpid/sys/posix/SocketAddress.cpp 257 src/qpid/sys/posix/BSDSocket.cpp 208 src/qpid/sys/posix/FileSysDir.cpp 50 src/qpid/sys/posix/Mutex.h 93 src/qpid/sys/posix/MemStat.cpp 13 src/qpid/sys/posix/IOHandle.cpp 5 src/qpid/sys/posix/Time.cpp 121 src/qpid/sys/DispatchHandle.cpp 278 src/qpid/sys/Poller.h 68 src/qpid/sys/ssl/util.cpp 85 src/qpid/sys/ssl/SslSocket.h 48 src/qpid/sys/ssl/check.h 27 src/qpid/sys/ssl/SslSocket.cpp 293 src/qpid/sys/ssl/util.h 20 src/qpid/sys/ssl/check.cpp 52 src/qpid/sys/AsynchIOHandler.cpp 175 src/qpid/sys/ExceptionHolder.h 32 src/qpid/sys/AtomicCount.h 19 src/qpid/sys/StrError.h 9 src/qpid/sys/SocketAddress.h 46 src/qpid/sys/SystemInfo.h 24 src/qpid/sys/TCPIOPlugin.cpp 31 src/qpid/sys/OutputTask.h 13 src/qpid/sys/PollableQueue.h 97 src/qpid/sys/Condition.h 10 src/qpid/sys/urlAdd.h 27 src/qpid/sys/ConnectionInputHandler.h 16 src/qpid/sys/uuid.h 12 src/qpid/sys/PollableCondition.h 24 src/qpid/sys/ShutdownHandler.h 13 src/qpid/sys/Shlib.cpp 12 src/qpid/sys/SecuritySettings.h 14 src/qpid/sys/Path.h 22 src/qpid/sys/AggregateOutput.h 31 src/qpid/sys/epoll/EpollPoller.cpp 499 src/qpid/sys/ConnectionOutputHandler.h 13 src/qpid/sys/AggregateOutput.cpp 55 src/qpid/sys/Timer.cpp 179 src/qpid/sys/AtomicValue_mutex.h 41 src/qpid/sys/LockFile.h 24 src/qpid/sys/SslPlugin.cpp 101 src/qpid/sys/regex.h 42 src/qpid/sys/cyrus/CyrusSecurityLayer.h 38 src/qpid/sys/cyrus/CyrusSecurityLayer.cpp 96 src/qpid/sys/AtomicValue.h 10 src/qpid/sys/TimerWarnings.h 36 src/qpid/sys/SecurityLayer.h 17 src/qpid/sys/Dispatcher.h 16 src/qpid/sys/CopyOnWriteArray.h 119 src/qpid/sys/Timer.h 64 src/qpid/sys/FreeBSD/uuid.cpp 21 src/qpid/sys/Codec.h 15 src/qpid/sys/Monitor.h 18 src/qpid/sys/Thread.h 39 src/qpid/sys/SocketTransport.h 52 src/qpid/sys/DeletionManager.h 86 src/qpid/sys/Runnable.h 16 src/qpid/sys/rdma/rdma_exception.h 39 src/qpid/sys/rdma/RdmaIO.h 174 src/qpid/sys/rdma/RdmaServer.cpp 148 src/qpid/sys/rdma/rdma_wrap.cpp 423 src/qpid/sys/rdma/RdmaIO.cpp 511 src/qpid/sys/rdma/rdma_wrap.h 193 src/qpid/sys/rdma/rdma_factories.h 16 src/qpid/sys/rdma/RdmaClient.cpp 178 src/qpid/sys/rdma/rdma_factories.cpp 64 src/qpid/sys/Dispatcher.cpp 13 src/qpid/sys/ConnectionCodec.h 29 src/qpid/sys/Fork.h 4 src/qpid/sys/SocketTransport.cpp 161 src/qpid/sys/MemStat.h 12 src/qpid/sys/MemoryMappedFile.h 26 src/qpid/sys/OutputControl.h 16 src/qpid/sys/BlockingQueue.h 74 src/qpid/sys/PipeHandle.h 20 src/qpid/sys/Mutex.h 60 src/qpid/sys/MemStat.cpp 4 src/qpid/sys/FileSysDir.h 19 src/qpid/sys/windows/Time.h 8 src/qpid/sys/windows/SslAsynchIO.h 105 src/qpid/sys/windows/SslCredential.cpp 213 src/qpid/sys/windows/Thread.cpp 218 src/qpid/sys/windows/util.cpp 41 src/qpid/sys/windows/QpidDllMain.h 28 src/qpid/sys/windows/IoHandlePrivate.h 23 src/qpid/sys/windows/Condition.h 41 src/qpid/sys/windows/SslAsynchIO.cpp 553 src/qpid/sys/windows/WinSocket.cpp 205 src/qpid/sys/windows/AsynchIO.cpp 532 src/qpid/sys/windows/Shlib.cpp 28 src/qpid/sys/windows/PipeHandle.cpp 67 src/qpid/sys/windows/LockFile.cpp 35 src/qpid/sys/windows/uuid.cpp 29 src/qpid/sys/windows/SystemInfo.cpp 154 src/qpid/sys/windows/MemoryMappedFile.cpp 34 src/qpid/sys/windows/AsynchIoResult.h 131 src/qpid/sys/windows/check.h 19 src/qpid/sys/windows/WinSocket.h 52 src/qpid/sys/windows/StrError.cpp 28 src/qpid/sys/windows/PollableCondition.cpp 67 src/qpid/sys/windows/util.h 21 src/qpid/sys/windows/Path.cpp 36 src/qpid/sys/windows/SocketAddress.cpp 250 src/qpid/sys/windows/IocpPoller.cpp 142 src/qpid/sys/windows/FileSysDir.cpp 56 src/qpid/sys/windows/mingw32_compat.h 9 src/qpid/sys/windows/Mutex.h 104 src/qpid/sys/windows/SslCredential.h 41 src/qpid/sys/windows/AsynchIO.h 116 src/qpid/sys/windows/IOHandle.cpp 5 src/qpid/sys/windows/Time.cpp 155 src/qpid/sys/solaris/ECFPoller.cpp 324 src/qpid/sys/solaris/SystemInfo.cpp 74 src/qpid/sys/ScopedIncrement.h 30 src/qpid/sys/IOHandle.h 7 src/qpid/sys/Probes.h 31 src/qpid/sys/AsynchIO.h 94 src/qpid/sys/Shlib.h 30 src/qpid/sys/TimerWarnings.cpp 52 src/qpid/sys/AtomicValue_gcc.h 29 src/qpid/sys/Socket.h 36 src/qpid/sys/Waitable.h 48 src/qpid/sys/aix/SystemInfo.cpp 150 src/qpid/sys/StateMonitor.h 31 src/qpid/RefCountedBuffer.cpp 19 src/qpid/DataDir.h 22 src/qpid/Url.h 42 src/qpid/Address.cpp 18 src/qpid/UrlArray.cpp 18 src/qpid/ha/QueueReplicator.cpp 331 src/qpid/ha/ReplicatingSubscription.cpp 236 src/qpid/ha/types.cpp 92 src/qpid/ha/Membership.h 56 src/qpid/ha/LogPrefix.h 34 src/qpid/ha/Settings.h 30 src/qpid/ha/Event.h 52 src/qpid/ha/types.h 87 src/qpid/ha/PrimaryQueueLimits.h 53 src/qpid/ha/Role.h 16 src/qpid/ha/BrokerReplicator.cpp 717 src/qpid/ha/Primary.h 77 src/qpid/ha/ReplicationTest.cpp 44 src/qpid/ha/QueueGuard.cpp 80 src/qpid/ha/QueueGuard.h 48 src/qpid/ha/QueueSnapshot.h 30 src/qpid/ha/LogPrefix.cpp 11 src/qpid/ha/ReplicationTest.h 31 src/qpid/ha/AlternateExchangeSetter.h 36 src/qpid/ha/FailoverExchange.h 33 src/qpid/ha/Primary.cpp 342 src/qpid/ha/Backup.h 43 src/qpid/ha/Membership.cpp 175 src/qpid/ha/RemoteBackup.h 52 src/qpid/ha/ConnectionObserver.h 38 src/qpid/ha/ReplicatingSubscription.h 92 src/qpid/ha/HaBroker.h 75 src/qpid/ha/BackupConnectionExcluder.h 22 src/qpid/ha/BrokerInfo.cpp 83 src/qpid/ha/StandAlone.h 13 src/qpid/ha/HaPlugin.cpp 70 src/qpid/ha/IdSetter.h 32 src/qpid/ha/StatusCheck.cpp 119 src/qpid/ha/Backup.cpp 98 src/qpid/ha/HaBroker.cpp 182 src/qpid/ha/RemoteBackup.cpp 78 src/qpid/ha/BrokerInfo.h 48 src/qpid/ha/BrokerReplicator.h 114 src/qpid/ha/StatusCheck.h 35 src/qpid/ha/Event.cpp 51 src/qpid/ha/management-schema.xml 29 src/qpid/ha/FailoverExchange.cpp 95 src/qpid/ha/ConnectionObserver.cpp 87 src/qpid/ha/QueueReplicator.h 87 src/qpid/ha/hash.h 39 src/qpid/InlineVector.h 33 src/qpid/legacystore/BufferValue.h 18 src/qpid/legacystore/JournalImpl.h 181 src/qpid/legacystore/TxnCtxt.cpp 120 src/qpid/legacystore/PreparedTransaction.h 41 src/qpid/legacystore/IdDbt.h 15 src/qpid/legacystore/IdDbt.cpp 17 src/qpid/legacystore/MessageStoreImpl.h 285 src/qpid/legacystore/jrnl/jrec.cpp 80 src/qpid/legacystore/jrnl/lpmgr.h 62 src/qpid/legacystore/jrnl/txn_map.cpp 200 src/qpid/legacystore/jrnl/wrfc.cpp 116 src/qpid/legacystore/jrnl/time_ns.h 66 src/qpid/legacystore/jrnl/pmgr.h 85 src/qpid/legacystore/jrnl/enq_rec.h 57 src/qpid/legacystore/jrnl/enq_map.h 62 src/qpid/legacystore/jrnl/aio.h 63 src/qpid/legacystore/jrnl/wmgr.cpp 886 src/qpid/legacystore/jrnl/aio.cpp 7 src/qpid/legacystore/jrnl/jerrno.cpp 155 src/qpid/legacystore/jrnl/file_hdr.h 111 src/qpid/legacystore/jrnl/deq_hdr.h 53 src/qpid/legacystore/jrnl/rrfc.h 55 src/qpid/legacystore/jrnl/jinf.cpp 456 src/qpid/legacystore/jrnl/rec_tail.h 22 src/qpid/legacystore/jrnl/smutex.h 26 src/qpid/legacystore/jrnl/fcntl.h 94 src/qpid/legacystore/jrnl/jcfg.h 43 src/qpid/legacystore/jrnl/slock.h 45 src/qpid/legacystore/jrnl/jcntl.cpp 827 src/qpid/legacystore/jrnl/lp_map.h 36 src/qpid/legacystore/jrnl/jdir.h 55 src/qpid/legacystore/jrnl/rcvdat.h 140 src/qpid/legacystore/jrnl/cvar.cpp 1 src/qpid/legacystore/jrnl/aio_callback.h 19 src/qpid/legacystore/jrnl/cvar.h 50 src/qpid/legacystore/jrnl/wmgr.h 83 src/qpid/legacystore/jrnl/enq_map.cpp 131 src/qpid/legacystore/jrnl/jexception.h 76 src/qpid/legacystore/jrnl/txn_hdr.h 43 src/qpid/legacystore/jrnl/rec_hdr.h 55 src/qpid/legacystore/jrnl/enums.h 65 src/qpid/legacystore/jrnl/jrec.h 53 src/qpid/legacystore/jrnl/fcntl.cpp 297 src/qpid/legacystore/jrnl/txn_rec.cpp 374 src/qpid/legacystore/jrnl/jexception.cpp 132 src/qpid/legacystore/jrnl/jdir.cpp 363 src/qpid/legacystore/jrnl/time_ns.cpp 18 src/qpid/legacystore/jrnl/slock.cpp 1 src/qpid/legacystore/jrnl/lp_map.cpp 43 src/qpid/legacystore/jrnl/rec_hdr.cpp 7 src/qpid/legacystore/jrnl/data_tok.cpp 144 src/qpid/legacystore/jrnl/jcntl.h 140 src/qpid/legacystore/jrnl/deq_rec.cpp 386 src/qpid/legacystore/jrnl/enq_hdr.h 79 src/qpid/legacystore/jrnl/jerrno.h 96 src/qpid/legacystore/jrnl/txn_rec.h 50 src/qpid/legacystore/jrnl/data_tok.h 113 src/qpid/legacystore/jrnl/smutex.cpp 1 src/qpid/legacystore/jrnl/lpmgr.cpp 167 src/qpid/legacystore/jrnl/rmgr.h 60 src/qpid/legacystore/jrnl/rmgr.cpp 549 src/qpid/legacystore/jrnl/jinf.h 86 src/qpid/legacystore/jrnl/txn_map.h 75 src/qpid/legacystore/jrnl/enq_rec.cpp 536 src/qpid/legacystore/jrnl/rfc.h 61 src/qpid/legacystore/jrnl/wrfc.h 62 src/qpid/legacystore/jrnl/pmgr.cpp 140 src/qpid/legacystore/jrnl/deq_rec.h 52 src/qpid/legacystore/jrnl/rfc.cpp 41 src/qpid/legacystore/jrnl/rrfc.cpp 78 src/qpid/legacystore/PreparedTransaction.cpp 49 src/qpid/legacystore/MessageStoreImpl.cpp 1453 src/qpid/legacystore/DataTokenImpl.h 20 src/qpid/legacystore/DataTokenImpl.cpp 4 src/qpid/legacystore/BufferValue.cpp 27 src/qpid/legacystore/TxnCtxt.h 68 src/qpid/legacystore/Cursor.h 22 src/qpid/legacystore/IdSequence.cpp 14 src/qpid/legacystore/StoreException.h 27 src/qpid/legacystore/management-schema.xml 70 src/qpid/legacystore/StorePlugin.cpp 47 src/qpid/legacystore/BindingDbt.h 26 src/qpid/legacystore/BindingDbt.cpp 23 src/qpid/legacystore/IdSequence.h 18 src/qpid/legacystore/JournalImpl.cpp 523 src/qpid/CommonImportExport.h 13 src/qpid/log/posix/SinkOptions.h 26 src/qpid/log/posix/SinkOptions.cpp 164 src/qpid/log/Selector.h 43 src/qpid/log/SinkOptions.h 19 src/qpid/log/Statement.cpp 151 src/qpid/log/Statement.h 81 src/qpid/log/Options.cpp 122 src/qpid/log/Options.h 27 src/qpid/log/OstreamOutput.cpp 17 src/qpid/log/OstreamOutput.h 19 src/qpid/log/Logger.cpp 143 src/qpid/log/windows/SinkOptions.h 21 src/qpid/log/windows/SinkOptions.cpp 104 src/qpid/log/Logger.h 50 src/qpid/log/Helpers.h 30 src/qpid/log/Selector.cpp 168 src/qpid/memory.h 8 src/qpid/SaslFactory.cpp 506 src/qpid/RefCountedBuffer.h 13 src/qpid/framing/AMQDataBlock.h 16 src/qpid/framing/FrameDecoder.cpp 53 src/qpid/framing/SequenceSet.cpp 79 src/qpid/framing/SendContent.h 24 src/qpid/framing/amqp_framing.h 10 src/qpid/framing/amqp_types_full.h 8 src/qpid/framing/Uuid.h 22 src/qpid/framing/FieldValue.h 357 src/qpid/framing/AMQHeartbeatBody.cpp 6 src/qpid/framing/Endian.h 37 src/qpid/framing/amqp_types.h 24 src/qpid/framing/Blob.h 1 src/qpid/framing/Blob.cpp 6 src/qpid/framing/Invoker.h 43 src/qpid/framing/MethodContent.h 15 src/qpid/framing/AMQBody.h 48 src/qpid/framing/AMQContentBody.h 28 src/qpid/framing/MethodBodyFactory.h 15 src/qpid/framing/BufferTypes.h 47 src/qpid/framing/FrameDecoder.h 20 src/qpid/framing/SequenceNumberSet.cpp 60 src/qpid/framing/FieldTable.cpp 318 src/qpid/framing/ProtocolVersion.cpp 21 src/qpid/framing/AMQMethodBody.h 37 src/qpid/framing/AMQHeaderBody.h 73 src/qpid/framing/SequenceNumber.cpp 22 src/qpid/framing/ProtocolInitiation.h 31 src/qpid/framing/ProtocolInitiation.cpp 51 src/qpid/framing/Buffer.cpp 270 src/qpid/framing/AMQFrame.h 66 src/qpid/framing/SequenceNumber.h 46 src/qpid/framing/Proxy.cpp 24 src/qpid/framing/SendContent.cpp 39 src/qpid/framing/Uuid.cpp 24 src/qpid/framing/ChannelHandler.h 24 src/qpid/framing/Array.cpp 94 src/qpid/framing/List.h 42 src/qpid/framing/ResizableBuffer.h 27 src/qpid/framing/Buffer.h 71 src/qpid/framing/AMQBody.cpp 35 src/qpid/framing/InputHandler.h 14 src/qpid/framing/Proxy.h 30 src/qpid/framing/BodyFactory.h 16 src/qpid/framing/List.cpp 62 src/qpid/framing/Array.h 53 src/qpid/framing/AMQFrame.cpp 108 src/qpid/framing/FrameSet.h 82 src/qpid/framing/FrameSet.cpp 92 src/qpid/framing/AccumulatedAck.cpp 122 src/qpid/framing/frame_functors.h 77 src/qpid/framing/StructHelper.h 30 src/qpid/framing/FrameDefaultVisitor.h 24 src/qpid/framing/FrameHandler.h 9 src/qpid/framing/AMQHeaderBody.cpp 36 src/qpid/framing/AMQHeartbeatBody.h 23 src/qpid/framing/InitiationHandler.h 14 src/qpid/framing/Handler.h 49 src/qpid/framing/AMQP_HighestVersion.h 9 src/qpid/framing/TransferContent.cpp 64 src/qpid/framing/TransferContent.h 31 src/qpid/framing/IsInSequenceSet.h 19 src/qpid/framing/ModelMethod.h 21 src/qpid/framing/AccumulatedAck.h 39 src/qpid/framing/AMQContentBody.cpp 22 src/qpid/framing/ProtocolVersion.h 35 src/qpid/framing/SequenceSet.h 37 src/qpid/framing/InitiationHandler.cpp 2 src/qpid/framing/SequenceNumberSet.h 38 src/qpid/framing/AMQMethodBody.cpp 5 src/qpid/framing/TypeFilter.h 22 src/qpid/framing/FieldValue.cpp 223 src/qpid/framing/FieldTable.h 77 src/qpid/framing/HeaderProperties.h 18 src/qpid/framing/variant.h 42 src/qpid/NullSaslServer.cpp 58 src/qpid/RefCounted.h 20 src/qpid/linearstore/journal/txn_map.cpp 218 src/qpid/linearstore/journal/RecoveryManager.cpp 821 src/qpid/linearstore/journal/time_ns.h 64 src/qpid/linearstore/journal/JournalFile.cpp 279 src/qpid/linearstore/journal/EmptyFilePoolManager.h 53 src/qpid/linearstore/journal/pmgr.h 69 src/qpid/linearstore/journal/enq_rec.h 40 src/qpid/linearstore/journal/enq_map.h 50 src/qpid/linearstore/journal/aio.h 64 src/qpid/linearstore/journal/wmgr.cpp 904 src/qpid/linearstore/journal/jerrno.cpp 157 src/qpid/linearstore/journal/Checksum.cpp 18 src/qpid/linearstore/journal/JournalLog.cpp 34 src/qpid/linearstore/journal/EmptyFilePoolPartition.h 50 src/qpid/linearstore/journal/smutex.h 24 src/qpid/linearstore/journal/jcfg.h 35 src/qpid/linearstore/journal/LinearFileController.cpp 183 src/qpid/linearstore/journal/slock.h 42 src/qpid/linearstore/journal/jcntl.cpp 360 src/qpid/linearstore/journal/jdir.h 47 src/qpid/linearstore/journal/utils/rec_hdr.c 26 src/qpid/linearstore/journal/utils/enq_hdr.c 32 src/qpid/linearstore/journal/utils/file_hdr.h 38 src/qpid/linearstore/journal/utils/deq_hdr.h 24 src/qpid/linearstore/journal/utils/rec_tail.h 27 src/qpid/linearstore/journal/utils/txn_hdr.h 19 src/qpid/linearstore/journal/utils/rec_hdr.h 23 src/qpid/linearstore/journal/utils/file_hdr.c 83 src/qpid/linearstore/journal/utils/enq_hdr.h 28 src/qpid/linearstore/journal/utils/rec_tail.c 22 src/qpid/linearstore/journal/utils/deq_hdr.c 19 src/qpid/linearstore/journal/utils/txn_hdr.c 10 src/qpid/linearstore/journal/EmptyFilePoolPartition.cpp 141 src/qpid/linearstore/journal/aio_callback.h 17 src/qpid/linearstore/journal/wmgr.h 102 src/qpid/linearstore/journal/enq_map.cpp 140 src/qpid/linearstore/journal/jexception.h 71 src/qpid/linearstore/journal/enums.h 28 src/qpid/linearstore/journal/jrec.h 34 src/qpid/linearstore/journal/EmptyFilePool.cpp 397 src/qpid/linearstore/journal/AtomicCounter.h 90 src/qpid/linearstore/journal/txn_rec.cpp 263 src/qpid/linearstore/journal/jexception.cpp 128 src/qpid/linearstore/journal/jdir.cpp 351 src/qpid/linearstore/journal/time_ns.cpp 16 src/qpid/linearstore/journal/EmptyFilePoolManager.cpp 170 src/qpid/linearstore/journal/data_tok.cpp 101 src/qpid/linearstore/journal/JournalFile.h 85 src/qpid/linearstore/journal/jcntl.h 123 src/qpid/linearstore/journal/deq_rec.cpp 270 src/qpid/linearstore/journal/LinearFileController.h 78 src/qpid/linearstore/journal/RecoveryManager.h 118 src/qpid/linearstore/journal/jerrno.h 94 src/qpid/linearstore/journal/txn_rec.h 34 src/qpid/linearstore/journal/data_tok.h 88 src/qpid/linearstore/journal/EmptyFilePoolTypes.h 29 src/qpid/linearstore/journal/txn_map.h 77 src/qpid/linearstore/journal/enq_rec.cpp 352 src/qpid/linearstore/journal/pmgr.cpp 110 src/qpid/linearstore/journal/deq_rec.h 36 src/qpid/linearstore/journal/JournalLog.h 32 src/qpid/linearstore/journal/EmptyFilePool.h 91 src/qpid/linearstore/journal/Checksum.h 21 src/qpid/linearstore/BufferValue.h 18 src/qpid/linearstore/JournalImpl.h 180 src/qpid/linearstore/TxnCtxt.cpp 122 src/qpid/linearstore/PreparedTransaction.h 40 src/qpid/linearstore/IdDbt.h 15 src/qpid/linearstore/IdDbt.cpp 17 src/qpid/linearstore/MessageStoreImpl.h 262 src/qpid/linearstore/JournalLogImpl.cpp 34 src/qpid/linearstore/PreparedTransaction.cpp 49 src/qpid/linearstore/MessageStoreImpl.cpp 1315 src/qpid/linearstore/JournalLogImpl.h 20 src/qpid/linearstore/DataTokenImpl.h 20 src/qpid/linearstore/DataTokenImpl.cpp 4 src/qpid/linearstore/BufferValue.cpp 27 src/qpid/linearstore/TxnCtxt.h 67 src/qpid/linearstore/Cursor.h 22 src/qpid/linearstore/IdSequence.cpp 14 src/qpid/linearstore/StoreException.h 27 src/qpid/linearstore/management-schema.xml 30 src/qpid/linearstore/StorePlugin.cpp 62 src/qpid/linearstore/BindingDbt.h 26 src/qpid/linearstore/BindingDbt.cpp 23 src/qpid/linearstore/IdSequence.h 17 src/qpid/linearstore/JournalImpl.cpp 393 src/qpid/Exception.h 54 src/qpid/assert.h 8 src/qpid/messaging/exceptions.cpp 32 src/qpid/messaging/ConnectionOptions.h 36 src/qpid/messaging/Sender.cpp 24 src/qpid/messaging/Message_io.cpp 22 src/qpid/messaging/ProtocolRegistry.cpp 184 src/qpid/messaging/Duration.cpp 27 src/qpid/messaging/Message.cpp 115 src/qpid/messaging/ConnectionOptions.cpp 114 src/qpid/messaging/AddressParser.cpp 216 src/qpid/messaging/amqp/TcpTransport.cpp 140 src/qpid/messaging/amqp/ReceiverContext.cpp 119 src/qpid/messaging/amqp/ConnectionContext.cpp 1236 src/qpid/messaging/amqp/util.cpp 20 src/qpid/messaging/amqp/SenderContext.cpp 673 src/qpid/messaging/amqp/Sasl.h 48 src/qpid/messaging/amqp/ConnectionContext.h 176 src/qpid/messaging/amqp/ReceiverContext.h 50 src/qpid/messaging/amqp/DriverImpl.cpp 50 src/qpid/messaging/amqp/DriverImpl.h 34 src/qpid/messaging/amqp/SslTransport.cpp 139 src/qpid/messaging/amqp/EncodedMessage.cpp 309 src/qpid/messaging/amqp/Transport.cpp 26 src/qpid/messaging/amqp/EncodedMessage.h 113 src/qpid/messaging/amqp/Sasl.cpp 150 src/qpid/messaging/amqp/PnData.cpp 204 src/qpid/messaging/amqp/SessionHandle.cpp 103 src/qpid/messaging/amqp/ConnectionHandle.h 29 src/qpid/messaging/amqp/PnData.h 29 src/qpid/messaging/amqp/SenderHandle.cpp 50 src/qpid/messaging/amqp/SslTransport.h 48 src/qpid/messaging/amqp/AddressHelper.h 67 src/qpid/messaging/amqp/TcpTransport.h 49 src/qpid/messaging/amqp/ReceiverHandle.cpp 73 src/qpid/messaging/amqp/TransportContext.h 21 src/qpid/messaging/amqp/util.h 12 src/qpid/messaging/amqp/ReceiverHandle.h 37 src/qpid/messaging/amqp/Transport.h 27 src/qpid/messaging/amqp/SenderHandle.h 32 src/qpid/messaging/amqp/Transaction.cpp 114 src/qpid/messaging/amqp/SessionHandle.h 37 src/qpid/messaging/amqp/SessionContext.cpp 241 src/qpid/messaging/amqp/windows/SslTransport.cpp 96 src/qpid/messaging/amqp/AddressHelper.cpp 688 src/qpid/messaging/amqp/Transaction.h 43 src/qpid/messaging/amqp/SessionContext.h 62 src/qpid/messaging/amqp/ConnectionHandle.cpp 74 src/qpid/messaging/amqp/SenderContext.h 108 src/qpid/messaging/PrivateImplRef.h 25 src/qpid/messaging/ProtocolRegistry.h 22 src/qpid/messaging/AddressImpl.h 21 src/qpid/messaging/Receiver.cpp 37 src/qpid/messaging/Session.cpp 77 src/qpid/messaging/SessionImpl.h 38 src/qpid/messaging/Address.cpp 77 src/qpid/messaging/ReceiverImpl.h 31 src/qpid/messaging/MessageImpl.cpp 213 src/qpid/messaging/ConnectionImpl.h 32 src/qpid/messaging/Logger.cpp 149 src/qpid/messaging/AddressParser.h 41 src/qpid/messaging/Connection.cpp 80 src/qpid/messaging/SenderImpl.h 25 src/qpid/messaging/MessageImpl.h 77 src/qpid/messaging/FailoverUpdates.cpp 57 src/qpid/SessionState.h 102 src/qpid/client/Connection.h 44 src/qpid/client/Completion.cpp 15 src/qpid/client/MessageReplayTracker.cpp 47 src/qpid/client/LoadPlugins.h 8 src/qpid/client/Completion.h 26 src/qpid/client/SessionImpl.cpp 555 src/qpid/client/LocalQueue.h 28 src/qpid/client/SubscriptionImpl.h 50 src/qpid/client/Future.h 29 src/qpid/client/amqp0_10/AcceptTracker.h 48 src/qpid/client/amqp0_10/SessionImpl.cpp 507 src/qpid/client/amqp0_10/SenderImpl.cpp 151 src/qpid/client/amqp0_10/OutgoingMessage.h 32 src/qpid/client/amqp0_10/OutgoingMessage.cpp 134 src/qpid/client/amqp0_10/AddressResolution.cpp 896 src/qpid/client/amqp0_10/ReceiverImpl.cpp 213 src/qpid/client/amqp0_10/AcceptTracker.cpp 114 src/qpid/client/amqp0_10/SessionImpl.h 193 src/qpid/client/amqp0_10/MessageSource.h 17 src/qpid/client/amqp0_10/MessageSink.h 22 src/qpid/client/amqp0_10/ReceiverImpl.h 103 src/qpid/client/amqp0_10/IncomingMessages.cpp 364 src/qpid/client/amqp0_10/AddressResolution.h 29 src/qpid/client/amqp0_10/ConnectionImpl.h 60 src/qpid/client/amqp0_10/ConnectionImpl.cpp 376 src/qpid/client/amqp0_10/SenderImpl.h 106 src/qpid/client/amqp0_10/IncomingMessages.h 70 src/qpid/client/ChainableFrameHandler.h 17 src/qpid/client/LocalQueueImpl.cpp 49 src/qpid/client/Message.cpp 28 src/qpid/client/SessionBase_0_10.cpp 50 src/qpid/client/StateManager.h 23 src/qpid/client/LocalQueueImpl.h 25 src/qpid/client/AsyncSession.h 8 src/qpid/client/Execution.h 15 src/qpid/client/ConnectionSettings.cpp 33 src/qpid/client/ConnectionSettings.h 38 src/qpid/client/ConnectionAccess.h 12 src/qpid/client/Message.h 46 src/qpid/client/SubscriptionManagerImpl.cpp 133 src/qpid/client/QueueOptions.cpp 69 src/qpid/client/MessageReplayTracker.h 41 src/qpid/client/CompletionImpl.h 22 src/qpid/client/SubscriptionManager.cpp 57 src/qpid/client/FutureCompletion.h 20 src/qpid/client/PrivateImplRef.h 25 src/qpid/client/ClientImportExport.h 13 src/qpid/client/FutureResult.cpp 18 src/qpid/client/CompletionImpl.cpp 9 src/qpid/client/Dispatcher.h 50 src/qpid/client/Demux.h 64 src/qpid/client/FailoverManager.h 48 src/qpid/client/QueueOptions.h 33 src/qpid/client/ssl.h 8 src/qpid/client/Session.h 8 src/qpid/client/FailoverManager.cpp 100 src/qpid/client/SessionImpl.h 140 src/qpid/client/TCPConnector.h 75 src/qpid/client/Dispatcher.cpp 117 src/qpid/client/StateManager.cpp 67 src/qpid/client/LocalQueue.cpp 23 src/qpid/client/Handle.h 24 src/qpid/client/SubscriptionManager.h 70 src/qpid/client/Connector.cpp 60 src/qpid/client/SessionBase_0_10Access.h 15 src/qpid/client/SubscriptionSettings.h 41 src/qpid/client/FailoverListener.h 36 src/qpid/client/SubscriptionImpl.cpp 124 src/qpid/client/Connector.h 49 src/qpid/client/SubscriptionManagerImpl.h 67 src/qpid/client/ConnectionHandler.h 95 src/qpid/client/Subscription.h 42 src/qpid/client/SessionBase_0_10.h 44 src/qpid/client/MessageImpl.cpp 38 src/qpid/client/ConnectionImpl.h 63 src/qpid/client/FailoverListener.cpp 61 src/qpid/client/ConnectionHandler.cpp 320 src/qpid/client/Bounds.h 22 src/qpid/client/ConnectionImpl.cpp 330 src/qpid/client/RdmaConnector.cpp 328 src/qpid/client/Results.h 25 src/qpid/client/LoadPlugins.cpp 33 src/qpid/client/MessageListener.cpp 2 src/qpid/client/Demux.cpp 92 src/qpid/client/windows/ClientDllMain.cpp 1 src/qpid/client/windows/SaslFactory.cpp 153 src/qpid/client/windows/SslConnector.cpp 105 src/qpid/client/MessageListener.h 15 src/qpid/client/Connection.cpp 120 src/qpid/client/Subscription.cpp 28 src/qpid/client/SslConnector.cpp 326 src/qpid/client/Results.cpp 44 src/qpid/client/FlowControl.h 24 src/qpid/client/FutureCompletion.cpp 22 src/qpid/client/TypedResult.h 23 src/qpid/client/TCPConnector.cpp 238 src/qpid/client/MessageImpl.h 30 src/qpid/client/FutureResult.h 18 src/qpid/client/Bounds.cpp 41 src/qpid/client/Future.cpp 20 src/qpid/SessionState.cpp 218 src/qpid/acl/AclPlugin.cpp 57 src/qpid/acl/Acl.h 87 src/qpid/acl/AclReader.cpp 665 src/qpid/acl/AclValidator.h 69 src/qpid/acl/AclData.h 208 src/qpid/acl/AclResourceCounter.h 35 src/qpid/acl/AclConnectionCounter.cpp 183 src/qpid/acl/Acl.cpp 345 src/qpid/acl/AclData.cpp 626 src/qpid/acl/AclValidator.cpp 445 src/qpid/acl/AclLexer.cpp 95 src/qpid/acl/AclLexer.h 144 src/qpid/acl/AclResourceCounter.cpp 96 src/qpid/acl/management-schema.xml 47 src/qpid/acl/AclConnectionCounter.h 52 src/qpid/acl/AclReader.h 104 src/qpid/acl/AclTopicMatch.h 54 src/qpid/store/StorageProvider.h 101 src/qpid/store/MessageStorePlugin.h 82 src/qpid/store/MessageStorePlugin.cpp 297 src/qpid/store/ms-sql/BlobRecordset.cpp 55 src/qpid/store/ms-sql/MessageRecordset.cpp 128 src/qpid/store/ms-sql/AmqpTransaction.h 35 src/qpid/store/ms-sql/BlobAdapter.h 23 src/qpid/store/ms-sql/BlobEncoder.cpp 101 src/qpid/store/ms-sql/MessageRecordset.h 33 src/qpid/store/ms-sql/Recordset.h 32 src/qpid/store/ms-sql/DatabaseConnection.h 25 src/qpid/store/ms-sql/VariantHelper.h 25 src/qpid/store/ms-sql/SqlTransaction.cpp 43 src/qpid/store/ms-sql/SqlTransaction.h 21 src/qpid/store/ms-sql/BindingRecordset.h 41 src/qpid/store/ms-sql/State.cpp 20 src/qpid/store/ms-sql/TplRecordset.h 19 src/qpid/store/ms-sql/AmqpTransaction.cpp 36 src/qpid/store/ms-sql/Recordset.cpp 56 src/qpid/store/ms-sql/VariantHelper.cpp 42 src/qpid/store/ms-sql/BlobAdapter.cpp 32 src/qpid/store/ms-sql/MessageMapRecordset.h 44 src/qpid/store/ms-sql/BlobRecordset.h 18 src/qpid/store/ms-sql/BindingRecordset.cpp 124 src/qpid/store/ms-sql/MessageMapRecordset.cpp 214 src/qpid/store/ms-sql/Exception.h 39 src/qpid/store/ms-sql/TplRecordset.cpp 92 src/qpid/store/ms-sql/State.h 13 src/qpid/store/ms-sql/DatabaseConnection.cpp 62 src/qpid/store/ms-sql/MSSqlProvider.cpp 921 src/qpid/store/ms-sql/BlobEncoder.h 25 src/qpid/store/StoreException.h 22 src/qpid/store/ms-clfs/Log.cpp 128 src/qpid/store/ms-clfs/TransactionLog.cpp 332 src/qpid/store/ms-clfs/Messages.h 64 src/qpid/store/ms-clfs/Messages.cpp 335 src/qpid/store/ms-clfs/MessageLog.cpp 317 src/qpid/store/ms-clfs/TransactionLog.h 34 src/qpid/store/ms-clfs/MessageLog.h 42 src/qpid/store/ms-clfs/Log.h 34 src/qpid/store/ms-clfs/Transaction.cpp 52 src/qpid/store/ms-clfs/Lsn.h 10 src/qpid/store/ms-clfs/Transaction.h 70 src/qpid/store/ms-clfs/MSSqlClfsProvider.cpp 780 src/qpidd.cpp 65 src/expand_types.cpp 33 src/cppabi.cpp 10 src/rdma.cmake 101 src/linearstore.cmake 160 src/finddb.cmake 67 src/qpid.pc.in 28 src/config.h.cmake 55 src/qmf2.pc.in 28 src/versions.cmake 48 src/msvc.cmake 129 src/legacystore.cmake 163 src/amqp.cmake 141 src/qmf/AgentEvent.cpp 51 src/qmf/exceptions.cpp 11 src/qmf/DataAddrImpl.h 40 src/qmf/SchemaImpl.h 57 src/qmf/SchemaIdImpl.h 49 src/qmf/Query.cpp 98 src/qmf/agentCapability.h 9 src/qmf/SchemaMethod.cpp 122 src/qmf/Schema.cpp 271 src/qmf/SubscriptionImpl.h 25 src/qmf/AgentSessionImpl.h 128 src/qmf/SchemaMethodImpl.h 41 src/qmf/SchemaCache.cpp 48 src/qmf/constants.cpp 40 src/qmf/ConsoleEvent.cpp 49 src/qmf/SchemaProperty.cpp 348 src/qmf/AgentSubscription.cpp 21 src/qmf/EventNotifierImpl.h 22 src/qmf/Data.cpp 80 src/qmf/SchemaCache.h 28 src/qmf/PrivateImplRef.h 24 src/qmf/DataImpl.h 51 src/qmf/ConsoleSessionImpl.h 93 src/qmf/ConsoleSession.cpp 477 src/qmf/constants.h 45 src/qmf/EventNotifierImpl.cpp 31 src/qmf/ConsoleEventImpl.h 52 src/qmf/DataAddr.cpp 67 src/qmf/Expression.h 44 src/qmf/SchemaId.cpp 58 src/qmf/QueryImpl.h 42 src/qmf/PosixEventNotifier.cpp 32 src/qmf/PosixEventNotifierImpl.h 31 src/qmf/AgentSession.cpp 754 src/qmf/PosixEventNotifierImpl.cpp 67 src/qmf/AgentSubscription.h 27 src/qmf/AgentEventImpl.h 63 src/qmf/Hash.cpp 19 src/qmf/AgentImpl.h 84 src/qmf/Expression.cpp 358 src/qmf/Subscription.cpp 47 src/qmf/Hash.h 20 src/qmf/SchemaPropertyImpl.h 57 src/qmf/Agent.cpp 491 src/qpidd.h 40 src/windows/resources/version-resource.h 9 src/windows/SCM.h 38 src/windows/QpiddBroker.cpp 378 src/windows/SCM.cpp 213