From c07ad72f016930e2aba6471d0e2e9625b935bf9a Mon Sep 17 00:00:00 2001 From: Mauro Sardara Date: Thu, 24 Jan 2019 17:52:53 +0100 Subject: Remove cframework files from master Change-Id: I02f17ede1cf97986a8b8852ed6d6a28fc016f590 Signed-off-by: Mauro Sardara --- libparc/parc/algol/parc_EventSocket.c | 140 ---------------------------------- 1 file changed, 140 deletions(-) delete mode 100755 libparc/parc/algol/parc_EventSocket.c (limited to 'libparc/parc/algol/parc_EventSocket.c') diff --git a/libparc/parc/algol/parc_EventSocket.c b/libparc/parc/algol/parc_EventSocket.c deleted file mode 100755 index 62aa10bc..00000000 --- a/libparc/parc/algol/parc_EventSocket.c +++ /dev/null @@ -1,140 +0,0 @@ -/* - * 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 -#include -#include - -static int _parc_event_socket_debug_enabled = 0; - -#define parcEventSocket_LogDebug(parcEventSocket, ...) \ - if (_parc_event_socket_debug_enabled) \ - parcLog_Debug(parcEventScheduler_GetLogger(parcEventSocket->eventScheduler), __VA_ARGS__) - -/** - * Current implementation based on top of libevent2 - */ - -#include -#include - -/** - * @typedef PARCEventSocket - * @brief A structure containing private event state - */ -struct PARCEventSocket { - struct evconnlistener *listener; - - // Event scheduler we have been queued with - PARCEventScheduler *eventScheduler; - - // Interpose on EventSocket callbacks - PARCEventSocket_Callback *socketCallback; - void *socketUserData; - PARCEventSocket_ErrorCallback *socketErrorCallback; - void *socketErrorUserData; -}; - -static void -_parc_evconn_callback(struct evconnlistener *listener, evutil_socket_t fd, - struct sockaddr *address, int socklen, void *ctx) -{ - PARCEventSocket *parcEventSocket = (PARCEventSocket *) ctx; - parcEventSocket_LogDebug(parcEventSocket, "_parc_evconn_callback(fd=%d,,parcEventSocket=%p)\n", fd, parcEventSocket); - - parcEventSocket->socketCallback((int) fd, address, socklen, parcEventSocket->socketUserData); -} - -static void -_parc_evconn_error_callback(struct evconnlistener *listener, void *ctx) -{ - PARCEventSocket *parcEventSocket = (PARCEventSocket *) ctx; - - int error = EVUTIL_SOCKET_ERROR(); - char *errorString = evutil_socket_error_to_string(error); - parcEventSocket_LogDebug(parcEventSocket, - "_parc_evconn_error_callback(error=%d,errorString=%s,parcEventSocket=%p)\n", - error, errorString, parcEventSocket); - - parcEventSocket->socketErrorCallback(parcEventSocket->eventScheduler, - error, errorString, parcEventSocket->socketErrorUserData); -} - -PARCEventSocket * -parcEventSocket_Create(PARCEventScheduler *eventScheduler, - PARCEventSocket_Callback *callback, - PARCEventSocket_ErrorCallback *errorCallback, - void *userData, const struct sockaddr *sa, int socklen) -{ - PARCEventSocket *parcEventSocket = parcMemory_AllocateAndClear(sizeof(PARCEventSocket)); - parcAssertNotNull(parcEventSocket, "parcMemory_Allocate(%zu) returned NULL", sizeof(PARCEventSocket)); - - parcEventSocket->eventScheduler = eventScheduler; - parcEventSocket->socketCallback = callback; - parcEventSocket->socketErrorCallback = errorCallback; - parcEventSocket->socketUserData = userData; - parcEventSocket->socketErrorUserData = userData; - parcEventSocket->listener = evconnlistener_new_bind(parcEventScheduler_GetEvBase(eventScheduler), - _parc_evconn_callback, parcEventSocket, - LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE, -1, - sa, socklen); - if (parcEventSocket->listener == NULL) { - parcLog_Error(parcEventScheduler_GetLogger(eventScheduler), - "Libevent evconnlistener_new_bind error (%d): %s", - errno, strerror(errno)); - parcEventSocket_Destroy(&parcEventSocket); - return NULL; - } - - if (errorCallback) { - evconnlistener_set_error_cb(parcEventSocket->listener, _parc_evconn_error_callback); - } - parcEventSocket_LogDebug(parcEventSocket, - "parcEventSocket_Create(cb=%p,args=%p) = %p\n", - callback, userData, parcEventSocket); - return parcEventSocket; -} - -void -parcEventSocket_Destroy(PARCEventSocket **socketEvent) -{ - parcAssertNotNull(*socketEvent, "parcEventSocket_Destroy must be passed a valid socketEvent!"); - - if ((*socketEvent)->listener) { - evconnlistener_free((*socketEvent)->listener); - } - parcEventSocket_LogDebug((*socketEvent), "parcEventSocket_Destroy(%p)\n", *socketEvent); - parcMemory_Deallocate((void **) socketEvent); -} - -void -parcEventSocket_EnableDebug(void) -{ - _parc_event_socket_debug_enabled = 1; -} - -void -parcEventSocket_DisableDebug(void) -{ - _parc_event_socket_debug_enabled = 0; -} -- cgit 1.2.3-korg