src/Proton/Engine/Implementation/ProtonEngine.cs (7 lines): - line 150: // TODO : Cancellation Token -> nextIdleTimeoutCheck.Cancel(false); - line 212: // TODO - As an additional feature of this method we could allow for calling before connection is - line 220: // TODO : idleTimeoutExecutor.TryExecuteTask(new IdleTimeoutCheck()); - line 264: // TODO : nextIdleTimeoutCheck.cancel(false); - line 529: // TODO - Some computation to work out a reasonable delay that still compensates for - line 536: // TODO :nextIdleTimeoutCheck = idleTimeoutExecutor.schedule(this, delay, TimeUnit.MILLISECONDS); - line 539: // TODO - If no local timeout but remote hasn't opened we might return zero and not src/Proton.TestPeer/Expectations/FlowExpectation.cs (6 lines): - line 83: // TODO: The auto response values need to be pulled from session activity to produce meaningful auto - line 89: response.WithNextIncomingId((uint)flow.NextOutgoingId); //TODO: this could be wrong, need to know about the transfers received (and sent by peer). - line 94: response.WithIncomingWindow(int.MaxValue); //TODO: shouldn't be hard coded - line 99: response.WithNextOutgoingId((uint)flow.NextIncomingId); //TODO: this could be wrong, need to know about the transfers sent (and received at recipient peer). - line 104: response.WithOutgoingWindow(0); //TODO: shouldn't be hard coded, session might have senders on it as well as receivers - line 112: // TODO: blow up on response if credit not populated? src/Proton.Client/Client/Implementation/ClientConnection.cs (4 lines): - line 799: // TODO Shutdown the IO Context here once a quiet period is supported. - line 920: // TODO: Blocking here isn't ideal but for now we want to await - line 1139: // TODO: Executor scheduling would handle connection close, this will - line 1161: // TODO: Executor scheduling would handle connection close, this will src/Proton.TestPeer/Driver/SessionTracker.cs (4 lines): - line 442: // TODO - Update session state based on transfer - line 463: // TODO - Update session state based on transfer - line 469: // TODO Forward to attached links or issue errors if invalid. - line 474: // TODO Forward to attached links or issue error if invalid. src/Proton.Client/Client/Transport/IOContext.cs (3 lines): - line 31: // TODO Add shutdown quiesse timeouts - line 56: eventLoop.Shutdown(); // TODO graceful shutdown with quiesce - line 66: // TODO - WebSockets src/Proton.Client/Client/Implementation/ClientDeliveryState.cs (2 lines): - line 255: DeliveryStateType.Rejected => new Rejected(),// TODO - How do we aggregate the different values into one DeliveryState Object - line 256: DeliveryStateType.Modified => new Modified(),// TODO - How do we aggregate the different values into one DeliveryState Object src/Proton/Engine/Implementation/ProtonTransactionManager.cs (2 lines): - line 243: // TODO: We should be closing the link if the remote did not report that it supports the - line 364: // TODO: If the remote did not indicate it supports reject we should really close the link. src/Proton.TestPeer/Driver/DriverSessions.cs (1 line): - line 74: // TODO: Respect local channel max if one was set on open. src/Proton.TestPeer/Actions/FlowInjectAction.cs (1 line): - line 125: // TODO: The values set in the outbound flow should be read from actively maintained src/Proton.Client/Client/Implementation/ClientExceptionSupport.cs (1 line): - line 88: // TODO interrogate task exceptions for any client exception src/Proton/Buffer/ProtonCompositeBuffer.cs (1 line): - line 448: // TODO There could be an issue here with the copy if the source and dest buffers overlap src/Proton/Engine/Implementation/ProtonSessionIncomingWindow.cs (1 line): - line 205: // TODO - need to revisit this logic and decide on sane cutoff for capacity restriction. src/Proton.Client/Client/Implementation/ClientTransportProxy.cs (1 line): - line 94: // TODO - How do we handle case of not all data read ? src/Proton/Engine/Sasl/Client/AbstractScramSHAMechanism.cs (1 line): - line 272: // TODO - a real implementation of SaslPrep [rfc4013] src/Proton.Client/Client/Implementation/ClientSession.cs (1 line): - line 652: // TODO Consider ways to flatten this check src/Proton.TestPeer/Expectations/TransferExpectation.cs (1 line): - line 257: // TODO - Create Matcher which describes the mismatch in detail src/Proton.TestPeer/Utilities/Eventloop.cs (1 line): - line 118: // TODO Fire uncaught exception handler src/Proton.TestPeer/Expectations/AttachExpectation.cs (1 line): - line 244: // TODO - Need to match on the driver types for DeliveryState src/Proton.Client/Client/Implementation/ClientStreamReceiverMessage.cs (1 line): - line 581: // TODO: At the moment there is no automatic rejection or release etc src/Proton.Client/Client/Concurrent/DefaultEventloop.cs (1 line): - line 119: // TODO Fire uncaught exception handler src/Proton/Logging/ProtonLoggerFactory.cs (1 line): - line 71: // TODO: Loggers already created will be using the old logger factory src/Proton/Buffer/ProtonByteBuffer.cs (1 line): - line 277: // TODO compute the index values src/Proton/Engine/Sasl/Client/SaslAuthenticator.cs (1 line): - line 105: // TODO LOG.debug("SASL Negotiations proceeding using selected mechanisms: {}", chosenMechanism);