ibrdtn/ibrdtn/utils/Utils.cpp

Go to the documentation of this file.

#include "ibrdtn/utils/Utils.h"
#include "ibrcommon/data/BLOB.h"
#include "ibrdtn/data/Exceptions.h"
#include "ibrdtn/data/PayloadBlock.h"
#include "ibrdtn/utils/Clock.h"

#include <math.h>

namespace dtn
{
        namespace utils
        {
                void Utils::rtrim(std::string &str)
                {
                        // trim trailing spaces
                        size_t endpos = str.find_last_not_of(" \t");
                        if( string::npos != endpos )
                        {
                                str = str.substr( 0, endpos+1 );
                        }
                }

                void Utils::ltrim(std::string &str)
                {
                        // trim leading spaces
                        size_t startpos = str.find_first_not_of(" \t");
                        if( string::npos != startpos )
                        {
                                str = str.substr( startpos );
                        }
                }

                void Utils::trim(std::string &str)
                {
                        ltrim(str);
                        rtrim(str);
                }

                vector<string> Utils::tokenize(string token, string data, size_t max)
                {
                        vector<string> l;
                        string value;

                        // Skip delimiters at beginning.
                        string::size_type lastPos = data.find_first_not_of(token, 0);
                        // Find first "non-delimiter".
                        string::size_type pos     = data.find_first_of(token, lastPos);

                        while (string::npos != pos || string::npos != lastPos)
                        {
                                // Found a token, add it to the vector.
                                value = data.substr(lastPos, pos - lastPos);
                                l.push_back(value);
                                // Skip delimiters.  Note the "not_of"
                                lastPos = data.find_first_not_of(token, pos);
                                // Find next "non-delimiter"
                                pos = data.find_first_of(token, lastPos);

                                // if maximum reached
                                if (l.size() >= max)
                                {
                                        // add the remaining part to the vector as last element
                                        l.push_back(data.substr(lastPos, data.length() - lastPos));

                                        // and break the search loop
                                        break;
                                }
                        }

                        return l;
                }

                 double Utils::distance(double lat1, double lon1, double lat2, double lon2)
                 {
                        const double r = 6371; //km

                        double dLat = toRad( (lat2-lat1) );
                        double dLon = toRad( (lon2-lon1) );

                        double a =      sin(dLat/2) * sin(dLat/2) +
                                                cos(toRad(lat1)) * cos(toRad(lat2)) *
                                                sin(dLon/2) * sin(dLon/2);
                        double c = 2 * atan2(sqrt(a), sqrt(1-a));
                        return r * c;
                 }

                 const double Utils::pi = 3.14159;

                 double Utils::toRad(double value)
                 {
                        return value * pi / 180;
                 }

                void Utils::encapsule(dtn::data::Bundle &capsule, const std::list<dtn::data::Bundle> &bundles)
                {
                        bool custody = false;
                        size_t exp_time = 0;

                        try {
                                const dtn::data::PayloadBlock &payload = capsule.getBlock<dtn::data::PayloadBlock>();

                                // get the stream object of the payload
                                ibrcommon::BLOB::Reference ref = payload.getBLOB();

                                // clear the hole payload
                                ref.iostream().clear();

                                // encapsule the bundles into the BLOB
                                Utils::encapsule(ref, bundles);
                        } catch (const dtn::data::Bundle::NoSuchBlockFoundException&) {
                                ibrcommon::BLOB::Reference ref = ibrcommon::TmpFileBLOB::create();

                                // encapsule the bundles into the BLOB
                                Utils::encapsule(ref, bundles);

                                // add a new payload block
                                capsule.push_back(ref);
                        }

                        // get maximum lifetime
                        for (std::list<dtn::data::Bundle>::const_iterator iter = bundles.begin(); iter != bundles.end(); iter++)
                        {
                                const dtn::data::Bundle &b = (*iter);

                                // get the expiration time of this bundle
                                size_t expt = dtn::utils::Clock::getExpireTime(b);

                                // if this bundle expire later then use this lifetime
                                if (expt > exp_time) exp_time = expt;

                                // set custody to true if at least one bundle has custody requested
                                if (b.get(dtn::data::PrimaryBlock::CUSTODY_REQUESTED)) custody = true;
                        }

                        // set the bundle flags
                        capsule.set(dtn::data::PrimaryBlock::CUSTODY_REQUESTED, custody);

                        // set the new lifetime
                        capsule._lifetime = exp_time - capsule._timestamp;
                }

                void Utils::encapsule(ibrcommon::BLOB::Reference &ref, const std::list<dtn::data::Bundle> &bundles)
                {
                        ibrcommon::BLOB::iostream stream = ref.iostream();

                        // the number of encapsulated bundles
                        dtn::data::SDNV elements(bundles.size());
                        (*stream) << elements;

                        // create a serializer
                        dtn::data::DefaultSerializer serializer(*stream);

                        // write bundle offsets
                        std::list<dtn::data::Bundle>::const_iterator iter = bundles.begin();

                        for (size_t i = 0; i < (bundles.size() - 1); i++, iter++)
                        {
                                const dtn::data::Bundle &b = (*iter);
                                (*stream) << dtn::data::SDNV(serializer.getLength(b));
                        }

                        // serialize all bundles
                        for (std::list<dtn::data::Bundle>::const_iterator iter = bundles.begin(); iter != bundles.end(); iter++)
                        {
                                serializer << (*iter);
                        }
                }

                void Utils::decapsule(const dtn::data::Bundle &capsule, std::list<dtn::data::Bundle> &bundles)
                {
                        try {
                                const dtn::data::PayloadBlock &payload = capsule.getBlock<dtn::data::PayloadBlock>();
                                ibrcommon::BLOB::iostream stream = payload.getBLOB().iostream();

                                // read the number of bundles
                                dtn::data::SDNV nob; (*stream) >> nob;

                                // read all offsets
                                for (size_t i = 0; i < (nob.getValue() - 1); i++)
                                {
                                        dtn::data::SDNV offset; (*stream) >> offset;
                                }

                                // create a deserializer for all bundles
                                dtn::data::DefaultDeserializer deserializer(*stream);
                                dtn::data::Bundle b;

                                try {
                                        // read all bundles
                                        for (size_t i = 0; i < nob.getValue(); i++)
                                        {
                                                // deserialize the next bundle
                                                deserializer >> b;

                                                // add the bundle to the list
                                                bundles.push_back(b);
                                        }
                                }
                                catch (const dtn::InvalidDataException &ex) { };
                        } catch (const dtn::data::Bundle::NoSuchBlockFoundException&) { };
                }
        }
}