SysHelper.h

Go to the documentation of this file.

// Copyright 2014 GSI, Inc. All rights reserved.
//
// This file contains a number of helpers and wrappers of system calls.
//
#ifndef _DDS_SYSHELPER_H_
#define _DDS_SYSHELPER_H_

// API
#include <fcntl.h>
#include <limits.h>
#include <netdb.h>
#include <pwd.h>
#include <sys/stat.h>
#include <sys/syscall.h>
#include <sys/types.h>
#include <unistd.h>
#ifdef __APPLE__
#include <sys/sysctl.h>
#endif

// STD
#include <typeinfo>
// BOOST
#include <boost/asio.hpp>

// HACK: On the SLC3 HOST_NAME_MAX is undefined
#ifndef HOST_NAME_MAX
#define HOST_NAME_MAX 64
#endif

// Misc
#include "ErrorCode.h"
#include "MiscUtils.h"
#include "def.h"

namespace dds::misc
{
    inline void get_cuser_name(std::string* _RetVal)
    {
        if (!_RetVal)
            return;

        passwd* pwd(getpwuid(geteuid()));
        *_RetVal = pwd ? std::string(pwd->pw_name) : "";
    }
    inline void get_homedir(uid_t _uid, std::string* _RetVal)
    {
        if (!_RetVal)
            return;

        passwd* pwd = getpwuid(_uid);
        *_RetVal = pwd ? std::string(pwd->pw_dir) : "";
    }
    inline void get_homedir(const char* _UName, std::string* _RetVal)
    {
        if (!_RetVal)
            return;

        passwd* pwd = getpwnam(_UName);
        *_RetVal = pwd ? std::string(pwd->pw_dir) : "";
    }
    inline void get_cuser_homedir(std::string* _RetVal)
    {
        get_homedir(getuid(), _RetVal);
    }
    template <class _T>
    inline void smart_path(_T* _Path)
    {
        if (nullptr == _Path || _Path->empty())
            return;

        // Checking for "~/"
        std::string path(*_Path);
        trim_left(&path, ' ');
        if ('~' == path[0])
        {
            std::string path(*_Path);
            // ~/.../.../
            if ('/' == path[1])
            {
                std::string sHome;
                get_cuser_homedir(&sHome);
                smart_append(&sHome, '/');

                path.erase(path.begin(), path.begin() + 2);
                sHome += path;
                path.swap(sHome);
                _Path->swap(path);
            }
            else // ~user/.../.../
            {
                typename _T::size_type p = path.find(_T( "/" ));
                if (_T::npos != p)
                {
                    const std::string uname = path.substr(1, p - 1);
                    std::string home_dir;
                    get_homedir(uname.c_str(), &home_dir);
                    path.erase(path.begin(), path.begin() + p);
                    path = home_dir + path;
                    _Path->swap(path);
                }
            }
        }

        typename _T::size_type p_begin = _Path->find(_T( "$" ));
        if (_T::npos == p_begin)
        {
            // make the path to be the canonicalized absolute pathname
            char resolved_path[PATH_MAX];
            char* res = realpath(_Path->c_str(), resolved_path);
            if (NULL != res)
            {
                // add trailing slash if needed, since realpath removes it
                std::string::iterator it = _Path->end() - 1;
                bool trailing_slash = (*it == '/');
                *_Path = resolved_path;
                if (trailing_slash)
                    smart_append(_Path, '/');
            };

            return;
        }

        ++p_begin; // Excluding '$' from the name

        typename _T::size_type p_end = _Path->find(_T( "/" ), p_begin);
        if (_T::npos == p_end)
            p_end = _Path->size();

        const _T env_var(_Path->substr(p_begin, p_end - p_begin));
        // TODO: needs to be fixed to wide char: getenv
        LPCTSTR szvar(getenv(env_var.c_str()));
        if (!szvar)
            return;
        const _T var_val(szvar);
        if (var_val.empty())
            return;

        replace(_Path, _T( "$" ) + env_var, var_val);

        smart_path(_Path);
    }
    template <class _T>
    inline _T smart_path(const _T& _Path)
    {
        _T tmp(_Path);
        smart_path(&tmp);
        return tmp;
    }
    inline void get_hostname(std::string* _RetVal)
    {
        if (!_RetVal)
            return;

        *_RetVal = boost::asio::ip::host_name();
    }

    inline unsigned long gettid()
    {
#ifdef __APPLE__
        union
        {
            pthread_t th;
            unsigned long int i;
        } v = {};
        v.th = pthread_self();
        return v.i;
#elif __linux
        return syscall(__NR_gettid);
#else
        return 0;
#endif
    }

    class CMutex
    {
      public:
        CMutex()
        {
            pthread_mutex_init(&m, 0);
        }

        void Lock()
        {
            pthread_mutex_lock(&m);
        }

        void Unlock()
        {
            pthread_mutex_unlock(&m);
        }

      private:
        pthread_mutex_t m;
    };
    class smart_mutex : public NONCopyable
    {
      public:
        smart_mutex(CMutex& _mutex)
            : m(_mutex)
        {
            m.Lock();
        }
        ~smart_mutex()
        {
            m.Unlock();
        }

      private:
        CMutex& m;
    };

    extern "C" char* __cxa_demangle(const char* mangled, char* buf, size_t* len, int* status);
    inline std::string demangle(const std::type_info& ti)
    {
        char* s = __cxa_demangle(ti.name(), 0, 0, 0);
        std::string ret(s);
        free(s);
        return ret;
    }

    inline void get_env(const std::string& _EnvVarName, std::string* _RetVal)
    {
        if (!_RetVal)
            return;

        char* szBuf(getenv(_EnvVarName.c_str()));
        if (szBuf)
            _RetVal->assign(szBuf);
    }
    inline off_t file_size(const std::string& _FileName)
    {
        const int fd(::open(_FileName.c_str(), O_RDONLY));
        if (-1 == fd)
            throw system_error("Can't get file size of \"" + _FileName + "\"");

        struct stat fs;
        const int ret(::fstat(fd, &fs));
        close(fd);

        if (-1 == ret)
            throw system_error("Can't get file size of \"" + _FileName + "\"");

        return fs.st_size;
    }
    inline bool file_exists(const std::string& _FileName)
    {
        try
        {
            file_size(_FileName);
            return true;
        }
        catch (...)
        {
            return false;
        }
    }
    inline size_t getNCores()
    {
        size_t numCPU(1);
#ifdef __APPLE__ // FreeBSD, MacOS X, NetBSD, OpenBSD, etc.
        int mib[4];
        size_t len = sizeof(numCPU);

        /* set the mib for hw.ncpu */
        mib[0] = CTL_HW;
        mib[1] = HW_AVAILCPU; // alternatively, try HW_NCPU;

        /* get the number of CPUs from the system */
        sysctl(mib, 2, &numCPU, &len, NULL, 0);

        if (numCPU < 1)
        {
            mib[1] = HW_NCPU;
            sysctl(mib, 2, &numCPU, &len, NULL, 0);

            if (numCPU < 1)
            {
                numCPU = 1;
            }
        }
#elif __linux // Linux, Solaris, & AIX (per comments)
        numCPU = sysconf(_SC_NPROCESSORS_ONLN);
#endif
        return numCPU;
    }
};     // namespace dds::misc
#endif /*_DDS_SYSHELPER_H_*/