test_bothservers.cpp

// Copyright (C) 2009-2010 Institut de Robòtica i Informàtica Industrial, CSIC-UPC.
// Author Sergi Hernandez  (shernand@iri.upc.edu)
// All rights reserved.
//
// This file is part of iriutils
// iriutils 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 3 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 Lesser 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, see <http://www.gnu.org/licenses/>.

#include "eventserver.h"
#include "threadserver.h"
#include <stdio.h>
#include <unistd.h>
#include <iostream>
#include "log.h"

const std::string thread1_id="thread1";
const std::string thread2_id="thread2";

const std::string event1_id="event1";
const std::string event2_id="event2";
const std::string event3_id="event3";

void *thread1_function(void *param)
{
  std::list<std::string> event_list1;
  CEventServer *event_server=CEventServer::instance();
  CLog thread_log("thread1");

  event_list1.push_back(event1_id);
  std::cout << "Thread1 - Waiting for event " << event1_id << std::endl;
  thread_log.log((const std::string)"Thread1 - Waiting for event" + event1_id);
  event_server->wait_first(event_list1);
  std::cout << "Thread1 - Event " << event1_id << " received" << std::endl;
//  thread_log.log((const std::string)"Thread1 - Event " + event1_id + " received");
//  std::cout << "Thread1 - Sending event " << event2_id << std::endl;
//  thread_log.log((const std::string)"Thread1 - Sending event" + event2_id);
//  event_server->set_event(event2_id);
//  sleep(2);
//  std::cout << "Thread1 - Sending event " << event3_id << std::endl;
//  thread_log.log((const std::string)"Thread1 - Sending event" + event3_id);
//  event_server->set_event(event3_id);
//  std::cout << "Thread1 - Ending" << std::endl;
//  thread_log.log((const std::string)"Thread1 - Ending");

  pthread_exit(NULL);
}

void *thread2_function(void *param)
{
  std::list<std::string> event_list2;
  CEventServer *event_server=CEventServer::instance();
  CLog thread_log("thread2");

  event_list2.push_back(event1_id);
  std::cout << "Thread2 - Waiting for event " << event1_id << std::endl;
  thread_log.log((const std::string)"Thread2 - Waiting for event" + event1_id);
  event_server->wait_first(event_list2);
  std::cout << "Thread2 - Event " << event1_id << " received" << std::endl;
//  event_list2.push_back(event2_id);
//  event_list2.push_back(event3_id);
//  std::cout << "Thread2 - Sending event " << event1_id << std::endl;
//  thread_log.log((const std::string)"Thread2 - Sending event " + event1_id);
//  event_server->set_event(event1_id);
//  std::cout << "Thread2 - Waiting for event " << event2_id << std::endl;
//  thread_log.log((const std::string)"Thread2 - Waiting for event " + event2_id);
//  event_server->wait_all(event_list2);
//  std::cout << "Thread2 - Event " << event2_id << " and " << event3_id << " received" << std::endl;
//  thread_log.log((const std::string)"Thread2 - Event " + event2_id + " and " + event3_id + " received");
//  std::cout << "Thread2 - Ending" << std::endl;
//  thread_log.log((const std::string)"Thread2 - Ending");

  pthread_exit(NULL);
}

int main(int argc,char *argv[])
{
  CEventServer *event_server=CEventServer::instance();
  CThreadServer *thread_server=CThreadServer::instance();
  CLog main_log("main");

  //thread test
  main_log.log("Creating events ...");
  event_server->create_event(event1_id);
  event_server->create_event(event2_id);
  event_server->create_event(event3_id);

  main_log.log((const std::string)"Creating threads ...");
  thread_server->create_thread(thread1_id);
  thread_server->create_thread(thread2_id);
  thread_server->attach_thread(thread1_id,thread1_function,NULL);
  thread_server->attach_thread(thread2_id,thread2_function,NULL);
  main_log.log((const std::string)"Starting thread 1 ...");
  thread_server->start_thread(thread1_id);
  sleep(3);
  main_log.log((const std::string)"Starting thread 2 ...");
  thread_server->start_thread(thread2_id);
  sleep(3);
  event_server->set_event(event1_id);
  sleep(2);
  event_server->set_event(event1_id);
  sleep(2);
  thread_server->end_thread(thread2_id);
  thread_server->end_thread(thread1_id);
  std::cout << "End of the program" << std::endl;
  main_log.log((const std::string)"End of the program");
}