src | |
common | |
communication.c | General-purpose socket communication functions used from global controller, runtime, or MSUs |
communication.h | Interface for general-purpose socket communication |
ctrl_runtime_messages.h | Definitions of structures for sending messages from the global controller to runtimes |
dfg.c | Code for the creation and modifcation of the data-flow graph |
dfg.h | Interfaces for the creation and modification of the data-flow-graph and and general description of the application running within DeDOS |
dfg_reader.c | Defines conversion of JSON strings to dedos_dfg |
dfg_reader.h | Declares function for converting JSON to dedos_dfg |
epollops.c | Wrapper functions for epoll to manage event-based communication |
epollops.h | Wrapper functions for epoll to manage event-based communication |
jsmn.c | Https://github.com/zserge/jsmn |
jsmn.h | |
jsmn_parser.c | General-purpose function to interact with JSMN library, and create objects (potentially with circular references) from the parsed json |
jsmn_parser.h | General-purpose function to interact with JSMN library, and create objects (potentially with circular references) from the parsed json |
local_files.c | Accessing local files within the repo |
local_files.h | Access local files within the repo |
logging.h | Logging of status messages to the terminal |
rt_controller_messages.h | Definitiions of structures for sending messages from runtimes to controller |
stat_ids.h | Declares the identifiers with which stats can be logged |
stats.c | Functions for the sending and receiving of statsitics between ctrl and runtime |
stats.h | Functions for the sending and receiving of statistics between ctrl and runtime |
unused_def.h | Macro for declaring functions or variables as unused to avoid compiler warnings |
uthash.h | |
global_controller | |
api.c | |
api.h | |
cli.c | |
cli.h | |
controller_dfg.c | |
controller_dfg.h | |
controller_mysql.c | |
controller_mysql.h | |
controller_stats.c | |
controller_stats.h | |
dedos_msu_msg_type.h | |
dfg_writer.c | |
dfg_writer.h | |
haproxy.c | |
haproxy.h | |
jsmn.h | |
main.c | |
msu_ids.h | |
runtime_communication.c | |
runtime_communication.h | |
runtime_messages.c | |
runtime_messages.h | |
scheduling.c | |
scheduling.h | |
scheduling_cut.h | |
scheduling_decision.c | |
scheduling_decision.h | |
socket_interface.c | |
socket_interface.h | |
stat_msg_handler.c | |
stat_msg_handler.h | |
test.c | |
timeseries.c | |
timeseries.h | |
msus | |
baremetal | |
baremetal_msu.c | |
baremetal_msu.h | |
baremetal_socket_msu.c | |
baremetal_socket_msu.h | |
webserver | |
cache_msu.c | |
cache_msu.h | |
connection-handler.c | |
connection-handler.h | |
dbops.c | |
dbops.h | |
fileio_msu.c | |
fileio_msu.h | |
http_msu.c | |
http_msu.h | |
http_parser.c | |
http_parser.h | |
httpops.c | |
httpops.h | |
read_msu.c | |
read_msu.h | |
regex.c | |
regex.h | |
regex_msu.c | |
regex_msu.h | |
regex_routing_msu.c | |
regex_routing_msu.h | |
request_parser.c | |
request_parser.h | |
socketops.c | |
socketops.h | |
sslops.c | |
sslops.h | |
uthash.h | |
webserver.h | |
write_msu.c | |
write_msu.h | |
socket_msu.c | |
socket_msu.h | |
runtime | |
controller_communication.c | Communication with global controller from runtime |
controller_communication.h | Communication with global controller from runtime |
dedos_threads.c | Control spawned threads with message queue within DeDOS |
dedos_threads.h | Control spawned threads with message queue within DeDOS |
dfg_instantiation.c | Instantiation of a dfg on a runtime |
dfg_instantiation.h | Instantiation of a dfg on a runtime |
inter_runtime_messages.h | Definitions of the message types that can be passed between runtimes |
local_msu.c | Defines the structures and functions used by MSUs on the local machine |
local_msu.h | Declares the structures and functions applicable to MSUs on the local machine |
main.c | Main executable file to start the runtime |
message_queue.c | Structures and functions for enqueueing and dequeuing general-purpose messages from a queue |
message_queue.h | Structures and functions for enqueueing and dequeuing general-purpose messages from a queue |
msu_calls.c | Defines methods used for calling MSUs from other MSUs |
msu_calls.h | Declares the methods available for calling an MSU from another MSU |
msu_message.c | |
msu_message.h | Messages passed to MSUs |
msu_state.c | State storage that is tied to a specific MSU message |
msu_state.h | State storage that is tied to a specific MSU mesasge |
msu_type.c | Registration and location of msu types |
msu_type.h | Defines a type of MSU, including callback and accessor functions |
msu_type_list.h | Defines the list of MSUs that can be instantiated on a runtime |
output_thread.c | A dedos_thread which monitors a queue for output to be sent to other runtimes or the global controller |
output_thread.h | A dedos_thread which monitors a queue for output to be sent to other runtimes or the global controller |
profiler.c | For profiling the path of MSU messages through DeDOS |
profiler.h | For profiling the path of MSU messages through DeDOS |
routing.c | Functions for routing MSU messages between MSUs |
routing.h | Functions for routing MSU messages between MSUs |
routing_strategies.c | Defines strategies that MSUs can use for routing to endpoints |
routing_strategies.h | Declares strategies that MSUs can use for routing to endpoints |
rt_stats.c | Collecting statistics within the runtime |
rt_stats.h | Collecting statistics within the runtime |
runtime_communication.c | All communication to and from other runtimes |
runtime_communication.h | Socket-handling between runtimes |
runtime_dfg.c | Interactions with the global dfg from an individual runtime's perspective |
runtime_dfg.h | Interactions with global dfg from individual runtime |
socket_monitor.c | Monitors an incoming port for messages from runtime or controller |
socket_monitor.h | Monitors an incoming port for messages from runtime or controller |
thread_message.c | Messages to be delivered to dedos_threads |
thread_message.h | Messages to be delivered to dedos_threads |
worker_thread.c | Threads that hold MSUs |
worker_thread.h | Threads that hold MSUs |