t_sequence_tracker.cpp

Go to the documentation of this file.

/*****************************************************************************\
*                                                                             *
*  Name   : test_sequence_tracker                                             *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*  Purpose:                                                                   *
*                                                                             *
*    Runs a couple of tests on the sequence tracker object.                   *
*                                                                             *
*******************************************************************************
* Copyright (c) 2003-$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/chaos.h>
#include <basis/istring.h>
#include <basis/set.cpp>
#include <opsystem/application_shell.h>
#include <data_struct/static_memory_gremlin.h>
#include <loggers/console_logger.h>
#include <sockets/machine_uid.h>
#include <sockets/sequence_tracker.h>

#include <stdio.h>
#include <string.h>

class test_sequence_tracker : public application_shell
{
public:
  test_sequence_tracker() : application_shell(class_name()) {}
  IMPLEMENT_CLASS_NAME("test_sequence_tracker");
  virtual int execute();
};

int test_sequence_tracker::execute()
{
  // some arbitrary ip addresses.
  byte arb1[] = { 127, 0, 0, 1 };
  byte arb2[] = { 192, 168, 0, 1 };
  byte arb3[] = { 28, 42, 56, 253 };

  machine_uid eep(machine_uid::TCPIP_LOCATION, byte_array(4, arb1));
  machine_uid op(machine_uid::TCPIP_LOCATION, byte_array(4, arb2));
  machine_uid ork(machine_uid::TCPIP_LOCATION, byte_array(4, arb3));

  sequence_tracker chevy(1 * MINUTE_ms, 10 * MINUTE_ms);

  int_set eep_set;
  int adds = randomizer().inclusive(400, 900);
  int starter = 12092;
  while (adds--) {
    int seq = starter + randomizer().inclusive(1, 129);
    eep_set += seq;
    chevy.add_pair(eep, seq);
  }

  int_set op_set;
  adds = randomizer().inclusive(200, 600);
  starter = 1222;
  while (adds--) {
    int seq = starter + randomizer().inclusive(1, 129);
    op_set += seq;
    chevy.add_pair(op, seq);
  }

  int_set ork_set;
  adds = randomizer().inclusive(200, 600);
  starter = 992981;
  while (adds--) {
    int seq = starter + randomizer().inclusive(1, 129);
    ork_set += seq;
    chevy.add_pair(ork, seq);
  }

  int i;
  for (i = 0; i < eep_set.elements(); i++) {
    int seq = eep_set[i];
    if (!chevy.have_seen(eep, seq)) {
      log(isprintf("missing sequence is %d", seq));
      log(chevy.text_form(true));
      deadly_error("test_sequence_tracker", "eep check", "missing sequence");
    }
  }
  for (i = 0; i < op_set.elements(); i++) {
    int seq = op_set[i];
    if (!chevy.have_seen(op, seq)) {
      log(isprintf("missing sequence is %d", seq));
      log(chevy.text_form(true));
      deadly_error("test_sequence_tracker", "op check", "missing sequence");
    }
  }
  for (i = 0; i < ork_set.elements(); i++) {
    int seq = ork_set[i];
    if (!chevy.have_seen(ork, seq)) {
      log(isprintf("missing sequence is %d", seq));
      log(chevy.text_form(true));
      deadly_error("test_sequence_tracker", "ork check", "missing sequence");
    }
  }

  log("sequence_tracker:: works for those functions tested.");
  return 0;
}

HOOPLE_MAIN(test_sequence_tracker, )

---