#pragma once #include #include /* for epoll_create1(), epoll_ctl(), struct epoll_event */ #include #include #include "likely.h" #include "types.h" #define LISTENER_THREAD_CORE_ID 0 /* Dedicated Listener Core */ #define LISTENER_THREAD_MAX_EPOLL_EVENTS 128 #define RUNTIME_LOG_FILE "sledge.log" #define RUNTIME_MAX_SANDBOX_REQUEST_COUNT (1 << 19) /* random! */ #define RUNTIME_READ_WRITE_VECTOR_LENGTH 16 /* * Descriptor of the epoll instance used to monitor the socket descriptors of registered * serverless modules. The listener cores listens for incoming client requests through this. */ extern int runtime_epoll_file_descriptor; /* Optional path to a file to log sandbox perf metrics */ extern FILE *runtime_sandbox_perf_log; /* * Assumption: All cores are the same speed * See runtime_get_processor_speed_MHz for further details */ extern uint32_t runtime_processor_speed_MHz; /* Count of worker threads and array of their pthread identifiers */ extern pthread_t runtime_worker_threads[]; extern uint32_t runtime_worker_threads_count; void alloc_linear_memory(void); void expand_memory(void); INLINE char *get_function_from_table(uint32_t idx, uint32_t type_id); INLINE char *get_memory_ptr_for_runtime(uint32_t offset, uint32_t bounds_check); void runtime_initialize(void); void listener_thread_initialize(void); void stub_init(int32_t offset); unsigned long long __getcycles(void); /** * Used to determine if running in the context of a worker thread * @returns true if worker. false if listener core */ static inline bool runtime_is_worker() { pthread_t self = pthread_self(); for (int i = 0; i < runtime_worker_threads_count; i++) { if (runtime_worker_threads[i] == self) return true; } return false; } enum RUNTIME_SCHEDULER { RUNTIME_SCHEDULER_FIFO = 0, RUNTIME_SCHEDULER_EDF = 1 }; static inline char * print_runtime_scheduler(enum RUNTIME_SCHEDULER variant) { switch (variant) { case RUNTIME_SCHEDULER_FIFO: return "RUNTIME_SCHEDULER_FIFO"; case RUNTIME_SCHEDULER_EDF: return "RUNTIME_SCHEDULER_EDF"; } }; extern enum RUNTIME_SCHEDULER runtime_scheduler;