return;
}
- // create remote endpoint
- CAEndpoint_t *endpoint = NULL;
-
printf("URI : %s\n", uri);
addressSet_t address = {{}, 0};
parsing_coap_uri(uri, &address, &flags);
+ // create remote endpoint
+ CAEndpoint_t *endpoint = NULL;
res = CACreateEndpoint(flags, g_selected_nw_type,
(const char*)address.ipAddress, address.port, &endpoint);
if (CA_STATUS_OK != res || !endpoint)
return;
}
- printf("Generated token %s\n", token);
-
// extract relative resourceuri from give uri
char resourceURI[RESOURCE_URI_LENGTH + 1] = {0};
get_resource_uri(uri, resourceURI, RESOURCE_URI_LENGTH);
if (NULL == requestData.payload)
{
printf("Memory allocation fail\n");
- CADestroyEndpoint(endpoint);
- CADestroyToken(token);
- return;
+ goto exit;
}
snprintf((char *) requestData.payload, length, SECURE_INFO_DATA,
(const char *) resourceURI, g_local_secure_port);
if (!binaryPayload)
{
free(binaryPayload);
- CADestroyToken(token);
- CADestroyEndpoint(endpoint);
- return;
+ goto exit;
}
requestData.payload = (CAPayload_t) malloc(payloadLength);
{
printf("Memory allocation failed!");
free(binaryPayload);
- CADestroyToken(token);
- CADestroyEndpoint(endpoint);
- return;
+ goto exit;
}
memcpy(requestData.payload, binaryPayload, payloadLength);
requestData.payloadSize = payloadLength;
if (NULL == requestData.payload)
{
printf("Memory allocation fail\n");
- CADestroyEndpoint(endpoint);
- CADestroyToken(token);
- return;
+ goto exit;
}
snprintf((char *) requestData.payload, length, NORMAL_INFO_DATA,
(const char *) resourceURI);
printf("Could not send request : %d\n", res);
}
- if (headerOpt)
- {
- free(headerOpt);
- }
+ free(headerOpt);
+ free(requestData.payload);
- //destroy token
+exit:
+ // cleanup
CADestroyToken(token);
- // destroy remote endpoint
CADestroyEndpoint(endpoint);
- free(requestData.payload);
-
printf("=============================================\n");
}
goto exit;
}
- printf("Generated token %s\n", token);
-
// create request data
CAInfo_t requestData = { .type = CA_MSG_NONCONFIRM,
.messageId = 0,
return;
}
- printf("generated token %s\n", token);
-
// create request data
CAPayload_t payload = (CAPayload_t) "TempJsonPayload";
size_t payloadSize = strlen((const char *) payload);
g_last_request_token = token;
}
- if (headerOpt)
- {
- free(headerOpt);
- }
-
+ free(headerOpt);
// destroy remote endpoint
CADestroyEndpoint(group);
return;
}
- printf("Generated token %s\n", token);
-
// create response data
CAPayload_t payload = (CAPayload_t) "TempNotificationData";
size_t payloadSize = strlen((const char *) payload);
}
printf("##########received request from remote device #############\n");
- if (CA_ADAPTER_IP == object->adapter)
+ if (CA_ADAPTER_IP == object->adapter || CA_ADAPTER_TCP == object->adapter)
{
printf("Remote Address: %s Port: %d secured:%d\n", object->addr,
object->port, object->flags & CA_SECURE);
printf("############################################################\n");
//Check if this has secure communication information
- if (requestInfo->info.payload &&
- (CA_ADAPTER_IP == object->adapter))
+ if (requestInfo->info.payload && (CA_ADAPTER_IP == object->adapter))
{
int securePort = get_secure_information(requestInfo->info.payload);
if (0 < securePort) //Set the remote endpoint secure details and send response
CAPayload_t binaryPayload = get_binary_payload(&payloadLength);
if (NULL == binaryPayload)
{
- free(binaryPayload);
+ printf("Failed to read binary file");
return;
}
printf("Send response success\n");
}
- if (responseData.payload)
- {
- free(responseData.payload);
- }
+ free(responseData.payload);
printf("=============================================\n");
}
if (!get_address_set(pAddress, address))
{
printf("address parse error\n");
-
- free(cloneUri);
- return;
}
+
free(cloneUri);
return;
}
}
return true;
}
- else
- {
- return false;
- }
+
+ return false;
}
void create_file(CAPayload_t bytes, size_t length)