t_rendezvous.cpp

Go to the documentation of this file.

/*****************************************************************************\
*                                                                             *
*  Name   : test of rendezvous object                                         *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*******************************************************************************
* Copyright (c) 2004-$now By Author.  This program is free software; you can  *
* redistribute it and/or modify it under the terms of the GNU General Public  *
* License as published by the Free Software Foundation; either version 2 of   *
* the License or (at your option) any later version.  This is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include <basis/byte_array.h>
#include <basis/function.h>
#include <basis/guards.h>
#include <opsystem/application_shell.h>
#include <loggers/console_logger.h>
#include <loggers/file_logger.h>
#include <opsystem/rendezvous.h>
#include <data_struct/static_memory_gremlin.h>

#include <stdio.h>

const int CHECKING_INTERVAL = 200;
  // this many milliseconds elapses between timer hits.

#define LOG(s) CLASS_EMERGENCY_LOG(program_wide_logger(), s)


class test_rendezvous : public application_shell
{
public:
  test_rendezvous()
  : application_shell(class_name()),
    _got_lock(false),
    _mutt("rendezvous_testers_rendezvous_lock") {}

  ~test_rendezvous() {
  }

  IMPLEMENT_CLASS_NAME("test_rendezvous");

  bool already_running(rendezvous::locking_methods how_to_check) {
    FUNCDEF("already_running");
    LOG("checking whether the application is already running...");
    _got_lock = _mutt.lock(how_to_check);
    return !_got_lock;
  }

  int execute() {
    FUNCDEF("execute");
    rendezvous::locking_methods check_mode = rendezvous::IMMEDIATE_RETURN;
//    LOG("note: you can pass -infinite if you want to wait for rendezvous.");
    if (__argc >= 2) {
      istring flag = __argv[1];
      if (flag.contains("infinite")) {
        check_mode = rendezvous::ENDLESS_WAIT;
      }
    }
    if (already_running(check_mode)) {
      LOG("the application was already running.");
      return 1;
    }
    LOG("this is the only instance running.  hit enter to leave.");
    getchar();
    return 0;
  }

private:
  bool _got_lock;
  rendezvous _mutt;
};
    

HOOPLE_MAIN(test_rendezvous, )

---