Path Lines of Code bindings/qpid/dotnet/src/Message.h 299 bindings/qpid/dotnet/src/QpidMarshal.h 41 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/python/qpid_messaging.i 487 bindings/qpid/ruby/features/step_definitions/receiver_steps.rb 40 bindings/qpid/ruby/lib/qpid_messaging/session.rb 72 management/python/lib/qlslibs/analyze.py 543 management/python/lib/qlslibs/jrnl.py 342 management/python/lib/qmf/console.py 2887 management/python/lib/qpidstore/janal.py 424 management/python/lib/qpidstore/jrnl.py 482 packaging/winsdk/bld-winsdk.ps1 451 rubygen/amqpgen.rb 383 rubygen/framing.0-10/Session.rb 341 rubygen/framing.0-10/constants.rb 161 src/qmf/AgentSession.cpp 754 src/qmf/ConsoleSession.cpp 477 src/qpid/RangeSet.h 224 src/qpid/SaslFactory.cpp 506 src/qpid/Serializer.h 101 src/qpid/SessionState.cpp 218 src/qpid/acl/AclConnectionCounter.cpp 183 src/qpid/amqp/MessageReader.cpp 624 src/qpid/amqp_0_10/Codecs.cpp 483 src/qpid/amqp_0_10/SessionHandler.cpp 266 src/qpid/amqp_0_10/SessionHandler.h 65 src/qpid/broker/Broker.cpp 1437 src/qpid/broker/ConnectionHandler.cpp 360 src/qpid/broker/ConsumerFactory.h 27 src/qpid/broker/Daemon.cpp 128 src/qpid/broker/DtxAck.h 24 src/qpid/broker/DtxManager.cpp 171 src/qpid/broker/DtxWorkRecord.cpp 143 src/qpid/broker/HeadersExchange.cpp 329 src/qpid/broker/Link.cpp 635 src/qpid/broker/LinkRegistry.cpp 348 src/qpid/broker/LossyQueue.cpp 57 src/qpid/broker/Message.cpp 328 src/qpid/broker/Message.h 185 src/qpid/broker/MessageAdapter.cpp 48 src/qpid/broker/MessageAdapter.h 32 src/qpid/broker/MessageBuilder.cpp 89 src/qpid/broker/MessageMap.cpp 123 src/qpid/broker/PagedQueue.cpp 385 src/qpid/broker/Queue.cpp 1498 src/qpid/broker/Queue.h 312 src/qpid/broker/RecoveredDequeue.h 27 src/qpid/broker/RecoveredEnqueue.h 27 src/qpid/broker/SaslAuthenticator.cpp 396 src/qpid/broker/Selector.cpp 207 src/qpid/broker/SemanticState.cpp 727 src/qpid/broker/SessionAdapter.cpp 551 src/qpid/broker/SessionHandler.cpp 115 src/qpid/broker/SessionState.cpp 379 src/qpid/broker/amqp/Domain.cpp 261 src/qpid/broker/amqp/Filter.cpp 360 src/qpid/broker/amqp/Incoming.cpp 132 src/qpid/broker/amqp/Message.cpp 486 src/qpid/broker/amqp/NodeProperties.cpp 323 src/qpid/broker/amqp/Outgoing.cpp 307 src/qpid/broker/amqp/Relay.cpp 248 src/qpid/broker/amqp/Relay.h 96 src/qpid/broker/amqp/Sasl.cpp 138 src/qpid/broker/amqp/Session.cpp 933 src/qpid/broker/amqp/Translation.cpp 297 src/qpid/broker/amqp_0_10/Connection.cpp 454 src/qpid/broker/amqp_0_10/MessageTransfer.cpp 406 src/qpid/client/ConnectionImpl.cpp 330 src/qpid/client/FailoverManager.cpp 100 src/qpid/client/Handle.h 24 src/qpid/client/Message.h 46 src/qpid/client/PrivateImplRef.h 25 src/qpid/client/RdmaConnector.cpp 328 src/qpid/client/SessionImpl.cpp 555 src/qpid/client/SslConnector.cpp 326 src/qpid/client/TCPConnector.cpp 238 src/qpid/client/amqp0_10/AddressResolution.cpp 896 src/qpid/client/amqp0_10/IncomingMessages.cpp 364 src/qpid/client/amqp0_10/OutgoingMessage.cpp 134 src/qpid/client/amqp0_10/ReceiverImpl.cpp 213 src/qpid/client/amqp0_10/SenderImpl.cpp 151 src/qpid/client/amqp0_10/SenderImpl.h 106 src/qpid/client/windows/SaslFactory.cpp 153 src/qpid/framing/AMQFrame.cpp 108 src/qpid/framing/AMQHeaderBody.cpp 36 src/qpid/framing/Array.cpp 94 src/qpid/framing/BufferTypes.h 47 src/qpid/framing/InputHandler.h 14 src/qpid/framing/MethodContent.h 15 src/qpid/ha/BrokerReplicator.cpp 717 src/qpid/ha/HaBroker.cpp 182 src/qpid/ha/Primary.cpp 342 src/qpid/ha/PrimaryQueueLimits.h 53 src/qpid/ha/QueueReplicator.cpp 331 src/qpid/ha/StatusCheck.h 35 src/qpid/ha/hash.h 39 src/qpid/legacystore/JournalImpl.cpp 523 src/qpid/legacystore/MessageStoreImpl.cpp 1453 src/qpid/legacystore/MessageStoreImpl.h 285 src/qpid/legacystore/jrnl/data_tok.h 113 src/qpid/legacystore/jrnl/enq_rec.cpp 536 src/qpid/legacystore/jrnl/enums.h 65 src/qpid/legacystore/jrnl/fcntl.cpp 297 src/qpid/legacystore/jrnl/file_hdr.h 111 src/qpid/legacystore/jrnl/jcntl.cpp 827 src/qpid/legacystore/jrnl/jcntl.h 140 src/qpid/legacystore/jrnl/jdir.cpp 363 src/qpid/legacystore/jrnl/jdir.h 55 src/qpid/legacystore/jrnl/jexception.h 76 src/qpid/legacystore/jrnl/jinf.cpp 456 src/qpid/legacystore/jrnl/rfc.h 61 src/qpid/legacystore/jrnl/rmgr.cpp 549 src/qpid/legacystore/jrnl/rmgr.h 60 src/qpid/legacystore/jrnl/wmgr.cpp 886 src/qpid/legacystore/jrnl/wmgr.h 83 src/qpid/legacystore/jrnl/wrfc.cpp 116 src/qpid/linearstore/JournalImpl.cpp 393 src/qpid/linearstore/MessageStoreImpl.cpp 1315 src/qpid/linearstore/MessageStoreImpl.h 262 src/qpid/linearstore/journal/EmptyFilePool.cpp 397 src/qpid/linearstore/journal/EmptyFilePoolPartition.cpp 141 src/qpid/linearstore/journal/JournalFile.cpp 279 src/qpid/linearstore/journal/LinearFileController.cpp 183 src/qpid/linearstore/journal/RecoveryManager.cpp 821 src/qpid/linearstore/journal/data_tok.h 88 src/qpid/linearstore/journal/enums.h 28 src/qpid/linearstore/journal/jcntl.cpp 360 src/qpid/linearstore/journal/jcntl.h 123 src/qpid/linearstore/journal/jdir.cpp 351 src/qpid/linearstore/journal/jdir.h 47 src/qpid/linearstore/journal/jexception.h 71 src/qpid/linearstore/journal/txn_map.cpp 218 src/qpid/linearstore/journal/wmgr.cpp 904 src/qpid/linearstore/journal/wmgr.h 102 src/qpid/management/ManagementAgent.cpp 2205 src/qpid/messaging/amqp/ConnectionContext.cpp 1236 src/qpid/messaging/amqp/EncodedMessage.cpp 309 src/qpid/messaging/amqp/PnData.cpp 204 src/qpid/messaging/amqp/ReceiverContext.cpp 119 src/qpid/messaging/amqp/SenderContext.cpp 673 src/qpid/messaging/amqp/SessionContext.cpp 241 src/qpid/messaging/amqp/SessionHandle.cpp 103 src/qpid/store/MessageStorePlugin.h 82 src/qpid/store/StorageProvider.h 101 src/qpid/store/ms-clfs/MSSqlClfsProvider.cpp 780 src/qpid/store/ms-sql/MSSqlProvider.cpp 921 src/qpid/sys/AsynchIOHandler.cpp 175 src/qpid/sys/DispatchHandle.h 67 src/qpid/sys/PollableQueue.h 97 src/qpid/sys/RdmaIOPlugin.cpp 285 src/qpid/sys/SocketTransport.cpp 161 src/qpid/sys/Timer.cpp 179 src/qpid/sys/posix/AsynchIO.cpp 461 src/qpid/sys/posix/BSDSocket.cpp 208 src/qpid/sys/posix/PosixPoller.cpp 573 src/qpid/sys/rdma/RdmaIO.cpp 511 src/qpid/sys/rdma/RdmaIO.h 174 src/qpid/sys/rdma/rdma_wrap.cpp 423 src/qpid/sys/rdma/rdma_wrap.h 193 src/qpid/sys/solaris/ECFPoller.cpp 324 src/qpid/sys/ssl/check.cpp 52 src/qpid/sys/ssl/util.cpp 85 src/qpid/sys/windows/IocpPoller.cpp 142 src/qpid/sys/windows/SslAsynchIO.cpp 553 src/qpid/sys/windows/WinSocket.cpp 205 src/qpid/sys/windows/WinSocket.h 52 src/windows/QpiddBroker.cpp 378