src/qpid/linearstore/journal/wmgr.cpp (8 lines): - line 128: throw jexception(oss.str()); // TODO: complete exception - line 132: throw jexception("RHM_IORES_NOTIMPL: partial enqueues not implemented"); // TODO: complete exception; - line 190: // TODO: Incorrect - must set state to ENQ_CACHED; ENQ_SUBM is set when AIO returns. - line 247: throw jexception(oss.str()); // TODO: complete exception - line 331: // TODO: Incorrect - must set state to ENQ_CACHED; ENQ_SUBM is set when AIO returns. - line 391: throw jexception(oss.str()); // TODO: complete exception - line 492: throw jexception(oss.str()); // TODO: complete exception - line 934: // TODO: Replace for LFC src/qpid/linearstore/MessageStoreImpl.cpp (7 lines): - line 105: // TODO: check against list of existing partitions, throw if not found - line 123: // TODO: check against list of existing pools in the given partition - line 337: // TODO: Linearstore: harvest all discarded journal files into the empty file pool(s). - line 763: // TODO: Update this for new settings, as qpid.file_count and qpid.file_size no longer apply - line 806: //TODO: this is a copy&paste from recoverQueues - refactor! - line 901: // TODO: This optimization to skip reading if there are no enqueued messages to read - line 1146: // TODO: check if this result should be used... src/qpid/sys/rdma/RdmaIO.cpp (7 lines): - line 157: // TODO: It might turn out to be more efficient in high connection loads to reuse the - line 185: // TODO creating a function object every time isn't all that - line 263: // TODO: We might want to batch up sending credit - line 392: // TODO: Probably need to flush queues at this point - line 410: // TODO: Is this safe to do if the connection is disconnected already? - line 418: // TODO: This should use RDMA write with imm as there might not ever be a buffer to receive this message - line 447: // TODO: maybe don't call idle unless we're low on write buffers src/qpid/legacystore/MessageStoreImpl.cpp (6 lines): - line 46: // FIXME aconway 2010-03-09: was 10 - line 285: // TODO: Uncomment these lines when auto-expand is enabled. - line 847: //TODO: this is a copy&paste from recoverQueues - refactor! - line 944: // TODO: This optimization to skip reading if there are no enqueued messages to read - line 1276: // TODO: check if this result should be used... - line 1709: // TODO: Uncomment these lines when auto-expand is enabled. src/qpid/broker/Broker.cpp (6 lines): - line 845: //TODO: implement 'strict' option (check there are no unrecognised properties) - line 866: //TODO: unused doesn't take store settings into account... so can't yet implement strict - line 940: // TODO: strict checking here - line 1000: // TODO: strict checking here - line 1299: // TODO: this 'move' works in the static case but has no - line 1687: // FIXME aconway 2012-04-27: access to linkClientProperties is src/qpid/broker/SaslAuthenticator.cpp (6 lines): - line 179: // TODO: Figure out who owns the char* returned by - line 325: // TODO: Change this to an exception signaling - line 332: //TODO: should the actual SSF values be configurable here? - line 430: // TODO: Change this to an exception signaling - line 490: // TODO: Change this to an exception signaling - line 529: // TODO: Change to more specific exceptions, when they are src/qpid/linearstore/journal/jcntl.h (5 lines): - line 57: // TODO: This is not included in any files at present, add to file_hdr? - line 84: // TODO: It would be helpful to distinguish between states stopping and stopped. If stop(true) is called, - line 321: * TODO: Fix this lousy interface. The caller should NOT be required to clean up these - line 471: inline uint32_t get_enq_cnt() const { return _emap.size(); } // TODO: _emap: Thread safe? - line 500: // TODO Make this a const, but txn_map must support const first. src/qpid/linearstore/journal/RecoveryManager.cpp (5 lines): - line 113: // TODO: At a later time, this could be used to establish a new pool size provided the partition exists. - line 277: throw jexception(jerrno::JERR_JREC_BADRECTAIL, oss.str(), "RecoveryManager", "readNextRemainingRecord"); // TODO: Don't throw exception, log info - line 402: // TODO: place this bit into a common function as it is also used in EmptyFilePool.cpp::deleteSymlink() - line 433: throw jexception(oss.str()); // TODO: complete this exception - line 438: // TODO: Logic weak here for detecting error conditions in journal, specifically when no src/qpid/legacystore/jrnl/jcntl.h (5 lines): - line 80: // TODO: This is not included in any files at present, add to file_hdr? - line 117: // TODO: It would be helpful to distinguish between states stopping and stopped. If stop(true) is called, - line 417: * TODO: Fix this lousy interface. The caller should NOT be required to clean up these - line 599: // TODO Make this a const, but txn_map must support const first. - line 655: // FIXME these are _rmgr to _wmgr interactions, remove when _rmgr contains ref to _wmgr: src/qpid/legacystore/jrnl/rmgr.cpp (5 lines): - line 189: // TODO: Add member _fid to pmgr::page_cb which indicates the fid from which this page was - line 604: // TODO: Future perf improvement: Do a single AIO read for all available file - line 614: // TODO: For perf, combine contiguous pages into single read - line 648: // FIXME: _pg_cntr should be sync'd with aio ops, not use of page as it is now... - line 682: /* TODO (sometime in the future) src/qpid/broker/SessionAdapter.cpp (4 lines): - line 128: //TODO: implement if-unused - line 278: //TODO: check alternate-exchange is as expected - line 487: // FIXME aconway 2008-05-12: create SequenceSet directly, no need for intermediate results vector. - line 517: //TODO: but currently never used client->server src/qpid/broker/amqp/Outgoing.cpp (4 lines): - line 155: outgoingMessageRejected();//TODO: not quite true... - line 173: outgoingMessageRejected();//TODO: not quite true... - line 178: //TODO: only settle once any dequeue on store has completed - line 201: //TODO: release in a clearer order? management/python/lib/qlslibs/analyze.py (4 lines): - line 337: self.last_record_offset = None # TODO: Move into JournalFile - line 338: self.num_filler_records_required = None # TODO: Move into JournalFile - line 406: #TODO: move this to JournalFile, append to file info - line 430: def _check_alignment(self): # TODO: Move into JournalFile src/qpid/SaslFactory.cpp (4 lines): - line 286: secprops.security_flags = 0;//TODO: provide means for application to configure these - line 437: // TODO: Change this to an exception signaling - line 444: //TODO: should the actual SSF values be configurable here? - line 561: // TODO: Change this to an exception signaling src/qpid/sys/posix/AsynchIO.cpp (4 lines): - line 33: // TODO The basic algorithm here is not really POSIX specific and with a - line 118: // TODO: Currently we ignore the peers address, perhaps we should - line 198: // TODO creating a function object every time isn't all that - line 403: // TODO creating a function object every time isn't all that src/qpid/linearstore/JournalImpl.cpp (4 lines): - line 186: // TODO: replace for linearstore: _lpmgr - line 219: // TODO: replace for linearstore: _lpmgr - line 233: // TODO: This is ugly, find a way for RecoveryManager to use boost::ptr_list* directly - line 281: // TODO: replace for linearstore: _lpmgr src/qpid/Serializer.h (3 lines): - line 27: #include "qpid/Exception.h" // FIXME aconway 2008-04-03: proper exception class. - line 115: throw Exception("Framing error: data overrun"); // FIXME aconway 2008-04-03: proper exception. - line 123: throw Exception("Framing error: data overrun"); // FIXME aconway 2008-04-03: proper exception. src/qpid/linearstore/MessageStoreImpl.h (3 lines): - line 114: // FIXME aconway 2010-03-09: was 10ms - line 246: // TODO: change the default dir to ~/.qpidd - line 327: inline uint32_t outstandingQueueAIO(const qpid::broker::PersistableQueue& /*queue*/) { return 0; }; // TODO: Deprecate this call src/qpid/broker/amqp/Message.cpp (3 lines): - line 141: //TODO: avoid allocating new string by just iterating over chars - line 245: // TODO: Would throwing an exception make more sense here? - line 527: //combine existing and added annotations (TODO: this could be src/qpid/client/amqp0_10/IncomingMessages.cpp (3 lines): - line 301: //TODO: handle other types of commands (e.g. message-accept, message-flow etc) - line 321: //TODO: handle other types of commands (e.g. message-accept, message-flow etc) - line 400: //TODO: unify conversion to and from 0-10 message that is currently src/qpid/legacystore/jrnl/jinf.cpp (3 lines): - line 349: // TODO: Uncomment these lines when auto-expand is enabled. - line 365: // TODO: This is *not* an XML writer, rather for simplicity, it uses literals. I'm sure a more elegant way can be - line 416: // TODO: This is *not* an XML reader, rather for simplicity, it is a brute-force line reader which relies on string src/qpid/legacystore/jrnl/jdir.cpp (3 lines): - line 166: // FIXME: Find out why this fails with false alarms/errors from time to time... - line 320: // FIXME: Find out why this fails with false alarms/errors from time to time... - line 367: // FIXME: Find out why this fails with false alarms/errors from time to time... src/qpid/sys/RdmaIOPlugin.cpp (3 lines): - line 132: // TODO: Dummy implementation, need to fill this in for heartbeat timeout to work - line 136: // TODO: Dummy implementation, need to fill this in for connection establishment timeout to work - line 145: // TODO: Shouldn't need this test as idle() should only ever be called when src/qmf/AgentSession.cpp (3 lines): - line 322: // TODO: Survey active subscriptions to see if they need to hear about this new data. - line 344: // TODO: Survey active subscriptions to see if they need to hear about this deleted data. - line 977: // TODO: process any active subscriptions on their intervals. rubygen/amqpgen.rb (3 lines): - line 20: # TODO aconway 2008-02-21: - line 398: # FIXME aconway 2008-04-11: - line 403: # FIXME aconway 2008-04-11: src/qpid/linearstore/journal/jdir.h (3 lines): - line 202: * FIXME: links are not handled correctly. - line 219: * FIXME: links are not handled correctly. - line 237: * FIXME: links are not handled correctly. src/qpid/broker/SemanticState.cpp (3 lines): - line 414: // TODO aconway 2009-06-08: if we have byte & message credit but - line 509: //TODO:if discard-unroutable, just drop it - line 510: //TODO:else if accept-mode is explicit, reject it src/qpid/linearstore/journal/jdir.cpp (3 lines): - line 143: // FIXME: Find out why this fails with false alarms/errors from time to time... - line 281: // FIXME: Find out why this fails with false alarms/errors from time to time... - line 319: // FIXME: Find out why this fails with false alarms/errors from time to time... src/qpid/client/SessionImpl.cpp (3 lines): - line 104: //TODO: timeout will not be set locally until get response to - line 525: //TODO: make sure this works with execution.exception - don't - line 699: // FIXME aconway 2008-10-07: wait for timeout response from broker src/qpid/legacystore/jrnl/jdir.h (3 lines): - line 222: * FIXME: links are not handled correctly. - line 239: * FIXME: links are not handled correctly. - line 257: * FIXME: links are not handled correctly. src/qpid/broker/Queue.cpp (3 lines): - line 41: //TODO: get rid of this - line 265: //TODO: move some of this out of the queue and into the publishing - line 437: //TODO: reduce lock scope src/qpid/amqp_0_10/Codecs.cpp (3 lines): - line 109: case 0x04: break; //TODO: iso-8859-15 char - line 118: case 0x27: break; //TODO: utf-32 char - line 127: //TODO: figure out whether and how to map values with codes 0x40-0xd8 src/qpid/broker/amqp/Relay.cpp (2 lines): - line 161: case PN_RELEASED://TODO: not quite true... - line 162: case PN_MODIFIED://TODO: not quite true... src/qpid/SessionState.cpp (2 lines): - line 50: // TODO aconway 2008-05-22: Do complete frame sequence validity check here, - line 74: // TODO aconway 2008-04-24: if we go to support for partial src/qpid/sys/ssl/util.cpp (2 lines): - line 65: //TODO: something else? - line 98: //use defaults for all args, TODO: may want to make this configurable src/qpid/framing/AMQFrame.cpp (2 lines): - line 109: // TODO: should we check reserved2 against zero as well? - the - line 114: // TODO: should no longer care about body size and only pass up src/qpid/broker/Message.cpp (2 lines): - line 236: //FIXME: modify Encoding interface to allow retrieval of - line 395: //TODO: this is still quite 0-10 specific... src/qpid/legacystore/jrnl/wmgr.h (2 lines): - line 86: // TODO: Convert _enq_busy etc into a proper threadsafe lock - line 87: // TODO: Convert to enum? Are these encodes mutually exclusive? src/qpid/ha/Primary.cpp (2 lines): - line 123: // TODO aconway 2014-01-31: Be more selective, suppress only expected errors? - line 375: // FIXME aconway 2014-08-13: Conditional on logging. src/qpid/legacystore/MessageStoreImpl.h (2 lines): - line 112: // TODO: set defAutoJrnlExpand to true and defAutoJrnlExpandMaxFiles to 16 when auto-expand comes on-line - line 258: // TODO: change the default dir to ~/.qpidd src/qpid/client/SslConnector.cpp (2 lines): - line 313: TODO mgoulish - fix the underlying cause and then - line 372: // TODO: unreading needs to go away, and when we can cope src/qpid/client/TCPConnector.cpp (2 lines): - line 206: TODO mgoulish - fix the underlying cause and then - line 268: // TODO: unreading needs to go away, and when we can cope src/windows/QpiddBroker.cpp (2 lines): - line 109: // TODO: Might need to search Global\\ name if unadorned name fails - line 191: // TODO: Might need to search Global\\ name if unadorned name fails src/qpid/sys/rdma/rdma_wrap.h (2 lines): - line 272: // TODO: Currently you can only connect with the default connection parameters - line 280: // TODO: Not sure how to default accept params - they come from the connection request src/qpid/legacystore/jrnl/wmgr.cpp (2 lines): - line 185: // TODO: Incorrect - must set state to ENQ_CACHED; ENQ_SUBM is set when AIO returns. - line 289: // TODO: Incorrect - must set state to ENQ_CACHED; ENQ_SUBM is set when AIO returns. src/qpid/client/amqp0_10/OutgoingMessage.cpp (2 lines): - line 45: //TODO: unify conversion to and from 0-10 message that is currently - line 56: //TODO: need to avoid copying as much as possible src/qpid/client/amqp0_10/SenderImpl.cpp (2 lines): - line 104: //TODO: add option to throw exception rather than blocking? - line 116: if (++window > (capacity / 4)) {//TODO: make this configurable? src/qpid/client/Message.h (2 lines): - line 34: class SequenceNumber; // FIXME aconway 2009-04-17: remove with getID? - line 164: // FIXME aconway 2009-04-17: does this need to be in public API? src/qpid/store/StorageProvider.h (2 lines): - line 75: * @TODO Should StorageProvider also inherit from MessageStore? If so, then - line 290: * @TODO This should probably not be here - it's only here because management/python/lib/qpidstore/jrnl.py (2 lines): - line 25: # TODO: Get rid of these! Use jinf instance instead - line 29: # TODO - this is messy - find a better way to handle this src/qpid/messaging/amqp/PnData.cpp (2 lines): - line 32: // TODO aconway 2014-11-20: PnData duplicates functionality of qpid::amqp::Encoder,Decoder. - line 224: // TODO aconway 2014-11-20: get described values. src/qpid/acl/AclConnectionCounter.cpp (2 lines): - line 294: // TODO: Ideally this would be a method of the connection itself. - line 295: // TODO: Verify it works with rdma connection names. bindings/qpid/ruby/lib/qpid_messaging/session.rb (2 lines): - line 146: # TODO: Add an optional block to be used for blocking calls. - line 182: # TODO: Add an optional block to be used for blocking calls. src/qpid/broker/DtxWorkRecord.cpp (2 lines): - line 61: //TODO: this should probably be flagged as internal error - line 107: //TODO: this should probably be flagged as internal error bindings/qpid/python/qpid_messaging.i (2 lines): - line 290: # FIXME aconway 2014-02-11: the following does not repsect the sync flag. - line 294: if disposition : # FIXME aconway 2014-02-11: support this src/qpid/ha/QueueReplicator.cpp (2 lines): - line 275: arguments.setInt(QPID_SYNC_FREQUENCY, 1); // TODO aconway 2012-05-22: optimize? - line 316: //TODO: should be able to optimise the following src/qpid/linearstore/journal/txn_map.cpp (2 lines): - line 79: throw jexception("Inconsistent 2PC count"); // TODO: complete exception details - line 82: throw jexception("Both abort and commit in same transaction"); // TODO: complete exception details src/qpid/linearstore/journal/LinearFileController.cpp (2 lines): - line 108: // TODO: Add checks that this file is of a valid size; if not, delete this and get one from the EFP - line 133: // TODO: Re-evaluate after testing and profiling src/qpid/sys/rdma/rdma_wrap.cpp (2 lines): - line 131: // TODO: make a default struct for this - line 477: // TODO: Currently you can only connect with the default connection parameters src/qpid/sys/AsynchIOHandler.cpp (2 lines): - line 154: //TODO: may still want to revise this... - line 170: // TODO: unreading needs to go away, and when we can cope src/qpid/ha/PrimaryQueueLimits.h (2 lines): - line 51: // FIXME aconway 2014-01-24: hardcoded maxQueues, use negotiated channel-max - line 88: // TODO aconway 2014-01-24: Currently replication links always use the src/qpid/linearstore/journal/wmgr.h (2 lines): - line 66: // TODO: Convert _enq_busy etc into a proper threadsafe lock - line 67: // TODO: Convert to enum? Are these encodes mutually exclusive? src/qpid/broker/amqp/Domain.cpp (2 lines): - line 198: domain->removePending(shared_from_this());//(TODO: add support for retry on connection failure) - line 219: domain->removePending(shared_from_this());//give up (TODO: add support for periodic retry) src/qpid/sys/posix/BSDSocket.cpp (1 line): - line 158: // TODO the correct thing to do here is loop on failure until you've used all the returned addresses src/qpid/ha/StatusCheck.h (1 line): - line 40: // TODO aconway 2012-12-21: This solution is incomplete. It will only protect src/qpid/client/amqp0_10/ReceiverImpl.cpp (1 line): - line 41: //TODO: should this be configurable management/python/lib/qmf/console.py (1 line): - line 3668: TODO: Add logic for client-side selection and filtering deleted objects from get-queries src/qpid/framing/InputHandler.h (1 line): - line 30: // TODO aconway 2007-08-29: Eliminate, replace with FrameHandler. src/qpid/framing/MethodContent.h (1 line): - line 34: //TODO: rethink this interface src/qpid/broker/Queue.h (1 line): - line 307: //TODO: get unbind out of the public interface; only there for purposes of one unit test src/qpid/ha/hash.h (1 line): - line 32: // TODO aconway 2013-08-06: would like to use boost::hash or std::hash here src/qpid/broker/MessageMap.cpp (1 line): - line 50: return size() == 0;//TODO: more efficient implementation src/qpid/ha/HaBroker.cpp (1 line): - line 68: // TODO aconway 2013-12-13: Can we restrict this to queues identified as replicated? src/qpid/legacystore/jrnl/jcntl.cpp (1 line): - line 837: // TODO - review this logic and tidy up how rd._lfid is assigned. See new jinf.get_end_file() fn. src/qpid/broker/MessageBuilder.cpp (1 line): - line 56: //TODO: rethink how to handle non-existent headers(?)... src/qpid/sys/ssl/check.cpp (1 line): - line 45: //them, add a few specific ones in here. (TODO: more complete src/qpid/amqp_0_10/SessionHandler.h (1 line): - line 65: QPID_COMMON_EXTERN void markReadyToSend();//TODO: only needed for inter-broker bridge; cleanup src/qpid/broker/Message.h (1 line): - line 28: //TODO: move the following out of framing or replace it src/qpid/broker/amqp/Filter.cpp (1 line): - line 404: pn_data_put_string(data, convert(i->second));//TODO: other types? src/qpid/store/MessageStorePlugin.h (1 line): - line 61: // @TODO Need a mgmt story for this. Maybe allow r/o access to provider store info? public qpid::management::Manageable src/qpid/client/Handle.h (1 line): - line 67: friend class PrivateImplRef; // FIXME aconway 2009-04-30: Specify src/qpid/messaging/amqp/SessionHandle.cpp (1 line): - line 101: //TODO: cache handles in this case to avoid frequent allocation src/qpid/sys/windows/WinSocket.cpp (1 line): - line 250: // TODO: I don't think this can ever be called! src/qpid/legacystore/jrnl/data_tok.h (1 line): - line 65: // TODO: Fix this, separate write state from operation src/qpid/broker/RecoveredDequeue.h (1 line): - line 44: // TODO aconway 2013-07-08: revisit src/qpid/linearstore/journal/enums.h (1 line): - line 29: // TODO: Change this to flags, as multiple of these conditions may exist simultaneously src/qpid/store/ms-sql/MSSqlProvider.cpp (1 line): - line 1003: // @TODO Much of this recovery code is way too similar... refactor to src/qpid/sys/Timer.cpp (1 line): - line 99: // TODO AStitcher 21/08/09 The threshholds for emitting warnings are a little arbitrary rubygen/framing.0-10/constants.rb (1 line): - line 190: # FIXME aconway 2008-10-07: there are no good exception codes in 0-10 for an invalid code. src/qpid/broker/amqp/Relay.h (1 line): - line 83: std::deque buffer;//TODO: optimise by replacing with simple circular array src/qpid/broker/amqp/Session.cpp (1 line): - line 566: //just use link name (TODO: could allow this to be src/qpid/broker/SessionHandler.cpp (1 line): - line 147: * TODO: this is a little ugly, fix it; its currently still relied on src/qmf/ConsoleSession.cpp (1 line): - line 186: Receiver topicRx = session.createReceiver(topicBase + "/agent.#"); // TODO: be more discriminating src/qpid/legacystore/jrnl/rfc.h (1 line): - line 91: * Note TODO: Comment on sync issues between change in num files in _lpmp and _fc_index/_curr_fc. src/qpid/amqp/MessageReader.cpp (1 line): - line 644: //TODO: might be better to decode this here src/qpid/client/PrivateImplRef.h (1 line): - line 32: // FIXME aconway 2009-04-24: details! src/qpid/broker/Selector.cpp (1 line): - line 112: // TODO: Just use a simple if chain for now - improve this later src/qpid/management/ManagementAgent.cpp (1 line): - line 2642: // TODO aconway 2010-03-04: see comment in encode(), readProperties doesn't set v2key. src/qpid/broker/ConsumerFactory.h (1 line): - line 25: // TODO aconway 2011-11-25: it's ugly exposing SemanticState::ConsumerImpl in public. management/python/lib/qlslibs/jrnl.py (1 line): - line 84: def __init__(self, file_handle): # TODO - clumsy, only allows reading from disk. Move all disk stuff to laod() src/qpid/legacystore/jrnl/fcntl.cpp (1 line): - line 315: // TODO - look at more efficient alternatives to allocating a null block: src/qpid/sys/windows/WinSocket.h (1 line): - line 97: // TODO The following are raw operations, maybe they need better wrapping? src/qpid/linearstore/journal/jexception.h (1 line): - line 50: // TODO: The following is a temporary bug-tracking aid which forces a core. bindings/qpid/perl/lib/qpid/messaging/Session.pm (1 line): - line 123: TODO: How to handle acknowledging a specific message? src/qpid/sys/DispatchHandle.h (1 line): - line 47: * TODO: astitcher document DispatchHandleRef to simplify this. src/qpid/ha/BrokerReplicator.cpp (1 line): - line 395: arguments.setInt(QueueReplicator::QPID_SYNC_FREQUENCY, 1); // TODO aconway 2012-05-22: optimize? src/qpid/linearstore/journal/jcntl.cpp (1 line): - line 409: throw jexception("_wmgr.curr_pg_blocked() with no events remaining"); // TODO - complete exception src/qpid/broker/amqp_0_10/Connection.cpp (1 line): - line 160: // TODO set last bool true if system connection src/qpid/client/RdmaConnector.cpp (1 line): - line 101: void abort() {} // TODO: need to fix this for heartbeat timeouts to work src/qpid/RangeSet.h (1 line): - line 103: typedef InlineVector, 3> Ranges; // TODO aconway 2008-04-21: what's the optimial inlined value? src/qpid/broker/PagedQueue.cpp (1 line): - line 203: //TODO: bindings/qpid/perl/lib/qpid/messaging/Message.pm (1 line): - line 569: TODO: Need to make the content automatically encode and decode for src/qpid/broker/DtxManager.cpp (1 line): - line 196: //TODO: do we want to have a timed task to cleanup, or can we rely on an explicit completion? src/qpid/broker/ConnectionHandler.cpp (1 line): - line 333: 0, // TODO -- mgoulish Fri Sep 24 2010 src/qpid/linearstore/journal/JournalFile.cpp (1 line): - line 300: // TODO: ::rand() is not thread safe, either lock or use rand_r(seed) with a thread-local seed. src/qpid/messaging/amqp/ReceiverContext.cpp (1 line): - line 33: //TODO: proper conversion to wide string for address src/qpid/client/amqp0_10/AddressResolution.cpp (1 line): - line 910: //TODO: could use a passive declare to check alternate-exchange src/qpid/broker/Link.cpp (1 line): - line 99: const framing::FieldTable* headers = 0;//TODO: msg.getMessage().getApplicationHeaders(); src/qpid/broker/amqp/Translation.cpp (1 line): - line 249: // TODO: FieldTable applicationHeaders; src/qpid/messaging/amqp/EncodedMessage.cpp (1 line): - line 235: //TODO: populate raw data? src/qpid/sys/PollableQueue.h (1 line): - line 32: #include "qpid/log/Statement.h" // FIXME aconway 2011-08-05: src/qpid/sys/posix/PosixPoller.cpp (1 line): - line 581: // TODO: avoid new snapshot, perhaps create an index to pollfds or a src/qpid/broker/amqp/Incoming.cpp (1 line): - line 58: return credit;//TODO: proper flow control src/qpid/broker/amqp/Sasl.cpp (1 line): - line 129: //TODO: what should we do with hostname here? bindings/qpid/dotnet/src/QpidMarshal.h (1 line): - line 43: /// TODO: figure out some encoding other than UTF-8 src/qpid/legacystore/jrnl/enq_rec.cpp (1 line): - line 312: * TODO: This section needs revision. Since it is known that the end of the page falls within the src/qpid/broker/HeadersExchange.cpp (1 line): - line 40: // TODO aconway 2006-09-20: More efficient matching algorithm. src/qpid/sys/windows/SslAsynchIO.cpp (1 line): - line 168: // @@TODO: Need to delay the write if the session is renegotiating. src/qpid/sys/windows/IocpPoller.cpp (1 line): - line 207: return Event(0, INVALID); // TODO - this may need to be changed. management/python/lib/qpidstore/janal.py (1 line): - line 397: #TODO - print size analysis here - ie how full, sparse, est. space remaining before enq threshold src/qpid/legacystore/jrnl/file_hdr.h (1 line): - line 178: // TODO: Standardize on method for getting time that does not requrie a context switch. src/qpid/broker/DtxAck.h (1 line): - line 42: // TODO aconway 2013-07-08: src/qpid/broker/amqp/NodeProperties.cpp (1 line): - line 129: pn_data_put_string(data, convert(MOVE));//TODO: should really add COPY as well, since queues can be browsed src/qpid/broker/SessionState.cpp (1 line): - line 287: //TODO: make command handling more uniform, regardless of whether src/qpid/linearstore/journal/EmptyFilePoolPartition.cpp (1 line): - line 185: // TODO: other validity checks here src/qpid/client/windows/SaslFactory.cpp (1 line): - line 194: return std::string(); // TODO - when GSSAPI is supported, return userId for connection. src/qpid/broker/RecoveredEnqueue.h (1 line): - line 44: // TODO aconway 2013-07-08: revisit src/qpid/sys/rdma/RdmaIO.h (1 line): - line 72: // TODO: Instead of specifying a buffer size specify the amount of memory the AsynchIO class can use src/qpid/broker/MessageAdapter.h (1 line): - line 32: // TODO aconway 2007-11-09: No longer needed, we only have one type of message. src/qpid/legacystore/jrnl/wrfc.cpp (1 line): - line 152: // TODO: update this to reflect all status data src/qpid/amqp_0_10/SessionHandler.cpp (1 line): - line 235: // TODO aconway 2008-05-12: support replay of partial commands. src/qpid/linearstore/journal/data_tok.h (1 line): - line 46: // TODO: Fix this, separate write state from operation src/qpid/linearstore/journal/EmptyFilePool.cpp (1 line): - line 315: // TODO: On a separate thread, process returned files by overwriting headers and, optionally, their contents and src/qpid/sys/solaris/ECFPoller.cpp (1 line): - line 41: //TODO: Remove this src/qpid/client/amqp0_10/SenderImpl.h (1 line): - line 125: //TODO: ideally want to put messages on the outbound src/qpid/legacystore/jrnl/jexception.h (1 line): - line 66: // TODO: The following is a temporary bug-tracking aid which forces a core. src/qpid/legacystore/jrnl/rmgr.h (1 line): - line 88: /* TODO (if required) src/qpid/broker/LossyQueue.cpp (1 line): - line 54: //TODO: arguably we should try and purge expired messages first but that src/qpid/broker/LinkRegistry.cpp (1 line): - line 42: // TODO: This constructor is only used by the store unit tests - bindings/qpid/dotnet/src/Message.h (1 line): - line 485: //TODO: EncodingException src/qpid/broker/amqp_0_10/MessageTransfer.cpp (1 line): - line 194: // TODO -- remove this code and replace it with a QPID_ASSERT(cachedRequiredCredit), src/qpid/messaging/amqp/ConnectionContext.cpp (1 line): - line 882: //TODO: Fix pn_engine_input() to take const buffer src/qpid/messaging/amqp/SessionContext.cpp (1 line): - line 167: pn_delivery_settle(i->second); //TODO: different settlement modes? src/qpid/legacystore/JournalImpl.cpp (1 line): - line 271: // TODO: This is a brutal approach - very inefficient and slow. Rather introduce a system of remembering rubygen/framing.0-10/Session.rb (1 line): - line 149: # FIXME aconway 2008-05-23: additional doc on sync/async use. src/qpid/framing/AMQHeaderBody.cpp (1 line): - line 39: // TODO: should just skip & keep for later dispatch. packaging/winsdk/bld-winsdk.ps1 (1 line): - line 353: # TODO: Fix up the .NET binding example solution/projects before including them. src/qpid/client/ConnectionImpl.cpp (1 line): - line 410: // FIXME aconway 2008-06-06: exception use, amqp0-10 does not seem to have src/qpid/sys/SocketTransport.cpp (1 line): - line 214: // TODO: Design question - should we do the error callback and also throw? src/qpid/client/FailoverManager.cpp (1 line): - line 53: session.sync();//TODO: shouldn't be required src/qpid/broker/Daemon.cpp (1 line): - line 20: * TODO: Note this is really a Posix specific implementation and so should be src/qpid/messaging/amqp/SenderContext.cpp (1 line): - line 54: //TODO: proper conversion to wide string for address src/qpid/framing/BufferTypes.h (1 line): - line 102: // TODO aconway 2013-07-26: Add integer types. src/qpid/framing/Array.cpp (1 line): - line 128: // FIXME aconway 2008-10-31: put meaningful strings in this message. bindings/qpid/ruby/features/step_definitions/receiver_steps.rb (1 line): - line 58: # TODO we shouldn't need to sleep a second in order to have this update src/qpid/store/ms-clfs/MSSqlClfsProvider.cpp (1 line): - line 897: // @TODO Much of this recovery code is way too similar... refactor to src/qpid/legacystore/jrnl/enums.h (1 line): - line 40: // TODO: Change this to flags, as multiple of these conditions may exist simultaneously bindings/qpid/perl/lib/qpid/messaging/Duration.pm (1 line): - line 196: # TODO: Need a better way to define FOREVER src/qpid/broker/MessageAdapter.cpp (1 line): - line 48: //TODO: delete this, immediate is no longer part of the spec