#include <application/application_shell.h>
#include <application/hoople_main.h>
#include <basis/astring.h>
#include <basis/byte_array.h>
#include <basis/functions.h>
#include <basis/guards.h>
#include <basis/mutex.h>
#include <configuration/application_configuration.h>
#include <loggers/console_logger.h>
#include <mathematics/chaos.h>
#include <octopus/entity_data_bin.h>
#include <octopus/entity_defs.h>
#include <octopus/unhandled_request.h>
#include <processes/ethread.h>
#include <processes/safe_roller.h>
#include <structures/amorph.h>
#include <structures/static_memory_gremlin.h>
#include <structures/string_array.h>
#include <textual/string_manipulation.h>
#include <timely/time_control.h>
#include <timely/time_stamp.h>
#include <unit_test/unit_base.h>
#include <stdio.h>

Include dependency graph for test_bin_threaded.cpp:

Macros
#define	LOG(s)

#define	BASE_LOG(s)

#define	randomizer() _rando()

Functions
	SAFE_STATIC (console_logger, ted,)

	SAFE_STATIC (bool_scared_ya, __threads_can_run_wild_and_free,(false))

	SAFE_STATIC (chaos, _rando,)

octopus_request_id	create_request_id ()

Variables
const int	MAXIMUM_CHARS_PER_LINE = 108

const int	DEFAULT_RUN_TIME = 4 * SECOND_ms

const int	MAXIMUM_DATA_PER_ENTITY = 5 * KILOBYTE

const int	MIN_ADDER_THREAD_PAUSE = 3

const int	MAX_ADDER_THREAD_PAUSE = 20

const int	MIN_WHACKER_THREAD_PAUSE = 8

const int	MAX_WHACKER_THREAD_PAUSE = 70

const int	MIN_TIDIER_THREAD_PAUSE = 60

const int	MAX_TIDIER_THREAD_PAUSE = 500

const int	MIN_MONK_THREAD_PAUSE = 14 * SECOND_ms

const int	MAX_MONK_THREAD_PAUSE = 28 * SECOND_ms

const int	MINIMUM_ITEMS_HANDLED = 1

const int	MAXIMUM_ITEMS_HANDLED = 20

const int	DEFAULT_THREADS = 90

const int	DATA_DECAY_TIME = 1 * MINUTE_ms

const int	MONKS_CLEANING_TIME = 10 * SECOND_ms

entity_data_bin	binger (MAXIMUM_DATA_PER_ENTITY)

Macro Definition Documentation

◆ BASE_LOG

#define BASE_LOG ( s )

Value:

  { \
  auto_synchronizer critical_section(__loggers_lock()); \
  /* we set the eol every time, since console_logger constructor doesn't currently provide. */ \
  ted().eol(parser_bits::NO_ENDING); \
  astring joe(s); \
  int len = joe.length(); \
  /* naive check for line length. */ \
  if (chars_printed + len > MAXIMUM_CHARS_PER_LINE) { \
    ted().log(astring("\n"), basis::ALWAYS_PRINT); \
    chars_printed = 0; \
  } \
  chars_printed += len; \
  ted().log(joe, basis::ALWAYS_PRINT); \
}

Definition at line 75 of file test_bin_threaded.cpp.

◆ LOG

#define LOG ( s )

Value:

  { \
  auto_synchronizer critical_section(__loggers_lock()); \
  CLASS_EMERGENCY_LOG(program_wide_logger::get(), astring(s)); \
}

Definition at line 61 of file test_bin_threaded.cpp.

◆ randomizer

#define randomizer ( ) _rando()

Definition at line 159 of file test_bin_threaded.cpp.

Function Documentation

◆ create_request_id()

octopus_request_id create_request_id ( )

Definition at line 165 of file test_bin_threaded.cpp.

References octopi::octopus_request_id::_entity, octopi::octopus_request_id::_request_num, MAXINT32, and randomizer.

◆ SAFE_STATIC() [1/3]

SAFE_STATIC	(	bool_scared_ya	,
		__threads_can_run_wild_and_free	,
		(false)
	)

◆ SAFE_STATIC() [2/3]

SAFE_STATIC	(	chaos	,
		_rando
	)

◆ SAFE_STATIC() [3/3]

SAFE_STATIC	(	console_logger	,
		ted
	)

Variable Documentation

◆ binger

entity_data_bin binger(MAXIMUM_DATA_PER_ENTITY) ( MAXIMUM_DATA_PER_ENTITY )

◆ DATA_DECAY_TIME

const int DATA_DECAY_TIME = 1 * MINUTE_ms

Definition at line 146 of file test_bin_threaded.cpp.

◆ DEFAULT_RUN_TIME

const int DEFAULT_RUN_TIME = 4 * SECOND_ms

Definition at line 115 of file test_bin_threaded.cpp.

◆ DEFAULT_THREADS

const int DEFAULT_THREADS = 90

Definition at line 143 of file test_bin_threaded.cpp.

◆ MAX_ADDER_THREAD_PAUSE

const int MAX_ADDER_THREAD_PAUSE = 20

Definition at line 124 of file test_bin_threaded.cpp.

◆ MAX_MONK_THREAD_PAUSE

const int MAX_MONK_THREAD_PAUSE = 28 * SECOND_ms

Definition at line 137 of file test_bin_threaded.cpp.

◆ MAX_TIDIER_THREAD_PAUSE

const int MAX_TIDIER_THREAD_PAUSE = 500

Definition at line 133 of file test_bin_threaded.cpp.

◆ MAX_WHACKER_THREAD_PAUSE

const int MAX_WHACKER_THREAD_PAUSE = 70

Definition at line 129 of file test_bin_threaded.cpp.

◆ MAXIMUM_CHARS_PER_LINE

const int MAXIMUM_CHARS_PER_LINE = 108

Definition at line 73 of file test_bin_threaded.cpp.

◆ MAXIMUM_DATA_PER_ENTITY

const int MAXIMUM_DATA_PER_ENTITY = 5 * KILOBYTE

Definition at line 119 of file test_bin_threaded.cpp.

◆ MAXIMUM_ITEMS_HANDLED

const int MAXIMUM_ITEMS_HANDLED = 20

Definition at line 141 of file test_bin_threaded.cpp.

◆ MIN_ADDER_THREAD_PAUSE

const int MIN_ADDER_THREAD_PAUSE = 3

Definition at line 123 of file test_bin_threaded.cpp.

◆ MIN_MONK_THREAD_PAUSE

const int MIN_MONK_THREAD_PAUSE = 14 * SECOND_ms

Definition at line 136 of file test_bin_threaded.cpp.

◆ MIN_TIDIER_THREAD_PAUSE

const int MIN_TIDIER_THREAD_PAUSE = 60

Definition at line 132 of file test_bin_threaded.cpp.

◆ MIN_WHACKER_THREAD_PAUSE

const int MIN_WHACKER_THREAD_PAUSE = 8

Definition at line 128 of file test_bin_threaded.cpp.

◆ MINIMUM_ITEMS_HANDLED

const int MINIMUM_ITEMS_HANDLED = 1

Definition at line 140 of file test_bin_threaded.cpp.

◆ MONKS_CLEANING_TIME

const int MONKS_CLEANING_TIME = 10 * SECOND_ms

Definition at line 149 of file test_bin_threaded.cpp.

Macros

Functions

Variables