ibrcommon/ibrcommon/net/lowpansocket.cpp

Go to the documentation of this file.

/*
 * lowpansocket.cpp
 *
 *  Created on: 01.06.2010
 *      Author: stschmid
 */

#include "ibrcommon/net/lowpansocket.h"
#include <sys/socket.h>
#include <errno.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <cassert>
#include <string.h>
#include <stdlib.h>

/* Move to a better place */
#include "ibrcommon/net/ieee802154.h"

namespace ibrcommon
{
        lowpansocket::lowpansocket(u_char proto) throw (SocketException)
        {
                // Create socket for listening for client connection requests.
                if ((_socket = ::socket(PF_IEEE802154, SOCK_DGRAM, 0)) < 0) // Ignoring proto for now
                {
                        throw SocketException("lowpansocket: cannot create listen socket");
                }

                bzero(&_sockaddr, sizeof(_sockaddr));
                _sockaddr.family = AF_IEEE802154;
                _sockaddr.addr.addr_type = IEEE802154_ADDR_SHORT;
        }

        lowpansocket::~lowpansocket()
        {
                if (_socket != 0)
                {
                        shutdown();
                        ::close(_socket);
                }
        }

        void lowpansocket::shutdown()
        {
                //::shutdown(_socket, SHUT_RDWR);
                ::close(_socket);
        }

        int lowpansocket::receive(char* data, size_t maxbuffer)
        {
                struct sockaddr_ieee802154 clientAddress;
                socklen_t clientAddressLength = sizeof(clientAddress);

                int ret = recvfrom(_socket, data, maxbuffer, MSG_WAITALL, (struct sockaddr *) &clientAddress, &clientAddressLength);
                return ret;
        }

        lowpansocket::peer::peer(lowpansocket &socket, const struct sockaddr_ieee802154 &dest, const unsigned int panid)
         : _socket(socket)
        {
                bzero(&_destaddress, sizeof(_destaddress));
                _destaddress.family = AF_IEEE802154;
                _destaddress.addr.addr_type = IEEE802154_ADDR_SHORT;

                memcpy(&_destaddress.addr.short_addr, &dest.addr.short_addr, sizeof(_destaddress.addr.short_addr));
                _destaddress.addr.pan_id = panid;
        }

        int lowpansocket::peer::send(const char *data, const size_t length)
        {
                ::connect(_socket._socket, (struct sockaddr *) &_destaddress, sizeof(_destaddress));
                //printf("lowpan send() address %04x, PAN %04x\n", _destaddress.addr.short_addr, _destaddress.addr.pan_id);
                //return ::sendto(_socket._socket, data, length, 0, (struct sockaddr *) &_destaddress, sizeof(_destaddress));
                return ::send(_socket._socket, data, length, 0);
        }

        lowpansocket::peer lowpansocket::getPeer(const string address, const unsigned int panid)
        {
                struct sockaddr_ieee802154 destaddress;

                destaddress.addr.short_addr = atoi(address.c_str());
                return lowpansocket::peer(*this, destaddress, panid);
        }
}