xref: /trunk/main/sal/qa/osl/socket/osl_Socket.cxx (revision cf6516809c57e1bb0a940545cca99cdad54d4ce2)

/**************************************************************
 *
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 *
 *************************************************************/



// MARKER(update_precomp.py): autogen include statement, do not remove
#include "precompiled_sal.hxx"

/**  test coder preface:
    1. the BSD socket function will meet "unresolved external symbol error" on Windows platform
    if you are not including ws2_32.lib in makefile.mk,  the including format will be like this:

    .IF "$(GUI)" == "WNT"
    SHL1STDLIBS +=  $(SOLARLIBDIR)$/cppunit.lib
    SHL1STDLIBS +=  ws2_32.lib
    .ENDIF

    likewise on Solaris platform.
    .IF "$(GUI)" == "UNX"
    SHL1STDLIBS+=$(SOLARLIBDIR)$/libcppunit$(DLLPOSTFIX).a
    SHL1STDLIBS += -lsocket -ldl -lnsl
    .ENDIF

    2. since the Socket implementation of osl is only IPv4 oriented, our test are mainly focus on IPv4
    category.

    3. some fragment of Socket source implementation are lack of comment so it is hard for testers
    guess what the exact functionality or usage of a member.  Hope the Socket section's comment
    will be added.

    4. following functions are declared but not implemented:
    inline sal_Bool SAL_CALL operator== (const SocketAddr & Addr) const;
 */


//------------------------------------------------------------------------
// include files
//------------------------------------------------------------------------

#ifndef _OSL_SOCKET_CONST_H_
#include <osl_Socket_Const_orig.h>
#endif

#include <osl/signal.h>
#include "gtest/gtest.h"

using namespace osl;
using namespace rtl;

//------------------------------------------------------------------------
// helper functions
//------------------------------------------------------------------------

/** compare two OUString.
*/
inline sal_Bool compareUString( const ::rtl::OUString & ustr1, const ::rtl::OUString & ustr2 )
{
    sal_Bool bOk = ustr1.equalsIgnoreAsciiCase( ustr2 );

    return bOk;
}

/** compare a OUString and an ASCII string.
*/
inline sal_Bool compareUString( const ::rtl::OUString & ustr, const sal_Char *astr )
{
    ::rtl::OUString ustr2 = rtl::OUString::createFromAscii( astr );
    sal_Bool bOk = ustr.equalsIgnoreAsciiCase( ustr2 );

    return bOk;
}

/** compare two socket address.
*/
inline sal_Bool compareSocketAddr( const ::osl::SocketAddr & addr1 , const ::osl::SocketAddr & addr2  )
{
    return ( ( sal_True == compareUString( addr1.getHostname( 0 ), addr2.getHostname( 0 ) ) ) && ( addr2.getPort( ) == addr2.getPort( ) ) );
}

inline char * oustring2char( const ::rtl::OUString & str )
{
    rtl::OString aString;
    aString = ::rtl::OUStringToOString( str, RTL_TEXTENCODING_ASCII_US );
    return (char *)aString.getStr( );
}

/** print a UNI_CODE String. And also print some comments of the string.
*/
inline void printUString( const ::rtl::OUString & str, const sal_Char * msg = "" )
{
    printf("#%s #printUString_u# ", msg );
    printf("%s\n", oustring2char( str ) );
}

/** get the local host name.
    mindy: gethostbyname( "localhost" ), on Linux, it returns the hostname in /etc/hosts + domain name,
    if no entry in /etc/hosts, it returns "localhost" + domain name
*/
inline ::rtl::OUString getHost( void )
{
    struct hostent *hptr;

    hptr = gethostbyname( "localhost" );
    EXPECT_TRUE(hptr != NULL) << "#In getHostname function, error on gethostbyname()";
    ::rtl::OUString aUString = ::rtl::OUString::createFromAscii( (const sal_Char *) hptr->h_name );

    return aUString;
}

/** get the full host name of the current processor, such as "aegean.prc.sun.com" --mindyliu
*/
inline ::rtl::OUString getThisHostname( void )
{
    ::rtl::OUString aUString;
#ifdef WNT
    struct hostent *hptr;
    hptr = gethostbyname( "localhost" );
    EXPECT_TRUE(hptr != NULL) << "#In getHostname function, error on gethostbyname()";
    aUString = ::rtl::OUString::createFromAscii( (const sal_Char *) hptr->h_name );
#else
    char hostname[255];
    EXPECT_TRUE(gethostname(hostname, 255) == 0) << "#Error: gethostname failed.";

    struct hostent *hptr;
    //first search /ets/hosts, then search from dns
    hptr = gethostbyname( hostname);
    if ( hptr != NULL )
    {
        strcpy( hostname, hptr->h_name );
    }

    printf("hostname is %s \n", hostname );
    aUString = ::rtl::OUString::createFromAscii( (const sal_Char *) hostname );
#endif
    return aUString;
}

/** get IP by name, search /etc/hosts first, then search from dns, fail return OUString("")
*/
inline ::rtl::OUString getIPbyName( rtl::OString const& str_name )
{
    ::rtl::OUString aUString;
    struct hostent *hptr;
    //first search /ets/hosts, then search from dns
    hptr = gethostbyname( str_name.getStr());
    if ( hptr != NULL )
    {
        struct in_addr ** addrptr;
        addrptr = (struct in_addr **) hptr->h_addr_list ;
        //if there are more than one IPs on the same machine, we select one
        for (; *addrptr; addrptr++)
        {
            printf("#Local IP Address: %s\n", inet_ntoa(**addrptr));
            aUString = ::rtl::OUString::createFromAscii( (sal_Char *) (inet_ntoa(**addrptr)) );
        }
    }
    return aUString;
}

/** get local ethernet IP
*/
inline ::rtl::OUString getLocalIP( )
{
    char hostname[255];
    gethostname(hostname, 255);

        return getIPbyName( hostname );
}

/** construct error message
*/
inline ::rtl::OUString outputError( const ::rtl::OUString & returnVal, const ::rtl::OUString & rightVal, const sal_Char * msg = "")
{
    ::rtl::OUString aUString;
    if ( returnVal.equals( rightVal ) )
        return aUString;
    aUString += ::rtl::OUString::createFromAscii(msg);
    aUString += ::rtl::OUString::createFromAscii(": the returned value is '");
    aUString += returnVal;
    aUString += ::rtl::OUString::createFromAscii("', but the value should be '");
    aUString += rightVal;
    aUString += ::rtl::OUString::createFromAscii("'.");
    return aUString;
}

/** wait _nSec seconds.
*/
void thread_sleep( sal_Int32 _nSec )
{
    /// print statement in thread process must use fflush() to force display.
    printf("# wait %d seconds. ", _nSec );
    fflush(stdout);

#ifdef WNT                               //Windows
    Sleep( _nSec * 100 );
#endif
#if ( defined UNX ) || ( defined OS2 )   //Unix
    usleep(_nSec * 100000);
#endif
    printf("# done\n" );
}

/** print Boolean value.
*/
inline void printBool( sal_Bool bOk )
{
    printf("#printBool# " );
    ( sal_True == bOk ) ? printf("YES!\n" ): printf("NO!\n" );
}

/** print content of a ByteSequence.
*/
inline void printByteSequence_IP( const ::rtl::ByteSequence & bsByteSeq, sal_Int32 nLen )
{
    printf("#ByteSequence is: " );
    for ( int i = 0; i < nLen; i++ ){
        if ( bsByteSeq[i] < 0 )
            printf("%d ",  256 + bsByteSeq[i] );
        else
            printf("%d ",  bsByteSeq[i] );
    }
    printf(" .\n" );
}

/** convert an IP which is stored as a UString format to a ByteSequence array for later use.
*/
inline ::rtl::ByteSequence UStringIPToByteSequence( ::rtl::OUString aUStr )
{

    rtl::OString aString = ::rtl::OUStringToOString( aUStr, RTL_TEXTENCODING_ASCII_US );
    const sal_Char *pChar = aString.getStr( ) ;
    sal_Char tmpBuffer[4];
    sal_Int32 nCharCounter = 0;
    ::rtl::ByteSequence bsByteSequence( IP_VER );
    sal_Int32 nByteSeqCounter = 0;

    for ( int i = 0; i < aString.getLength( ) + 1 ; i++ )
    {
        if ( ( *pChar != '.' ) && ( i !=aString.getLength( ) ) )
            tmpBuffer[nCharCounter++] = *pChar;
        else
        {
            tmpBuffer[nCharCounter] = '\0';
            nCharCounter = 0;
            bsByteSequence[nByteSeqCounter++] = static_cast<sal_Int8>( atoi( tmpBuffer ) );
        }
        pChar++;
    }
    return bsByteSequence;
}

/** print a socket result name.
*/
inline void printSocketResult( oslSocketResult eResult )
{
    printf("#printSocketResult# " );
    if (!eResult)
    switch (eResult)
    {
        case osl_Socket_Ok:
            printf("client connected\n");
            break;
        case osl_Socket_Error:
            printf("got an error ... exiting\r\n\r\n" );
            break;
        case osl_Socket_TimedOut:
            printf("timeout\n");
            break;

    case osl_Socket_FORCE_EQUAL_SIZE:
        printf("FORCE EQUAL SIZE\n");
        break;
    case osl_Socket_InProgress:
        printf("In Progress\n");
        break;
    case osl_Socket_Interrupted:
        printf("Interrupted\n");
        break;
    }
}

/** Client Socket Thread, served as a temp little client to communicate with server.
*/
class ClientSocketThread : public Thread
{
protected:
    oslThreadIdentifier m_id;
    ::osl::SocketAddr saTargetSocketAddr;
    ::osl::ConnectorSocket csConnectorSocket;

    void SAL_CALL run( )
    {
        TimeValue *pTimeout;
        pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
        pTimeout->Seconds = 5;
        pTimeout->Nanosec = 0;

        /// if the thread should terminate, schedule return false
        //while ( schedule( ) == sal_True )
        //{
            if ( osl_Socket_Ok == csConnectorSocket.connect( saTargetSocketAddr, pTimeout ))
            {
                csConnectorSocket.send( pTestString1, 11 ); // "test socket"
                csConnectorSocket.send( pTestString2, 10);
            }
            else
                printf("# ClientSocketThread: connect failed! \n");
         //     terminate();
        //}
        csConnectorSocket.close();
        free( pTimeout );
    }

    void SAL_CALL onTerminated( )
    {
        //printf("# normally terminate this thread %d!\n",  m_id );
    }

public:
    ClientSocketThread( ):
        saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT9 ),
        csConnectorSocket( )
    {
        m_id = getIdentifier( );
        //printf("# successfully creat this client thread %d!\n",  m_id );
    }

    ~ClientSocketThread( )
    {
        if ( isRunning( ) )
            printf("# error: client thread not terminated.\n" );
    }

};


/** Server Socket Thread, served as a temp little server to communicate with client.
*/
class ServerSocketThread : public Thread
{
protected:
    oslThreadIdentifier m_id;

    void SAL_CALL run( )
    {
        ::osl::AcceptorSocket asAcceptorSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT9 );
        ::osl::StreamSocket ssStreamConnection;

        //if has not set this option, socket addr can not be binded in some time(maybe 2 minutes) by another socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //integer not sal_Bool : sal_True);
        while ( schedule( ) == sal_True )
        {
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        if  ( sal_True != bOK1 )
        {
            printf("# ServerSocketThread: AcceptorSocket bind address failed.\n" ) ;
            break;
        }
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        if  ( sal_True != bOK2 )
        {
            printf("# ServerSocketThread: AcceptorSocket listen address failed.\n" ) ;
            break;
        }

        asAcceptorSocket.enableNonBlockingMode( sal_False );

        oslSocketResult eResult = asAcceptorSocket.acceptConnection( ssStreamConnection );
        if (eResult != osl_Socket_Ok )
        {
            printf("ServerSocketThread: acceptConnection failed! \n");
            break;
        }
            sal_Int32 nReadNumber1 = ssStreamConnection.recv( pReadBuffer, 11 );
            sal_Int32 nReadNumber2 = ssStreamConnection.recv( pReadBuffer + nReadNumber1, 11 );
            pReadBuffer[nReadNumber1 + nReadNumber2] = '\0';
            //printf("# read buffer content: %s\n", pReadBuffer );
            break;
        }
        ssStreamConnection.close();
        asAcceptorSocket.close();

    }

    void SAL_CALL onTerminated( )
    {
        //printf("# normally terminate this server thread %d!\n",  m_id );
    }

public:
    // public to check if data transmission is OK
    sal_Char pReadBuffer[30];
    ServerSocketThread( )
    {
        m_id = getIdentifier( );
        //printf("# successfully create this server thread %d!\n",  m_id );
    }

    ~ServerSocketThread( )
    {
        if ( isRunning( ) )
            printf("# error: server thread not terminated.\n" );
    }
};

// -----------------------------------------------------------------------------
// Helper functions, to create buffers, check buffers
class ValueCheckProvider
{
    bool m_bFoundFailure;
    char *m_pBuffer;
    sal_Int32 m_nBufferSize;

public:
    ValueCheckProvider()
            :
             m_bFoundFailure(false),
            m_pBuffer(NULL),
             m_nBufferSize(0)
        {
        }

    bool       isFailure() {return m_bFoundFailure;}

    const char* getBuffer() {return m_pBuffer;}
    char*       getWriteBuffer() {return m_pBuffer;}

    sal_Int32   getBufferSize() {return m_nBufferSize;}

    bool checkValues(sal_Int32 _nLength, int _nValue)
        {
            m_bFoundFailure = false;
            for(sal_Int32 i=0;i<_nLength;i++)
            {
                if (m_pBuffer[i] != _nValue)
                {
                    m_bFoundFailure = true;
                }
            }
            return m_bFoundFailure;
        }

