rvtcp.c

h.248协议源码

/*****************************************************************************
Filename   : rvtcp.c
Description: Socket TCP interface definition.
******************************************************************************
                Copyright (c) 1999 RADVision Inc.
******************************************************************************
NOTICE:
This document contains information that is proprietary to RADVision Inc.
No part of this publication may be reproduced in any form whatsoever 
without written prior approval by RADVision Inc.

RADVision Inc. reserves the right to revise this publication and make 
changes without obligation to notify any person of such revisions or 
changes.
******************************************************************************
$Revision:$
$Date:$
$Author: S. Cipolli$
*****************************************************************************/

#include <string.h>
#include "rvplatform.h"
#include "rvlog.h"
#include "rvsocket_.h"
#include "rvsocket.h"


RvSocket* rvSocketConstructTcpActive(RvSocket* s, RvInetPort port, RvSocketAddr* addr)
{
    RvSocketAddr localAddr;

#if defined(RV_INET_IPV6)
    *s = rvSocketOpen_(AF_INET6, SOCK_STREAM, IPPROTO_TCP);
    {
        RvIpv6Addr ipv6;
        rvIpv6AddrConstruct(&ipv6, &RV_INET_ADDRANY);
        rvSocketAddrConstructIpv6(&localAddr, &ipv6, port);
    }
#else
    *s = rvSocketOpen_(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    {
        RvIpv4Addr ipv4;
        rvIpv4AddrConstruct(&ipv4, htonl(RV_INET_ADDRANY));
        rvSocketAddrConstructIpv4(&localAddr, &ipv4, port);
    }
#endif

    if(*s < 0)
        return NULL;

    /* If port not zero, bind socket */
    if (port)
        if (!rvSocketBind(s, &localAddr)) {
            rvSocketClose_(*s);
            return NULL;
        }

    if (rvSocketConnect_(*s, addr)) {
        rvSocketClose_(*s);
        return NULL;
    }

    return s;
}

RvSocket* rvSocketConstructTcpPassive(RvSocket* s, RvInetPort port) 
{
    RvSocketAddr localAddr;

    /* Initialize socket */
#if defined(RV_INET_IPV6)
    *s = rvSocketOpen_(AF_INET6, SOCK_STREAM, IPPROTO_TCP);
    {
        RvIpv6Addr ipv6;
        rvIpv6AddrConstruct(&ipv6, &RV_INET_ADDRANY);
        rvSocketAddrConstructIpv6(&localAddr, &ipv6, port);
    }
#else
    *s = rvSocketOpen_(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    {
        RvIpv4Addr ipv4;
        rvIpv4AddrConstruct(&ipv4, htonl(RV_INET_ADDRANY));
        rvSocketAddrConstructIpv4(&localAddr, &ipv4, port);
    }
#endif

    if(*s < 0)
        return NULL;
    
    /* If port not zero, bind socket */
#if !defined(RV_SOCKETS_NUCLEUS) /* nucleus listen won't work if port == 0 with no bind */
    if (port != 0)
#endif
        if (!rvSocketBind(s, &localAddr)) {
            rvSocketClose_(*s);
            return NULL;
        }

    if(rvSocketListen_(*s, 2)) {
        rvSocketClose_(*s);
        return NULL;
    }
    return s;
}

RvBool rvSocketGetRemoteAddr(RvSocket* s, RvSocketAddr* addr) 
{
    return rvSocketGetPeerName_(*s, addr);
}


RvBool rvSocketAccept(RvSocket* s, RvSocket* socket) 
{
    RvBool succeeded;
    RvSocketAddr address;

    rvSocketAddrConstruct(&address);
    succeeded = rvSocketAccept_(*s, socket, &address);
    rvSocketAddrDestruct(&address);
    
    return succeeded;
}

int rvSocketRecv(RvSocket* s, void* pkt, int len) 
{
    return rvSocketRecv_(*s, (char*)pkt, len, 0);
}

RvBool rvSocketSend(RvSocket* s, void* pkt, int len) 
{
    return (rvSocketSend_(*s, (char*)pkt, len, 0) == len);
}