activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r960923 - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net: DatagramPacket.cpp DatagramPacket.h
Date Tue, 06 Jul 2010 15:50:00 GMT
Author: tabish
Date: Tue Jul  6 15:50:00 2010
New Revision: 960923

URL: http://svn.apache.org/viewvc?rev=960923&view=rev
Log:
Add an initial implementation of a DatagramPacket class.

Added:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp   (with
props)
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h   (with props)

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp?rev=960923&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp Tue Jul
 6 15:50:00 2010
@@ -0,0 +1,258 @@
+/*
+ * 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.
+ */
+
+#include "DatagramPacket.h"
+
+using namespace decaf;
+using namespace decaf::net;
+using namespace decaf::lang;
+using namespace decaf::lang::exceptions;
+using namespace decaf::util::concurrent;
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int length ) {
+
+    this->setData( bytes, size, 0, length );
+
+    this->port = -1;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int offset, int length )
{
+
+    this->setData( bytes, size, offset, length );
+
+    this->port = -1;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int offset, int length, const
InetAddress& address DECAF_UNUSED, int port ) {
+
+    this->setData( bytes, size, offset, length );
+
+    this->port = port;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int length, const InetAddress&
address DECAF_UNUSED, int port ) {
+
+    this->setData( bytes, size, 0, length );
+
+    this->port = port;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int length, const SocketAddress&
address DECAF_UNUSED) {
+
+    this->setData( bytes, size, 0, length );
+
+    // TODO
+    this->port = -1;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::DatagramPacket( unsigned char* bytes, int size, int offset, int length, const
SocketAddress& address DECAF_UNUSED ) {
+
+    this->setData( bytes, size, offset, length );
+
+    // TODO
+    this->port = -1;
+    this->address = NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+DatagramPacket::~DatagramPacket() {
+
+    try{
+        delete this->address;
+    }
+    DECAF_CATCH_NOTHROW( Exception )
+    DECAF_CATCHALL_NOTHROW()
+}
+
+////////////////////////////////////////////////////////////////////////////////
+InetAddress* DatagramPacket::getAddress() const {
+
+    InetAddress* result = 0;
+    synchronized( &mutex ) {
+        result = this->address;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setAddress( const InetAddress& address DECAF_UNUSED ) {
+
+    // TODO
+}
+
+////////////////////////////////////////////////////////////////////////////////
+SocketAddress* DatagramPacket::getSocketAddress() const {
+
+    // TODO
+    return NULL;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setSocketAddress( const SocketAddress& address DECAF_UNUSED ) {
+
+    // TODO
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int DatagramPacket::getPort() const {
+
+    int result = 0;
+    synchronized( &mutex ) {
+        result = this->port;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setPort( int port ) {
+
+    if( port < 0 || port > 65535 ) {
+        throw IllegalArgumentException(
+            __FILE__, __LINE__, "Given port value is out of range, %d", port );
+    }
+
+    synchronized( &mutex ) {
+        this->port = port;
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int DatagramPacket::getOffset() const {
+
+    int result = 0;
+    synchronized( &mutex ) {
+        result = this->offset;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setOffset( int offset ) {
+
+    synchronized( &mutex ) {
+        if( offset < 0 || offset > size ) {
+            throw IllegalArgumentException( __FILE__, __LINE__, "Offset value is invalid:
%d", offset );
+        }
+
+        this->offset = offset;
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int DatagramPacket::getLength() const {
+
+    int result = 0;
+    synchronized( &mutex ) {
+        result = this->length;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setLength( int length ) {
+
+    synchronized( &mutex ) {
+        if( length < 0 || ( size - offset ) > length ) {
+            throw IllegalArgumentException( __FILE__, __LINE__, "Length value is invalid:
%d", length );
+        }
+
+        this->length = length;
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+unsigned char* DatagramPacket::getData() const {
+
+    unsigned char* result = 0;
+    synchronized( &mutex ) {
+        result = this->buffer;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+int DatagramPacket::getSize() const {
+
+    int result = 0;
+    synchronized( &mutex ) {
+        result = this->size;
+    }
+
+    return result;
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setData( unsigned char* buffer, int size ) {
+
+    if( buffer == NULL ) {
+        throw NullPointerException( __FILE__, __LINE__, "Provided Buffer pointer was NULL."
);
+    }
+
+    if( size <= 0 ) {
+        throw IllegalArgumentException( __FILE__, __LINE__, "Size value is invalid: %d",
size );
+    }
+
+    synchronized( &mutex ) {
+        this->buffer = buffer;
+        this->size = size;
+        this->length = size;
+        this->offset = 0;
+    }
+}
+
+////////////////////////////////////////////////////////////////////////////////
+void DatagramPacket::setData( unsigned char* buffer, int size, int offset, int length ) {
+
+    if( buffer == NULL ) {
+        throw NullPointerException( __FILE__, __LINE__, "Provided Buffer pointer was NULL."
);
+    }
+
+    if( size <= 0 ) {
+        throw IllegalArgumentException( __FILE__, __LINE__, "Size value is invalid: %d",
size );
+    }
+
+    if( offset < 0 || offset > size ) {
+        throw IllegalArgumentException( __FILE__, __LINE__, "Offset value is invalid: %d",
offset );
+    }
+
+    if( length < 0 || ( size - offset ) > length ) {
+        throw IllegalArgumentException( __FILE__, __LINE__, "Length value is invalid: %d",
length );
+    }
+
+    synchronized( &mutex ) {
+        this->buffer = buffer;
+        this->size = size;
+        this->length = length;
+        this->offset = offset;
+    }
+}

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Added: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h?rev=960923&view=auto
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h (added)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h Tue Jul 
6 15:50:00 2010
@@ -0,0 +1,302 @@
+/*
+ * 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.
+ */
+
+#ifndef _DECAF_NET_DATAGRAMPACKET_H_
+#define _DECAF_NET_DATAGRAMPACKET_H_
+
+#include <decaf/util/Config.h>
+
+#include <decaf/net/Inet4Address.h>
+#include <decaf/net/SocketAddress.h>
+
+#include <decaf/lang/exceptions/NullPointerException.h>
+#include <decaf/lang/exceptions/IndexOutOfBoundsException.h>
+#include <decaf/lang/exceptions/IllegalArgumentException.h>
+
+#include <decaf/util/concurrent/Mutex.h>
+
+namespace decaf {
+namespace net {
+
+    /**
+     * Class that represents a single datagram packet.
+     *
+     * Datagrams are sent in packets from machine to machine and can each be routed differently
+     * and can arrive in any order.  Delivery of a packet is not guaranteed.
+     *
+     * @since 1.0
+     */
+    class DatagramPacket {
+    private:
+
+        unsigned char* buffer;
+        int size;
+        int offset;
+        int length;
+
+        InetAddress* address;
+        int port;
+
+        mutable decaf::util::concurrent::Mutex mutex;
+
+    public:
+
+        /**
+         * Creates a new DatagramPacket for use in receiving a packet of the given length.
+         *
+         * @param bytes
+         *      The array of bytes to hold the incoming datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to read exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int length );
+
+        /**
+         * Creates a new DatagramPacket for use in receiving a packet of the given length
+         * starting at the specified offset into the buffer.
+         *
+         * @param bytes
+         *      The array of bytes to hold the incoming datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param offset
+         *      The position in the array to start writing to.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to copy exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int offset, int length );
+
+        /**
+         * Creates a new DatagramPacket for use in sending a packet of the given length
+         * starting at the specified offset into the buffer to the specified host on the
+         * specified port.
+         *
+         * @param bytes
+         *      The array of bytes to hold the outgoing datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param offset
+         *      The position in the array to start writing to.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         * @param address
+         *      The Address to send the packet to
+         * @param port
+         *      The port on the destination that is to receive this packet.
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to copy exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int offset, int length, const InetAddress&
address, int port );
+
+        /**
+         * Creates a new DatagramPacket for use in sending a packet of the given length
+         * to the specified host on the specified port.
+         *
+         * @param bytes
+         *      The array of bytes to hold the outgoing datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         * @param address
+         *      The Address to send the packet to
+         * @param port
+         *      The port on the destination that is to receive this packet.
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to copy exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int length, const InetAddress&
address, int port );
+
+        /**
+         * Creates a new DatagramPacket for use in sending a packet of the given length
+         * into the buffer to the specified socket address.
+         *
+         * @param bytes
+         *      The array of bytes to hold the outgoing datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         * @param address
+         *      The Address to send the packet to
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to copy exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int length, const SocketAddress&
address );
+
+        /**
+         * Creates a new DatagramPacket for use in sending a packet of the given length
+         * starting at the specified offset into the buffer to the specified socket address.
+         *
+         * @param bytes
+         *      The array of bytes to hold the outgoing datagram buffer.
+         * @param size
+         *      The size of the supplied byte array.
+         * @param offset
+         *      The position in the array to start writing to.
+         * @param length
+         *      The number of byte to read starting at the supplied offset.
+         * @param address
+         *      The Address to send the packet to
+         *
+         * @throws NullPointerException if the pointer to the buffer is NULL.
+         * @throws IndexOutOfBoundsException if the number of bytes to copy exceeds the buffer
size.
+         */
+        DatagramPacket( unsigned char* bytes, int size, int offset, int length, const SocketAddress&
address );
+
+        virtual ~DatagramPacket();
+
+    public:
+
+        /**
+         * @return the IP address that this datagram packet is being sent to or was received
from.
+         */
+        InetAddress* getAddress() const;
+
+        /**
+         * Sets the IP address of the machine to which this datagram is being sent.
+         *
+         * @param address
+         *      The IP address.
+         */
+        void setAddress( const InetAddress& address );
+
+        /**
+         * Gets the SocketAddress (usually IP address + port number) of the remote host that
this
+         * packet is being sent to or is coming from.
+         *
+         * @returns the SocketAddress for this datagram packet.
+         */
+        SocketAddress* getSocketAddress() const;
+
+        /**
+         * Sets the SocketAddress (usually IP address + port number) of the remote host to
which
+         * this datagram is being sent.
+         *
+         * @param address
+         *      The SocketAddress (IP + port) for this datagram packet.
+         *
+         * @throws IllegalArgumentException if the subclass of address is not supported by
this Socket.
+         */
+        void setSocketAddress( const SocketAddress& address );
+
+        /**
+         * @return the port number that this datagram packet is being sent to or was received
from.
+         */
+        int getPort() const;
+
+        /**
+         * Sets the port number on the remote host to which this datagram is being sent.
+         *
+         * @param port
+         *      The port on the remote host.
+         *
+         * @throws IllegalArgumentException if the port value is not in the range [0..65535].
+         */
+        void setPort( int port );
+
+        /**
+         * @return the offset of the data to be sent or the offset of the data received.
+         */
+        int getOffset() const;
+
+        /**
+         * Sets the offset into the data buffer where data to sent is to be read from or
where
+         * the data that is received should start writing to.
+         *
+         * @param offset
+         *      The buffer offset value.
+         *
+         * @throws IllegalArgumentException if the offset value is greater than the buffer
size.
+         */
+        void setOffset( int offset );
+
+        /**
+         * @return the length of the data to be sent or the length of the data received.
+         */
+        int getLength() const;
+
+        /**
+         * Set the length for this packet. The length of the packet is the number of bytes
from the
+         * packet's data buffer that will be sent, or the number of bytes of the packet's
data buffer
+         * that will be used for receiving data. The length must be lesser or equal to the
offset
+         * plus the length of the packet's buffer.
+         *
+         * @param length
+         *      The length value to set for this packet.
+         *
+         * @throws IllegalArgumentException if the value is negative or exceeds the data
buffers length.
+         */
+        void setLength( int length );
+
+        /**
+         * @return the data buffer. The data received or the data to be sent starts from
the offset
+         *         in the buffer, and continues for length bytes.
+         */
+        unsigned char* getData() const;
+
+        /**
+         * @return the size of the buffer used in this datagram packet.
+         */
+        int getSize() const;
+
+        /**
+         * Set the data buffer for this packet. With the offset of this DatagramPacket set
to 0, and
+         * the length set to the size value specified.
+         *
+         * @param buffer
+         *      The new data buffer to use for this datagram packet.
+         * @param size
+         *      The size of the buffer.
+         *
+         * @throws NullPointerException if the buffer pointer is NULL.
+         */
+        void setData( unsigned char* buffer, int size );
+
+        /**
+         * Set the data buffer for this packet. With the offset of this DatagramPacket set
to 0, and
+         * the length set to the size value specified.
+         *
+         * @param buffer
+         *      The new data buffer to use for this datagram packet.
+         * @param size
+         *      The size of the buffer.
+         * @param offset
+         *      The position in the buffer to read from or write to.
+         * @param length
+         *      The number of bytes that will be read into the buffer or sent from the buffer.
+         *
+         * @throws NullPointerException if the buffer pointer is NULL.
+         */
+        void setData( unsigned char* buffer, int size, int offset, int length );
+
+    };
+
+}}
+
+#endif /* _DECAF_NET_DATAGRAMPACKET_H_ */

Propchange: activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/net/DatagramPacket.h
------------------------------------------------------------------------------
    svn:eol-style = native



Mime
View raw message