    void createBuffer(sal_Int32 _nLength, int _nValue)
        {
            m_nBufferSize = _nLength;
            m_pBuffer = (char*) malloc(m_nBufferSize);
            if (m_pBuffer)
            {
                memset(m_pBuffer, _nValue, m_nBufferSize);
            }
        }

    void freeBuffer()
        {
            if (m_pBuffer) free(m_pBuffer);
        }

};

// -----------------------------------------------------------------------------
/** Client Socket Thread, served as a temp little client to communicate with server.
*/

class ReadSocketThread : public Thread
{
    int m_nValue;
    ValueCheckProvider m_aValues;

protected:
    oslThreadIdentifier m_id;
    ::osl::SocketAddr saTargetSocketAddr;
    ::osl::ConnectorSocket csConnectorSocket;

    void SAL_CALL run( )
    {
        TimeValue *pTimeout;
        pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
        pTimeout->Seconds = 5;
        pTimeout->Nanosec = 0;

        /// if the thread should terminate, schedule return false
        //while ( schedule( ) == sal_True )
        //{
            if ( osl_Socket_Ok == csConnectorSocket.connect( saTargetSocketAddr, pTimeout ))
            {
                sal_Int32 nReadCount = csConnectorSocket.read( m_aValues.getWriteBuffer(), m_aValues.getBufferSize() );
                m_aValues.checkValues(nReadCount, m_nValue);
            }
            else
            {
            printf("# ReadSocketThread: connect failed! \n");
            }
        //      terminate();
        //}
        //remove this line for deadlock on solaris( margritte.germany )
        csConnectorSocket.close();
        free( pTimeout );
    }

    void SAL_CALL onTerminated( )
    {
        //printf("# normally terminate this thread %d!\n",  m_id );
    }

public:
    sal_Int32 getCount() {return m_aValues.getBufferSize();}
    bool       isOk() {return m_aValues.isFailure() == true ? false : true;}

    ReadSocketThread(sal_Int32 _nBufferSize, int _nValue )
            :
        m_nValue( _nValue ),
        saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT10 ),
        csConnectorSocket( )
    {
        m_id = getIdentifier( );
        //printf("# successfully creat this client thread %d!\n",  m_id );
        m_aValues.createBuffer(_nBufferSize, 0);
    }

    ~ReadSocketThread( )
        {
            if ( isRunning( ) )
                printf("# error: client thread not terminated.\n" );
            m_aValues.freeBuffer();
        }

};

/** Server Socket Thread, write a file which is large
*/
class WriteSocketThread : public Thread
{
    ValueCheckProvider m_aValues;

protected:
    oslThreadIdentifier m_id;

    void SAL_CALL run( )
    {
        ::osl::AcceptorSocket asAcceptorSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT10 );
        ::osl::StreamSocket ssStreamConnection;

        //if has not set this option, socket addr can not be binded in some time(maybe 2 minutes) by another socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 );    //sal_True);

        /// if the thread should terminate, schedule return false
        while ( schedule( ) == sal_True )
        {
            sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
            if  ( sal_True != bOK1 )
            {
                printf("# WriteSocketThread: AcceptorSocket bind address failed. \n" ) ;
                break;
            }
            sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
            if  ( sal_True != bOK2 )
            {
                printf("# WriteSocketThread: AcceptorSocket listen address failed. \n" ) ;
                break;
            }
            // blocking mode, if read/recv failed, block until success
            asAcceptorSocket.enableNonBlockingMode( sal_False);

            oslSocketResult eResult = asAcceptorSocket.acceptConnection( ssStreamConnection );
            if (eResult != osl_Socket_Ok )
            {
                printf("WriteSocketThread: acceptConnection failed! \n");
                break;
            }

            ssStreamConnection.write( m_aValues.getBuffer(), m_aValues.getBufferSize() );
            break;
        }
        ssStreamConnection.close();
        asAcceptorSocket.close();
    }

    void SAL_CALL onTerminated( )
    {
        //printf("# normally terminate this server thread %d!\n",  m_id );
    }

public:
    // public to check if data transmission is OK
    WriteSocketThread(sal_Int32 _nBufferSize, int _nValue )
    {
        m_id = getIdentifier( );
        //printf("# successfully create this server thread %d!\n",  m_id );

        m_aValues.createBuffer(_nBufferSize, _nValue);
    }

    ~WriteSocketThread( )
        {
            if ( isRunning( ) )
                printf("# error: server thread not terminated.\n" );
            m_aValues.freeBuffer();
        }

};

// -----------------------------------------------------------------------------
// just used to test socket::close() when accepting
class AcceptorThread : public Thread
{
    ::osl::AcceptorSocket asAcceptorSocket;
    ::rtl::OUString aHostIP;
    sal_Bool bOK;
protected:
    void SAL_CALL run( )
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIP, IP_PORT_MYPORT9 );
        ::osl::StreamSocket ssStreamConnection;

        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //integer not sal_Bool : sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        if  ( sal_True != bOK1 )
        {
            printf("# AcceptorSocket bind address failed.\n" ) ;
            return;
        }
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        if  ( sal_True != bOK2 )
        {
            printf("# AcceptorSocket listen address failed.\n" ) ;
            return;
        }

        asAcceptorSocket.enableNonBlockingMode( sal_False );

        oslSocketResult eResult = asAcceptorSocket.acceptConnection( ssStreamConnection );
        if (eResult != osl_Socket_Ok )
        {
            bOK = sal_True;
            printf("AcceptorThread: acceptConnection failed! \n");
        }
    }
public:
    AcceptorThread(::osl::AcceptorSocket & asSocket, ::rtl::OUString & aBindIP )
        : asAcceptorSocket( asSocket ), aHostIP( aBindIP )
    {
        bOK = sal_False;
    }

    sal_Bool isOK() { return bOK; }

    ~AcceptorThread( )
    {
        if ( isRunning( ) )
        {
            asAcceptorSocket.shutdown();
            printf("# error: Acceptor thread not terminated.\n" );
        }
    }
};

class CloseSocketThread : public Thread
{
    ::osl::Socket m_sSocket;
protected:
    void SAL_CALL run( )
    {
        thread_sleep( 1 );
        m_sSocket.close( );
    }
public:
    CloseSocketThread(::osl::Socket & sSocket )
        : m_sSocket( sSocket )
    {
    }

    ~CloseSocketThread( )
    {
        if ( isRunning( ) )
        {
            printf("# error: CloseSocketThread not terminated.\n" );
        }
    }
};

//------------------------------------------------------------------------
// tests cases begins here
//------------------------------------------------------------------------

namespace osl_SocketAddr
{

    /** testing the methods:
        inline SocketAddr();
        inline SocketAddr(const SocketAddr& Addr);
        inline SocketAddr(const oslSocketAddr , __osl_socket_NoCopy nocopy );
        inline SocketAddr(oslSocketAddr Addr);
        inline SocketAddr( const ::rtl::OUString& strAddrOrHostName, sal_Int32 nPort );
    */

    class SocketAddrCtors : public ::testing::Test
    {
    public:
    }; // class ctors

    TEST_F(SocketAddrCtors, ctors_none)
    {
        /// SocketAddr constructor.
        ::osl::SocketAddr saSocketAddr;

        // oslSocketResult aResult;
        // rtl::OUString suHost = saSocketAddr.getLocalHostname( &aResult);

        // rtl::OUString suHost2 = getThisHostname();

        ASSERT_TRUE(sal_True == saSocketAddr.is( )) << "test for none parameter constructor function: check if the socket address was created successfully";
    }

    TEST_F(SocketAddrCtors, ctors_none_000)
    {
        /// SocketAddr constructor.
        ::osl::SocketAddr saSocketAddr;

        oslSocketResult aResult;
        rtl::OUString suHost = saSocketAddr.getLocalHostname( &aResult);
        rtl::OUString suHost2 = getThisHostname();

        sal_Bool bOk = compareUString(suHost, suHost2);

        rtl::OUString suError = rtl::OUString::createFromAscii("Host names should be the same. From SocketAddr.getLocalHostname() it is'");
        suError += suHost;
        suError += rtl::OUString::createFromAscii("', from getThisHostname() it is '");
        suError += suHost2;
        suError += rtl::OUString::createFromAscii("'.");

        ASSERT_TRUE(sal_True == bOk) << suError.pData;
    }

    TEST_F(SocketAddrCtors, ctors_copy)
    {
        /// SocketAddr copy constructor.
        ::osl::SocketAddr saSocketAddr( aHostName1, IP_PORT_HTTP1 );
        ::osl::SocketAddr saCopySocketAddr( saSocketAddr );

        sal_Int32 nPort = saCopySocketAddr.getPort( );

        ASSERT_TRUE(( sal_True == saCopySocketAddr.is( ) ) && ( nPort == IP_PORT_HTTP1 )) << "test for SocketAddr copy constructor function: copy constructor, do an action of copy construction then check the port with original set.";
    }

    TEST_F(SocketAddrCtors, ctors_copy_no_001)
    {
#if 0
        ::osl::SocketAddr saSocketAddr( aHostName1, IP_PORT_HTTP1 );
        oslSocketAddr psaOSLSocketAddr = saSocketAddr.getHandle( );

        ::osl::SocketAddr saSocketAddrCopy( psaOSLSocketAddr, SAL_NO_COPY );
        saSocketAddrCopy.setPort( IP_PORT_HTTP2 );

        ASSERT_TRUE(saSocketAddr.getPort( ) == IP_PORT_HTTP2) << "test for SocketAddr no copy constructor function: do a no copy constructor on a given SocketAddr instance, modify the new instance's port, check the original one.";
#endif
        ::osl::SocketAddr* pSocketAddr = new ::osl::SocketAddr( aHostName1, IP_PORT_HTTP1 );
        ASSERT_TRUE(pSocketAddr != NULL) << "check for new SocketAddr";

        oslSocketAddr psaOSLSocketAddr = pSocketAddr->getHandle( );

        ::osl::SocketAddr* pSocketAddrCopy = new ::osl::SocketAddr( psaOSLSocketAddr, SAL_NO_COPY );

        pSocketAddrCopy->setPort( IP_PORT_HTTP2 );
        ASSERT_TRUE(pSocketAddr->getPort( ) == IP_PORT_HTTP2) << "test for SocketAddr no copy constructor function: do a no copy constructor on a given SocketAddr instance, modify the new instance's port, check the original one.";

        delete pSocketAddrCopy;
        // LLA: don't do this also:           delete pSocketAddr;
    }

    TEST_F(SocketAddrCtors, ctors_copy_no_002)
    {
        ::osl::SocketAddr* pSocketAddr = new ::osl::SocketAddr( aHostName1, IP_PORT_HTTP1 );
            ASSERT_TRUE(pSocketAddr != NULL) << "check for new SocketAddr";
            oslSocketAddr psaOSLSocketAddr = pSocketAddr->getHandle( );
            ::osl::SocketAddr* pSocketAddrCopy = new ::osl::SocketAddr( psaOSLSocketAddr, SAL_NO_COPY );

            ASSERT_TRUE(pSocketAddr->getHandle( ) ==  pSocketAddrCopy->getHandle( )) << "test for SocketAddr no copy constructor function: do a no copy constructor on a given SocketAddr instance, modify the new instance's port, check the original one.";

            delete pSocketAddrCopy;
    }

    TEST_F(SocketAddrCtors, ctors_copy_handle_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostName1, IP_PORT_HTTP1 );
        ::osl::SocketAddr saSocketAddrCopy( saSocketAddr.getHandle( ) );

