From ec688b4723a041044226358bcd4dd6e2da39da49 Mon Sep 17 00:00:00 2001 From: Luca Muscariello Date: Thu, 23 Feb 2017 17:01:02 +0100 Subject: Initial commit: cframework. Longbow and Libparc Change-Id: I90378dbd30da6033b20fb1f829b3b822cf366c59 Signed-off-by: Luca Muscariello --- libparc/parc/algol/parc_EventScheduler.c | 171 +++++++++++++++++++++++++++++++ 1 file changed, 171 insertions(+) create mode 100755 libparc/parc/algol/parc_EventScheduler.c (limited to 'libparc/parc/algol/parc_EventScheduler.c') diff --git a/libparc/parc/algol/parc_EventScheduler.c b/libparc/parc/algol/parc_EventScheduler.c new file mode 100755 index 00000000..55de5c52 --- /dev/null +++ b/libparc/parc/algol/parc_EventScheduler.c @@ -0,0 +1,171 @@ +/* + * Copyright (c) 2017 Cisco and/or its affiliates. + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at: + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +/** + */ +#include + +#include + +#include +#include + +#include "internal_parc_Event.h" +#include +#include +#include +#include + +/** + * Current implementation based on top of libevent2 + */ +#include + +static int _parc_event_scheduler_debug_enabled = 0; + +#define parcEventScheduler_LogDebug(parcEventScheduler, ...) \ + if (_parc_event_scheduler_debug_enabled) \ + parcLog_Debug(parcEventScheduler->log, __VA_ARGS__) + +struct PARCEventScheduler { + /** + * Base of the libevent manager. + */ + struct event_base *evbase; + PARCLog *log; +}; + +static PARCLog * +_parc_logger_create(void) +{ + PARCFileOutputStream *fileOutput = parcFileOutputStream_Create(dup(STDOUT_FILENO)); + PARCOutputStream *output = parcFileOutputStream_AsOutputStream(fileOutput); + parcFileOutputStream_Release(&fileOutput); + + PARCLogReporter *reporter = parcLogReporterFile_Create(output); + parcOutputStream_Release(&output); + + PARCLog *log = parcLog_Create("localhost", "test_parc_Log", NULL, reporter); + parcLogReporter_Release(&reporter); + + parcLog_SetLevel(log, PARCLogLevel_All); + return log; +} + +void * +parcEventScheduler_GetEvBase(PARCEventScheduler *parcEventScheduler) +{ + return (void *) parcEventScheduler->evbase; +} + +PARCEventScheduler * +parcEventScheduler_Create(void) +{ + internal_parc_initializeLibevent(); + + PARCEventScheduler *parcEventScheduler = parcMemory_Allocate(sizeof(PARCEventScheduler)); + assertNotNull(parcEventScheduler, "parcMemory_Allocate(%zu) returned NULL", sizeof(PARCEventScheduler)); + + // Initialize libevent base pointer. + parcEventScheduler->evbase = event_base_new(); + + assertNotNull(parcEventScheduler->evbase, "Could not obtain an event base!"); + int result = event_base_priority_init(parcEventScheduler->evbase, PARCEventPriority_NumberOfPriorities); + assertTrue(result == 0, "Could not set scheduler priorities (%d)", result); + + parcEventScheduler->log = _parc_logger_create(); + assertNotNull(parcEventScheduler->log, "Could not create parc logger"); + + parcEventScheduler_LogDebug(parcEventScheduler, "parcEventScheduler_Create() = %p\n", parcEventScheduler); + + return parcEventScheduler; +} + +int +parcEventScheduler_Start(PARCEventScheduler *parcEventScheduler, PARCEventSchedulerDispatchType type) +{ + parcEventScheduler_LogDebug(parcEventScheduler, "parcEventScheduler_Start(%p, %d)\n", parcEventScheduler, type); + assertNotNull(parcEventScheduler, "parcEventScheduler_Start must be passed a valid base parcEventScheduler!"); + int result = event_base_loop(parcEventScheduler->evbase, + internal_PARCEventSchedulerDispatchType_to_eventloop_options(type)); + return result; +} + +int +parcEventScheduler_DispatchBlocking(PARCEventScheduler *parcEventScheduler) +{ + return parcEventScheduler_Start(parcEventScheduler, PARCEventSchedulerDispatchType_Blocking); +} + +int +parcEventScheduler_DispatchNonBlocking(PARCEventScheduler *parcEventScheduler) +{ + return parcEventScheduler_Start(parcEventScheduler, PARCEventSchedulerDispatchType_NonBlocking); +} + +int +parcEventScheduler_Stop(PARCEventScheduler *parcEventScheduler, struct timeval *delay) +{ + parcEventScheduler_LogDebug(parcEventScheduler, "parcEventScheduler_Stop(%p, %p)\n", parcEventScheduler, delay); + assertNotNull(parcEventScheduler, "parcEventScheduler_Stop must be passed a valid base parcEventScheduler!"); + int result = event_base_loopexit(parcEventScheduler->evbase, delay); + return result; +} + +int +parcEventScheduler_Abort(PARCEventScheduler *parcEventScheduler) +{ + parcEventScheduler_LogDebug(parcEventScheduler, "parcEventScheduler_Abort(%p)\n", parcEventScheduler); + assertNotNull(parcEventScheduler, "parcEventScheduler_Abort must be passed a valid base parcEventScheduler!"); + int result = event_base_loopbreak(parcEventScheduler->evbase); + return result; +} + +static int _event_enable_debug_mode_called = 0; + +void +parcEventScheduler_EnableDebug(void) +{ + _parc_event_scheduler_debug_enabled = 1; + if (_event_enable_debug_mode_called == 0) { + event_enable_debug_mode(); + _event_enable_debug_mode_called = 1; + } +} + +void +parcEventScheduler_DisableDebug(void) +{ + _parc_event_scheduler_debug_enabled = 0; +} + +void +parcEventScheduler_Destroy(PARCEventScheduler **parcEventScheduler) +{ + parcEventScheduler_LogDebug((*parcEventScheduler), "parcEventScheduler_Destroy(%p)\n", *parcEventScheduler); + + assertNotNull(*parcEventScheduler, "parcEventScheduler_Destroy must be passed a valid base parcEventScheduler!"); + assertNotNull((*parcEventScheduler)->evbase, "parcEventScheduler_Destroy passed a NULL event base member!"); + + event_base_free((*parcEventScheduler)->evbase); + parcLog_Release(&((*parcEventScheduler)->log)); + parcMemory_Deallocate((void **) parcEventScheduler); +} + +PARCLog * +parcEventScheduler_GetLogger(PARCEventScheduler *parcEventScheduler) +{ + return parcEventScheduler->log; +} -- cgit 1.2.3-korg