tcp_private.h

/*NB_REVISION*/
 
/*NB_COPYRIGHT*/
 
#ifndef _NB_PVT_TCP_H
#define _NB_PVT_TCP_H
 
/**********************************************************************/
/*   Internal TCP Definitions                                         */
/**********************************************************************/
typedef struct
{
    beuint16_t srcPort;
    beuint16_t dstPort;
    beuint32_t SeqNumber;
    beuint32_t AckNumber;
    uint8_t header_len;
    uint8_t flags;
    beuint16_t window;
    uint16_t csum;   // Do not make big endian. csum is calculated as if native
    beuint16_t urgent;
    uint8_t DATA[];   // The data field is actually as long as the packet....
} TCPPKT;
 
typedef TCPPKT *PTCPPKT;
 
/**********************************************************************/
/*   Warning  WARNING  WARNING  If  you  use  these  functions on an  */
/*   uninitialized  buffer you will get bogus values for the pointer  */
/*   As  the header length field in the IP packet is not yet set up!  */
/*   Use the GetInitxxx functions instead             */
/**********************************************************************/
 
inline PTCPPKT GetTcpPkt(PIPPKT pIp)
{
    if (pIp == NULL) { return NULL; }
    if (pIp->bVerHdrLen == 0x45) { return (PTCPPKT)pIp->DATA; }
    return (PTCPPKT)(pIp->DATA + (((pIp->bVerHdrLen & 0XF) * 4) - 20));
}
 
inline PTCPPKT GetTcpPkt(PoolPtr p)
{
    return GetTcpPkt(GetIpPkt(p));
};
inline PTCPPKT GetTcpPkt(PEFRAME pFrame)
{
    return GetTcpPkt(GetIpPkt(pFrame));
};
 
inline PTCPPKT GetInitTcpPkt4(PIPPKT pIp)
{
    pIp->bVerHdrLen = 0x45;
    return (PTCPPKT)pIp->DATA;
}
 
inline PTCPPKT GetInitTcpPkt4(PoolPtr p)
{
    return GetInitTcpPkt4(GetIpPkt(p));
};
 
// Used by the IP.cpp process packet function
void process_tcp4(PoolPtr pp, PIPPKT pIP, uint16_t csum);
 
void DumpTcpDebug();
void EnableTcpDebug(uint16_t);
void DumpTcpPacket(PIPPKT pIP);
 
int CoreConnect(const IPADDR &ipAddress, uint16_t localPort, uint16_t remotePort, TickTimeout &timeout, const IPADDR &ifip, int ifn);
int NoBlockCoreConnect(const IPADDR &ipAddress, uint16_t localPort, uint16_t remotePort, const IPADDR &ifip, int ifn);
 
#ifdef IPV6
inline int CoreConnect4(IPADDR4 ipAddress, uint16_t localPort, uint16_t remotePort, TickTimeout &timeout, IPADDR4 ifip, int ifn)
{
    IPADDR ipl = ipAddress;
    IPADDR ipf;
    if (ifip.IsNull()) { ipf = IPADDR::NullIP(); }
    else
        ipf = ifip;
    return CoreConnect(ipl, localPort, remotePort, timeout, ipf, ifn);
}
 
inline int NoBlockCoreConnect4(IPADDR4 ipAddress, uint16_t localPort, uint16_t remotePort, IPADDR4 ifip, int ifn)
{
    IPADDR ipl = ipAddress;
    IPADDR ipf;
    if (ifip.IsNull()) { ipf = IPADDR::NullIP(); }
    else
        ipf = ifip;
    return NoBlockCoreConnect(ipl, localPort, remotePort, ipf, ifn);
}
#endif
 
int CoreListen(const IPADDR &addr, uint16_t port, int ifn, const IPADDR &localIpAddress, uint8_t maxpend = 5);
 
#ifdef IPV6
inline int CoreListen4(IPADDR4 ipAddress, uint16_t port, int ifn, const IPADDR4 localIpAddress, uint8_t maxpend)
{
    IPADDR ipl = ipAddress;
    IPADDR ipf;
    if (localIpAddress.IsNull()) { ipf = IPADDR4::NullIP(); }
    else
        ipf = localIpAddress;
    return CoreListen(ipl, port, ifn, ipf, maxpend);
}
#endif
 
void InitTCP();
 
#endif