        ASSERT_TRUE(saSocketAddrCopy.getPort( ) == IP_PORT_HTTP1) << "test for SocketAddr copy handle constructor function: copy another Socket's handle, get its port to check copy effect.";
    }

    TEST_F(SocketAddrCtors, ctors_copy_handle_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostName1, IP_PORT_HTTP1 );
        ::osl::SocketAddr saSocketAddrCopy( saSocketAddr.getHandle( ) );
        saSocketAddrCopy.setPort( IP_PORT_HTTP2 );

        ASSERT_TRUE(saSocketAddr.getPort( ) != IP_PORT_HTTP2) << "test for SocketAddr copy handle constructor function: copy another Socket's handle, the original one should not be changed.";
    }

    TEST_F(SocketAddrCtors, ctors_hostname_port_001)
    {
        /// tcpip-specif constructor.
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP );
        printUString(saSocketAddr.getHostname( ), "ctors_hostname_port_001:getHostname");

        ASSERT_TRUE(saSocketAddr.is( ) == sal_True &&
                                ( saSocketAddr.getPort( ) == IP_PORT_FTP )/*&&
                                ( sal_True == compareUString( saSocketAddr.getHostname( ), aHostName1 ) ) */) << "test for SocketAddr tcpip specific constructor function: do a constructor using tcpip spec, check the result.";
    }

    //same as is_002
    TEST_F(SocketAddrCtors, ctors_hostname_port_002)
    {
        /// tcpip-specif constructor.
        ::osl::SocketAddr saSocketAddr( aHostIpInval1, IP_PORT_MYPORT2 );

        ASSERT_TRUE(sal_False == saSocketAddr.is( )) << "test for SocketAddr tcpip specific constructor function: using an invalid IP address, the socketaddr ctors should fail";
    }

    /** testing the method:
        inline sal_Bool is() const;
    */

    class is : public ::testing::Test
    {
    public:
    }; // class is

    TEST_F(is, is_001)
    {
        ::osl::SocketAddr saSocketAddr;

        ASSERT_TRUE(sal_True == saSocketAddr.is( )) << "test for is() function: create an unknown type socket, it should be True when call is.";
    }
    // refer to setPort_003()
    TEST_F(is, is_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_INVAL );

        ASSERT_TRUE(sal_True == saSocketAddr.is( )) << "test for is() function: create a tcp-ip socket using invalid port number";
    }

    TEST_F(is, is_003)
    {
        ::osl::SocketAddr saSocketAddr( aHostIpInval1, IP_PORT_MYPORT );

        ASSERT_TRUE(sal_True != saSocketAddr.is( )) << "test for is() function: create a tcp-ip socket using invalid Ip number";
    }

    /** testing the method:
        inline ::rtl::OUString SAL_CALL getHostname( oslSocketResult *pResult = 0 ) const;
    */

    class getHostname : public ::testing::Test
    {
    public:
        void SetUp()
        {
        }

        void TearDown()
        {
        }
    }; // class getHostname

    TEST_F(getHostname, getHostname_000)
        {
            ::osl::SocketAddr saSocketAddr( aHostIp4, IP_PORT_FTP );

        }

    /** it will search the Ip in current machine's /etc/hosts at first, if find, then return the
        mapped hostname, otherwise, it will search via DNS server, and often return hostname+ Domain name
        like "sceri.PRC.Sun.COM"
        The process is same as Socket::getLocalHost(), but getLocalHost can only return hostname of the current machine.
    */
    TEST_F(getHostname, getHostname_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp4, IP_PORT_FTP );
        rtl::OUString suResult = saSocketAddr.getHostname( 0 );
        rtl::OUString suError = outputError(suResult, aHostName4, "test for getHostname(0)");
        sal_Bool bOK = compareUString( suResult, aHostName4 );
        // search the returned hostname in /etc/hosts, if find, and the IP in the row is same as IP
        // in the Addr, it's right also.
        if ( bOK == sal_False)
        {
            if ( compareUString( getIPbyName( oustring2char( suResult ) ), aHostIp4 ) == sal_True )
                bOK = sal_True;
        }
        ASSERT_TRUE(sal_True == bOK) << suError.pData;
    }

    // LLA: now we have to control, if this behaviour is right.
    // LLA: this function does not work in company (Linux, Windows) but at home
    TEST_F(getHostname, getHostname_002)
    {
        rtl::OUString suHostname = rtl::OUString::createFromAscii("cn-1.germany.sun.com");
        rtl::OUString aHostIP    = getIPbyName( oustring2char( suHostname ) );

        ::osl::SocketAddr saSocketAddr( aHostName1, IP_PORT_FTP );
        sal_Bool bOK = saSocketAddr.setHostname( suHostname );
        ASSERT_TRUE(sal_True == bOK) << "#SocketAddr.setHostname failed";
        oslSocketResult aResult;
        rtl::OUString suResult = saSocketAddr.getHostname( &aResult );
        ASSERT_TRUE(aResult == osl_Socket_Ok) << "SocketAddr.getHostname failed.";

        rtl::OUString suError = outputError(suResult, suHostname, "test for getHostname(0)");
        bOK = compareUString( suResult, suHostname );
        if ( bOK == sal_False)
        {
            rtl::OString aString = ::rtl::OUStringToOString( suResult, RTL_TEXTENCODING_ASCII_US );
            if ( compareUString( getIPbyName( aString) , aHostIp6 ) == sal_True )
            {
                bOK = sal_True;
            }
        }

        ASSERT_TRUE(sal_True == bOK) << suError.pData;
    }

    /** testing the method:
        inline sal_Int32 SAL_CALL getPort() const;
    */

    class getPort : public ::testing::Test
    {
    public:
    }; // class getPort

    TEST_F(getPort, getPort_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP );

        ASSERT_TRUE(IP_PORT_FTP == saSocketAddr.getPort( )) << "test for getPort() function: get a normal port number.";
    }

    TEST_F(getPort, getPort_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp2, IP_PORT_INVAL );

        //printf("#getPort_002: Port number is %d \n", saSocketAddr.getPort( ));

        ASSERT_TRUE(saSocketAddr.getPort( )>=1 && saSocketAddr.getPort( ) <= 65535) << "test for getPort( ) function: give an invalid port to a SocketAddr, get the port to see if it can detect. it did not pass in (W32).";
    }
    //two cases will return OSL_INVALID_PORT: 1. not valid SocketAddr
    //2. SocketAddr family is not osl_Socket_FamilyInet, but case 2 could not be constructed
    TEST_F(getPort, getPort_003)
    {
        ::osl::SocketAddr saSocketAddr( aHostIpInval1, IP_PORT_MYPORT );

        ASSERT_TRUE(saSocketAddr.getPort( ) == OSL_INVALID_PORT) << "test for getPort( ) function: give an invalid IP to a SocketAddr, get the port to see returned value. ";
    }

    /** testing the method:
        inline sal_Bool SAL_CALL setPort( sal_Int32 nPort );
        rfc1413.txt: TCP port numbers are from 1-65535
        rfc1700.txt: 0/tcp    Reserved ;  0/udp    Reserved
    */

    class setPort : public ::testing::Test
    {
    public:
    }; // class setPort

    TEST_F(setPort, setPort_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP );
        sal_Bool bOK = saSocketAddr.setPort( IP_PORT_TELNET );

        ASSERT_TRUE(( sal_True == bOK ) &&
                                ( IP_PORT_TELNET == saSocketAddr.getPort( ) )) << "test for setPort() function: modify a port number setting, and check it.";
    }

    /** 0 to 1024 is known as the reserved port range (traditionally only root can assign programs to ports in
        this range) and the ephemeral port range from 1025 to 65535.
        As many of you programmers will know, when you specify the source port of 0 when you connect to a host,
        the OS automatically reassigns the port number to high numbered ephemeral port. The same happens if you
        try to bind a listening socket to port 0.
        http://www.securiteam.com/securityreviews/5XP0Q2AAKS.html
        another: http://www.muq.org/~cynbe/muq/mufref_564.html
    */
    TEST_F(setPort, setPort_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP );
        sal_Bool bOK = saSocketAddr.setPort( IP_PORT_ZERO );

        oslSocket sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);
        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 );//sal_True);
        sal_Bool bOK1 = sSocket.bind( saSocketAddr );
        ASSERT_TRUE(bOK1 == sal_True) << "bind SocketAddr failed";

        sal_Int32 newPort = sSocket.getLocalPort();
        //printf("#new port is %d\n", newPort );

        ASSERT_TRUE(( 1024 <= newPort ) && ( 65535 >= newPort ) && ( bOK == sal_True )) << "test for setPort() function: port number should be in 1 ~ 65535, set port 0, it should be converted to a port number between 1024~65535.";

    }

    TEST_F(setPort, setPort_003)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP);
        sal_Bool bOK = saSocketAddr.setPort( IP_PORT_INVAL );
        //on Linux, getPort return 34463
        //printf("#Port number is %d \n", saSocketAddr.getPort( ));

        ASSERT_TRUE(( ( 1 <= saSocketAddr.getPort( ) ) && ( 65535 >= saSocketAddr.getPort( ) ) &&( bOK == sal_True ) ) ||
                                 bOK == sal_False) << "test for setPort( ) function: set an address with invalid port. it should return error or convert it to a valid port.";
    }

    /* this is not a inet-addr => can't set port */
    TEST_F(setPort, setPort_004)
    {
        ::osl::SocketAddr saSocketAddr( aHostIpInval1, IP_PORT_FTP);
        sal_Bool bOK = saSocketAddr.setPort( IP_PORT_MYPORT );

        ASSERT_TRUE(bOK == sal_False) << "test for setPort( ) function: set an invalid address with valid port. it should return error.";
    }

    /**  tester comment:

        In the following two functions, it use ::rtl::ByteSequence as an intermediate storage for address,
        the ByteSequence object can hold sal_Int8 arrays, which is raged [-127, 127], in case of IP addr
        that is greater than 127, say 129.158.217.202, it will stored as -127, -98, -39, -54,  it is unique
        in the range of sal_Int8, but lack of readability.
        so may be a sal_uInt8 array is better.
    */


    /** testing the method:
        inline sal_Bool SAL_CALL setAddr( const ::rtl::ByteSequence & address );
    */

    class setAddr : public ::testing::Test
    {
    public:
    }; // class setAddr

    TEST_F(setAddr, setAddr_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp2, IP_PORT_FTP );
        saSocketAddr.setAddr( UStringIPToByteSequence( aHostIp1 ) );
        ::rtl::ByteSequence bsSocketAddr = saSocketAddr.getAddr( 0 );
        sal_Bool bOK = sal_False;

         if ( ( bsSocketAddr[0] == 127 ) && ( bsSocketAddr[1] == 0 ) && ( bsSocketAddr[2] == 0 ) && ( bsSocketAddr[3] == 1 ) )
            bOK = sal_True;

        ASSERT_TRUE(sal_True == bOK) << "test for setAddr() function: construct Addr with  \"129.158.217.202\", set it to \"127.0.0.1\",  and check the correctness ";
    }

    /** testing the method:
        inline ::rtl::ByteSequence  SAL_CALL getAddr( oslSocketResult *pResult = 0 ) const;
    */

    class getAddr : public ::testing::Test
    {
    public:
    }; // class getAddr

    TEST_F(getAddr, getAddr_001)
    {
        oslSocketResult SocketResult;
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_FTP );
        ::rtl::ByteSequence bsSocketAddr = saSocketAddr.getAddr( &SocketResult );

        sal_Bool bOK = sal_False;

        if ( ( osl_Socket_Ok == SocketResult ) &&( bsSocketAddr[0] == 127 ) && ( bsSocketAddr[1] == 0 ) &&( bsSocketAddr[2] == 0 ) && ( bsSocketAddr[3] == 1 ) )
            bOK = sal_True;

        ASSERT_TRUE(sal_True == bOK && SocketResult == osl_Socket_Ok) << "test for getAddr() function: construct a socketaddr with IP assigned, get the address to check correctness.Caught unknown exception on (Win32)";
    }

    /** testing the methods:
        inline SocketAddr & SAL_CALL operator= (oslSocketAddr Addr);
        inline SocketAddr & SAL_CALL operator= (const SocketAddr& Addr);
        inline SocketAddr & SAL_CALL assign( oslSocketAddr Addr, __osl_socket_NoCopy nocopy );
        inline sal_Bool SAL_CALL operator== (oslSocketAddr Addr) const;
        inline sal_Bool SAL_CALL operator== (const SocketAddr & Addr) const;    /// not implemented.
    */

    class operator_equal : public ::testing::Test
    {
    public:
    }; // class operator_equal

    TEST_F(operator_equal, operator_equal_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_TELNET);
        ::osl::SocketAddr saSocketAddrEqual( aHostIp2, IP_PORT_FTP );

        saSocketAddrEqual = saSocketAddr;
        sal_Bool bOK = sal_False;
        ::rtl::ByteSequence bsSocketAddr = saSocketAddrEqual.getAddr( 0 );

         if ( ( IP_PORT_TELNET == saSocketAddrEqual.getPort( ) ) &&( bsSocketAddr[0] == 127 ) && ( bsSocketAddr[1] == 0 ) &&( bsSocketAddr[2] == 0 ) && ( bsSocketAddr[3] == 1 ) )
            bOK = sal_True;

        ASSERT_TRUE(sal_True == bOK) << "test for operator_equal() function: use operator= to assign Ip1 to Ip2, check its modification.";
    }


    TEST_F(operator_equal, operator_equal_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp3, IP_PORT_TELNET);
        ::osl::SocketAddr saSocketAddrEqual( aHostIp2, IP_PORT_FTP );

        saSocketAddrEqual = saSocketAddr;
        ASSERT_TRUE(IP_PORT_TELNET == saSocketAddrEqual.getPort( )) << "after assign, the assigned SocketAddr is not same as the original Addr";
        saSocketAddrEqual.setPort( IP_PORT_MYPORT3 );
        saSocketAddr.setPort( IP_PORT_HTTP2 );

        ASSERT_TRUE(IP_PORT_MYPORT3 == saSocketAddrEqual.getPort( )) << "test for operator_equal() function: perform an equal action, then try to change the original address's port. it should not be changed ( handle released), it did not pass in (W32), this is under discussion.";
    }

    TEST_F(operator_equal, operator_equal_const_001)
    {
        const ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_TELNET);
        ::osl::SocketAddr saSocketAddrEqual( aHostIp2, IP_PORT_FTP );

        saSocketAddrEqual = saSocketAddr;
        sal_Bool bOK = sal_False;
        ::rtl::ByteSequence bsSocketAddr = saSocketAddrEqual.getAddr( 0 );

         if ( ( IP_PORT_TELNET == saSocketAddrEqual.getPort( ) ) &&( bsSocketAddr[0] == 127 ) && ( bsSocketAddr[1] == 0 ) &&( bsSocketAddr[2] == 0 ) && ( bsSocketAddr[3] == 1 ) )
            bOK = sal_True;

        ASSERT_TRUE(sal_True == bOK) << "test for operator_equal_const() function: use operator= const to assign Ip1 to Ip2, verify the change on the second one.";
    }

    TEST_F(operator_equal, operator_equal_const_002)
    {
        const ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_TELNET);
        ::osl::SocketAddr saSocketAddrEqual( aHostIp2, IP_PORT_FTP );

        saSocketAddrEqual = saSocketAddr;
        saSocketAddrEqual.setPort( IP_PORT_HTTP1 );

        ASSERT_TRUE(IP_PORT_HTTP1 != saSocketAddr.getPort( )) << "test for operator_equal_const() function: change the second instance, the first one should not be altered, since it does not released the handle.";
    }

    TEST_F(operator_equal, operator_equal_assign_001)
    {
        ::osl::SocketAddr* pSocketAddr = new ::osl::SocketAddr( aHostIp1, IP_PORT_TELNET );
            ASSERT_TRUE(pSocketAddr != NULL) << "check for new SocketAddr";
            ::osl::SocketAddr* pSocketAddrAssign = new ::osl::SocketAddr( aHostIp2, IP_PORT_FTP );
            oslSocketAddr poslSocketAddr = pSocketAddr->getHandle( );
            //if( m_handle ) osl_destroySocketAddr( m_handle ); so pSocketAddrAssign had been destroyed and then point to pSocketAddr
            pSocketAddrAssign->assign(poslSocketAddr, SAL_NO_COPY);

            ASSERT_TRUE(pSocketAddrAssign->getPort( ) == IP_PORT_TELNET) << "test for SocketAddr no copy constructor function: do a no copy constructor on a given SocketAddr instance, modify the new instance's port, check the original one.";

            delete pSocketAddrAssign;
    }

    TEST_F(operator_equal, operator_is_equal_001)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_TELNET);
        ::osl::SocketAddr saSocketAddrequal( aHostIp1, IP_PORT_TELNET );

        ASSERT_TRUE(sal_True == ( saSocketAddrequal == saSocketAddr.getHandle( ) )) << "test for operator_equal_equal() function: check two identical Address.";
    }

    TEST_F(operator_equal, operator_is_equal_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostIp2, IP_PORT_FTP);
        ::osl::SocketAddr saSocketAddrequal( aHostIp1, IP_PORT_TELNET );

        ASSERT_TRUE(sal_False == ( saSocketAddrequal == saSocketAddr.getHandle( ) )) << "test for operator_equal_equal() function: check two different Address.";
    }


    /** testing the method:
        inline oslSocketAddr SAL_CALL getHandle() const;
    */

    class getSocketAddrHandle : public ::testing::Test
    {
    public:
    }; // class getSocketAddrHandle

    TEST_F(getSocketAddrHandle, getSocketAddrHandle_001)
    {
        ::osl::SocketAddr* pSocketAddr = new ::osl::SocketAddr( aHostName1, IP_PORT_HTTP1 );
            ASSERT_TRUE(pSocketAddr != NULL) << "check for new SocketAddr";
            oslSocketAddr psaOSLSocketAddr = pSocketAddr->getHandle( );
            ::osl::SocketAddr* pSocketAddrCopy = new ::osl::SocketAddr( psaOSLSocketAddr, SAL_NO_COPY );

            ASSERT_TRUE(pSocketAddr->getHandle( ) ==  pSocketAddrCopy->getHandle( )) << "test for SocketAddr no copy constructor function: do a no copy constructor on a given SocketAddr instance, modify the new instance's port, check the original one.";

            delete pSocketAddrCopy;
    }

    TEST_F(getSocketAddrHandle, getSocketAddrHandle_002)
    {
        ::osl::SocketAddr saSocketAddr( aHostName3, IP_PORT_MYPORT4 );
        oslSocketAddr poslSocketAddr = saSocketAddr.getHandle( );

        sal_Bool bOK = ( saSocketAddr == poslSocketAddr );
        //printf("getSocketAddrHandle_002\n");
        ASSERT_TRUE(sal_True == bOK) << "test for getHandle() function: use getHandle() function as an intermediate way to create identical address.";
    }

    /** testing the method:
        static inline ::rtl::OUString SAL_CALL getLocalHostname( oslSocketResult *pResult = 0);
    */

    class getLocalHostname : public ::testing::Test
    {
    public:
    }; // class getLocalHostname

    /* the process of getLocalHostname: 1.gethostname (same as /bin/hostname) returned name A
       2. search A in /etc/hosts, if there is an alias name is A, return the name in the same row
    */

    TEST_F(getLocalHostname, getLocalHostname_000)
        {
            // _osl_getFullQualifiedDomainName( );
            oslSocketResult aResult = osl_Socket_Error;
            rtl::OUString suHostname = osl::SocketAddr::getLocalHostname(&aResult);
            ASSERT_TRUE(aResult == osl_Socket_Ok) << "getLocalHostname failed";
        }

    TEST_F(getLocalHostname, getLocalHostname_001)
    {
        oslSocketResult *pResult = NULL;
        //printSocketResult(*pResult);
        ::rtl::OUString suResult = ::osl::SocketAddr::getLocalHostname( pResult );

        // LLA: IMHO localhost, or hostname by itself should be ok.
        rtl::OUString suThisHost = getThisHostname( );
        bool bOk = false;
        if (suThisHost.equals(rtl::OUString::createFromAscii("localhost")))
        {
            bOk = true;
        }
        else
        {
            if (suThisHost.equals(suResult))
            {
                bOk = true;
            }
        }

        ::rtl::OUString suError;
        suError = outputError(suResult, getThisHostname( ), "test for getLocalHostname() function");

        ASSERT_TRUE(bOk == true) << suError.pData;
    }

    /** testing the method:
        static inline void SAL_CALL resolveHostname( const ::rtl::OUString & strHostName , SocketAddr & Addr );
    */

    class resolveHostname : public ::testing::Test
    {
    public:
    }; // class resolveHostname

    TEST_F(resolveHostname, resolveHostname_001)
    {
        ::osl::SocketAddr saSocketAddr;
        ::osl::SocketAddr::resolveHostname( aHostIp1, saSocketAddr );
        ::rtl::ByteSequence bsSocketAddr = saSocketAddr.getAddr( 0 );
        sal_Bool bOK = sal_False;

         if ( ( bsSocketAddr[0] == 127 ) && ( bsSocketAddr[1] == 0 ) &&( bsSocketAddr[2] == 0 ) && ( bsSocketAddr[3] == 1 ) )
            bOK = sal_True;

        ASSERT_TRUE(sal_True == bOK) << "test for resolveHostname() function: try to resolve localhost to 127.0.0.1.";
    }

    /** testing the method:
        static inline sal_Int32 SAL_CALL getServicePort(
            const ::rtl::OUString& strServiceName,
            const ::rtl::OUString & strProtocolName= ::rtl::OUString::createFromAscii( "tcp" ) );
    */

    class gettheServicePort : public ::testing::Test
    {
    public:
    }; // class gettheServicePort

    TEST_F(gettheServicePort, gettheServicePort_001)
    {
        ASSERT_TRUE(IP_PORT_FTP== ::osl::SocketAddr::getServicePort( aServiceFTP, aProtocolTCP )) << "test for getServicePort() function: try to get ftp service port on TCP protocol.";
    }

    TEST_F(gettheServicePort, gettheServicePort_002)
    {
        ASSERT_TRUE(IP_PORT_TELNET== ::osl::SocketAddr::getServicePort( aServiceTELNET, aProtocolTCP )) << "test for getServicePort() function: try to get telnet service port on TCP protocol.";
    }

    TEST_F(gettheServicePort, gettheServicePort_003)
    {
    //Solaris has no service called "https", please see /etc/services
        ASSERT_TRUE(IP_PORT_NETBIOS_DGM == ::osl::SocketAddr::getServicePort( aServiceNETBIOS, aProtocolUDP )) << "test for getServicePort() function: try to get netbios-ssn service port on UDP protocol.";
    }

    TEST_F(gettheServicePort, gettheServicePort_004)
    {
        ASSERT_TRUE(OSL_INVALID_PORT == ::osl::SocketAddr::getServicePort( ::rtl::OUString::createFromAscii( "notexist" ), aProtocolUDP )) << "test for getServicePort() function: try to get a service port which is not exist.";
    }


} // namespace osl_SocketAddr



