paco_thread.cc

Go to the documentation of this file.

#if 0
#include "paco_thread.h"

// Implementation of paco_mutex

paco_mutex::~paco_mutex() {}


// Implementation of paco_condition

paco_condition::~paco_condition() {}

// Implementation of paco_fabrique_thread

paco_fabrique_thread::paco_fabrique_thread() {}
paco_fabrique_thread::~paco_fabrique_thread() {}

void paco_fabrique_thread::paco_register(const string& lib_thread, paco_individual_fabrique_thread * pift) {

  thread_map_t::iterator it = _thread_map.find(lib_thread);

  if (it == _thread_map.end() ) {
    _thread_map[lib_thread] = pift;
  } else {
    cerr << "Ignoring: already register thread lib " << lib_thread << endl;
  }

}
  
paco_mutex* 
paco_fabrique_thread::paco_create_mutex(const string& lib_thread)
{
  thread_map_t::iterator it = _thread_map.find(lib_thread);

  if (it == _thread_map.end() ) {
    cerr << "Not found thread lib " << lib_thread << endl;
    return NULL;
  } else {
    //    cout << "Going to call paco_create_mutex of @ " << it->second << endl;
    return it->second->paco_create_mutex();
  }
}

paco_condition* 
paco_fabrique_thread::paco_create_condition(const string& lib_thread, paco_mutex * mutex)
{
  thread_map_t::iterator it = _thread_map.find(lib_thread);

  if (it == _thread_map.end() ) {
    cerr << "Not found thread lib " << lib_thread << endl;
    return NULL;
  } else {
    //    cout << "Going to call paco_create_condition of @ " << it->second << endl;
    return it->second->paco_create_condition((paco_mutex*) mutex);
  }
}
paco_thread *
paco_fabrique_thread::paco_create_thread(const string& lib_thread, void* (*fn)(void*), void* arg)
  {
    thread_map_t::iterator it = _thread_map.find(lib_thread);

    if (it == _thread_map.end() ) 
      {
   cerr << "Not found thread lib " << lib_thread << endl;
   return NULL;
      } 
    else 
      {
   return it->second->paco_create_thread(fn, arg);
      }
  }
paco_thread *
paco_fabrique_thread::paco_create_thread(const string& lib_thread, void (*fn)(void*), void* arg)
  {
    thread_map_t::iterator it = _thread_map.find(lib_thread);

    if (it == _thread_map.end() ) 
      {
   cerr << "Not found thread lib " << lib_thread << endl;
   return NULL;
      } 
    else 
      {
   return it->second->paco_create_thread(fn, arg);
      }
  }
#endif