ThreadSafeContext.cpp File Reference

#include <iostream>
#include <fstream>
#include <sstream>
#include <iterator>
#include <memory>
#include <string.h>
#include <stdio.h>
#include <time.h>
#include "madara/logger/GlobalLogger.h"
#include "madara/utility/DeepIterator.h"
#include "madara/exceptions/MemoryException.h"
#include "madara/exceptions/FileException.h"
#include "madara/exceptions/FilterException.h"
#include "madara/utility/Utility.h"
#include "madara/knowledge/ThreadSafeContext.h"
#include "madara/knowledge/ContextGuard.h"
#include "madara/expression/Interpreter.h"
#include "madara/transport/Transport.h"
#include "madara/knowledge/CheckpointPlayer.h"

Go to the source code of this file.

Namespaces
	madara
	Copyright(c) 2020 Galois.
	madara::knowledge
	Provides functions and classes for the distributed knowledge base.

Functions
static void	madara::knowledge::checkpoint_do_incremental (const ThreadSafeContext &context, logger::Logger *logger_, uint64_t clock_, const CheckpointSettings &settings, std::fstream &file, FileHeader &meta, transport::MessageHeader &checkpoint_header)
static void	madara::knowledge::checkpoint_do_initial (const ThreadSafeContext &context, logger::Logger *logger_, uint64_t clock_, const CheckpointSettings &settings, std::fstream &file, FileHeader &meta, transport::MessageHeader &checkpoint_header)
static void	madara::knowledge::checkpoint_write_record (logger::Logger *logger_, const std::string &name, const KnowledgeRecord *record, const CheckpointSettings &settings, transport::MessageHeader &checkpoint_header, char *&current, utility::ScopedArray< char > &buffer, int64_t &buffer_remaining)
static void	madara::knowledge::checkpoint_write_records (const ThreadSafeContext &context, logger::Logger *logger_, const CheckpointSettings &settings, transport::MessageHeader &checkpoint_header, char *&current, utility::ScopedArray< char > &buffer, int64_t &buffer_remaining)
static char *	madara::knowledge::init_checkpoint_header (logger::Logger *logger_, uint64_t clock_, const CheckpointSettings &settings, FileHeader &meta, transport::MessageHeader &checkpoint_header, int64_t &buffer_remaining, utility::ScopedArray< char > &buffer)
static uint64_t	madara::knowledge::update_checkpoint_header (logger::Logger *logger_, uint64_t clock_, const CheckpointSettings &settings, std::fstream &file, FileHeader &meta, transport::MessageHeader &checkpoint_header, int64_t &buffer_remaining, utility::ScopedArray< char > &buffer)

Variable Documentation

clear_modifieds_

bool clear_modifieds_ = false

private

Definition at line 2521 of file ThreadSafeContext.cpp.

context_

const ThreadSafeContext* context_

private

Definition at line 2517 of file ThreadSafeContext.cpp.

guard_

std::unique_ptr<ContextGuard> guard_

private

Definition at line 2518 of file ThreadSafeContext.cpp.

iter_

VariableReferenceMap::iterator iter_

private

Definition at line 2520 of file ThreadSafeContext.cpp.

map_

VariableReferenceMap map_

private

Definition at line 2519 of file ThreadSafeContext.cpp.