namespace osl_Socket
{

    /** testing the methods:
        inline Socket( );
        inline Socket( const Socket & socket );
        inline Socket( oslSocket socketHandle );
        inline Socket( oslSocket socketHandle, __sal_NoAcquire noacquire );
    */

    /**  test writer's comment:

        class Socket can not be initialized by its protected constructor, though the protected
        constructor is the most convenient way to create a new socket.
        it only allow the method of C function osl_createSocket like:
        ::osl::Socket sSocket( osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream,
                                          osl_Socket_ProtocolIp ) );
        the use of C method lost some of the transparent of tester using C++ wrapper.
    */


    class OslSocketCtors : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp()
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown()
        {
            sHandle = NULL;
        }
    };

    TEST_F(OslSocketCtors, ctors_none)
    {
        /// Socket constructor.
        // ::osl::Socket sSocket;

        ASSERT_TRUE(1 == 1) << "test for ctors_none constructor function: check if the socket was created successfully, if no exception occurred";
    }

    TEST_F(OslSocketCtors, ctors_acquire)
    {
        /// Socket constructor.
        ::osl::Socket sSocket( sHandle );

        ASSERT_TRUE(osl_Socket_TypeStream == sSocket.getType( )) << "test for ctors_acquire constructor function: check if the socket was created successfully";
    }

    TEST_F(OslSocketCtors, ctors_no_acquire)
    {
        /// Socket constructor.
        ::osl::Socket sSocket( sHandle, SAL_NO_ACQUIRE );

        ASSERT_TRUE(osl_Socket_TypeStream == sSocket.getType( )) << " test for ctors_no_acquire constructor function: check if the socket was created successfully";
    }

    TEST_F(OslSocketCtors, ctors_copy_ctor)
    {
        ::osl::Socket sSocket( sHandle );
        /// Socket copy constructor.
        ::osl::Socket copySocket( sSocket );

        ASSERT_TRUE(osl_Socket_TypeStream == copySocket.getType( )) << " test for ctors_copy_ctor constructor function: create new Socket instance using copy constructor";
    }

    TEST_F(OslSocketCtors, ctors_TypeRaw)
    {
#ifdef WNT
        oslSocket sHandleRaw = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeRaw, osl_Socket_ProtocolIp );
// LLA: ?           ::osl::Socket sSocket( sHandleRaw );
        ASSERT_TRUE(sHandleRaw != NULL) << " type osl_Socket_TypeRaw socket create failed on UNX ";
#else
        oslSocket sHandleRaw = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeRaw, osl_Socket_ProtocolIp );
        ASSERT_TRUE(sHandleRaw == NULL) << " can't create socket with type osl_Socket_TypeRaw within UNX is ok.";
#endif
    }

    TEST_F(OslSocketCtors, ctors_family_Ipx)
    {
        oslSocket sHandleIpx = osl_createSocket( osl_Socket_FamilyIpx, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        ASSERT_TRUE(sHandleIpx != NULL) << " family osl_Socket_FamilyIpx socket create failed! ";
        ::osl::Socket sSocket( sHandleIpx );        //, SAL_NO_ACQUIRE );
        printf("#Type is %d \n", sSocket.getType( ) );

        ASSERT_TRUE(osl_Socket_TypeStream == sSocket.getType( )) << " test for create new Socket instance that family is osl_Socket_FamilyIpx";
    }


    /** testing the methods:
        inline Socket& SAL_CALL operator= ( oslSocket socketHandle);
        inline Socket& SAL_CALL operator= (const Socket& sock);
        inline sal_Bool SAL_CALL operator==( const Socket& rSocket ) const ;
        inline sal_Bool SAL_CALL operator==( const oslSocket socketHandle ) const;
    */

    class operators : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class operators



    /**  test writer's comment:

        the assignment operator does not support direct assignment like:
        ::osl::Socket sSocket = sHandle.
    */
    TEST_F(operators, operators_assignment_handle)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::Socket assignSocket = sSocket.getHandle();

        ASSERT_TRUE(osl_Socket_TypeStream == assignSocket.getType( )) << "test for operators_assignment_handle function: test the assignment operator.";
    }

    TEST_F(operators, operators_assignment)
    {
        ::osl::Socket sSocket( sHandle );
        ::osl::Socket assignSocket = sSocket;

        ASSERT_TRUE(osl_Socket_TypeStream == assignSocket.getType( )) << "test for operators_assignment function: assignment operator";
    }

    TEST_F(operators, operators_equal_handle_001)
    {
        /// Socket constructor.
        ::osl::Socket sSocket( sHandle );
        ::osl::Socket equalSocket = sSocket;

        ASSERT_TRUE(equalSocket == sHandle) << " test for operators_equal_handle_001 function: check equal.";
    }

    TEST_F(operators, operators_equal_handle_002)
    {
        /// Socket constructor.
        ::osl::Socket equalSocket( osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp ) );

        ASSERT_TRUE(!( equalSocket == sHandle )) << " test for operators_equal_handle_001 function: check unequal.";
    }

    TEST_F(operators, operators_equal_001)
    {
        ::osl::Socket sSocket( sHandle );
        /// Socket copy constructor.
        ::osl::Socket equalSocket( sSocket );

        ASSERT_TRUE(equalSocket == sSocket) << " test for operators_equal function: check equal.";
    }

    TEST_F(operators, operators_equal_002)
    {
        ::osl::Socket sSocket( sHandle );
        /// Socket copy constructor.
        ::osl::Socket equalSocket( osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp ) );

        ASSERT_TRUE(!( equalSocket == sSocket )) << " test for operators_equal_002 function: check unequal.";
    }

    /** testing the methods:
        inline void SAL_CALL shutdown( oslSocketDirection Direction = osl_Socket_DirReadWrite );
        inline void SAL_CALL close();
    */

    class close : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class close

    TEST_F(close, close_001)
    {
        ::osl::Socket sSocket(sHandle);
        sSocket.close();

        ASSERT_TRUE(sSocket.getHandle() == sHandle) << "test for close_001 function: this function is reserved for test.";
    }

    TEST_F(close, close_002)
    {
        // This blocks forever on FreeBSD
#if defined(LINUX)
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        AcceptorThread myAcceptorThread( asSocket, aHostIp1 );
        myAcceptorThread.create();

        thread_sleep( 1 );
        //when accepting, close the socket, the thread will not block for accepting
        //man close:Any locks held on the file it was associated with, and owned by the process, are removed
        asSocket.close();
        //thread_sleep( 2 );
        myAcceptorThread.join();

        ASSERT_TRUE(myAcceptorThread.isOK() == sal_True) << "test for close when is accepting: the socket will quit accepting status.";
#endif
    }

    // to cover "if ( pSockAddrIn->sin_addr.s_addr == htonl(INADDR_ANY) )" in osl_closeSocket( )
    TEST_F(close, close_003)
    {
        // This blocks forever on FreeBSD
#if defined(LINUX)
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        AcceptorThread myAcceptorThread( asSocket, aHostIpZero );
        myAcceptorThread.create();

        thread_sleep( 1 );
        asSocket.close();
        myAcceptorThread.join();

        ASSERT_TRUE(myAcceptorThread.isOK() == sal_True) << "test for close when is accepting: the socket will quit accepting status.";
#endif
    }

    /** testing the method:
        inline void SAL_CALL getLocalAddr( SocketAddr &Addr ) const;
    */

    class getLocalAddr : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getLocalAddr

    // get the Address of the local end of the socket
    TEST_F(getLocalAddr, getLocalAddr_001)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIp1, IP_PORT_MYPORT8 );
        ::osl::SocketAddr saLocalSocketAddr;

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);

        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        ::rtl::OUString suError1 = ::rtl::OUString::createFromAscii("Socket bind fail:") + sSocket.getErrorAsString();
        ASSERT_TRUE(sal_True == bOK1) << suError1.pData;

        sSocket.getLocalAddr( saLocalSocketAddr );

        sal_Bool bOK = compareUString( saLocalSocketAddr.getHostname( 0 ), sSocket.getLocalHost() ) ;

        ASSERT_TRUE(sal_True == bOK) << "test for getLocalAddr function: first create a new socket, then a socket address, bind them, and check the address.";
    }


    /** testing the method:
        inline sal_Int32    SAL_CALL getLocalPort() const;
    */

    class getLocalPort : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getLocalPort

    TEST_F(getLocalPort, getLocalPort_001)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIp1, IP_PORT_MYPORT7 );  // aHostIp1 localhost
        ::osl::SocketAddr saLocalSocketAddr;

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);

        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        ::rtl::OUString suError1 = ::rtl::OUString::createFromAscii("Socket bind fail:") + sSocket.getErrorAsString();
        ASSERT_TRUE(sal_True == bOK1) << suError1.pData;
        sal_Bool bOK = ( IP_PORT_MYPORT7 == sSocket.getLocalPort( )  );

        ASSERT_TRUE(sal_True == bOK) << "test for getLocalPort function: first create a new socket, then a socket address, bind them, and check the port.";
    }

