/openthread-latest/src/core/api/ |
D | tcp_api.cpp | 43 otTcpEndpoint *aEndpoint, in otTcpEndpointInitialize() argument 46 return AsCoreType(aEndpoint).Initialize(AsCoreType(aInstance), *aArgs); in otTcpEndpointInitialize() 49 otInstance *otTcpEndpointGetInstance(otTcpEndpoint *aEndpoint) { return &AsCoreType(aEndpoint).GetI… in otTcpEndpointGetInstance() argument 51 void *otTcpEndpointGetContext(otTcpEndpoint *aEndpoint) { return AsCoreType(aEndpoint).GetContext()… in otTcpEndpointGetContext() argument 53 const otSockAddr *otTcpGetLocalAddress(const otTcpEndpoint *aEndpoint) in otTcpGetLocalAddress() argument 55 return &AsCoreType(aEndpoint).GetLocalAddress(); in otTcpGetLocalAddress() 58 const otSockAddr *otTcpGetPeerAddress(const otTcpEndpoint *aEndpoint) in otTcpGetPeerAddress() argument 60 return &AsCoreType(aEndpoint).GetPeerAddress(); in otTcpGetPeerAddress() 63 otError otTcpBind(otTcpEndpoint *aEndpoint, const otSockAddr *aSockName) in otTcpBind() argument 65 return AsCoreType(aEndpoint).Bind(AsCoreType(aSockName)); in otTcpBind() [all …]
|
D | tcp_ext_api.cpp | 56 otError otTcpCircularSendBufferWrite(otTcpEndpoint *aEndpoint, in otTcpCircularSendBufferWrite() argument 64 return AsCoreType(aSendBuffer).Write(AsCoreType(aEndpoint), aData, aLength, *aWritten, aFlags); in otTcpCircularSendBufferWrite()
|
/openthread-latest/include/openthread/ |
D | tcp.h | 76 typedef void (*otTcpEstablished)(otTcpEndpoint *aEndpoint); 90 typedef void (*otTcpSendDone)(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData); 159 typedef void (*otTcpForwardProgress)(otTcpEndpoint *aEndpoint, size_t aInSendBuffer, size_t aBacklo… 179 typedef void (*otTcpReceiveAvailable)(otTcpEndpoint *aEndpoint, 211 typedef void (*otTcpDisconnected)(otTcpEndpoint *aEndpoint, otTcpDisconnectedReason aReason); 316 otTcpEndpoint *aEndpoint, 327 otInstance *otTcpEndpointGetInstance(otTcpEndpoint *aEndpoint); 337 void *otTcpEndpointGetContext(otTcpEndpoint *aEndpoint); 349 const otSockAddr *otTcpGetLocalAddress(const otTcpEndpoint *aEndpoint); 361 const otSockAddr *otTcpGetPeerAddress(const otTcpEndpoint *aEndpoint); [all …]
|
D | tcp_ext.h | 149 otError otTcpCircularSendBufferWrite(otTcpEndpoint *aEndpoint,
|
/openthread-latest/src/cli/ |
D | cli_tcp.hpp | 98 static void HandleTcpEstablishedCallback(otTcpEndpoint *aEndpoint); 99 static void HandleTcpSendDoneCallback(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData); 100 …static void HandleTcpForwardProgressCallback(otTcpEndpoint *aEndpoint, size_t aInSendBuffer, size_… 101 static void HandleTcpReceiveAvailableCallback(otTcpEndpoint *aEndpoint, 105 …static void HandleTcpDisconnectedCallback(otTcpEndpoint *aEndpoint, otTcpDisconnectedReason aReaso… 110 otTcpEndpoint *aEndpoint, 113 void HandleTcpEstablished(otTcpEndpoint *aEndpoint); 114 void HandleTcpSendDone(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData); 115 void HandleTcpForwardProgress(otTcpEndpoint *aEndpoint, size_t aInSendBuffer, size_t aBacklog); 116 void HandleTcpReceiveAvailable(otTcpEndpoint *aEndpoint, [all …]
|
D | cli_tcp.cpp | 787 void TcpExample::HandleTcpEstablishedCallback(otTcpEndpoint *aEndpoint) in HandleTcpEstablishedCallback() argument 789 static_cast<TcpExample *>(otTcpEndpointGetContext(aEndpoint))->HandleTcpEstablished(aEndpoint); in HandleTcpEstablishedCallback() 792 void TcpExample::HandleTcpSendDoneCallback(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData) in HandleTcpSendDoneCallback() argument 794 …static_cast<TcpExample *>(otTcpEndpointGetContext(aEndpoint))->HandleTcpSendDone(aEndpoint, aData); in HandleTcpSendDoneCallback() 797 void TcpExample::HandleTcpForwardProgressCallback(otTcpEndpoint *aEndpoint, size_t aInSendBuffer, s… in HandleTcpForwardProgressCallback() argument 799 static_cast<TcpExample *>(otTcpEndpointGetContext(aEndpoint)) in HandleTcpForwardProgressCallback() 800 ->HandleTcpForwardProgress(aEndpoint, aInSendBuffer, aBacklog); in HandleTcpForwardProgressCallback() 803 void TcpExample::HandleTcpReceiveAvailableCallback(otTcpEndpoint *aEndpoint, in HandleTcpReceiveAvailableCallback() argument 808 static_cast<TcpExample *>(otTcpEndpointGetContext(aEndpoint)) in HandleTcpReceiveAvailableCallback() 809 ->HandleTcpReceiveAvailable(aEndpoint, aBytesAvailable, aEndOfStream, aBytesRemaining); in HandleTcpReceiveAvailableCallback() [all …]
|
/openthread-latest/src/core/net/ |
D | tcp6.cpp | 692 void Tcp::ProcessSignals(Endpoint &aEndpoint, in ProcessSignals() argument 697 VerifyOrExit(IsInitialized(aEndpoint) && !aEndpoint.IsClosed()); in ProcessSignals() 698 if (aSignals.conn_established && aEndpoint.mEstablishedCallback != nullptr) in ProcessSignals() 700 aEndpoint.mEstablishedCallback(&aEndpoint); in ProcessSignals() 703 VerifyOrExit(IsInitialized(aEndpoint) && !aEndpoint.IsClosed()); in ProcessSignals() 704 if (aEndpoint.mSendDoneCallback != nullptr) in ProcessSignals() 714 VerifyOrExit(i == 0 || (IsInitialized(aEndpoint) && !aEndpoint.IsClosed())); in ProcessSignals() 717 aEndpoint.mSendDoneCallback(&aEndpoint, curr); in ProcessSignals() 722 VerifyOrExit(IsInitialized(aEndpoint) && !aEndpoint.IsClosed()); in ProcessSignals() 723 if (aEndpoint.mForwardProgressCallback != nullptr) in ProcessSignals() [all …]
|
D | tcp6_ext.cpp | 52 Error TcpCircularSendBuffer::Write(Tcp::Endpoint &aEndpoint, in Write() argument 117 error = aEndpoint.SendByReference(dataSendLink, flags); in Write() 123 error = aEndpoint.SendByExtension(aLength, flags); in Write() 140 error = aEndpoint.SendByExtension(bytesUntilWrap, flags | OT_TCP_SEND_MORE_TO_COME); in Write() 151 error = aEndpoint.SendByReference(wrappedDataSendLink, flags); in Write()
|
D | dns_client.hpp | 829 static void HandleTcpEstablishedCallback(otTcpEndpoint *aEndpoint); 830 static void HandleTcpSendDoneCallback(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData); 831 …static void HandleTcpDisconnectedCallback(otTcpEndpoint *aEndpoint, otTcpDisconnectedReason aReaso… 832 static void HandleTcpReceiveAvailableCallback(otTcpEndpoint *aEndpoint, 837 void HandleTcpEstablished(otTcpEndpoint *aEndpoint); 838 void HandleTcpSendDone(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData); 839 void HandleTcpDisconnected(otTcpEndpoint *aEndpoint, otTcpDisconnectedReason aReason); 840 void HandleTcpReceiveAvailable(otTcpEndpoint *aEndpoint,
|
D | dns_client.cpp | 1771 void Client::HandleTcpSendDone(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData) in HandleTcpSendDone() argument 1773 OT_UNUSED_VARIABLE(aEndpoint); in HandleTcpSendDone() 1781 void Client::HandleTcpSendDoneCallback(otTcpEndpoint *aEndpoint, otLinkedBuffer *aData) in HandleTcpSendDoneCallback() argument 1783 static_cast<Client *>(otTcpEndpointGetContext(aEndpoint))->HandleTcpSendDone(aEndpoint, aData); in HandleTcpSendDoneCallback() 1786 void Client::HandleTcpEstablished(otTcpEndpoint *aEndpoint) in HandleTcpEstablished() argument 1788 OT_UNUSED_VARIABLE(aEndpoint); in HandleTcpEstablished() 1793 void Client::HandleTcpEstablishedCallback(otTcpEndpoint *aEndpoint) in HandleTcpEstablishedCallback() argument 1795 static_cast<Client *>(otTcpEndpointGetContext(aEndpoint))->HandleTcpEstablished(aEndpoint); in HandleTcpEstablishedCallback() 1842 void Client::HandleTcpReceiveAvailable(otTcpEndpoint *aEndpoint, in HandleTcpReceiveAvailable() argument 1847 OT_UNUSED_VARIABLE(aEndpoint); in HandleTcpReceiveAvailable() [all …]
|
D | tcp6.hpp | 625 bool IsInitialized(const Endpoint &aEndpoint) const { return mEndpoints.Contains(aEndpoint); } in IsInitialized() 645 void ProcessSignals(Endpoint &aEndpoint,
|
D | tcp6_ext.hpp | 86 …Error Write(Tcp::Endpoint &aEndpoint, const void *aData, size_t aLength, size_t &aWritten, uint32_…
|