diff options
Diffstat (limited to 'metis/ccnx/forwarder/metis/io/metis_LocalListener.c')
-rw-r--r-- | metis/ccnx/forwarder/metis/io/metis_LocalListener.c | 189 |
1 files changed, 189 insertions, 0 deletions
diff --git a/metis/ccnx/forwarder/metis/io/metis_LocalListener.c b/metis/ccnx/forwarder/metis/io/metis_LocalListener.c new file mode 100644 index 00000000..6e188966 --- /dev/null +++ b/metis/ccnx/forwarder/metis/io/metis_LocalListener.c @@ -0,0 +1,189 @@ +/* + * 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. + */ + +/** + * Implements a listener that works with stream connections over a named pipe. + * + */ + +#include <config.h> +#include <stdio.h> +#include <stdbool.h> +#include <string.h> +#include <sys/un.h> +#include <errno.h> +#include <unistd.h> + +#include <ccnx/forwarder/metis/core/metis_ConnectionTable.h> +#include <ccnx/forwarder/metis/core/metis_Forwarder.h> +#include <ccnx/forwarder/metis/io/metis_Listener.h> +#include <ccnx/forwarder/metis/io/metis_LocalListener.h> +#include <ccnx/forwarder/metis/io/metis_StreamConnection.h> + +#include <LongBow/runtime.h> +#include <parc/algol/parc_Memory.h> + +struct metis_local_listener { + MetisForwarder *metis; + MetisLogger *logger; + PARCEventSocket *listener; + CPIAddress *localAddress; + unsigned id; +}; + +static void _metisLocalListener_OpsDestroy(MetisListenerOps **listenerOpsPtr); +static unsigned _metisLocalListener_OpsGetInterfaceIndex(const MetisListenerOps *ops); +static const CPIAddress *_metisLocalListener_OpsGetListenAddress(const MetisListenerOps *ops); +static MetisEncapType _metisLocalListener_OpsGetEncapType(const MetisListenerOps *ops); + +static MetisListenerOps localTemplate = { + .context = NULL, + .destroy = &_metisLocalListener_OpsDestroy, + .getInterfaceIndex = &_metisLocalListener_OpsGetInterfaceIndex, + .getListenAddress = &_metisLocalListener_OpsGetListenAddress, + .getEncapType = &_metisLocalListener_OpsGetEncapType, +}; + +// STREAM daemon listener callback +static void metisListenerLocal_Listen(int, struct sockaddr *, int socklen, void *localVoid); + +MetisListenerOps * +metisLocalListener_Create(MetisForwarder *metis, const char *path) +{ + MetisLocalListener *local = parcMemory_AllocateAndClear(sizeof(MetisLocalListener)); + assertNotNull(local, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(MetisLocalListener)); + local->metis = metis; + local->logger = metisLogger_Acquire(metisForwarder_GetLogger(metis)); + + struct sockaddr_un addr_unix; + memset(&addr_unix, 0, sizeof(addr_unix)); + + addr_unix.sun_family = PF_UNIX; + strcpy(addr_unix.sun_path, path); + + unlink(path); + + local->listener = metisDispatcher_CreateListener(metisForwarder_GetDispatcher(metis), metisListenerLocal_Listen, + (void *) local, -1, (struct sockaddr*) &addr_unix, sizeof(addr_unix)); + + assertNotNull(local->listener, "Got null listener from metisDispatcher_CreateListener: (%d) %s", errno, strerror(errno)); + + struct sockaddr_un addr_un; + memset(&addr_un, 0, sizeof(addr_un)); + addr_un.sun_family = AF_UNIX; + strcpy(addr_un.sun_path, path); + + local->localAddress = cpiAddress_CreateFromUnix(&addr_un); + local->id = metisForwarder_GetNextConnectionId(metis); + + MetisListenerOps *ops = parcMemory_AllocateAndClear(sizeof(MetisListenerOps)); + assertNotNull(ops, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(MetisListenerOps)); + memcpy(ops, &localTemplate, sizeof(MetisListenerOps)); + ops->context = local; + + return ops; +} + +void +metisLocalListener_Destroy(MetisLocalListener **listenerPtr) +{ + assertNotNull(listenerPtr, "Parameter must be non-null double pointer"); + assertNotNull(*listenerPtr, "Parameter must dereference to non-null pointer"); + + MetisLocalListener *local = *listenerPtr; + + metisLogger_Release(&local->logger); + + cpiAddress_Destroy(&local->localAddress); + metisDispatcher_DestroyListener(metisForwarder_GetDispatcher(local->metis), &local->listener); + + parcMemory_Deallocate((void **) &local); + *listenerPtr = NULL; +} + +// ================================================== + +/** + * @function metisListenerLocal_Listen + * @abstract Called when a client connects to the server socket + * @discussion + * Accepts a client connection. Creates a new Stream connection and adds it + * to the connection table. + * + * @param fd the remote client socket (it will be AF_UNIX type) + * @param sa the remote client address + * @param socklen the bytes of sa + * @param localVoid a void point to the MetisLocalListener that owns the server socket + */ +static void +metisListenerLocal_Listen(int fd, + struct sockaddr *sa, int socklen, void *localVoid) +{ + MetisLocalListener *local = (MetisLocalListener *) localVoid; + assertTrue(sa->sa_family == AF_UNIX, "Got wrong address family, expected %d got %d", AF_UNIX, sa->sa_family); + + CPIAddress *remote = cpiAddress_CreateFromUnix((struct sockaddr_un *) sa); + MetisAddressPair *pair = metisAddressPair_Create(local->localAddress, remote); + + MetisIoOperations *ops = metisStreamConnection_AcceptConnection(local->metis, fd, pair, true); + MetisConnection *conn = metisConnection_Create(ops); + + metisConnectionTable_Add(metisForwarder_GetConnectionTable(local->metis), conn); + + if (metisLogger_IsLoggable(local->logger, MetisLoggerFacility_IO, PARCLogLevel_Debug)) { + char *str = metisAddressPair_ToString(pair); + metisLogger_Log(local->logger, MetisLoggerFacility_IO, PARCLogLevel_Debug, __func__, + "Listener %p started on address pair %s", (void *) local, str); + free(str); + } + + cpiAddress_Destroy(&remote); +} + +static void +_metisLocalListener_OpsDestroy(MetisListenerOps **listenerOpsPtr) +{ + MetisListenerOps *ops = *listenerOpsPtr; + MetisLocalListener *local = (MetisLocalListener *) ops->context; + + if (metisLogger_IsLoggable(local->logger, MetisLoggerFacility_IO, PARCLogLevel_Debug)) { + metisLogger_Log(local->logger, MetisLoggerFacility_IO, PARCLogLevel_Debug, __func__, + "Listener %p destroyed", (void *) local); + } + + metisLocalListener_Destroy(&local); + parcMemory_Deallocate((void **) &ops); + *listenerOpsPtr = NULL; +} + +static unsigned +_metisLocalListener_OpsGetInterfaceIndex(const MetisListenerOps *ops) +{ + MetisLocalListener *local = (MetisLocalListener *) ops->context; + return local->id; +} + +static const CPIAddress * +_metisLocalListener_OpsGetListenAddress(const MetisListenerOps *ops) +{ + MetisLocalListener *local = (MetisLocalListener *) ops->context; + return local->localAddress; +} + +static MetisEncapType +_metisLocalListener_OpsGetEncapType(const MetisListenerOps *ops) +{ + return METIS_ENCAP_LOCAL; +} |