/**  test writer's comment:

    the invalid port number can not be set by giving invalid port number
    such as 99999 or -1, it will convert to ( x mod 65535 ), so it will always be
    valid,  the only instance that the getLocalPort returns OSL_INVALID_PORT
    is when saSocketAddr itself is an invalid one, that is , the IP or host name
    can not be found, then the created socket address is not valid.
*/
#if 0
    TEST_F(getLocalPort, getLocalPort_002)
    {
        ::osl::SocketAddr saBindSocketAddr( aHostIpInval, IP_PORT_TELNET);
#ifdef WNT
        ::osl::Socket sSocket(sHandle);
        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); // sal_True);
        sSocket.bind( saBindSocketAddr );
        //Invalid IP, so bind should fail
        ::rtl::OUString suError = outputError(::rtl::OUString::valueOf(sSocket.getLocalPort( )),
            ::rtl::OUString::valueOf((sal_Int32)OSL_INVALID_PORT),
            "test for getLocalPort function: first create a new socket, then an invalid socket address, bind them, and check the port assigned.");
        sal_Bool bOK = ( OSL_INVALID_PORT == sSocket.getLocalPort( ) );
        (void)bOK;
#else
        //on Unix, if Addr is not an address of type osl_Socket_FamilyInet, it returns OSL_INVALID_PORT
        ::rtl::OUString suError = ::rtl::OUString::createFromAscii( "on Unix, if Addr is not an address of type osl_Socket_FamilyInet, it returns OSL_INVALID_PORT, but can not create Addr of that case");
#endif
        ASSERT_TRUE(sal_False) << suError;

    }
#endif

    TEST_F(getLocalPort, getLocalPort_003)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( getLocalIP(), IP_PORT_INVAL);

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);

        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        ::rtl::OUString suError1 = ::rtl::OUString::createFromAscii("Socket bind fail:") + sSocket.getErrorAsString();
        ASSERT_TRUE(sal_True == bOK1) << suError1.pData;
        ::rtl::OUString suError = outputError(::rtl::OUString::valueOf(sSocket.getLocalPort( )),
            ::rtl::OUString::createFromAscii("34463"),
            "test for getLocalPort function: first create a new socket, then an invalid socket address, bind them, and check the port assigned");
        sal_Bool bOK = ( sSocket.getLocalPort( ) >= 1 &&  sSocket.getLocalPort( ) <= 65535);

        ASSERT_TRUE(sal_True == bOK) << suError.pData;
    }

    /** testing the method:
        inline ::rtl::OUString SAL_CALL getLocalHost() const;

        Mindyliu: on Linux, at first it will check the binded in /etc/hosts, if it has the binded IP, it will return the hostname in it;
        else if the binded IP is "127.0.0.1", it will return "localhost", if it's the machine's ethernet ip such as "129.158.217.90", it
        will return hostname of current processor such as "aegean.PRC.Sun.COM"
    */

    class getLocalHost : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getLocalHost

    TEST_F(getLocalHost, getLocalHost_001)
    {
        ::osl::Socket sSocket(sHandle);
        //port number from IP_PORT_HTTP1 to IP_PORT_MYPORT6, mindyliu
        ::osl::SocketAddr saBindSocketAddr( aHostIp1, IP_PORT_MYPORT6 );

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);

        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        ::rtl::OUString suError1 = ::rtl::OUString::createFromAscii("Socket bind fail:") + sSocket.getErrorAsString();
        ASSERT_TRUE(sal_True == bOK1) << suError1.pData;
        sal_Bool bOK;
        ::rtl::OUString suError;
#ifdef WNT
        bOK = compareUString( sSocket.getLocalHost( ), getThisHostname( ) ) ;
        suError = outputError(sSocket.getLocalHost( ), getThisHostname( ),
"test for getLocalHost function: create localhost socket and check name");
#else
        ::rtl::OUString aUString = ::rtl::OUString::createFromAscii( (const sal_Char *) "localhost" );
        sal_Bool bRes1, bRes2;
        bRes1 = compareUString( sSocket.getLocalHost( ), aUString ) ;
        bRes2 = compareUString( sSocket.getLocalHost( ), saBindSocketAddr.getHostname(0) ) ;
        bOK = bRes1 || bRes2;
        suError = outputError(sSocket.getLocalHost( ), aUString, "test for getLocalHost function: create localhost socket and check name");
#endif
        ASSERT_TRUE(sal_True == bOK) << suError.pData;
    }

    TEST_F(getLocalHost, getLocalHost_002)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIpInval, IP_PORT_POP3);
        ::osl::SocketAddr saLocalSocketAddr;

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sSocket.bind( saBindSocketAddr );
        //Invalid IP, so bind should fail
        sal_Bool bOK = compareUString( sSocket.getLocalHost( ), aNullURL ) ;
        ::rtl::OUString suError = outputError(sSocket.getLocalHost( ), aNullURL, "test for getLocalHost function: getLocalHost with invalid SocketAddr");

        ASSERT_TRUE(sal_True == bOK) << suError.pData;
    }

    /** testing the methods:
        inline void SAL_CALL getPeerAddr( SocketAddr & Addr) const;
        inline sal_Int32    SAL_CALL getPeerPort() const;
        inline ::rtl::OUString SAL_CALL getPeerHost() const;
    */
    class getPeer : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        TimeValue *pTimeout;
        ::osl::AcceptorSocket asAcceptorSocket;
        ::osl::ConnectorSocket csConnectorSocket;


        // initialization
        void SetUp( )
        {
            pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
            pTimeout->Seconds = 3;
            pTimeout->Nanosec = 0;
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            free( pTimeout );
            sHandle = NULL;
            asAcceptorSocket.close( );
            csConnectorSocket.close( );
        }
    }; // class getPeer

    TEST_F(getPeer, getPeer_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );
        ::osl::StreamSocket ssConnection;
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        /// launch server socket
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind '127.0.0.1' address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";

        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        /// launch client socket
        csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...

        /// get peer information
        csConnectorSocket.getPeerAddr( saPeerSocketAddr );/// connected.
        sal_Int32 peerPort = csConnectorSocket.getPeerPort( );
        ::rtl::OUString peerHost = csConnectorSocket.getPeerHost( );

        ASSERT_TRUE(( sal_True == compareSocketAddr( saPeerSocketAddr, saLocalSocketAddr ) )&&
                                ( sal_True == compareUString( peerHost, saLocalSocketAddr.getHostname( 0 ) ) ) &&
                                ( peerPort == saLocalSocketAddr.getPort( ) )) << "test for getPeer function: setup a connection and then get the peer address, port and host from client side.";
    }

    /** testing the methods:
        inline sal_Bool SAL_CALL bind(const SocketAddr& LocalInterface);
    */


    class bind : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class bind

    TEST_F(bind, bind_001)
    {
        ::osl::Socket sSocket(sHandle);
        //bind must use local IP address ---mindyliu
        ::osl::SocketAddr saBindSocketAddr( getLocalIP(), IP_PORT_MYPORT5 );

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "Socket bind fail.";

        sal_Bool bOK2 = compareUString( sSocket.getLocalHost( ), saBindSocketAddr.getHostname( ) ) ;

        sSocket.close();
        ASSERT_TRUE(sal_True == bOK2) << "test for bind function: bind a valid address.";
    }

    TEST_F(bind, bind_002)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIpInval, IP_PORT_NETBIOS );
        ::osl::SocketAddr saLocalSocketAddr;

        sSocket.setOption( osl_Socket_OptionReuseAddr, 1); // sal_True);
        sal_Bool bOK1 = sSocket.bind( saBindSocketAddr );
        sal_Bool bOK2 = compareUString( sSocket.getLocalHost( ), getThisHostname( ) ) ;

        ASSERT_TRUE(( sal_False == bOK1 ) && ( sal_False == bOK2 )) << "test for bind function: bind a valid address.";
    }


    /** testing the methods:
        inline sal_Bool SAL_CALL isRecvReady(const TimeValue *pTimeout = 0) const;

    */
    class isRecvReady : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        TimeValue *pTimeout;
        ::osl::AcceptorSocket asAcceptorSocket;
        ::osl::ConnectorSocket csConnectorSocket;


        // initialization
        void SetUp( )
        {
            pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
            pTimeout->Seconds = 3;
            pTimeout->Nanosec = 0;
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            free( pTimeout );
            sHandle = NULL;
            asAcceptorSocket.close( );
            csConnectorSocket.close( );
        }
    }; // class isRecvReady

    TEST_F(isRecvReady, isRecvReady_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT1 );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT1 );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );
        ::osl::StreamSocket ssConnection;
        /// launch server socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); // sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        /// launch client socket
        csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...

        /// is receive ready?
        sal_Bool bOK3 = asAcceptorSocket.isRecvReady( pTimeout );

        ASSERT_TRUE(( sal_True == bOK3 )) << "test for isRecvReady function: setup a connection and then check if it can transmit data.";
    }

    /** testing the methods:
        inline sal_Bool SAL_CALL isSendReady(const TimeValue *pTimeout = 0) const;
    */
    class isSendReady : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        TimeValue *pTimeout;
        ::osl::AcceptorSocket asAcceptorSocket;
        ::osl::ConnectorSocket csConnectorSocket;


        // initialization
        void SetUp( )
        {
            pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
            pTimeout->Seconds = 3;
            pTimeout->Nanosec = 0;
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            free( pTimeout );
            sHandle = NULL;
            asAcceptorSocket.close( );
            csConnectorSocket.close( );
        }
    }; // class isSendReady

    TEST_F(isSendReady, isSendReady_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        /// launch client socket
        csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...

        /// is send ready?
        sal_Bool bOK3 = csConnectorSocket.isSendReady( pTimeout );

        ASSERT_TRUE(( sal_True == bOK3 )) << "test for isSendReady function: setup a connection and then check if it can transmit data.";
    }

    /** testing the methods:
        inline oslSocketType    SAL_CALL getType() const;

    */

    class getType : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {

        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getType

    TEST_F(getType, getType_001)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        ASSERT_TRUE(osl_Socket_TypeStream ==  sSocket.getType( )) << "test for getType function: get type of socket.";
    }

    TEST_F(getType, getType_002)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        ASSERT_TRUE(osl_Socket_TypeDgram ==  sSocket.getType( )) << "test for getType function: get type of socket.";
    }

#ifdef UNX
    // mindy: since on LINUX and SOLARIS, Raw type socket can not be created, so do not test getType() here
    // mindy: and add one test case to test creating Raw type socket--> ctors_TypeRaw()
    TEST_F(getType, getType_003)
    {
        ASSERT_TRUE(sal_True) << "test for getType function: get type of socket.this is not passed in (LINUX, SOLARIS), the osl_Socket_TypeRaw, type socket can not be created.";
    }
#else
    TEST_F(getType, getType_003)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeRaw, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        ASSERT_TRUE(osl_Socket_TypeRaw ==  sSocket.getType( )) << "test for getType function: get type of socket.";
    }
