cpp/source/client/ClientManagerImpl.cpp (4 lines): - line 305: // TODO: Would this leak some memory? - line 532: // TODO: handle other cases. - line 861: // TODO: NACK it immediately - line 974: // TODO: Use capture by move and pass-by-value paradigm when C++ 14 is available. cpp/source/client/RpcClientImpl.cpp (2 lines): - line 42: // TODO: execute orphan callback in event-loop thread? - line 53: // TODO: execute orphan callback in event-loop thread? cpp/source/rocketmq/ProducerImpl.cpp (2 lines): - line 57: // TODO: initialize client_config_ and fault_strategy_ - line 550: // TODO: propagate error_code to caller csharp/rocketmq-client-csharp/Endpoints.cs (2 lines): - line 79: // TODO: Multiple addresses has not been supported yet. - line 137: // TODO: Support multiple addresses. cpp/source/rocketmq/ClientImpl.cpp (1 line): - line 523: // TODO: Use capture by move if C++14 is possible golang/message_id_codec.go (1 line): - line 116: // TODO Implement System.nanoTime() in golang, see https://github.com/golang/go/issues/16658 cpp/source/rocketmq/PushConsumerImpl.cpp (1 line): - line 306: // TODO: remove it from current assignment such that a second attempt will be made again in the next round. csharp/rocketmq-client-csharp/Session.cs (1 line): - line 60: // TODO: Test concurrency. csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs (1 line): - line 56: // TODO: use SipHash24 algorithm rust/src/session.rs (1 line): - line 208: // TODO tls config cpp/source/client/include/ClientConfig.h (1 line): - line 55: // TODO: use std::chrono::milliseconds rust/src/client.rs (1 line): - line 751: // TODO use countdown latch instead sleeping python/rocketmq/client.py (1 line): - line 173: # TODO: stats implement cpp/source/base/UtilAll.cpp (1 line): - line 104: // TODO: running out of memory golang/conn.go (1 line): - line 113: // TODO get requestID in header cpp/proto/apache/rocketmq/v2/definition.proto (1 line): - line 181: // TODO: define semantics of invalid-digest-when-broadcasting. golang/client.go (1 line): - line 626: // TODO get stack php/protocol/apache/rocketmq/v2/definition.proto (1 line): - line 181: // TODO: define semantics of invalid-digest-when-broadcasting. cpp/source/client/include/SessionImpl.h (1 line): - line 39: // TODO: use unique_ptr cpp/source/client/include/ClientManagerImpl.h (1 line): - line 53: * TODO: Make it protected such that instantiating it through ClientManagerFactory only, achieving Singleton python/rocketmq/session.py (1 line): - line 42: # TODO handle read operation exceed the time limit cpp/source/base/MixAll.cpp (1 line): - line 204: * TODO: std::localtime is not thread-safe, output, as a result, may be less reliable in highly contending cpp/source/stats/OpencensusExporter.cpp (1 line): - line 81: // TODO: Opencensus provides end-timestamp of the statistics conducted whilst OpenTelemetry requires