Lines Matching refs:Tcp
47 static_assert(sizeof(struct tcpcb) == sizeof(Tcp::Endpoint::mTcb), "mTcb field in otTcpEndpoint is …
48 static_assert(alignof(struct tcpcb) == alignof(decltype(Tcp::Endpoint::mTcb)),
50 static_assert(offsetof(Tcp::Endpoint, mTcb) == 0, "mTcb field in otTcpEndpoint has nonzero offset");
52 static_assert(sizeof(struct tcpcb_listen) == sizeof(Tcp::Listener::mTcbListen),
54 static_assert(alignof(struct tcpcb_listen) == alignof(decltype(Tcp::Listener::mTcbListen)),
56 static_assert(offsetof(Tcp::Listener, mTcbListen) == 0, "mTcbListen field in otTcpEndpoint has nonz…
58 Tcp::Tcp(Instance &aInstance) in Tcp() function in ot::Ip6::Tcp
67 Error Tcp::Endpoint::Initialize(Instance &aInstance, const otTcpEndpointInitializeArgs &aArgs) in Initialize()
74 SuccessOrExit(error = aInstance.Get<Tcp>().mEndpoints.Add(*this)); in Initialize()
112 Instance &Tcp::Endpoint::GetInstance(void) const { return AsNonConst(AsCoreType(GetTcb().instance))… in GetInstance()
114 const SockAddr &Tcp::Endpoint::GetLocalAddress(void) const in GetLocalAddress()
126 const SockAddr &Tcp::Endpoint::GetPeerAddress(void) const in GetPeerAddress()
138 Error Tcp::Endpoint::Bind(const SockAddr &aSockName) in Bind()
144 VerifyOrExit(Get<Tcp>().CanBind(aSockName), error = kErrorInvalidState); in Bind()
154 Error Tcp::Endpoint::Connect(const SockAddr &aSockName, uint32_t aFlags) in Connect()
183 Error Tcp::Endpoint::SendByReference(otLinkedBuffer &aBuffer, uint32_t aFlags) in SendByReference()
209 Error Tcp::Endpoint::SendByExtension(size_t aNumBytes, uint32_t aFlags) in SendByExtension()
238 Error Tcp::Endpoint::ReceiveByReference(const otLinkedBuffer *&aBuffer) in ReceiveByReference()
248 Error Tcp::Endpoint::ReceiveContiguify(void) in ReceiveContiguify()
257 Error Tcp::Endpoint::CommitReceive(size_t aNumBytes, uint32_t aFlags) in CommitReceive()
274 Error Tcp::Endpoint::SendEndOfStream(void) in SendEndOfStream()
281 Error Tcp::Endpoint::Abort(void) in Abort()
290 Error Tcp::Endpoint::Deinitialize(void) in Deinitialize()
294 SuccessOrExit(error = Get<Tcp>().mEndpoints.Remove(*this)); in Deinitialize()
303 bool Tcp::Endpoint::IsClosed(void) const { return GetTcb().t_state == TCP6S_CLOSED; } in IsClosed()
305 uint8_t Tcp::Endpoint::TimerFlagToIndex(uint8_t aTimerFlag) in TimerFlagToIndex()
329 bool Tcp::Endpoint::IsTimerActive(uint8_t aTimerIndex) in IsTimerActive()
354 void Tcp::Endpoint::SetTimer(uint8_t aTimerFlag, uint32_t aDelay) in SetTimer()
370 Get<Tcp>().mTimer.FireAtIfEarlier(newFireTime); in SetTimer()
373 void Tcp::Endpoint::CancelTimer(uint8_t aTimerFlag) in CancelTimer()
387 bool Tcp::Endpoint::FirePendingTimers(TimeMilli aNow, bool &aHasFutureTimer, TimeMilli &aEarliestFu… in FirePendingTimers()
458 void Tcp::Endpoint::PostCallbacksAfterSend(size_t aSent, size_t aBacklogBefore) in PostCallbacksAfterSend()
465 Get<Tcp>().mTasklet.Post(); in PostCallbacksAfterSend()
469 bool Tcp::Endpoint::FirePendingCallbacks(void) in FirePendingCallbacks()
484 size_t Tcp::Endpoint::GetSendBufferBytes(void) const in GetSendBufferBytes()
490 size_t Tcp::Endpoint::GetInFlightBytes(void) const in GetInFlightBytes()
496 size_t Tcp::Endpoint::GetBacklogBytes(void) const { return GetSendBufferBytes() - GetInFlightBytes(… in GetBacklogBytes()
498 Address &Tcp::Endpoint::GetLocalIp6Address(void) { return *reinterpret_cast<Address *>(&GetTcb().la… in GetLocalIp6Address()
500 const Address &Tcp::Endpoint::GetLocalIp6Address(void) const in GetLocalIp6Address()
505 Address &Tcp::Endpoint::GetForeignIp6Address(void) { return *reinterpret_cast<Address *>(&GetTcb().… in GetForeignIp6Address()
507 const Address &Tcp::Endpoint::GetForeignIp6Address(void) const in GetForeignIp6Address()
512 bool Tcp::Endpoint::Matches(const MessageInfo &aMessageInfo) const in Matches()
529 Error Tcp::Listener::Initialize(Instance &aInstance, const otTcpListenerInitializeArgs &aArgs) in Initialize()
534 SuccessOrExit(error = aInstance.Get<Tcp>().mListeners.Add(*this)); in Initialize()
547 Instance &Tcp::Listener::GetInstance(void) const { return AsNonConst(AsCoreType(GetTcbListen().inst… in GetInstance()
549 Error Tcp::Listener::Listen(const SockAddr &aSockName) in Listen()
555 VerifyOrExit(Get<Tcp>().CanBind(aSockName), error = kErrorInvalidState); in Listen()
566 Error Tcp::Listener::StopListening(void) in StopListening()
576 Error Tcp::Listener::Deinitialize(void) in Deinitialize()
580 SuccessOrExit(error = Get<Tcp>().mListeners.Remove(*this)); in Deinitialize()
587 bool Tcp::Listener::IsClosed(void) const { return GetTcbListen().t_state == TCP6S_CLOSED; } in IsClosed()
589 Address &Tcp::Listener::GetLocalIp6Address(void) { return *reinterpret_cast<Address *>(&GetTcbListe… in GetLocalIp6Address()
591 const Address &Tcp::Listener::GetLocalIp6Address(void) const in GetLocalIp6Address()
596 bool Tcp::Listener::Matches(const MessageInfo &aMessageInfo) const in Matches()
611 Error Tcp::HandleMessage(ot::Ip6::Header &aIp6Header, Message &aMessage, MessageInfo &aMessageInfo) in HandleMessage()
634 VerifyOrExit(length >= sizeof(Tcp::Header), error = kErrorParse); in HandleMessage()
680 ProcessSignals(Tcp::Endpoint::FromTcb(*sig.accepted_connection), nullptr, 0, sig); in HandleMessage()
692 void Tcp::ProcessSignals(Endpoint &aEndpoint, in ProcessSignals()
752 Error Tcp::BsdErrorToOtError(int aBsdError) in BsdErrorToOtError()
766 bool Tcp::CanBind(const SockAddr &aSockName) in CanBind()
801 bool Tcp::AutoBind(const SockAddr &aPeer, SockAddr &aToBind, bool aBindAddress, bool aBindPort) in AutoBind()
849 void Tcp::HandleTimer(void) in HandleTimer()
911 void Tcp::ProcessCallbacks(void) in ProcessCallbacks()
978 Tcp::Endpoint &endpoint = Tcp::Endpoint::FromTcb(*aTcb); in tcplp_sys_set_timer()
984 Tcp::Endpoint &endpoint = Tcp::Endpoint::FromTcb(*aTcb); in tcplp_sys_stop_timer()
990 Tcp::Listener &listener = Tcp::Listener::FromTcbListen(*aTcbListen); in tcplp_sys_accept_ready()
991 Tcp &tcp = listener.Get<Tcp>(); in tcplp_sys_accept_ready()
1009 Tcp::Endpoint &endpoint = AsCoreType(endpointPtr); in tcplp_sys_accept_ready()
1040 Tcp::Listener &listener = Tcp::Listener::FromTcbListen(*aTcbListen); in tcplp_sys_accepted_connection()
1041 Tcp::Endpoint &endpoint = Tcp::Endpoint::FromTcb(*aAccepted); in tcplp_sys_accepted_connection()
1042 Tcp &tcp = endpoint.Get<Tcp>(); in tcplp_sys_accepted_connection()
1064 Tcp::Endpoint &endpoint = Tcp::Endpoint::FromTcb(*aTcb); in tcplp_sys_connection_lost()
1134 …return instance.Get<Tcp>().AutoBind(*static_cast<const SockAddr *>(aPeer), *static_cast<SockAddr *… in tcplp_sys_autobind()