#endif


    /** testing the methods:
        inline sal_Int32 SAL_CALL getOption(
            oslSocketOption Option,
            void* pBuffer,
            sal_uInt32 BufferLen,
            oslSocketOptionLevel Level= osl_Socket_LevelSocket) const;

        inline sal_Int32 getOption( oslSocketOption option ) const;

    */

    class getOption : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {

        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getOption

    /**  test writer's comment:

        in oslSocketOption, the osl_Socket_OptionType denote 1 as osl_Socket_TypeStream.
        2 as osl_Socket_TypeDgram, etc which is not mapping the oslSocketType enum. differ
        in 1.
    */

    TEST_F(getOption, getOption_001)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);
        sal_Int32 * pType = ( sal_Int32 * )malloc( sizeof ( sal_Int32 ) );
        *pType = 0;
        sSocket.getOption( osl_Socket_OptionType,  pType, sizeof ( sal_Int32 ) );
        sal_Bool bOK = ( SOCK_STREAM ==  *pType );
        // there is a TypeMap(socket.c) which map osl_Socket_TypeStream to SOCK_STREAM on UNX, and SOCK_STREAM != osl_Socket_TypeStream
        //sal_Bool bOK = ( TYPE_TO_NATIVE(osl_Socket_TypeStream) ==  *pType );
        free( pType );

        ASSERT_TRUE(sal_True == bOK) << "test for getOption function: get type option of socket.";
    }

    // getsockopt error
    TEST_F(getOption, getOption_004)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        sal_Bool * pbDontRoute = ( sal_Bool * )malloc( sizeof ( sal_Bool ) );
        sal_Int32 nRes = sSocket.getOption( osl_Socket_OptionInvalid,  pbDontRoute, sizeof ( sal_Bool ) );
        free( pbDontRoute );

        ASSERT_TRUE(nRes  ==  -1) << "test for getOption function: get invalid option of socket, should return -1.";
    }

    TEST_F(getOption, getOption_simple_001)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        sal_Bool bOK = ( sal_False  ==  sSocket.getOption( osl_Socket_OptionDontRoute ) );

        ASSERT_TRUE(sal_True == bOK) << "test for getOption function: get debug option of socket.";
    }

    TEST_F(getOption, getOption_simple_002)
    {
        sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeDgram, osl_Socket_ProtocolIp );
        ::osl::Socket sSocket(sHandle);

        sal_Bool bOK = ( sal_False  ==  sSocket.getOption( osl_Socket_OptionDebug ) );

        ASSERT_TRUE(sal_True == bOK) << "test for getOption function: get debug option of socket.";
    }

    /** testing the methods:
        inline sal_Bool SAL_CALL setOption( oslSocketOption Option,
                                            void* pBuffer,
                                            sal_uInt32 BufferLen,
                                            oslSocketOptionLevel Level= osl_Socket_LevelSocket ) const;
    */

    class setOption : public ::testing::Test
    {
    public:
        TimeValue *pTimeout;
// LLA: maybe there is an error in the source,
//      as long as I remember, if a derived class do not overload all ctors there is a problem.

        ::osl::AcceptorSocket asAcceptorSocket;

        void SetUp( )
        {

        }

        void TearDown( )
        {
            asAcceptorSocket.close( );
        }
    }; // class setOption

    // LLA:
    // getSocketOption returns BufferLen, or -1 if something failed

    // setSocketOption returns sal_True, if option could stored
    // else sal_False

    TEST_F(setOption, setOption_001)
    {
        /// set and get option.
        int nBufferLen = sizeof ( sal_Int32);
        // LLA: SO_DONTROUTE expect an integer boolean, what ever it is, it's not sal_Bool!

        sal_Int32 * pbDontRouteSet = ( sal_Int32 * )malloc( sizeof ( sal_Int32 ) );
        *pbDontRouteSet = 1; // sal_True;

        sal_Int32 * pGetBuffer = ( sal_Int32 * )malloc( sizeof ( sal_Int32 ) );
        *pGetBuffer = 0;

        // maybe asAcceptorSocket is not right initialized
        sal_Bool  b1 = asAcceptorSocket.setOption( osl_Socket_OptionDontRoute,  pbDontRouteSet, nBufferLen );
        ASSERT_TRUE(( sal_True == b1 )) << "setOption function failed.";
        sal_Int32 n2 = asAcceptorSocket.getOption( osl_Socket_OptionDontRoute,  pGetBuffer, nBufferLen );
        ASSERT_TRUE(( n2 == nBufferLen )) << "getOption function failed.";

        // on Linux, the value of option is 1, on Solaris, it's 16, but it's not important the exact value,
        // just judge it is zero or not!
        sal_Bool bOK = ( 0  !=  *pGetBuffer );
        printf("#setOption_001: getOption is %d \n", *pGetBuffer);

        // toggle check, set to 0
        *pbDontRouteSet = 0;

        sal_Bool  b3 = asAcceptorSocket.setOption( osl_Socket_OptionDontRoute,  pbDontRouteSet, sizeof ( sal_Int32 ) );
        ASSERT_TRUE(( sal_True == b3 )) << "setOption function failed.";
        sal_Int32 n4 = asAcceptorSocket.getOption( osl_Socket_OptionDontRoute,  pGetBuffer, nBufferLen );
        ASSERT_TRUE(( n4 == nBufferLen )) << "getOption (DONTROUTE) function failed.";

        sal_Bool bOK2 = ( 0  ==  *pGetBuffer );

        printf("#setOption_001: getOption is %d \n", *pGetBuffer);

// LLA:             sal_Bool * pbDontTouteSet = ( sal_Bool * )malloc( sizeof ( sal_Bool ) );
// LLA:             *pbDontTouteSet = sal_True;
// LLA:             sal_Bool * pbDontTouteGet = ( sal_Bool * )malloc( sizeof ( sal_Bool ) );
// LLA:             *pbDontTouteGet = sal_False;
// LLA:             asAcceptorSocket.setOption( osl_Socket_OptionDontRoute,  pbDontTouteSet, sizeof ( sal_Bool ) );
// LLA:             asAcceptorSocket.getOption( osl_Socket_OptionDontRoute,  pbDontTouteGet, sizeof ( sal_Bool ) );
// LLA:             ::rtl::OUString suError = outputError(::rtl::OUString::valueOf((sal_Int32)*pbDontTouteGet),
// LLA:                 ::rtl::OUString::valueOf((sal_Int32)*pbDontTouteSet),
// LLA:                 "test for setOption function: set osl_Socket_OptionDontRoute and then check");
// LLA:
// LLA:             sal_Bool bOK = ( sal_True  ==  *pbDontTouteGet );
// LLA:             free( pbDontTouteSet );
// LLA:             free( pbDontTouteGet );

        ASSERT_TRUE(( sal_True == bOK ) && (sal_True == bOK2)) << "test for setOption function: set option of a socket and then check.";

        free( pbDontRouteSet );
        free( pGetBuffer );
// LLA:             ASSERT_TRUE(sal_True == bOK) << suError;
    }

    TEST_F(setOption, setOption_002)
    {
        /// set and get option.

        // sal_Int32 * pbLingerSet = ( sal_Int32 * )malloc( nBufferLen );
        // *pbLingerSet = 7;
        // sal_Int32 * pbLingerGet = ( sal_Int32 * )malloc( nBufferLen );
                /* struct */linger aLingerSet;
                sal_Int32 nBufferLen = sizeof( struct linger );
                aLingerSet.l_onoff = 1;
                aLingerSet.l_linger = 7;

            linger aLingerGet;

        asAcceptorSocket.setOption( osl_Socket_OptionLinger,  &aLingerSet, nBufferLen );

        sal_Int32 n1 = asAcceptorSocket.getOption( osl_Socket_OptionLinger,  &aLingerGet, nBufferLen );
                ASSERT_TRUE(( n1 == nBufferLen )) << "getOption (SO_LINGER) function failed.";

        //printf("#setOption_002: getOption is %d \n", aLingerGet.l_linger);
        sal_Bool bOK = ( 7  ==  aLingerGet.l_linger );
        ASSERT_TRUE(sal_True == bOK) << "test for setOption function: set option of a socket and then check. ";

    }

    TEST_F(setOption, setOption_003)
    {
        linger aLingerSet;
            aLingerSet.l_onoff = 1;
                aLingerSet.l_linger = 7;

        sal_Bool b1 = asAcceptorSocket.setOption( osl_Socket_OptionLinger,  &aLingerSet, 0 );
                printUString( asAcceptorSocket.getErrorAsString() );
        ASSERT_TRUE(( b1 == sal_False )) << "setOption (SO_LINGER) function failed for optlen is 0.";
    }

    TEST_F(setOption, setOption_simple_001)
    {
        /// set and get option.
        asAcceptorSocket.setOption( osl_Socket_OptionDontRoute, 1 ); //sal_True );
        sal_Bool bOK = ( 0  !=  asAcceptorSocket.getOption( osl_Socket_OptionDontRoute ) );

        printf("setOption_simple_001(): getoption is %d \n", asAcceptorSocket.getOption( osl_Socket_OptionDontRoute ) );
        ASSERT_TRUE(( sal_True == bOK )) << "test for setOption function: set option of a socket and then check.";
    }

    TEST_F(setOption, setOption_simple_002)
    {
        /// set and get option.
        // LLA: this does not work, due to the fact that SO_LINGER is a structure
// LLA:         asAcceptorSocket.setOption( osl_Socket_OptionLinger,  7 );
// LLA:         sal_Bool bOK = ( 7  ==  asAcceptorSocket.getOption( osl_Socket_OptionLinger ) );

// LLA:         ASSERT_TRUE(// LLA:                                     ( sal_True == bOK )) << "test for setOption function: set option of a socket and then check.";
    }


    /** testing the method:
        inline sal_Bool SAL_CALL enableNonBlockingMode( sal_Bool bNonBlockingMode);
    */
    class enableNonBlockingMode : public ::testing::Test
    {
    public:
        ::osl::AcceptorSocket asAcceptorSocket;
    }; // class enableNonBlockingMode

    TEST_F(enableNonBlockingMode, enableNonBlockingMode_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        /// if reach this statement, it is non-blocking mode, since acceptConnection will blocked by default.
        sal_Bool bOK  = sal_True;
        asAcceptorSocket.close( );

        ASSERT_TRUE(( sal_True == bOK  )) << "test for enableNonBlockingMode function: launch a server socket and make it non blocking. if it can pass the acceptConnection statement, it is non-blocking";
    }

    /** testing the method:
        inline sal_Bool SAL_CALL isNonBlockingMode() const;
    */
    class isNonBlockingMode : public ::testing::Test
    {
    public:
        ::osl::AcceptorSocket asAcceptorSocket;
    }; // class isNonBlockingMode

    TEST_F(isNonBlockingMode, isNonBlockingMode_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); // sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";

        sal_Bool bOK3 = asAcceptorSocket.isNonBlockingMode( );
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        /// if reach this statement, it is non-blocking mode, since acceptConnection will blocked by default.
        sal_Bool bOK4 = asAcceptorSocket.isNonBlockingMode( );
        asAcceptorSocket.close( );

        ASSERT_TRUE(( sal_False == bOK3 ) && ( sal_True == bOK4 )) << "test for isNonBlockingMode function: launch a server socket and make it non blocking. it is expected to change from blocking mode to non-blocking mode.";
    }

    /** testing the method:
        inline void SAL_CALL clearError() const;
    */
    class clearError : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class clearError

    TEST_F(clearError, clearError_001)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIpInval, IP_PORT_HTTP2 );
        ::osl::SocketAddr saLocalSocketAddr;
        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sSocket.bind( saBindSocketAddr );//build an error "osl_Socket_E_AddrNotAvail"
        oslSocketError seBind = sSocket.getError( );
        sSocket.clearError( );

        ASSERT_TRUE(osl_Socket_E_None == sSocket.getError( ) && seBind != osl_Socket_E_None) << "test for clearError function: trick an error called sSocket.getError( ), and then clear the error states, check the result.";
    }

    /** testing the methods:
        inline oslSocketError getError() const;
        inline ::rtl::OUString getErrorAsString( ) const;
    */
    class getError : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getError

    TEST_F(getError, getError_001)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIp1, IP_PORT_FTP );
        ::osl::SocketAddr saLocalSocketAddr;

        ASSERT_TRUE(osl_Socket_E_None == sSocket.getError( )) << "test for getError function: should get no error.";
    }

    TEST_F(getError, getError_002)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::SocketAddr saBindSocketAddr( aHostIpInval, IP_PORT_FTP );
        ::osl::SocketAddr saLocalSocketAddr;
        sSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sSocket.bind( saBindSocketAddr );//build an error "osl_Socket_E_AddrNotAvail"
        //on Solaris, the error no is EACCES, but it has no mapped value, so getError() returned osl_Socket_E_InvalidError.
#if defined(SOLARIS)
        ASSERT_TRUE(osl_Socket_E_InvalidError == sSocket.getError( )) << "trick an error called sSocket.getError( ), check the getError result.Failed on Solaris, returned osl_Socket_E_InvalidError because no entry to map the errno EACCES. ";
#else
        //while on Linux & Win32, the errno is EADDRNOTAVAIL, getError returned osl_Socket_E_AddrNotAvail.

        ASSERT_TRUE(osl_Socket_E_AddrNotAvail == sSocket.getError( )) << "trick an error called sSocket.getError( ), check the getError result.Failed on Solaris, returned osl_Socket_E_InvalidError because no entry to map the errno EACCES. Passed on Linux & Win32";
#endif
    }


    /** testing the methods:
        inline oslSocket getHandle() const;
    */

    class getHandle : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class getHandle


    TEST_F(getHandle, getHandle_001)
    {
        ::osl::Socket sSocket(sHandle);
        ::osl::Socket assignSocket = sSocket.getHandle();

        ASSERT_TRUE(osl_Socket_TypeStream == assignSocket.getType( )) << "test for operators_assignment_handle function: test the assignment operator.";
    }

    TEST_F(getHandle, getHandle_002)
    {
        ::osl::Socket sSocket( sHandle );
        ::osl::Socket assignSocket ( sSocket.getHandle( ) );

        ASSERT_TRUE(osl_Socket_TypeStream == assignSocket.getType( )) << "test for operators_assignment function: assignment operator";
    }


} // namespace osl_Socket



namespace osl_StreamSocket
{

    /** testing the methods:
        inline StreamSocket(oslAddrFamily Family = osl_Socket_FamilyInet,
                            oslProtocol Protocol = osl_Socket_ProtocolIp,
                            oslSocketType   Type = osl_Socket_TypeStream);

        inline StreamSocket( const StreamSocket & );

        inline StreamSocket( oslSocket Socket , __sal_NoAcquire noacquire );

        inline StreamSocket( oslSocket Socket );
    */

    class OslStreamSocketCtors : public ::testing::Test
    {
    public:
        oslSocket sHandle;
        // initialization
        void SetUp( )
        {
            sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            sHandle = NULL;
        }
    }; // class ctors

