Lines Matching refs:Tcb
54 IN OUT TCP_CB *Tcb in TcpInitTcbLocal() argument
60 if (Tcb->Sk->IpVersion == IP_VERSION_4) { in TcpInitTcbLocal()
61 Tcb->HeadSum = NetPseudoHeadChecksum ( in TcpInitTcbLocal()
62 Tcb->LocalEnd.Ip.Addr[0], in TcpInitTcbLocal()
63 Tcb->RemoteEnd.Ip.Addr[0], in TcpInitTcbLocal()
68 Tcb->HeadSum = NetIp6PseudoHeadChecksum ( in TcpInitTcbLocal()
69 &Tcb->LocalEnd.Ip.v6, in TcpInitTcbLocal()
70 &Tcb->RemoteEnd.Ip.v6, in TcpInitTcbLocal()
76 Tcb->Iss = TcpGetIss (); in TcpInitTcbLocal()
77 Tcb->SndUna = Tcb->Iss; in TcpInitTcbLocal()
78 Tcb->SndNxt = Tcb->Iss; in TcpInitTcbLocal()
80 Tcb->SndWl2 = Tcb->Iss; in TcpInitTcbLocal()
81 Tcb->SndWnd = 536; in TcpInitTcbLocal()
83 Tcb->RcvWnd = GET_RCV_BUFFSIZE (Tcb->Sk); in TcpInitTcbLocal()
88 Tcb->RcvWndScale = 0; in TcpInitTcbLocal()
90 Tcb->ProbeTimerOn = FALSE; in TcpInitTcbLocal()
103 IN OUT TCP_CB *Tcb, in TcpInitTcbPeer() argument
110 ASSERT ((Tcb != NULL) && (Seg != NULL) && (Opt != NULL)); in TcpInitTcbPeer()
113 Tcb->SndWnd = Seg->Wnd; in TcpInitTcbPeer()
114 Tcb->SndWndMax = Tcb->SndWnd; in TcpInitTcbPeer()
115 Tcb->SndWl1 = Seg->Seq; in TcpInitTcbPeer()
118 Tcb->SndWl2 = Seg->Ack; in TcpInitTcbPeer()
120 Tcb->SndWl2 = Tcb->Iss + 1; in TcpInitTcbPeer()
124 Tcb->SndMss = (UINT16) MAX (64, Opt->Mss); in TcpInitTcbPeer()
126 RcvMss = TcpGetRcvMss (Tcb->Sk); in TcpInitTcbPeer()
127 if (Tcb->SndMss > RcvMss) { in TcpInitTcbPeer()
128 Tcb->SndMss = RcvMss; in TcpInitTcbPeer()
135 Tcb->RcvMss = 536; in TcpInitTcbPeer()
138 Tcb->CWnd = Tcb->SndMss; in TcpInitTcbPeer()
140 Tcb->Irs = Seg->Seq; in TcpInitTcbPeer()
141 Tcb->RcvNxt = Tcb->Irs + 1; in TcpInitTcbPeer()
143 Tcb->RcvWl2 = Tcb->RcvNxt; in TcpInitTcbPeer()
145 if (TCP_FLG_ON (Opt->Flag, TCP_OPTION_RCVD_WS) && !TCP_FLG_ON (Tcb->CtrlFlag, TCP_CTRL_NO_WS)) { in TcpInitTcbPeer()
147 Tcb->SndWndScale = Opt->WndScale; in TcpInitTcbPeer()
149 Tcb->RcvWndScale = TcpComputeScale (Tcb); in TcpInitTcbPeer()
150 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_RCVD_WS); in TcpInitTcbPeer()
156 Tcb->RcvWndScale = 0; in TcpInitTcbPeer()
159 if (TCP_FLG_ON (Opt->Flag, TCP_OPTION_RCVD_TS) && !TCP_FLG_ON (Tcb->CtrlFlag, TCP_CTRL_NO_TS)) { in TcpInitTcbPeer()
161 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_SND_TS); in TcpInitTcbPeer()
162 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_RCVD_TS); in TcpInitTcbPeer()
164 Tcb->TsRecent = Opt->TSVal; in TcpInitTcbPeer()
171 Tcb->SndMss -= TCP_OPTION_TS_ALIGNED_LEN; in TcpInitTcbPeer()
321 TCP_CB *Tcb; in TcpFindTcbByPeer() local
328 Tcb = NET_LIST_USER_STRUCT (Entry, TCP_CB, List); in TcpFindTcbByPeer()
330 if ((Version == Tcb->Sk->IpVersion) && in TcpFindTcbByPeer()
331 TcpIsIpEqual (Addr, &Tcb->LocalEnd.Ip, Version) && in TcpFindTcbByPeer()
332 (LocalPort == Tcb->LocalEnd.Port) in TcpFindTcbByPeer()
340 Tcb = NET_LIST_USER_STRUCT (Entry, TCP_CB, List); in TcpFindTcbByPeer()
342 if ((Version == Tcb->Sk->IpVersion) && in TcpFindTcbByPeer()
343 TcpIsIpEqual (Addr, &Tcb->LocalEnd.Ip, Version) && in TcpFindTcbByPeer()
344 (LocalPort == Tcb->LocalEnd.Port) in TcpFindTcbByPeer()
381 TCP_CB *Tcb; in TcpLocateTcb() local
393 Tcb = NET_LIST_USER_STRUCT (Entry, TCP_CB, List); in TcpLocateTcb()
395 if ((Version == Tcb->Sk->IpVersion) && in TcpLocateTcb()
396 TCP_PEER_EQUAL (&Remote, &Tcb->RemoteEnd, Version) && in TcpLocateTcb()
397 TCP_PEER_EQUAL (&Local, &Tcb->LocalEnd, Version) in TcpLocateTcb()
400 RemoveEntryList (&Tcb->List); in TcpLocateTcb()
401 InsertHeadList (&mTcpRunQue, &Tcb->List); in TcpLocateTcb()
403 return Tcb; in TcpLocateTcb()
428 IN TCP_CB *Tcb in TcpInsertTcb() argument
436 (Tcb != NULL) && in TcpInsertTcb()
438 (Tcb->State == TCP_LISTEN) || in TcpInsertTcb()
439 (Tcb->State == TCP_SYN_SENT) || in TcpInsertTcb()
440 (Tcb->State == TCP_SYN_RCVD) || in TcpInsertTcb()
441 (Tcb->State == TCP_CLOSED) in TcpInsertTcb()
445 if (Tcb->LocalEnd.Port == 0) { in TcpInsertTcb()
451 if (Tcb->State == TCP_LISTEN) { in TcpInsertTcb()
461 if (TCP_PEER_EQUAL (&Tcb->LocalEnd, &Node->LocalEnd, Tcb->Sk->IpVersion) && in TcpInsertTcb()
462 TCP_PEER_EQUAL (&Tcb->RemoteEnd, &Node->RemoteEnd, Tcb->Sk->IpVersion) in TcpInsertTcb()
469 InsertHeadList (Head, &Tcb->List); in TcpInsertTcb()
485 IN TCP_CB *Tcb in TcpCloneTcb() argument
496 CopyMem (Clone, Tcb, sizeof (TCP_CB)); in TcpCloneTcb()
501 NET_GET_REF (Tcb->IpInfo); in TcpCloneTcb()
507 Clone->Sk = SockClone (Tcb->Sk); in TcpCloneTcb()
608 IN TCP_CB *Tcb, in TcpSetState() argument
612 ASSERT (Tcb->State < (sizeof (mTcpStateName) / sizeof (CHAR16 *))); in TcpSetState()
618 Tcb, in TcpSetState()
619 mTcpStateName[Tcb->State], in TcpSetState()
623 Tcb->State = State; in TcpSetState()
628 SockConnEstablished (Tcb->Sk); in TcpSetState()
630 if (Tcb->Parent != NULL) { in TcpSetState()
635 TcpInstallDevicePath (Tcb->Sk); in TcpSetState()
642 SockConnClosed (Tcb->Sk); in TcpSetState()
690 IN TCP_CB *Tcb, in TcpFormatNetbuf() argument
708 Seg->Wnd = (NTOHS (Head->Wnd) << Tcb->SndWndScale); in TcpFormatNetbuf()
738 IN OUT TCP_CB *Tcb in TcpOnAppConnect() argument
741 TcpInitTcbLocal (Tcb); in TcpOnAppConnect()
742 TcpSetState (Tcb, TCP_SYN_SENT); in TcpOnAppConnect()
744 TcpSetTimer (Tcb, TCP_TIMER_CONNECT, Tcb->ConnectTimeout); in TcpOnAppConnect()
745 TcpToSendData (Tcb, 1); in TcpOnAppConnect()
757 IN OUT TCP_CB *Tcb in TcpOnAppClose() argument
760 ASSERT (Tcb != NULL); in TcpOnAppClose()
762 if (!IsListEmpty (&Tcb->RcvQue) || GET_RCV_DATASIZE (Tcb->Sk) != 0) { in TcpOnAppClose()
767 Tcb) in TcpOnAppClose()
770 TcpResetConnection (Tcb); in TcpOnAppClose()
771 TcpClose (Tcb); in TcpOnAppClose()
775 switch (Tcb->State) { in TcpOnAppClose()
779 TcpSetState (Tcb, TCP_CLOSED); in TcpOnAppClose()
784 TcpSetState (Tcb, TCP_FIN_WAIT_1); in TcpOnAppClose()
788 TcpSetState (Tcb, TCP_LAST_ACK); in TcpOnAppClose()
794 TcpToSendData (Tcb, 1); in TcpOnAppClose()
809 IN OUT TCP_CB *Tcb in TcpOnAppSend() argument
813 switch (Tcb->State) { in TcpOnAppSend()
826 TcpToSendData (Tcb, 0); in TcpOnAppSend()
852 IN TCP_CB *Tcb in TcpOnAppConsume() argument
857 switch (Tcb->State) { in TcpOnAppConsume()
859 TcpOld = TcpRcvWinOld (Tcb); in TcpOnAppConsume()
860 if (TcpRcvWinNow (Tcb) > TcpOld) { in TcpOnAppConsume()
862 if (TcpOld < Tcb->RcvMss) { in TcpOnAppConsume()
867 Tcb) in TcpOnAppConsume()
870 TcpSendAck (Tcb); in TcpOnAppConsume()
871 } else if (Tcb->DelayedAck == 0) { in TcpOnAppConsume()
876 Tcb) in TcpOnAppConsume()
879 Tcb->DelayedAck = 1; in TcpOnAppConsume()
899 IN TCP_CB *Tcb in TcpOnAppAbort() argument
905 Tcb) in TcpOnAppAbort()
908 switch (Tcb->State) { in TcpOnAppAbort()
914 TcpResetConnection (Tcb); in TcpOnAppAbort()
920 TcpSetState (Tcb, TCP_CLOSED); in TcpOnAppAbort()
931 IN TCP_CB *Tcb in TcpResetConnection() argument
954 Nhead->Seq = HTONL (Tcb->SndNxt); in TcpResetConnection()
955 Nhead->Ack = HTONL (Tcb->RcvNxt); in TcpResetConnection()
956 Nhead->SrcPort = Tcb->LocalEnd.Port; in TcpResetConnection()
957 Nhead->DstPort = Tcb->RemoteEnd.Port; in TcpResetConnection()
963 Nhead->Checksum = TcpChecksum (Nbuf, Tcb->HeadSum); in TcpResetConnection()
965 TcpSendIpPacket (Tcb, Nbuf, &Tcb->LocalEnd.Ip, &Tcb->RemoteEnd.Ip, Tcb->Sk->IpVersion); in TcpResetConnection()
986 TCP_CB *Tcb; in TcpInstallDevicePath() local
996 Tcb = TcpProto->TcpPcb; in TcpInstallDevicePath()
998 LocalPort = NTOHS (Tcb->LocalEnd.Port); in TcpInstallDevicePath()
999 RemotePort = NTOHS (Tcb->RemoteEnd.Port); in TcpInstallDevicePath()
1004 Tcb->LocalEnd.Ip.Addr[0], in TcpInstallDevicePath()
1006 Tcb->RemoteEnd.Ip.Addr[0], in TcpInstallDevicePath()
1009 Tcb->UseDefaultAddr in TcpInstallDevicePath()
1012 IP4_COPY_ADDRESS (&Ip4DPathNode.SubnetMask, &Tcb->SubnetMask); in TcpInstallDevicePath()
1019 &Tcb->LocalEnd.Ip.v6, in TcpInstallDevicePath()
1021 &Tcb->RemoteEnd.Ip.v6, in TcpInstallDevicePath()