test_subscription_tracker.cpp File Reference

#include <arpa/inet.h>
#include <netinet/in.h>
#include <sys/socket.h>
#include <unistd.h>
#include <atomic>
#include <chrono>
#include <cstring>
#include <iostream>
#include <set>
#include <thread>
#include <vector>
#include "elodin/ElodinClient.hpp"
#include "elodin/SubscriptionTracker.hpp"

Include dependency graph for test_subscription_tracker.cpp:

Go to the source code of this file.

Classes
class	SubscriptionTracker
	SubscriptionTracker + ElodinClient::subscribe_table: a subscription the DB refuses is asked for again, and only that one. More...

Macros
#define	CHECK(cond)

Functions
static void	test_error_response_is_recognised ()
static void	test_refused_table_is_asked_for_again ()
static void	test_accepted_table_is_never_asked_for_twice ()
static void	test_unknown_request_id_names_nothing ()
static void	test_ids_rotate_and_skip_0_and_255 ()
static void	test_reset_forgets_everything ()
static void	test_request_id_is_on_the_wire ()
	subscribe_table puts the request id where the DB echoes it from: header byte 7.
int	main ()

Variables
static int	g_failures = 0

Macro Definition Documentation

CHECK

#define CHECK

(

cond

)

Value:

    do {                                                                 \
        if (!(cond)) {                                                   \
            std::cerr << "FAIL " << __LINE__ << ": " #cond << std::endl; \
            g_failures++;                                                \
        }                                                                \
    } while (0)

Definition at line 30 of file test_subscription_tracker.cpp.

Referenced by test_accepted_table_is_never_asked_for_twice(), test_error_response_is_recognised(), test_ids_rotate_and_skip_0_and_255(), test_refused_table_is_asked_for_again(), test_request_id_is_on_the_wire(), test_reset_forgets_everything(), and test_unknown_request_id_names_nothing().

Function Documentation

main()

int main

(

)

Definition at line 150 of file test_subscription_tracker.cpp.

References g_failures, test_accepted_table_is_never_asked_for_twice(), test_error_response_is_recognised(), test_ids_rotate_and_skip_0_and_255(), test_refused_table_is_asked_for_again(), test_request_id_is_on_the_wire(), test_reset_forgets_everything(), and test_unknown_request_id_names_nothing().

test_accepted_table_is_never_asked_for_twice()

void test_accepted_table_is_never_asked_for_twice ( )

static

Definition at line 64 of file test_subscription_tracker.cpp.

References fsw::elodin::SubscriptionTracker::assign(), CHECK, fsw::elodin::SubscriptionTracker::due(), and fsw::elodin::SubscriptionTracker::refused().

Referenced by main().

test_error_response_is_recognised()

void test_error_response_is_recognised ( )

static

Definition at line 38 of file test_subscription_tracker.cpp.

References CHECK, and fsw::elodin::is_error_response().

Referenced by main().

test_ids_rotate_and_skip_0_and_255()

void test_ids_rotate_and_skip_0_and_255 ( )

static

Definition at line 81 of file test_subscription_tracker.cpp.

References fsw::elodin::SubscriptionTracker::assign(), and CHECK.

Referenced by main().

test_refused_table_is_asked_for_again()

void test_refused_table_is_asked_for_again ( )

static

Definition at line 47 of file test_subscription_tracker.cpp.

References fsw::elodin::SubscriptionTracker::assign(), CHECK, fsw::elodin::SubscriptionTracker::due(), fsw::elodin::SubscriptionTracker::refused(), and fsw::elodin::SubscriptionTracker::rejected().

Referenced by main().

test_request_id_is_on_the_wire()

void test_request_id_is_on_the_wire ( )

static

subscribe_table puts the request id where the DB echoes it from: header byte 7.

Definition at line 104 of file test_subscription_tracker.cpp.

References a, CHECK, port, and read().

Referenced by main().

test_reset_forgets_everything()

void test_reset_forgets_everything ( )

static

Definition at line 92 of file test_subscription_tracker.cpp.

References fsw::elodin::SubscriptionTracker::assign(), CHECK, fsw::elodin::SubscriptionTracker::due(), fsw::elodin::SubscriptionTracker::rejected(), and fsw::elodin::SubscriptionTracker::reset().

Referenced by main().

test_unknown_request_id_names_nothing()

void test_unknown_request_id_names_nothing ( )

static

Definition at line 74 of file test_subscription_tracker.cpp.

References CHECK, fsw::elodin::SubscriptionTracker::refused(), and fsw::elodin::SubscriptionTracker::rejected().

Referenced by main().

Variable Documentation

g_failures

int g_failures = 0

static

Definition at line 29 of file test_subscription_tracker.cpp.