    TEST_F(OslStreamSocketCtors, ctors_none)
    {
        /// Socket constructor.
        ::osl::StreamSocket ssSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );

        ASSERT_TRUE(osl_Socket_TypeStream ==  ssSocket.getType( )) << "test for ctors_none constructor function: check if the stream socket was created successfully.";
    }

    TEST_F(OslStreamSocketCtors, ctors_acquire)
    {
        /// Socket constructor.
        ::osl::StreamSocket ssSocket( sHandle );

        ASSERT_TRUE(osl_Socket_TypeStream == ssSocket.getType( )) << "test for ctors_acquire constructor function: check if the socket was created successfully";
    }

    TEST_F(OslStreamSocketCtors, ctors_no_acquire)
    {
        /// Socket constructor.
        ::osl::StreamSocket ssSocket( sHandle, SAL_NO_ACQUIRE );

        ASSERT_TRUE(osl_Socket_TypeStream == ssSocket.getType( )) << " test for ctors_no_acquire constructor function: check if the socket was created successfully";
    }

    TEST_F(OslStreamSocketCtors, ctors_copy_ctor)
    {
        /// Socket constructor.
        ::osl::StreamSocket ssSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        /// Socket copy constructor.
        ::osl::StreamSocket copySocket( ssSocket );

        ASSERT_TRUE(osl_Socket_TypeStream == copySocket.getType( )) << " test for ctors_copy_ctor constructor function: create new Socket instance using copy constructor";
    }

    class send_recv: public ::testing::Test
    {
    public:
        // initialization
        void SetUp( )
        {
        }

        void TearDown( )
        {

        }

        void write_read(sal_Int32 _nBufferSize, int _nValue)
        {
            //client sent two strings, and server received, check the order and value
            WriteSocketThread myServerThread(_nBufferSize, _nValue);
            ReadSocketThread myClientThread(_nBufferSize, _nValue);
            myServerThread.create( );
    //          thread_sleep( 1 );
            myClientThread.create( );

            //wait until the thread terminate
            myClientThread.join( );
            myServerThread.join( );

            //Maximum Packet Size is ( ARPANET, MILNET = 1007 Ethernet (10Mb) = 1500
            // Proteon PRONET  = 2046), so here test read 4000 bytes
            sal_Int32 nLength = myClientThread.getCount();
            bool       bIsOk   = myClientThread.isOk(); // check if the values are right.

            printf("Length:=%d\n", nLength);
            printf(" bIsOk:=%d\n", bIsOk);

            ASSERT_TRUE(nLength == _nBufferSize && bIsOk == true) << " test for write/read values with two threads: send data from server, check readed data in client.";
        }
    }; // class send_recv

    TEST_F(send_recv, send_recv1)
    {
        //client sent two strings, and server received, check the order and value
        ServerSocketThread myServerThread;
        ClientSocketThread myClientThread;
        myServerThread.create( );
        myClientThread.create( );

        //wait until the thread terminate
        myClientThread.join( );
        myServerThread.join( );
        sal_Char myStr[30] = "";
        strcat( myStr, pTestString1 );
        strcat( myStr, pTestString2 );
        sal_Int32 nRes = strcmp( myServerThread.pReadBuffer, myStr );
        ASSERT_TRUE(nRes == 0) << " test for send/recv with two threads: launch Server/Client threads, send data from client, check received data in Server thread.";
    }

    // error when recv
    TEST_F(send_recv, send_recv2)
    {
        ::osl::AcceptorSocket asAcceptorSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT9 );
        ::osl::StreamSocket ssStreamConnection;
        sal_Char pReadBuffer[30] = "";

        ClientSocketThread myClientThread;
        myClientThread.create( );

        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 );

        asAcceptorSocket.bind( saLocalSocketAddr );
        asAcceptorSocket.listen( 1 );
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        asAcceptorSocket.acceptConnection( ssStreamConnection );
        sal_Int32 nReadNumber = ssStreamConnection.recv( pReadBuffer, 11 );

        myClientThread.join( ) ;
        ssStreamConnection.close();
        asAcceptorSocket.close();
        ASSERT_TRUE(nReadNumber == -1) << " test for send/recv, recv error!";
    }

    TEST_F(send_recv, write_read_001)
        {
            write_read(50, 10);
        }
    TEST_F(send_recv, write_read_002)
        {
            write_read(1024, 20);
        }
    TEST_F(send_recv, write_read_003)
        {
            write_read(4000, 1);
        }
    TEST_F(send_recv, write_read_004)
        {
            write_read(8192, 3);
        }


class SendClientThread : public ClientSocketThread
{
protected:

    void SAL_CALL run( )
    {
        TimeValue *pTimeout;
        pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
        pTimeout->Seconds = 5;
        pTimeout->Nanosec = 0;

        if ( osl_Socket_Ok == csConnectorSocket.connect( saTargetSocketAddr, pTimeout ))
        {
            sal_Int32 nWrite1 = csConnectorSocket.write( pTestString1, 11 ); // "test socket"

            sal_Int32 nWrite2 = csConnectorSocket.write( pTestString2, strlen( pTestString2 ) + 1 );
            thread_sleep( 2 );
            csConnectorSocket.write( pTestString2, strlen( pTestString2 ) + 1 );
            printf("nWrite1 is %d, nWrite2 is %d\n", nWrite1, nWrite2 );
            //thread_sleep( 1 );
        }
        else
            printf("# SendClientThread: connect failed! \n");

        csConnectorSocket.close();
        free( pTimeout );
    }

};

    class shutdown: public ::testing::Test
    {
    public:
        // initialization
        void SetUp( )
        {
        }

        void TearDown( )
        {

        }
    }; // class shutdown

    // similar to close_002
    TEST_F(shutdown, shutdown_001)
    {
#if defined(LINUX)
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        AcceptorThread myAcceptorThread( asSocket, aHostIp1 );
        myAcceptorThread.create();

        thread_sleep( 1 );

        //when accepting, shutdown the socket, the thread will not block for accepting
        asSocket.shutdown();
        myAcceptorThread.join();

        ASSERT_TRUE(myAcceptorThread.isOK( ) == sal_True) << "test for close when is accepting: the socket will quit accepting status.";
#endif
    }

    TEST_F(shutdown, shutdown_002)
    {
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT9);
        asSocket.setOption( osl_Socket_OptionReuseAddr, 1 );
        ASSERT_TRUE(asSocket.bind( saLocalSocketAddr ) == sal_True) << "shutdown_002: bind fail";
        ASSERT_TRUE(asSocket.listen( 1 ) == sal_True) << "shutdown_002: listen fail";
        sal_Char pReadBuffer[40];
        SendClientThread mySendThread;
        mySendThread.create();

        asSocket.enableNonBlockingMode( sal_False );
        ::osl::StreamSocket ssConnectionSocket;
        oslSocketResult eResult = asSocket.acceptConnection( ssConnectionSocket );
        ASSERT_TRUE(eResult == osl_Socket_Ok) << "shutdown_002: acceptConnection fail";

        /* set socket option SO_LINGER 0, so close immediately */
        linger aLingerSet;
            sal_Int32 nBufferLen = sizeof( struct linger );
                aLingerSet.l_onoff = 0;
                aLingerSet.l_linger = 0;

        ssConnectionSocket.setOption( osl_Socket_OptionLinger,  &aLingerSet, nBufferLen );
        thread_sleep( 1 );
        //sal_uInt32 nRecv1 = 0;
        sal_Int32 nRead1 = ssConnectionSocket.read( pReadBuffer, 11 );

        //shutdown read after client the first send complete
        ssConnectionSocket.shutdown( osl_Socket_DirRead );

        sal_Int32 nRead2 = ssConnectionSocket.read( pReadBuffer + nRead1, 12 );
        sal_Int32 nRead3 = ssConnectionSocket.read( pReadBuffer + nRead1 + nRead2, 12 );
        printf("after read 2, nRead1 is %d, nRead2 is %d, nRead3 is %d \n", nRead1, nRead2, nRead3 );
        mySendThread.join();

        ssConnectionSocket.close();
        asSocket.close();

        /* on Linux, if send is before shutdown(DirRead), can read, nRecv2 still > 0,
           http://dbforums.com/arch/186/2002/12/586417
           While on Solaris, after shutdown(DirRead), all read will return 0
        */
#ifdef LINUX
        ASSERT_TRUE(nRead1 > 0  && nRead3 == 0) << "test for shutdown read direction: the socket can not read(recv).";
#else
        ASSERT_TRUE(nRead1 > 0  && nRead2 == 0 && nRead3 == 0) << "test for shutdown read direction: the socket can not read(recv).";
#endif

    }

    TEST_F(shutdown, shutdown_003)
    {
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT9);
        asSocket.setOption( osl_Socket_OptionReuseAddr, 1 );
        ASSERT_TRUE(asSocket.bind( saLocalSocketAddr ) == sal_True) << "shutdown_002: bind fail";
        ASSERT_TRUE(asSocket.listen( 1 ) == sal_True) << "shutdown_002: listen fail";
        sal_Char pReadBuffer[40];
        SendClientThread mySendThread;
        mySendThread.create();

        asSocket.enableNonBlockingMode( sal_False );
        ::osl::StreamSocket ssConnectionSocket;
        oslSocketResult eResult = asSocket.acceptConnection( ssConnectionSocket );
        ASSERT_TRUE(eResult == osl_Socket_Ok) << "shutdown_002: acceptConnection fail";

        thread_sleep( 1 );
        //shutdown write after client the first send complete
        ssConnectionSocket.shutdown( osl_Socket_DirWrite );

        // recv should not shutdown
        sal_Int32 nRead1 = ssConnectionSocket.read( pReadBuffer, 11 );

        sal_Int32 nWrite = ssConnectionSocket.write( pReadBuffer, 11 );
        // still can read
        sal_Int32 nRead3 = ssConnectionSocket.read( pReadBuffer + nRead1 , 12 );
        printf("after read 2, nRead1 is %d, nWrite is %d, nRead3 is %d\n", nRead1, nWrite, nRead3 );
        mySendThread.join();
        ssConnectionSocket.close();
        asSocket.close();

        ASSERT_TRUE(nRead1  > 0  && nWrite == 0 && nRead3 > 0) << "test for shutdown read direction: the socket can not send(write).";

    }

    class isExceptionPending: public ::testing::Test
    {
    public:
    }; // class isExceptionPending

    /**tester's comments: lack of a case that return sal_True, do not know when it will return sal_True*/
    TEST_F(isExceptionPending, isExPending_001)
    {
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        TimeValue *pTimeout;
        pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
        pTimeout->Seconds = 3;
        pTimeout->Nanosec = 0;
        sal_Bool bOk = asSocket.isExceptionPending( pTimeout );
        free( pTimeout );

        ASSERT_TRUE(bOk == sal_False) << "test for isExceptionPending.";
    }


} // namespace osl_StreamSocket


namespace osl_ConnectorSocket
{

    /** testing the method:
        ConnectorSocket(oslAddrFamily Family = osl_Socket_FamilyInet,
                        oslProtocol Protocol = osl_Socket_ProtocolIp,
                        oslSocketType   Type = osl_Socket_TypeStream);
    */

    class OslConnectorSocketCtors : public ::testing::Test
    {
    public:
    }; // class ctors

    TEST_F(OslConnectorSocketCtors, ctors_001)
    {
        /// Socket constructor.
        ::osl::ConnectorSocket csSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );

        ASSERT_TRUE(osl_Socket_TypeStream ==  csSocket.getType( )) << "test for ctors_001 constructor function: check if the connector socket was created successfully.";
    }

    /** testing the method:
        oslSocketResult SAL_CALL connect(const SocketAddr& TargetHost, const TimeValue* pTimeout = 0);
    */

    class connect : public ::testing::Test
    {
    public:
        TimeValue *pTimeout;
        ::osl::AcceptorSocket asAcceptorSocket;
        ::osl::ConnectorSocket csConnectorSocket;


        // initialization
        void SetUp( )
        {
            pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
            pTimeout->Seconds = 3;
            pTimeout->Nanosec = 0;
        //  sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            free( pTimeout );
        //  sHandle = NULL;
            asAcceptorSocket.close( );
            csConnectorSocket.close( );
        }
    }; // class connect

    TEST_F(connect, connect_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT2 );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT2 );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";

        //asAcceptorSocket.enableNonBlockingMode( sal_True );
        //oslSocketResult eResultAccept = asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...
        //ASSERT_TRUE(osl_Socket_Ok == eResultAccept) << "accept failed.";
        /// launch client socket
        oslSocketResult eResult = csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...
        ASSERT_TRUE(osl_Socket_Ok == eResult) << "connect failed.";

        /// get peer information
        csConnectorSocket.getPeerAddr( saPeerSocketAddr );/// connected.

        ASSERT_TRUE(( sal_True == compareSocketAddr( saPeerSocketAddr, saLocalSocketAddr ) ) &&
                                ( osl_Socket_Ok == eResult )) << "test for connect function: try to create a connection with remote host. and check the setup address.";
    }
    //non-blocking mode connect?
    TEST_F(connect, connect_002)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT3 );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT3 );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );

        asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1 ); //sal_True);
        asAcceptorSocket.enableNonBlockingMode( sal_True );
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";

        csConnectorSocket.enableNonBlockingMode( sal_True );

        oslSocketResult eResult = csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...
        ASSERT_TRUE(osl_Socket_InProgress == eResult ||  osl_Socket_Ok == eResult) << "connect failed.";

        /// get peer information
        csConnectorSocket.getPeerAddr( saPeerSocketAddr );

        ASSERT_TRUE( sal_True == compareSocketAddr( saPeerSocketAddr, saLocalSocketAddr  )  )
            << "test for connect function: try to create a connection with remote host. and check the setup address.";
    }
    // really an error or just delayed
    // how to design scenarios that will return osl_Socket_Interrupted, osl_Socket_TimedOut
    TEST_F(connect, connect_003)
    {
        ::osl::SocketAddr saTargetSocketAddr1( aHostIp1, IP_PORT_MYPORT3 );
        ::osl::SocketAddr saTargetSocketAddr2( aHostIpInval1, IP_PORT_MYPORT3 );

        csConnectorSocket.enableNonBlockingMode( sal_False );

        oslSocketResult eResult1 = csConnectorSocket.connect( saTargetSocketAddr1, pTimeout );
        oslSocketResult eResult2 = csConnectorSocket.connect( saTargetSocketAddr2, pTimeout );
        CloseSocketThread myCloseThread( csConnectorSocket );
        oslSocketResult eResult3 = csConnectorSocket.connect( saTargetSocketAddr2, pTimeout );
        myCloseThread.join();
        ASSERT_TRUE(osl_Socket_Error == eResult1 &&
            osl_Socket_Error == eResult2 &&  osl_Socket_Error == eResult3) << "connect should failed.";

    }

    // really an error in non-blocking mode
    TEST_F(connect, connect_004)
    {
        ::osl::SocketAddr saTargetSocketAddr( aHostIpInval1, IP_PORT_MYPORT3 );

        csConnectorSocket.enableNonBlockingMode( sal_True );

        oslSocketResult eResult = csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...
        ASSERT_TRUE(osl_Socket_Error == eResult) << "connect should failed.";
    }
    /** here need a case: immediate connection, say in non-blocking mode connect return osl_Socket_Ok
    */


} // namespace osl_ConnectorSocket



