diff options
author | Giovanni Conte <gconte@cisco.com> | 2019-01-28 15:08:16 +0100 |
---|---|---|
committer | Giovanni Conte <gconte@cisco.com> | 2019-01-29 09:30:37 +0000 |
commit | 07db19960166bd7241836b858ecf41420dafc63e (patch) | |
tree | 701705407796d61f7400456d12012a5ce0697dbe /hicn-light/src/io | |
parent | 015dd3fa693039acd08171e8a8d27b3776670a41 (diff) |
[HICN-16] File Descriptors fixes for list commands
Change-Id: I052013d0d8c6c2bd4b7631c68065bca91024646b
Signed-off-by: Giovanni Conte <gconte@cisco.com>
Diffstat (limited to 'hicn-light/src/io')
-rwxr-xr-x | hicn-light/src/io/hicnConnection.c | 8 | ||||
-rwxr-xr-x | hicn-light/src/io/hicnConnection.h | 4 | ||||
-rwxr-xr-x | hicn-light/src/io/hicnListener.c | 64 | ||||
-rwxr-xr-x | hicn-light/src/io/hicnListener.h | 4 | ||||
-rwxr-xr-x | hicn-light/src/io/streamConnection.c | 8 |
5 files changed, 44 insertions, 44 deletions
diff --git a/hicn-light/src/io/hicnConnection.c b/hicn-light/src/io/hicnConnection.c index 85cf50921..6def8ed43 100755 --- a/hicn-light/src/io/hicnConnection.c +++ b/hicn-light/src/io/hicnConnection.c @@ -14,7 +14,7 @@ */ /** - * Embodies the reader/writer for a HIcn connection + * Embodies the reader/writer for a Hicn connection * * NB The Send() function may overflow the output buffer * @@ -112,7 +112,7 @@ static IoOperations _template = {.closure = NULL, // ================================================================= -static void _setConnectionState(_HicnState *HIcn, bool isUp); +static void _setConnectionState(_HicnState *Hicn, bool isUp); static bool _saveSockaddr(_HicnState *hicnConnState, const AddressPair *pair); static void _refreshProbeDestAddress(_HicnState *hicnConnState, const uint8_t *message); @@ -150,7 +150,7 @@ IoOperations *hicnConnection_Create(Forwarder *forwarder, int fd, char *str = addressPair_ToString(hicnConnState->addressPair); logger_Log(hicnConnState->logger, LoggerFacility_IO, PARCLogLevel_Info, __func__, - "HIcnConnection %p created for address %s (isLocal %d)", + "HicnConnection %p created for address %s (isLocal %d)", (void *)hicnConnState, str, hicnConnState->isLocal); free(str); } @@ -196,7 +196,7 @@ static void _destroy(IoOperations **opsPtr) { if (logger_IsLoggable(hicnConnState->logger, LoggerFacility_IO, PARCLogLevel_Info)) { logger_Log(hicnConnState->logger, LoggerFacility_IO, PARCLogLevel_Info, - __func__, "HIcnConnection %p destroyed", (void *)hicnConnState); + __func__, "HicnConnection %p destroyed", (void *)hicnConnState); } // XXX diff --git a/hicn-light/src/io/hicnConnection.h b/hicn-light/src/io/hicnConnection.h index 757e534ba..930e2d470 100755 --- a/hicn-light/src/io/hicnConnection.h +++ b/hicn-light/src/io/hicnConnection.h @@ -15,7 +15,7 @@ /** * @file hicnConnection.h - * @brief Represents a HIcn connection for the connection table + * @brief Represents a Hicn connection for the connection table * * <#Detailed Description#> * @@ -30,7 +30,7 @@ #include <src/utils/address.h> /** - * Creates a HIcn connection that can send to the remote address + * Creates a Hicn connection that can send to the remote address * * The address pair must both be same type (i.e. INET or INET6). * diff --git a/hicn-light/src/io/hicnListener.c b/hicn-light/src/io/hicnListener.c index 161f5b317..789face90 100755 --- a/hicn-light/src/io/hicnListener.c +++ b/hicn-light/src/io/hicnListener.c @@ -119,9 +119,9 @@ static bool _isEmptyAddressIPv4(Address *address) { ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, Address *address) { - HIcnListener *hicn = parcMemory_AllocateAndClear(sizeof(HIcnListener)); + HicnListener *hicn = parcMemory_AllocateAndClear(sizeof(HicnListener)); parcAssertNotNull(hicn, "parcMemory_AllocateAndClear(%zu) returned NULL", - sizeof(HIcnListener)); + sizeof(HicnListener)); hicn->forwarder = forwarder; hicn->logger = logger_Acquire(forwarder_GetLogger(forwarder)); @@ -134,7 +134,7 @@ ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, hicn->connection_id = -1; hicn_socket_helper_t *hicnSocketHelper = - forwarder_GetHIcnSocketHelper(forwarder); + forwarder_GetHicnSocketHelper(forwarder); if (_isEmptyAddressIPv4(address)) { hicn->hicn_fd = hicn_socket(hicnSocketHelper, symbolic, NULL); @@ -158,7 +158,7 @@ ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, PARCLogLevel_Debug)) { logger_Log( hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug, __func__, - "HIcnListener %s: error while creating an hicn listener in lib_hicn", + "HicnListener %s: error while creating an hicn listener in lib_hicn", symbolic); } logger_Release(&hicn->logger); @@ -190,7 +190,7 @@ ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, if (logger_IsLoggable(hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug)) { logger_Log(hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug, __func__, - "HIcnListener %s created", symbolic); + "HicnListener %s created", symbolic); } return ops; @@ -199,9 +199,9 @@ ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, ListenerOps *hicnListener_CreateInet6(Forwarder *forwarder, char *symbolic, Address *address) { - HIcnListener *hicn = parcMemory_AllocateAndClear(sizeof(HIcnListener)); + HicnListener *hicn = parcMemory_AllocateAndClear(sizeof(HicnListener)); parcAssertNotNull(hicn, "parcMemory_AllocateAndClear(%zu) returned NULL", - sizeof(HIcnListener)); + sizeof(HicnListener)); hicn->forwarder = forwarder; hicn->logger = logger_Acquire(forwarder_GetLogger(forwarder)); @@ -219,7 +219,7 @@ ListenerOps *hicnListener_CreateInet6(Forwarder *forwarder, char *symbolic, //address we just need to set the right type of packet hicn_socket_helper_t *hicnSocketHelper = - forwarder_GetHIcnSocketHelper(forwarder); + forwarder_GetHicnSocketHelper(forwarder); if (_isEmptyAddressIPv6(address)) { // create main listener @@ -248,7 +248,7 @@ ListenerOps *hicnListener_CreateInet6(Forwarder *forwarder, char *symbolic, PARCLogLevel_Debug)) { logger_Log( hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug, __func__, - "HIcnListener %s: error while creating an hicn listener in lib_hicn", + "HicnListener %s: error while creating an hicn listener in lib_hicn", symbolic); } logger_Release(&hicn->logger); @@ -280,16 +280,16 @@ ListenerOps *hicnListener_CreateInet6(Forwarder *forwarder, char *symbolic, if (logger_IsLoggable(hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug)) { logger_Log(hicn->logger, LoggerFacility_IO, PARCLogLevel_Debug, __func__, - "HIcnListener %s created", symbolic); + "HicnListener %s created", symbolic); } return ops; } bool _hicnListener_BindInet6(ListenerOps *ops, const Address *remoteAddress) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; hicn_socket_helper_t *hicnSocketHelper = - forwarder_GetHIcnSocketHelper(hicn->forwarder); + forwarder_GetHicnSocketHelper(hicn->forwarder); struct sockaddr_in6 *tmpAddr = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in6)); @@ -319,9 +319,9 @@ bool _hicnListener_BindInet6(ListenerOps *ops, const Address *remoteAddress) { } bool _hicnListener_BindInet(ListenerOps *ops, const Address *remoteAddress) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; hicn_socket_helper_t *hicnSocketHelper = - forwarder_GetHIcnSocketHelper(hicn->forwarder); + forwarder_GetHicnSocketHelper(hicn->forwarder); struct sockaddr_in *tmpAddr = parcMemory_AllocateAndClear(sizeof(struct sockaddr_in)); @@ -362,9 +362,9 @@ bool hicnListener_Bind(ListenerOps *ops, const Address *remoteAddress) { } bool hicnListener_Punting(ListenerOps *ops, const char *prefix) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; hicn_socket_helper_t *hicnSocketHelper = - forwarder_GetHIcnSocketHelper(hicn->forwarder); + forwarder_GetHicnSocketHelper(hicn->forwarder); int res = hicn_listen(hicnSocketHelper, hicn->hicn_fd, prefix); int retry = 0; @@ -388,7 +388,7 @@ bool hicnListener_Punting(ListenerOps *ops, const char *prefix) { } bool hicnListener_SetConnectionId(ListenerOps *ops, unsigned connId) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; if (hicn) { hicn->connection_id = connId; return true; @@ -396,12 +396,12 @@ bool hicnListener_SetConnectionId(ListenerOps *ops, unsigned connId) { return false; } -static void _hicnListener_Destroy(HIcnListener **listenerPtr) { +static void _hicnListener_Destroy(HicnListener **listenerPtr) { parcAssertNotNull(listenerPtr, "Parameter must be non-null double pointer"); parcAssertNotNull(*listenerPtr, "Parameter must derefernce to non-null pointer"); - HIcnListener *hicn = *listenerPtr; + HicnListener *hicn = *listenerPtr; // close(hicn->hicn_fd); //XXX close the fd in the hicnlib (detroy listener?) dispatcher_DestroyNetworkEvent(forwarder_GetDispatcher(hicn->forwarder), @@ -414,32 +414,32 @@ static void _hicnListener_Destroy(HIcnListener **listenerPtr) { static void _destroy(ListenerOps **listenerOpsPtr) { ListenerOps *ops = *listenerOpsPtr; - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; _hicnListener_Destroy(&hicn); parcMemory_Deallocate((void **)&ops); *listenerOpsPtr = NULL; } static unsigned _getInterfaceIndex(const ListenerOps *ops) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; return hicn->conn_id; } static const Address *_getListenAddress(const ListenerOps *ops) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; return hicn->localAddress; } static EncapType _getEncapType(const ListenerOps *ops) { return ENCAP_HICN; } static int _getSocket(const ListenerOps *ops) { - HIcnListener *hicn = (HIcnListener *)ops->context; + HicnListener *hicn = (HicnListener *)ops->context; return hicn->hicn_fd; } // =============================== -static void _readFrameToDiscard(HIcnListener *hicn, int fd) { +static void _readFrameToDiscard(HicnListener *hicn, int fd) { // we need to discard the frame. Read 1 byte. This will clear it off the // stack. uint8_t buffer; @@ -463,7 +463,7 @@ static void _readFrameToDiscard(HIcnListener *hicn, int fd) { } } -static unsigned _createNewConnection(HIcnListener *hicn, int fd, +static unsigned _createNewConnection(HicnListener *hicn, int fd, const AddressPair *pair) { bool isLocal = false; @@ -477,7 +477,7 @@ static unsigned _createNewConnection(HIcnListener *hicn, int fd, return connid; } -const Connection *_findConnectionFromPacket(HIcnListener *hicn, +const Connection *_findConnectionFromPacket(HicnListener *hicn, Address *packetSourceAddress) { const Connection *conn = NULL; if (hicn->connection_id != -1) { @@ -520,7 +520,7 @@ static Address *_createAddressFromPacket(uint8_t *msgBuffer) { return packetAddr; } -static void _handleProbeMessage(HIcnListener *hicn, uint8_t *msgBuffer) { +static void _handleProbeMessage(HicnListener *hicn, uint8_t *msgBuffer) { Address *packetAddr = _createAddressFromPacket(msgBuffer); if (packetAddr != NULL) { @@ -536,7 +536,7 @@ static void _handleProbeMessage(HIcnListener *hicn, uint8_t *msgBuffer) { parcMemory_Deallocate((void **)&msgBuffer); } -static void _handleWldrNotification(HIcnListener *hicn, uint8_t *msgBuffer) { +static void _handleWldrNotification(HicnListener *hicn, uint8_t *msgBuffer) { Address *packetAddr = _createAddressFromPacket(msgBuffer); if (packetAddr == NULL) { @@ -563,7 +563,7 @@ static void _handleWldrNotification(HIcnListener *hicn, uint8_t *msgBuffer) { } #ifdef WITH_MAPME -static void _handleMapMe(HIcnListener *hicn, int fd, uint8_t *msgBuffer) { +static void _handleMapMe(HicnListener *hicn, int fd, uint8_t *msgBuffer) { Address *packetAddr = _createAddressFromPacket(msgBuffer); if (packetAddr == NULL) { @@ -630,7 +630,7 @@ static void _handleMapMe(HIcnListener *hicn, int fd, uint8_t *msgBuffer) { } #endif /* WITH_MAPME */ -static Message *_readMessage(HIcnListener *hicn, int fd, uint8_t *msgBuffer) { +static Message *_readMessage(HicnListener *hicn, int fd, uint8_t *msgBuffer) { Message *message = NULL; ssize_t readLength = read(fd, msgBuffer, MTU_SIZE); @@ -702,7 +702,7 @@ static Message *_readMessage(HIcnListener *hicn, int fd, uint8_t *msgBuffer) { return message; } -static void _receivePacket(HIcnListener *hicn, int fd) { +static void _receivePacket(HicnListener *hicn, int fd) { Message *msg = NULL; uint8_t *msgBuffer = parcMemory_AllocateAndClear(MTU_SIZE); msg = _readMessage(hicn, fd, msgBuffer); @@ -713,7 +713,7 @@ static void _receivePacket(HIcnListener *hicn, int fd) { } static void _hicnListener_readcb(int fd, PARCEventType what, void *hicnVoid) { - HIcnListener *hicn = (HIcnListener *)hicnVoid; + HicnListener *hicn = (HicnListener *)hicnVoid; if (hicn->inetFamily == IPv4 || hicn->inetFamily == IPv6) { if (what & PARCEventType_Read) { diff --git a/hicn-light/src/io/hicnListener.h b/hicn-light/src/io/hicnListener.h index 98c5387c9..5897d33ad 100755 --- a/hicn-light/src/io/hicnListener.h +++ b/hicn-light/src/io/hicnListener.h @@ -15,7 +15,7 @@ /** * @file hicnListener.h - * @brief Listens for in coming HIcn connections + * @brief Listens for in coming Hicn connections * * */ @@ -29,7 +29,7 @@ #include <stdlib.h> struct hicn_listener; -typedef struct hicn_listener HIcnListener; +typedef struct hicn_listener HicnListener; ListenerOps *hicnListener_CreateInet(Forwarder *forwarder, char *symbolic, Address *address); diff --git a/hicn-light/src/io/streamConnection.c b/hicn-light/src/io/streamConnection.c index fedbb157a..948b6c01b 100755 --- a/hicn-light/src/io/streamConnection.c +++ b/hicn-light/src/io/streamConnection.c @@ -504,13 +504,13 @@ PARCEventBuffer *_tryReadControlMessage(_StreamState *stream, return NULL; } -static bool _isAnHIcnPacket(PARCEventBuffer *input) { +static bool _isAnHicnPacket(PARCEventBuffer *input) { size_t bytesAvailable = parcEventBuffer_GetLength(input); parcAssertTrue(bytesAvailable >= sizeof(header_control_message), "Called with too short an input: %zu", bytesAvailable); uint8_t *fh = parcEventBuffer_Pullup(input, sizeof(header_control_message)); - return messageHandler_IsValidHIcnPacket(fh); + return messageHandler_IsValidHicnPacket(fh); } static Message *_readMessage(_StreamState *stream, Ticks time, @@ -607,8 +607,8 @@ static void _conn_readcb(PARCEventQueue *event, PARCEventType type, parcEventBuffer_Destroy(&message); } - } else if (_isAnHIcnPacket(input)) { - // this is an HIcn packet (here we should distinguish between IPv4 and + } else if (_isAnHicnPacket(input)) { + // this is an Hicn packet (here we should distinguish between IPv4 and // IPv6 tryReadMessage may set nextMessageLength Message *message = _tryReadMessage(input, stream); |