test_sequencer_concurrency.cpp File Reference

#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>
#include <atomic>
#include <chrono>
#include <cstdio>
#include <fstream>
#include <iostream>
#include <string>
#include <thread>
#include <vector>
#include "control/SequencerService.hpp"
#include "control/StateMachine.hpp"

Include dependency graph for test_sequencer_concurrency.cpp:

Go to the source code of this file.

Enumerations
enum class	State
	System state IDs — must match the TypeScript SystemState enum in web-gui/shared/types.ts. More...

Functions
static void	check (bool ok, const std::string &what)
static void	fakeController (int listen_fd, std::atomic< bool > &run)
	Minimal stand-in for controller_service: accept, drain, close.
static int	bindEphemeral (uint16_t &out_port)
int	main ()

Variables
static int	g_failures = 0

Enumeration Type Documentation

State

enum class sequencer::State : uint8_t

strong

System state IDs — must match the TypeScript SystemState enum in web-gui/shared/types.ts.

Definition at line 14 of file StateMachine.hpp.

Function Documentation

bindEphemeral()

int bindEphemeral ( uint16_t & out_port )

static

Definition at line 84 of file test_sequencer_concurrency.cpp.

References a.

Referenced by main().

check()

void check ( bool ok, const std::string & what )

static

Definition at line 62 of file test_sequencer_concurrency.cpp.

References g_failures, and ok.

Referenced by main().

fakeController()

void fakeController ( int listen_fd, std::atomic< bool > & run )

static

Minimal stand-in for controller_service: accept, drain, close.

Without it every fire transition pays notifyControllerFire's connect timeout and the test crawls.

Definition at line 70 of file test_sequencer_concurrency.cpp.

Referenced by main().

main()

int main

(

)

Definition at line 100 of file test_sequencer_concurrency.cpp.

References bindEphemeral(), check(), sequencer::SequencerService::currentState(), fakeController(), StateMachine::fromName(), g_failures, sequencer::SequencerService::init(), sequencer::SequencerService::setDebugMode(), and sequencer::SequencerService::transitionTo().

Variable Documentation

g_failures

int g_failures = 0

static

Definition at line 60 of file test_sequencer_concurrency.cpp.