namespace osl_AcceptorSocket
{

    /** testing the methods:
        inline AcceptorSocket(oslAddrFamily Family = osl_Socket_FamilyInet,
                              oslProtocol   Protocol = osl_Socket_ProtocolIp,
                              oslSocketType Type = osl_Socket_TypeStream);
    */

    class OslAcceptorSocketCtors : public ::testing::Test
    {
    public:
    }; // class ctors

    TEST_F(OslAcceptorSocketCtors, ctors_001)
    {
        /// Socket constructor.
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );

        ASSERT_TRUE(osl_Socket_TypeStream ==  asSocket.getType( )) << "test for ctors_001 constructor function: check if the acceptor socket was created successfully.";
    }

#if 0
    class operator_assign : public ::testing::Test
    {
    public:
    }; // class operator_assign

    TEST_F(operator_assign, assign_001)
    {
#if defined(LINUX)
        ::osl::AcceptorSocket asSocket( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        ::osl::AcceptorSocket asSocketAssign( osl_Socket_FamilyInet, osl_Socket_ProtocolIp, osl_Socket_TypeStream );
        asSocket.setOption( osl_Socket_OptionReuseAddr, 1);
        ::osl::SocketAddr saSocketAddr( aHostIp1, IP_PORT_MYPORT4 );
        asSocket.bind( saSocketAddr );

        AcceptorThread myAcceptorThread( asSocketAssign, aHostIp1 );
        myAcceptorThread.create();

        thread_sleep( 1 );
        //when accepting, assign another socket to the socket, the thread will not be closed, so is blocking
        asSocketAssign = asSocket;

        printf("#asSocketAssign port number is %d\n", asSocketAssign.getLocalPort() );

        asSocketAssign.shutdown();
        myAcceptorThread.join();

        ASSERT_TRUE(myAcceptorThread.isOK() == sal_True) << "test for close when is accepting: the socket will quit accepting status.";


#endif /* LINUX */
    }
#endif

    /** testing the method:
        inline sal_Bool SAL_CALL listen(sal_Int32 MaxPendingConnections= -1);
        inline oslSocketResult SAL_CALL acceptConnection( StreamSocket& Connection);
        inline oslSocketResult SAL_CALL acceptConnection( StreamSocket& Connection, SocketAddr & PeerAddr);
    */

    class listen_accept : public ::testing::Test
    {
    public:
        TimeValue *pTimeout;
        ::osl::AcceptorSocket asAcceptorSocket;
        ::osl::ConnectorSocket csConnectorSocket;


        // initialization
        void SetUp( )
        {
            pTimeout  = ( TimeValue* )malloc( sizeof( TimeValue ) );
            pTimeout->Seconds = 3;
            pTimeout->Nanosec = 0;
            asAcceptorSocket.setOption( osl_Socket_OptionReuseAddr, 1);
        //  sHandle = osl_createSocket( osl_Socket_FamilyInet, osl_Socket_TypeStream, osl_Socket_ProtocolIp );
        }

        void TearDown( )
        {
            free( pTimeout );
        //  sHandle = NULL;
            asAcceptorSocket.close( );
            csConnectorSocket.close( );
        }
    }; // class listen_accept

    TEST_F(listen_accept, listen_accept_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT3 );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT3 );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";
        asAcceptorSocket.enableNonBlockingMode( sal_True );

        /// launch client socket
        csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...

        oslSocketResult eResult = asAcceptorSocket.acceptConnection(ssConnection); /// waiting for incoming connection...

        ASSERT_TRUE(( osl_Socket_Ok == eResult )) << "test for listen_accept function: try to create a connection with remote host, using listen and accept.";
    }

    TEST_F(listen_accept, listen_accept_002)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT4 );
        ::osl::SocketAddr saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT4 );
        ::osl::SocketAddr saPeerSocketAddr( aHostIp2, IP_PORT_FTP );
        ::osl::StreamSocket ssConnection;

        /// launch server socket
        sal_Bool bOK1 = asAcceptorSocket.bind( saLocalSocketAddr );
        ASSERT_TRUE(sal_True == bOK1) << "AcceptorSocket bind address failed.";
        sal_Bool bOK2 = asAcceptorSocket.listen( 1 );
        ASSERT_TRUE(sal_True == bOK2) << "AcceptorSocket listen failed.";
        asAcceptorSocket.enableNonBlockingMode( sal_True );

        /// launch client socket
        csConnectorSocket.connect( saTargetSocketAddr, pTimeout );   /// connecting to server...

        oslSocketResult eResult = asAcceptorSocket.acceptConnection(ssConnection, saPeerSocketAddr); /// waiting for incoming connection...

        ASSERT_TRUE(( sal_True == bOK2 ) &&
                                ( osl_Socket_Ok == eResult ) &&
                                ( sal_True == compareSocketAddr( saPeerSocketAddr, saLocalSocketAddr ) )) << "test for listen_accept function: try to create a connection with remote host, using listen and accept, accept with peer address.";
    }

    TEST_F(listen_accept, listen_accept_003)
    {

    }


} // namespace osl_AcceptorSocket


namespace osl_DatagramSocket
{

    /** testing the methods:
        inline DatagramSocket(oslAddrFamily Family= osl_Socket_FamilyInet,
                              oslProtocol   Protocol= osl_Socket_ProtocolIp,
                              oslSocketType Type= osl_Socket_TypeDgram);
    */

    class DatagramSocketCtors : public ::testing::Test
    {
    public:
    }; // class ctors

    TEST_F(DatagramSocketCtors, ctors_001)
    {
        /// Socket constructor.
        ::osl::DatagramSocket dsSocket;

        ASSERT_TRUE(osl_Socket_TypeDgram ==  dsSocket.getType( )) << "test for ctors_001 constructor function: check if the datagram socket was created successfully.";
    }

/**thread do sendTo, refer to http://www.coding-zone.co.uk/cpp/articles/140101networkprogrammingv.shtml
*/
class TalkerThread : public Thread
{
protected:
    ::osl::SocketAddr saTargetSocketAddr;
    ::osl::DatagramSocket dsSocket;

    void SAL_CALL run( )
    {
        dsSocket.sendTo( saTargetSocketAddr, pTestString1, strlen( pTestString1 ) + 1 ); // "test socket"
        dsSocket.shutdown();
    }

    void SAL_CALL onTerminated( )
    {
    }

public:
    TalkerThread( ):
        saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT9 )
    {
    }

    ~TalkerThread( )
    {
        if ( isRunning( ) )
            printf("# error: TalkerThread not terminated normally.\n" );
    }
};

/**thread do listen, refer to http://www.coding-zone.co.uk/cpp/articles/140101networkprogrammingv.shtml
*/
class ListenerThread : public Thread
{
protected:
    ::osl::SocketAddr saTargetSocketAddr;
    ::osl::DatagramSocket dsSocket;

    void SAL_CALL run( )
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT10 );
        dsSocket.setOption( osl_Socket_OptionReuseAddr, 1 );
        if ( dsSocket.bind( saLocalSocketAddr ) == sal_False )
        {
            printf("DatagramSocket bind failed \n");
            return;
        }
        //blocking mode: default
        sal_Int32 nRecv = dsSocket.recvFrom( pRecvBuffer, 30, &saTargetSocketAddr); //strlen( pTestString2 ) + 1
        printf("After recvFrom, nRecv is %d\n", nRecv);
    }

    void SAL_CALL onTerminated( )
    {
    }

public:
    sal_Char pRecvBuffer[30];
    ListenerThread( ):
        saTargetSocketAddr( aHostIp1, IP_PORT_MYPORT10 )
    {
        pRecvBuffer[0] = '\0';
    }

    ~ListenerThread( )
    {
        if ( isRunning( ) )
            printf("# error: ListenerThread not terminated normally.\n" );
    }

};

    /** testing the methods:
        inline sal_Int32 DatagramSocket::recvFrom(void*  pBuffer, sal_uInt32 BufferSize,
              SocketAddr* pSenderAddr, oslSocketMsgFlag Flag )
        inline sal_Int32  DatagramSocket::sendTo( const SocketAddr& ReceiverAddr,
              const void* pBuffer, sal_uInt32 BufferSize, oslSocketMsgFlag Flag )
    */

    class sendTo_recvFrom : public ::testing::Test
    {
    public:
    }; // class sendTo_recvFrom

    TEST_F(sendTo_recvFrom, sr_001)
    {
        ::osl::SocketAddr saLocalSocketAddr( aHostIp1, IP_PORT_MYPORT9 );
        ::osl::DatagramSocket dsSocket;
        dsSocket.setOption( osl_Socket_OptionReuseAddr, 1 );
        dsSocket.bind( saLocalSocketAddr );

        sal_Char pReadBuffer[30];
        TalkerThread myTalkThread;
        myTalkThread.create();
        sal_Int32 nRecv = dsSocket.recvFrom( pReadBuffer, 30, &saLocalSocketAddr);
        myTalkThread.join();
        //printf("#received buffer is %s# \n", pReadBuffer);

        sal_Bool bOk = ( strcmp(pReadBuffer, pTestString1) == 0 );

        ASSERT_TRUE(nRecv > 0 && bOk == sal_True) << "test for sendTo/recvFrom function: create a talker thread and recvFrom in the main thread, check if the datagram socket can communicate successfully.";
    }

    TEST_F(sendTo_recvFrom, sr_002)
    {
        ::osl::SocketAddr saListenSocketAddr( aHostIp1, IP_PORT_MYPORT10 );
        ::osl::DatagramSocket dsSocket;

        //listener thread construct a DatagramSocket, recvFrom waiting for data, then main thread sendto data
        ListenerThread myListenThread;
        myListenThread.create();
        //to grantee the recvFrom is before sendTo
        thread_sleep( 1 );

        sal_Int32 nSend = dsSocket.sendTo( saListenSocketAddr, pTestString2, strlen( pTestString2 ) + 1 );

        ASSERT_TRUE(nSend > 0) << "DatagramSocket sendTo failed: nSend <= 0.";

        myListenThread.join();
        //printf("#received buffer is %s# \n", myListenThread.pRecvBuffer);

        sal_Bool bOk = ( strcmp( myListenThread.pRecvBuffer, pTestString2) == 0 );

        ASSERT_TRUE(bOk == sal_True) << "test for sendTo/recvFrom function: create a listener thread and sendTo in the main thread, check if the datagram socket can communicate successfully.";
    }

    //sendTo error, return -1; recvFrom error, return -1
    TEST_F(sendTo_recvFrom, sr_003)
    {
        ::osl::SocketAddr saListenSocketAddr( aHostIpInval1, IP_PORT_MYPORT10 );
        ::osl::DatagramSocket dsSocket;
        // Transport endpoint is not connected
        sal_Int32 nSend = dsSocket.sendTo( saListenSocketAddr, pTestString2, strlen( pTestString2 ) + 1 );
        ASSERT_TRUE(nSend == -1) << "DatagramSocket sendTo should fail: nSend <= 0.";
    }

    TEST_F(sendTo_recvFrom, sr_004)
    {
        ::osl::SocketAddr saListenSocketAddr1( aHostIpInval1, IP_PORT_MYPORT10 );
        ::osl::SocketAddr saListenSocketAddr2( aHostIp2, IP_PORT_MYPORT10 );
        ::osl::DatagramSocket dsSocket;

        dsSocket.enableNonBlockingMode( sal_True );

        sal_Char pReadBuffer[30];
        //sal_Int32 nRecv1 = dsSocket.recvFrom( pReadBuffer, 30, &saListenSocketAddr1 );

        // will block ?
        CloseSocketThread myThread( dsSocket );
        myThread.create();
        sal_Int32 nRecv2 = dsSocket.recvFrom( pReadBuffer, 30, &saListenSocketAddr1 );
        myThread.join();
        //printf("#nRecv1 is %d nRecv2 is %d\n", nRecv1, nRecv2 );
        ASSERT_TRUE(nRecv2 == -1) << "DatagramSocket sendTo should fail: nSend <= 0.";
    }


} // namespace osl_DatagramSocket

static oslSignalAction SAL_CALL signalHandler(void* pData, oslSignalInfo* pInfo)
{
    return osl_Signal_ActCallNextHdl;
}

int main(int argc, char **argv)
{
    osl_addSignalHandler(signalHandler, NULL);
    ::testing::InitGoogleTest(&argc, argv);
    return RUN_ALL_TESTS();
}