/home/vlg/develop/libASSA/libassa/assa/ConUDPSocket.cpp

Go to the documentation of this file.

// -*- c++ -*-
//------------------------------------------------------------------------
//                              ConUDPSocket.cpp
//------------------------------------------------------------------------------
//  Copyright (C) 1999  Vladislav Grinchenko 
//
//  This library is free software; you can redistribute it and/or
//  modify it under the terms of the GNU Library General Public
//  License as published by the Free Software Foundation; either
//  version 2 of the License, or (at your option) any later version.
//------------------------------------------------------------------------

#ifndef WIN32

#include "assa/ConUDPSocket.h"
#include "assa/UNIXAddress.h"
#include "assa/INETAddress.h"

using namespace ASSA;

bool
ConUDPSocket::
connect (const Address& peer_address_)
{
    char self[] = "ConUDPSocket::connect"; trace(self);

    if ( ::connect (getHandler(),peer_address_.getAddress(),
                    peer_address_.getLength()) < 0 ) {
        setstate (Socket::failbit);
        return false;
    }
    return true;
}

void
ConUDPSocket::
unconnect()
{
    // Ignore errors here. On some systems connect() might return
    // EAFNOSUPPORT error, on some might not, but it is OK.
    //
    char self[] = "ConUDPSocket::unconnect"; trace(self);

    if ( getDomain() == AF_INET ) {
        INETAddress addr;
        SA_IN* addrp = (SA_IN*) addr.getAddress();

        addrp->sin_family = AF_UNSPEC;
        (void) connect(addr);
    }
    else {          // AF_LOCAL
        // I haven't tested whether it works at all.
        
        UNIXAddress addr("");
        SA_UN* addrp = (SA_UN*) addr.getAddress();

        addrp->sun_family = AF_UNSPEC;
        (void) connect(addr);       
    }
}

int
ConUDPSocket::
read(char* packet_, const unsigned int size_)
{
    int len;
    len = ::read(getHandler(), packet_, size_);

    if (len == -1) {
        setstate (Socket::failbit);
    }
    else if ( len == 0 ) {
        setstate (Socket::failbit | Socket::eofbit);
    }
    return len;
}

int
ConUDPSocket::
write (const char* packet_, const unsigned int size_)
{
    return  ::write(getHandler(), (const void*) packet_, size_);
}

#endif // WIN32

---