1 files changed, 0 insertions, 282 deletions
diff --git a/libparc/parc/algol/parc_EventBuffer.c b/libparc/parc/algol/parc_EventBuffer.c
deleted file mode 100644
index 6293680c..00000000
--- a/libparc/parc/algol/parc_EventBuffer.c
+++ /dev/null
@@ -1,282 +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 <config.h>
-
-#include <parc/assert/parc_Assert.h>
-
-#include "internal_parc_Event.h"
-#include <parc/algol/parc_Event.h>
-#include <parc/algol/parc_EventBuffer.h>
-#include <parc/algol/parc_FileOutputStream.h>
-#include <parc/logging/parc_Log.h>
-#include <parc/logging/parc_LogReporterFile.h>
-
-static PARCLog *parcEventBufferDebugLog = NULL;
-
-#define parcEventBuffer_LogDebug(parcEvent, ...) \
-    if (parcEventBufferDebugLog) \
-        parcLog_Debug(parcEventBufferDebugLog, __VA_ARGS__)
-
-/**
- * Current implementation based on top of libevent2
- */
-
-#include <event2/buffer.h>
-
-/**
- * @typedef PARCEventBuffer
- * @brief A structure containing private libevent state data variables
- *
- * The evbuffer either points to an evbuffer owned by the bufferevent, or an
- * allocated evbuffer (allocated_evbuffer) that is our responsibility to destroy.
- */
-struct PARCEventBuffer {
-    struct evbuffer *evbuffer;
-    struct evbuffer *allocated_evbuffer;
-};
-
-PARCEventBuffer *
-parcEventBuffer_Create(void)
-{
-    internal_parc_initializeLibevent();
-    struct evbuffer *new_evbuffer = evbuffer_new();
-    parcAssertNotNull(new_evbuffer, "libevent returned a null evbuffer.\n");
-
-    PARCEventBuffer *parcEventBuffer = parcMemory_AllocateAndClear(sizeof(PARCEventBuffer));
-    parcAssertNotNull(parcEventBuffer, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(PARCEventBuffer));
-    parcEventBuffer->allocated_evbuffer = new_evbuffer;
-    parcEventBuffer->evbuffer = parcEventBuffer->allocated_evbuffer;
-
-    parcEventBuffer_LogDebug(parcEventBuffer, "parcEventBuffer_Create() = %p\n", parcEventBuffer);
-
-    return parcEventBuffer;
-}
-
-void
-parcEventBuffer_Destroy(PARCEventBuffer **parcEventBuffer)
-{
-    parcEventBuffer_LogDebug((*parcEventBuffer), "parcEventBuffer_Destroy(parcEventBuffer=%p)\n", *parcEventBuffer);
-    parcAssertNotNull(parcEventBuffer, "parcEventBuffer_Destroy was passed a null parcEventBuffer pointer\n");
-    parcAssertNotNull(*parcEventBuffer, "parcEventBuffer_Destroy was passed a null parcEventBuffer\n");
-
-    // Destroy allocated eveventBuffer if it was allocated by us, otherwise it's owned by bufferevent
-    if ((*parcEventBuffer)->allocated_evbuffer) {
-        parcEventBuffer_LogDebug((*parcEventBuffer), "parcEventBuffer_Destroy(parcEventBuffer=%p) freeing evbuffer %p\n", *parcEventBuffer, (*parcEventBuffer)->allocated_evbuffer);
-        evbuffer_free((*parcEventBuffer)->allocated_evbuffer);
-    }
-    parcMemory_Deallocate((void **) parcEventBuffer);
-    parcEventBuffer_LogDebug((*parcEventBuffer), "parcEventBuffer_Destroy() buffer already deallocated\n");
-}
-
-bool
-parcEventBuffer_IsValid(const PARCEventBuffer *eventBuffer)
-{
-    bool result = false;
-
-    if (eventBuffer != NULL) {
-        if (eventBuffer->evbuffer) {
-            result = true;
-        }
-    }
-
-    return result;
-}
-
-void
-parcEventBuffer_AssertValid(const PARCEventBuffer *eventBuffer)
-{
-    parcAssertTrue(parcEventBuffer_IsValid(eventBuffer),
-               "PARCEventBuffer@%p is not valid.", (void *) eventBuffer);
-}
-
-size_t
-parcEventBuffer_GetLength(PARCEventBuffer *parcEventBuffer)
-{
-    parcEventBuffer_LogDebug(parcEventBuffer, "parcEventBuffer_GetLength(parcEventBuffer=%p)\n", parcEventBuffer);
-//    parcEventBuffer_OptionalAssertValid(parcEventBuffer);
-    parcAssertNotNull(parcEventBuffer, "parcEventBuffer_GetLength was passed a null parcEventBuffer\n");
-
-    if (parcEventBuffer->evbuffer) {
-        return evbuffer_get_length(parcEventBuffer->evbuffer);
-    } else {
-        return 0;
-    }
-}
-
-uint8_t *
-parcEventBuffer_Pullup(PARCEventBuffer *parcEventBuffer, ssize_t size)
-{
-    parcEventBuffer_LogDebug(parcEventBuffer, "parcEventBuffer_Pullup(parcEventBuffer=%p,size=%zx)\n", parcEventBuffer, size);
-
-    parcEventBuffer_OptionalAssertValid(parcEventBuffer);
-//    parcAssertNotNull(parcEventBuffer, "parcEventBuffer_Pullup was passed a null parcEventBuffer\n");
-//    parcAssertNotNull(parcEventBuffer->evbuffer, "parcEventBuffer_Pullup was passed a null libevent evbuffer\n");
-
-    return evbuffer_pullup(parcEventBuffer->evbuffer, (ev_ssize_t) size);
-}
-
-int
-parcEventBuffer_ReadIntoBuffer(PARCEventBuffer *source, PARCEventBuffer *destination, size_t length)
-{
-    parcEventBuffer_OptionalAssertValid(source);
-    parcEventBuffer_OptionalAssertValid(destination);
-//    parcAssertNotNull(source, "parcEventBuffer_ReadIntoBuffer was passed a null source buffer\n");
-//    parcAssertNotNull(source->evbuffer, "parcEventBuffer_ReadIntoBuffer was passed a null source evbuffer\n");
-//    parcAssertNotNull(destination, "parcEventBuffer_ReadIntoBuffer was passed a null destination buffer\n");
-//    parcAssertNotNull(destination->evbuffer, "parcEventBuffer_ReadIntoBuffer was passed a null destination evbuffer\n");
-
-    return evbuffer_remove_buffer(source->evbuffer, destination->evbuffer, length);
-}
-
-int
-parcEventBuffer_Read(PARCEventBuffer *readBuffer, void *data, size_t length)
-{
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-//    parcAssertNotNull(readBuffer, "parcEventBuffer_Read was passed a null buffer\n");
-//    parcAssertNotNull(readBuffer->evbuffer, "parcEventBuffer_Read was passed a null libevent evbuffer\n");
-
-    if (data == NULL) {
-        return evbuffer_drain(readBuffer->evbuffer, length);
-    } else {
-        return evbuffer_remove(readBuffer->evbuffer, data, length);
-    }
-}
-
-int
-parcEventBuffer_copyOut(PARCEventBuffer *readBuffer, void *data_out, size_t length)
-{
-    parcAssertNotNull(data_out, "parcEventBuffer_Copy was passed a null data_out buffer\n");
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-    return evbuffer_copyout(readBuffer->evbuffer, data_out, length);
-}
-
-int
-parcEventBuffer_WriteToFileDescriptor(PARCEventBuffer *writeBuffer, int fd, ssize_t length)
-{
-    parcEventBuffer_OptionalAssertValid(writeBuffer);
-
-//    parcAssertNotNull(writeBuffer, "parcEventBuffer_WriteToFileDescriptor was passed a null buffer\n");
-//    parcAssertNotNull(writeBuffer->evbuffer, "parcEventBuffer_WriteToFileDescriptor was passed a null libevent evbuffer\n");
-
-    return evbuffer_write_atmost(writeBuffer->evbuffer, fd, length);
-}
-
-int
-parcEventBuffer_ReadFromFileDescriptor(PARCEventBuffer *readBuffer, int fd, size_t length)
-{
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-//    parcAssertNotNull(readBuffer, "parcEventBuffer_ReadFromFileDescriptor was passed a null buffer\n");
-//    parcAssertNotNull(readBuffer->evbuffer, "parcEventBuffer_ReadFromFileDescriptor was passed a null libevent evbuffer\n");
-
-    return evbuffer_read(readBuffer->evbuffer, fd, (int) length);
-}
-
-void
-parcEventBuffer_FreeLine(PARCEventBuffer *readBuffer, char **line)
-{
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-//    parcAssertNotNull(readBuffer, "parcEventBuffer_ReadLine was passed a null readBuffer\n");
-//    parcAssertNotNull(readBuffer->evbuffer, "parcEventBuffer_ReadLine was passed a null libevent evbuffer\n");
-
-    parcMemory_Deallocate((void **) line);
-}
-
-char *
-parcEventBuffer_ReadLine(PARCEventBuffer *readBuffer, size_t *length)
-{
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-//    parcAssertNotNull(readBuffer, "parcEventBuffer_ReadLine was passed a null readBuffer\n");
-//    parcAssertNotNull(readBuffer->evbuffer, "parcEventBuffer_ReadLine was passed a null libevent evbuffer\n");
-
-    return evbuffer_readln(readBuffer->evbuffer, length, EVBUFFER_EOL_CRLF);
-}
-
-int
-parcEventBuffer_AppendBuffer(PARCEventBuffer *source, PARCEventBuffer *destination)
-{
-    parcEventBuffer_OptionalAssertValid(source);
-    parcEventBuffer_OptionalAssertValid(destination);
-//    parcAssertNotNull(source, "parcEventBuffer_AppendBuffer was passed a null source parcEventBuffer\n");
-//    parcAssertNotNull(destination, "parcEventBuffer_AppendBuffer was passed a null destination parcEventBuffer\n");
-//    parcAssertNotNull(source->evbuffer, "parcEventBuffer_AppendBuffer was passed a null source libevent evbuffer\n");
-//    parcAssertNotNull(destination->evbuffer, "parcEventBuffer_AppendBuffer was passed a null destination libevent evbuffer\n");
-
-    return evbuffer_add_buffer(destination->evbuffer, source->evbuffer);
-}
-
-int
-parcEventBuffer_Append(PARCEventBuffer *parcEventBuffer, void *data, size_t length)
-{
-    parcEventBuffer_OptionalAssertValid(parcEventBuffer);
-//    parcAssertNotNull(parcEventBuffer, "parcEventBuffer_Append was passed a null parcEventBuffer\n");
-//    parcAssertNotNull(parcEventBuffer->evbuffer, "parcEventBuffer_Append was passed a null libevent evbuffer\n");
-    parcAssertNotNull(data, "parcEventBuffer_Append was passed a null data buffer\n");
-
-    return evbuffer_add(parcEventBuffer->evbuffer, data, length);
-}
-
-int
-parcEventBuffer_Prepend(PARCEventBuffer *readBuffer, void *data, size_t length)
-{
-    parcEventBuffer_OptionalAssertValid(readBuffer);
-//    parcAssertNotNull(readBuffer->evbuffer, "parcEventBuffer_Prepend was passed a null libevent evbuffer\n");
-//    parcAssertNotNull(readBuffer, "parcEventBuffer_Prepend was passed a null buffer\n");
-    parcAssertNotNull(data, "parcEventBuffer_Prepend was passed a null data buffer\n");
-
-    return evbuffer_prepend(readBuffer->evbuffer, data, length);
-}
-
-PARCEventBuffer *
-parcEventBuffer_GetQueueBufferInput(PARCEventQueue *queue)
-{
-    parcAssertNotNull(queue, "parcEventBuffer_GetQueueBufferInput was passed a null queue\n");
-
-    PARCEventBuffer *parcEventBuffer = parcMemory_AllocateAndClear(sizeof(PARCEventBuffer));
-    parcAssertNotNull(parcEventBuffer, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(PARCEventBuffer));
-
-    parcEventBuffer->evbuffer = internal_parcEventQueue_GetEvInputBuffer(queue);
-    parcEventBuffer_LogDebug(parcEventBuffer, "parcEventBuffer_GetQueueBufferInput(queue=%p)\n", queue);
-
-    return parcEventBuffer;
-}
-
-PARCEventBuffer *
-parcEventBuffer_GetQueueBufferOutput(PARCEventQueue *queue)
-{
-    parcAssertNotNull(queue, "parcEventBuffer_GetQueueBufferOutput was passed a null queue\n");
-
-    PARCEventBuffer *parcEventBuffer = parcMemory_AllocateAndClear(sizeof(PARCEventBuffer));
-    parcAssertNotNull(parcEventBuffer, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(PARCEventBuffer));
-
-    parcEventBuffer->evbuffer = internal_parcEventQueue_GetEvOutputBuffer(queue);
-    parcEventBuffer_LogDebug(parcEventBuffer, "parcEventBuffer_GetQueueBufferInput(queue=%p)\n", queue);
-
-    return parcEventBuffer;
-}
-
-void
-parcEventBuffer_EnableDebug(PARCLog *logger)
-{
-    parcEventBufferDebugLog = logger;
-}
-
-void
-parcEventBuffer_DisableDebug(void)
-{
-    parcEventBufferDebugLog = NULL;
-}