threaddict.cpp

Go to the documentation of this file.

/**************************************************************************

   begin                : Sat Sep 09 2007
   copyright            : (C) 2007 by Ewald Arnold
   email                : log4sendpp at ewald-arnold dot de

   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU Lesser General Public License as
   published by the Free Software Foundation; either version 2 of the License,
   or (at your option) any later version.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.

   You should have received a copy of the GNU Lesser General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.

 **/


#define LOG4SENDPP_NEED_EXPORTS
#include <log4sendpp/log4sendpp.h>  // always first header

#include <log4sendpp/mutex.h>
#include <log4sendpp/threaddict.h>
#include <log4sendpp/arguments.h>


LOG4SENDPP_NS_START


LOG4SENDPP_ANON_NS_START

  Mutex             dictMutex;  

LOG4SENDPP_NS_END


ThreadDictionary ThreadDictionary::threadDict;


LOG4SENDPP_API_IMPL0 ThreadDictionary::ThreadDictionary()
{
}


LOG4SENDPP_API_IMPL(void)
  ThreadDictionary::add(Handle handle, const LOG4SENDPP_STD_NS::string &nickname)
{
  LOG4SENDPP_STD_NS::string name = nickname;
  if (nickname.length() == 0)
    name = LOG4SENDPP_STD_NS::string("0x") + LOG4SENDPP_NS::number((unsigned long) handle, 16);

  Mutex::Locker lock (dictMutex);

  handles.push_back(handle);
  names.push_back(name);
}


LOG4SENDPP_API_IMPL(void) ThreadDictionary::remove(Handle handle)
{
  Mutex::Locker lock (dictMutex);

  for (int i = handles.size()-1; i >= 0; --i)
    if (handles[i] == handle)
    {
      handles.erase(handles.begin() + i);
      names.erase(names.begin() + i);
    }
}


LOG4SENDPP_API_IMPL(unsigned) ThreadDictionary::numThreads() const
{
  Mutex::Locker lock (dictMutex);

  return handles.size();
}


LOG4SENDPP_API_IMPL(LOG4SENDPP_STD_NS::string)
  ThreadDictionary::getNickname(Handle handle) const
{
  Mutex::Locker lock (dictMutex);

  for (unsigned i = 0; i < handles.size(); ++i)
    if (handles[i] == handle)
      return names[i];

  return "??";
}


LOG4SENDPP_API_IMPL(ThreadDictionary::Handle)
  ThreadDictionary::getCurrentHandle()
{
#ifdef __WIN32__
  return (HANDLE) GetCurrentThreadId();
#elif defined (__unix__)
   return pthread_self();
#else
 #error Plattform spezifischer Code fehlt
#endif
}


LOG4SENDPP_API_IMPL(LOG4SENDPP_STD_NS::string)
  ThreadDictionary::getCurrentNickname()
{
  return get()->getNickname(getCurrentHandle());
}


LOG4SENDPP_API_IMPL(ThreadDictionary *) ThreadDictionary::get()
{
  return &threadDict;
}


LOG4SENDPP_NS_END

---