diff options
Diffstat (limited to 'libparc/parc/algol/parc_Network.c')
| -rw-r--r-- | libparc/parc/algol/parc_Network.c | 390 |
1 files changed, 390 insertions, 0 deletions
diff --git a/libparc/parc/algol/parc_Network.c b/libparc/parc/algol/parc_Network.c new file mode 100644 index 00000000..35279648 --- /dev/null +++ b/libparc/parc/algol/parc_Network.c @@ -0,0 +1,390 @@ +/* + * 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 <LongBow/runtime.h> + +#include <sys/socket.h> +#include <ctype.h> +#include <sys/types.h> +#include <netdb.h> + +#include <parc/algol/parc_Network.h> + +#include <parc/algol/parc_Memory.h> +#include <parc/algol/parc_BufferComposer.h> +#include <parc/algol/parc_Buffer.h> +#include <parc/algol/parc_URI.h> + +struct sockaddr * +parcNetwork_SockAddress(const char *address, in_port_t port) +{ + // this is the final return value from the function + struct sockaddr *addr = NULL; + + struct addrinfo hints; + memset(&hints, 0, sizeof(struct addrinfo)); + hints.ai_family = PF_UNSPEC; + hints.ai_flags = AI_ADDRCONFIG; + + // getaddrinfo allocates this pointer + struct addrinfo *ai; + int failure = getaddrinfo(address, NULL, &hints, &ai); + if (failure == 0) { + switch (ai->ai_family) { + case PF_INET: { + struct sockaddr_in *result = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in)); + assertNotNull(result, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(struct sockaddr_in)); + if (result != NULL) { + assertTrue(ai->ai_addrlen == sizeof(struct sockaddr_in), + "Sockaddr wrong length, expected %zu got %u", sizeof(struct sockaddr_in), ai->ai_addrlen); + memcpy(result, ai->ai_addr, ai->ai_addrlen); + result->sin_port = htons(port); + addr = (struct sockaddr *) result; + } + break; + } + + case PF_INET6: { + struct sockaddr_in6 *result = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in6)); + assertNotNull(result, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(struct sockaddr_in6)); + if (result != NULL) { + assertTrue(ai->ai_addrlen == sizeof(struct sockaddr_in6), + "Sockaddr wrong length, expected %zu got %u", sizeof(struct sockaddr_in6), ai->ai_addrlen); + + memcpy(result, ai->ai_addr, ai->ai_addrlen); + result->sin6_port = htons(port); + result->sin6_flowinfo = 0; + result->sin6_scope_id = 0; + addr = (struct sockaddr *) result; + } + break; + } + + default: { + // unsupported protocol + addr = NULL; + break; + } + } + + freeaddrinfo(ai); + } + + return addr; +} + +struct sockaddr_in * +parcNetwork_SockInet4Address(const char *address, in_port_t port) +{ + struct sockaddr_in *result = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in)); + assertNotNull(result, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(struct sockaddr_in)); + if (result != NULL) { + result->sin_family = AF_INET; + result->sin_port = htons(port); +#if defined(SIN6_LEN) + result->sin_len = sizeof(struct sockaddr_in); +#endif + if (inet_pton(AF_INET, address, &(result->sin_addr)) == 1) { + return result; + } + parcMemory_Deallocate((void **) &result); + } + + return NULL; +} + +struct sockaddr_in6 * +parcNetwork_SockInet6Address(const char *address, in_port_t port, uint32_t flowInfo, uint32_t scopeId) +{ + struct sockaddr_in6 *result = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in6)); + assertNotNull(result, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(struct sockaddr_in6)); + if (result != NULL) { + result->sin6_family = AF_INET6; + result->sin6_port = htons(port); + result->sin6_flowinfo = flowInfo; + result->sin6_scope_id = scopeId; +#if defined(SIN6_LEN) + result->sin6_len = sizeof(struct sockaddr_in6); +#endif + + if (inet_pton(AF_INET6, address, &(result->sin6_addr)) == 1) { + return result; + } + parcMemory_Deallocate((void **) &result); + } + + return NULL; +} + +struct sockaddr_in * +parcNetwork_SockInet4AddressAny() +{ + struct sockaddr_in *result = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in)); + assertNotNull(result, "parcMemory_AllocateAndClear(%zu) returned NULL", sizeof(struct sockaddr_in)); + if (result != NULL) { + result->sin_family = AF_INET; + result->sin_addr.s_addr = INADDR_ANY; +#if defined(SIN6_LEN) + result->sin_len = sizeof(struct sockaddr_in); +#endif + return result; + } + return NULL; +} + +PARCBufferComposer * +parcNetwork_SockInet4Address_BuildString(const struct sockaddr_in *address, PARCBufferComposer *composer) +{ + assertNotNull(address, "Parameter must be a non-null pointer to a struct sockaddr_in."); + + if (address->sin_family != AF_INET) { + trapIllegalValue(address->sin_family, "Expected an AF_INET configured address, not %d", address->sin_family); + } + + char buffer[INET_ADDRSTRLEN]; + inet_ntop(address->sin_family, &address->sin_addr, buffer, INET_ADDRSTRLEN); + parcBufferComposer_Format(composer, "inet4://%s:%u", buffer, ntohs(address->sin_port)); + + return composer; +} + +PARCBufferComposer * +parcNetwork_SockInet6Address_BuildString(const struct sockaddr_in6 *address, PARCBufferComposer *composer) +{ + assertNotNull(address, "Parameter must be a non-null pointer to a struct sockaddr_in."); + + if (address->sin6_family != AF_INET6) { + trapIllegalValue(address->sin_family, "Expected an AF_INET6 configured address, not %d", address->sin6_family); + } + + char buffer[INET6_ADDRSTRLEN]; + inet_ntop(address->sin6_family, &address->sin6_addr, buffer, INET6_ADDRSTRLEN); + + parcBufferComposer_Format(composer, "inet6://[%s%%%u]:%u", + buffer, + address->sin6_scope_id, + ntohs(address->sin6_port)); + + return composer; +} + +PARCBufferComposer * +parcNetwork_LinkAddress_BuildString(const unsigned char *address, size_t length, PARCBufferComposer *composer) +{ + parcBufferComposer_PutString(composer, "link://"); + for (size_t i = 0; i < length; i++) { + if (i > 0) { + parcBufferComposer_PutString(composer, "-"); + } + parcBufferComposer_Format(composer, "%02x", address[i]); + } + return composer; +} + +struct sockaddr_in * +parcNetwork_ParseInet4Address(const char *addressURI) +{ + struct sockaddr_in *result = NULL; + + PARCURI *uri = parcURI_Parse(addressURI); + if (strcmp("inet4", parcURI_GetScheme(uri)) == 0) { + } + parcURI_Release(&uri); + + return result; +} + +static PARCBuffer * +_parseMAC48AddressDashOrColon(const char *address, PARCBuffer *result) +{ + char *nextP = NULL; + + const char *p = address; + + int i = 0; + for (i = 0; i < 6; i++) { + long value = strtol(p, &nextP, 16); + if (nextP == p || (*nextP != ':' && *nextP != '-' && *nextP != 0)) { + result = NULL; + break; + } + parcBuffer_PutUint8(result, (uint8_t) value); + + p = nextP + 1; + } + + if (i != 6) { + result = NULL; + } + + return result; +} + +static PARCBuffer * +_parseMAC48AddressDot(const char *address, PARCBuffer *result) +{ + char *nextP = NULL; + + const char *p = address; + + int i = 0; + for (i = 0; i < 3; i++) { + long value = strtol(p, &nextP, 16); + if (nextP == p || (*nextP != '.' && *nextP != 0)) { + result = NULL; + break; + } + parcBuffer_PutUint16(result, (uint16_t) value); + + p = nextP + 1; + } + + if (i != 3) { + result = NULL; + } + + return result; +} + +bool +parcNetwork_ParseMAC48Address(const char *address, PARCBuffer *buffer) +{ + bool result = false; + + size_t originalPosition = parcBuffer_Position(buffer); + + if (strchr(address, '-') != NULL || strchr(address, ':') != NULL) { + if (_parseMAC48AddressDashOrColon(address, buffer) != NULL) { + result = true; + } + } + + if (strchr(address, '.') != NULL) { + if (_parseMAC48AddressDot(address, buffer) != NULL) { + result = true; + } + ; + } + + if (result == false) { + parcBuffer_SetPosition(buffer, originalPosition); + } + + return result; +} + +PARCBuffer * +parcNetwork_ParseLinkAddress(const char *address) +{ + if (strncmp("link://", address, 7) == 0) { + PARCBuffer *result = parcBuffer_Allocate(7); + + if (parcNetwork_ParseMAC48Address(&address[7], result) == false) { + parcBuffer_Release(&result); + trapIllegalValue(address, "Syntax error '%s'", address); + } + + return parcBuffer_Flip(result); + } + + trapIllegalValue(address, "Bad scheme '%s'", address); +} + +bool +parcNetwork_Inet4Equals(const struct sockaddr_in *x, const struct sockaddr_in *y) +{ + if (x == y) { + return true; + } + if (x == NULL || y == NULL) { + return false; + } + if (x->sin_family == y->sin_family) { + if (x->sin_addr.s_addr == y->sin_addr.s_addr) { + if (x->sin_port == y->sin_port) { + return true; + } + } + } + + return false; +} + +/* + * Returns true for ::1 address, false otherwise + * + * The address is in network byte order + * + * @return true The address is local + * @return false The address is not local + */ +static bool +_isInet6Loopback(struct sockaddr_in6 *sin6) +{ + if (IN6_IS_ADDR_LOOPBACK(&sin6->sin6_addr)) { + return true; + } + return false; +} + +/** + * Returns true if the address is on the 127.0.0.0/8 network + * + * The address is expected to be in network byte order + * + * @param [in] sin4 A pointer to a sockaddr_in containing an IPv4 address. + * + * @return true Address on 127.0.0.0/8 + * @return false Not a 127.0.0.0/8 + */ +static bool +_isInet4Loopback(struct sockaddr_in *sin4) +{ + uint32_t hostorder = htonl(sin4->sin_addr.s_addr); + if ((hostorder & 0xFF000000) == 0x7F000000) { + return true; + } + return false; +} + +bool +parcNetwork_IsSocketLocal(struct sockaddr *sock) +{ + assertNotNull(sock, "Parameter sock must be non-null"); + bool isLocal = false; + + switch (sock->sa_family) { + case PF_LOCAL: + isLocal = true; + break; + + case PF_INET: + isLocal = _isInet4Loopback((struct sockaddr_in *) sock); + break; + + case PF_INET6: + isLocal = _isInet6Loopback((struct sockaddr_in6 *) sock); + break; + + default: + break; + } + + return isLocal; +} |