Microsoft Azure IoTHub client libraries
Dependents: sht15_remote_monitoring RobotArmDemo iothub_client_sample_amqp f767zi_mqtt ... more
This library implements the Microsoft Azure IoTHub client library. The code is replicated from https://github.com/Azure/azure-iot-sdks
Diff: iothub_message.c
- Revision:
- 39:2719651a5bee
- Parent:
- 38:a05929a75111
- Child:
- 45:54c11b1b1407
diff -r a05929a75111 -r 2719651a5bee iothub_message.c --- a/iothub_message.c Fri Apr 08 13:24:33 2016 -0700 +++ b/iothub_message.c Sun Apr 24 16:40:16 2016 -0700 @@ -15,7 +15,7 @@ DEFINE_ENUM_STRINGS(IOTHUBMESSAGE_CONTENT_TYPE, IOTHUBMESSAGE_CONTENT_TYPE_VALUES); #define LOG_IOTHUB_MESSAGE_ERROR() \ - LogError("(result = %s)\r\n", ENUM_TO_STRING(IOTHUB_MESSAGE_RESULT, result)); + LogError("(result = %s)", ENUM_TO_STRING(IOTHUB_MESSAGE_RESULT, result)); typedef struct IOTHUB_MESSAGE_HANDLE_DATA_TAG { @@ -68,7 +68,7 @@ result = malloc(sizeof(IOTHUB_MESSAGE_HANDLE_DATA)); if (result == NULL) { - LogError("unable to malloc\r\n"); + LogError("unable to malloc"); /*Codes_SRS_IOTHUBMESSAGE_02_024: [If there are any errors then IoTHubMessage_CreateFromByteArray shall return NULL.] */ /*let it go through*/ } @@ -81,7 +81,7 @@ /*Codes_SRS_IOTHUBMESSAGE_06_002: [If size is NOT zero then byteArray MUST NOT be NULL*/ if (byteArray == NULL) { - LogError("Attempted to create a Hub Message from a NULL pointer!\r\n"); + LogError("Attempted to create a Hub Message from a NULL pointer!"); free(result); result = NULL; source = NULL; @@ -101,7 +101,7 @@ /*Codes_SRS_IOTHUBMESSAGE_02_022: [IoTHubMessage_CreateFromByteArray shall call BUFFER_create passing byteArray and size as parameters.] */ if ((result->value.byteArray = BUFFER_create(source, size)) == NULL) { - LogError("BUFFER_create failed\r\n"); + LogError("BUFFER_create failed"); /*Codes_SRS_IOTHUBMESSAGE_02_024: [If there are any errors then IoTHubMessage_CreateFromByteArray shall return NULL.] */ free(result); result = NULL; @@ -109,7 +109,7 @@ /*Codes_SRS_IOTHUBMESSAGE_02_023: [IoTHubMessage_CreateFromByteArray shall call Map_Create to create the message properties.] */ else if ((result->properties = Map_Create(ValidateAsciiCharactersFilter)) == NULL) { - LogError("Map_Create failed\r\n"); + LogError("Map_Create failed"); /*Codes_SRS_IOTHUBMESSAGE_02_024: [If there are any errors then IoTHubMessage_CreateFromByteArray shall return NULL.] */ BUFFER_delete(result->value.byteArray); free(result); @@ -134,7 +134,7 @@ result = malloc(sizeof(IOTHUB_MESSAGE_HANDLE_DATA)); if (result == NULL) { - LogError("malloc failed\r\n"); + LogError("malloc failed"); /*Codes_SRS_IOTHUBMESSAGE_02_029: [If there are any encountered in the execution of IoTHubMessage_CreateFromString then IoTHubMessage_CreateFromString shall return NULL.] */ /*let it go through*/ } @@ -143,7 +143,7 @@ /*Codes_SRS_IOTHUBMESSAGE_02_027: [IoTHubMessage_CreateFromString shall call STRING_construct passing source as parameter.] */ if ((result->value.string = STRING_construct(source)) == NULL) { - LogError("STRING_construct failed\r\n"); + LogError("STRING_construct failed"); /*Codes_SRS_IOTHUBMESSAGE_02_029: [If there are any encountered in the execution of IoTHubMessage_CreateFromString then IoTHubMessage_CreateFromString shall return NULL.] */ free(result); result = NULL; @@ -151,7 +151,7 @@ /*Codes_SRS_IOTHUBMESSAGE_02_028: [IoTHubMessage_CreateFromString shall call Map_Create to create the message properties.] */ else if ((result->properties = Map_Create(ValidateAsciiCharactersFilter)) == NULL) { - LogError("Map_Create failed\r\n"); + LogError("Map_Create failed"); /*Codes_SRS_IOTHUBMESSAGE_02_029: [If there are any encountered in the execution of IoTHubMessage_CreateFromString then IoTHubMessage_CreateFromString shall return NULL.] */ STRING_delete(result->value.string); free(result); @@ -178,7 +178,7 @@ if (source == NULL) { result = NULL; - LogError("iotHubMessageHandle parameter cannot be NULL for IoTHubMessage_Clone\r\n"); + LogError("iotHubMessageHandle parameter cannot be NULL for IoTHubMessage_Clone"); } else { @@ -188,7 +188,7 @@ { /*Codes_SRS_IOTHUBMESSAGE_03_004: [IoTHubMessage_Clone shall return NULL if it fails for any reason.]*/ /*do nothing and return as is*/ - LogError("unable to malloc\r\n"); + LogError("unable to malloc"); } else { @@ -196,13 +196,13 @@ result->correlationId = NULL; if (source->messageId != NULL && mallocAndStrcpy_s(&result->messageId, source->messageId) != 0) { - LogError("unable to Copy messageId\r\n"); + LogError("unable to Copy messageId"); free(result); result = NULL; } else if (source->correlationId != NULL && mallocAndStrcpy_s(&result->correlationId, source->correlationId) != 0) { - LogError("unable to Copy correlationId\r\n"); + LogError("unable to Copy correlationId"); if (result->messageId != NULL) { free(result->messageId); @@ -217,7 +217,7 @@ if ((result->value.byteArray = BUFFER_clone(source->value.byteArray)) == NULL) { /*Codes_SRS_IOTHUBMESSAGE_03_004: [IoTHubMessage_Clone shall return NULL if it fails for any reason.]*/ - LogError("unable to BUFFER_clone\r\n"); + LogError("unable to BUFFER_clone"); if (result->messageId) { free(result->messageId); @@ -235,7 +235,7 @@ else if ((result->properties = Map_Clone(source->properties)) == NULL) { /*Codes_SRS_IOTHUBMESSAGE_03_004: [IoTHubMessage_Clone shall return NULL if it fails for any reason.]*/ - LogError("unable to Map_Clone\r\n"); + LogError("unable to Map_Clone"); BUFFER_delete(result->value.byteArray); if (result->messageId) { @@ -275,13 +275,13 @@ } free(result); result = NULL; - LogError("failed to STRING_clone\r\n"); + LogError("failed to STRING_clone"); } /*Codes_SRS_IOTHUBMESSAGE_02_005: [IoTHubMessage_Clone shall clone the properties map by using Map_Clone.] */ else if ((result->properties = Map_Clone(source->properties)) == NULL) { /*Codes_SRS_IOTHUBMESSAGE_03_004: [IoTHubMessage_Clone shall return NULL if it fails for any reason.]*/ - LogError("unable to Map_Clone\r\n"); + LogError("unable to Map_Clone"); STRING_delete(result->value.string); if (result->messageId) { @@ -317,7 +317,7 @@ ) { /*Codes_SRS_IOTHUBMESSAGE_01_014: [If any of the arguments passed to IoTHubMessage_GetByteArray is NULL IoTHubMessage_GetByteArray shall return IOTHUBMESSAGE_INVALID_ARG.] */ - LogError("invalid parameter (NULL) to IoTHubMessage_GetByteArray IOTHUB_MESSAGE_HANDLE iotHubMessageHandle=%p, const unsigned char** buffer=%p, size_t* size=%p\r\n", iotHubMessageHandle, buffer, size); + LogError("invalid parameter (NULL) to IoTHubMessage_GetByteArray IOTHUB_MESSAGE_HANDLE iotHubMessageHandle=%p, const unsigned char** buffer=%p, size_t* size=%p", iotHubMessageHandle, buffer, size); result = IOTHUB_MESSAGE_INVALID_ARG; } else @@ -327,7 +327,7 @@ { /*Codes_SRS_IOTHUBMESSAGE_02_021: [If iotHubMessageHandle is not a iothubmessage containing BYTEARRAY data, then IoTHubMessage_GetData shall write in *buffer NULL and shall set *size to 0.] */ result = IOTHUB_MESSAGE_INVALID_ARG; - LogError("invalid type of message %s\r\n", ENUM_TO_STRING(IOTHUBMESSAGE_CONTENT_TYPE, handleData->contentType)); + LogError("invalid type of message %s", ENUM_TO_STRING(IOTHUBMESSAGE_CONTENT_TYPE, handleData->contentType)); } else { @@ -389,7 +389,7 @@ /*Codes_SRS_IOTHUBMESSAGE_02_001: [If iotHubMessageHandle is NULL then IoTHubMessage_Properties shall return NULL.]*/ if (iotHubMessageHandle == NULL) { - LogError("invalid arg (NULL) passed to IoTHubMessage_Properties\r\n"); + LogError("invalid arg (NULL) passed to IoTHubMessage_Properties"); result = NULL; } else @@ -407,7 +407,7 @@ /* Codes_SRS_IOTHUBMESSAGE_07_016: [if the iotHubMessageHandle parameter is NULL then IoTHubMessage_GetCorrelationId shall return a NULL value.] */ if (iotHubMessageHandle == NULL) { - LogError("invalid arg (NULL) passed to IoTHubMessage_GetCorrelationId\r\n"); + LogError("invalid arg (NULL) passed to IoTHubMessage_GetCorrelationId"); result = NULL; } else @@ -425,7 +425,7 @@ /* Codes_SRS_IOTHUBMESSAGE_07_018: [if any of the parameters are NULL then IoTHubMessage_SetCorrelationId shall return a IOTHUB_MESSAGE_INVALID_ARG value.]*/ if (iotHubMessageHandle == NULL || correlationId == NULL) { - LogError("invalid arg (NULL) passed to IoTHubMessage_SetCorrelationId\r\n"); + LogError("invalid arg (NULL) passed to IoTHubMessage_SetCorrelationId"); result = IOTHUB_MESSAGE_INVALID_ARG; } else @@ -457,7 +457,7 @@ /* Codes_SRS_IOTHUBMESSAGE_07_012: [if any of the parameters are NULL then IoTHubMessage_SetMessageId shall return a IOTHUB_MESSAGE_INVALID_ARG value.] */ if (iotHubMessageHandle == NULL || messageId == NULL) { - LogError("invalid arg (NULL) passed to IoTHubMessage_SetMessageId\r\n"); + LogError("invalid arg (NULL) passed to IoTHubMessage_SetMessageId"); result = IOTHUB_MESSAGE_INVALID_ARG; } else @@ -488,7 +488,7 @@ /* Codes_SRS_IOTHUBMESSAGE_07_010: [if the iotHubMessageHandle parameter is NULL then IoTHubMessage_MessageId shall return a NULL value.] */ if (iotHubMessageHandle == NULL) { - LogError("invalid arg (NULL) passed to IoTHubMessage_GetMessageId\r\n"); + LogError("invalid arg (NULL) passed to IoTHubMessage_GetMessageId"); result = NULL; } else