Azure
/
azure-iot-c-analysis
зеркало из
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

Initial start for app_analysis

This commit is contained in:
jebrando 2018-11-16 18:11:15 -08:00
Родитель f140c4a057
Коммит e7b3155209
11 изменённых файлов: 154 добавлений и 40 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

1
CMakeLists.txt
Просмотреть файл

@ -62,6 +62,7 @@ set(SDK_CERT_INCLUDE_DIRS
)
set(REPORTER_DIR ${CMAKE_CURRENT_LIST_DIR})
add_analytic_directory(app_analysis "app_analysis")
add_analytic_directory(binary_info "binary_info")
add_subdirectory(network)
add_subdirectory(memory)

32
app_analysis/CMakeLists.txt Normal file
Просмотреть файл

@ -0,0 +1,32 @@
#Copyright (c) Microsoft. All rights reserved.
#Licensed under the MIT license. See LICENSE file in the project root for full license information.
set(app_analysis_c_files
src/main.c
)
set(app_analysis_h_files
inc/process_handler.h
)
if(WIN32)
set(app_analysis_c_files
${app_analysis_c_files}
src/process_handler_win.c
)
#windows needs this define
add_definitions(-D_CRT_SECURE_NO_WARNINGS)
else()
set(app_analysis_c_files
${app_analysis_c_files}
src/process_handler_linux.c
)
endif(WIN32)
message("${CMAKE_CURRENT_LIST_DIR}/inc")
include_directories(${CMAKE_CURRENT_LIST_DIR} ${CMAKE_CURRENT_LIST_DIR}/inc)
#include_directories(${SDK_INCLUDE_DIRS})
#set(BINARY_SOURCE_DIR ${CMAKE_CURRENT_LIST_DIR})
add_executable(app_analysis ${app_analysis_c_files} ${app_analysis_h_files})

28
app_analysis/inc/process_handler.h Normal file
Просмотреть файл

@ -0,0 +1,28 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
#ifndef PROCESS_HANDLER_H
#define PROCESS_HANDLER_H
#ifdef __cplusplus
#include <cstddef>
#include <cstdint>
extern "C" {
#else
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
#endif
typedef void* PROCESS_HANDLER_HANDLE;
//typedef struct PROCESS_HANDLER_INFO* PROCESS_HANDLER_HANDLE;
extern PROCESS_HANDLER_HANDLE process_handler_create(const char* process_path);
extern void process_handler_destroy(PROCESS_HANDLER_HANDLE handle);
extern int process_handler_start(PROCESS_HANDLER_HANDLE handle, const char* cmdline_args);
extern uint32_t process_handler_get_bin_size(PROCESS_HANDLER_HANDLE handle);
extern uint32_t process_handler_get_memory_used(PROCESS_HANDLER_HANDLE handle);
extern uint32_t process_handler_get_threads(PROCESS_HANDLER_HANDLE handle);
#endif // PROCESS_HANDLER_H

9
app_analysis/src/main.c Normal file
Просмотреть файл

@ -0,0 +1,9 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
#include "process_handler.h"
int main(int argc, char* argv[])
{
}

4
app_analysis/src/process_handler_linux.c Normal file
Просмотреть файл

@ -0,0 +1,4 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
#include "process_handler.h"

4
app_analysis/src/process_handler_win.c Normal file
Просмотреть файл

@ -0,0 +1,4 @@
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
#include "process_handler.h"

19
binary_info/binary_info.c
Просмотреть файл

@ -49,10 +49,10 @@ typedef enum ARGUEMENT_TYPE_TAG
ARGUEMENT_TYPE_CONN_STRING
} ARGUEMENT_TYPE;
static const char* get_binary_file(PROTOCOL_TYPE type)
static const char* get_binary_file(PROTOCOL_TYPE rpt_type)
{
const char* result;
switch (type)
switch (rpt_type)
{
case PROTOCOL_MQTT:
result = MQTT_BINARY_NAME;
@ -78,10 +78,10 @@ static const char* get_binary_file(PROTOCOL_TYPE type)
return result;
}
static bool is_lower_layer(FEATURE_TYPE type)
static bool is_lower_layer(FEATURE_TYPE rpt_type)
{
bool result;
switch (type)
switch (rpt_type)
{
case FEATURE_TELEMETRY_LL:
case FEATURE_C2D_LL:
@ -97,11 +97,11 @@ static bool is_lower_layer(FEATURE_TYPE type)
return result;
}
static int calculate_filesize(BINARY_INFO* bin_info, REPORT_HANDLE report_handle, PROTOCOL_TYPE type, const char* binary_path_fmt)
static int calculate_filesize(BINARY_INFO* bin_info, REPORT_HANDLE report_handle, PROTOCOL_TYPE rpt_type, const char* binary_path_fmt)
{
int result;
FILE* target_file;
const char* binary_name = get_binary_file(type);
const char* binary_name = get_binary_file(rpt_type);
if (binary_name == NULL)
{
(void)printf("Failed getting binary filename\r\n");
@ -125,7 +125,7 @@ static int calculate_filesize(BINARY_INFO* bin_info, REPORT_HANDLE report_handle
prov_exe = PROV_BINARY_NAME;
}
bin_info->iothub_protocol = type;
bin_info->iothub_protocol = rpt_type;
STRING_HANDLE filename_handle = STRING_construct_sprintf(binary_path_fmt, bin_info->cmake_dir, prov_exe, binary_name, suffix, prov_exe, binary_name, suffix, EXECUTABLE_EXT);
if (filename_handle == NULL)
{
@ -155,7 +155,7 @@ static int calculate_filesize(BINARY_INFO* bin_info, REPORT_HANDLE report_handle
return result;
}
// -c "<CMAKE DIRECTORY>" -t <report type - json, csv> -l
// -c "<CMAKE DIRECTORY>" -t <report rpt_type - json, csv> -l
static int parse_command_line(int argc, char* argv[], BINARY_INFO* bin_info)
{
int result = 0;
@ -250,6 +250,7 @@ int main(int argc, char* argv[])
BINARY_INFO bin_info;
REPORT_HANDLE report_handle;
memset(&bin_info, 0, sizeof(bin_info));
bin_info.sdk_type = SDK_TYPE_C;
if (parse_command_line(argc, argv, &bin_info) != 0)
{
@ -261,7 +262,7 @@ int main(int argc, char* argv[])
(void)printf("Failure cmake directory command line option not supplied\r\n");
result = __LINE__;
}
else if ((report_handle = report_initialize(bin_info.rpt_type)) == NULL)
else if ((report_handle = report_initialize(bin_info.rpt_type, bin_info.sdk_type)) == NULL)
{
(void)printf("Failure creating report handle\r\n");
result = __LINE__;

82
mem_reporter.c
Просмотреть файл

@ -36,12 +36,12 @@ static REPORTER_TYPE g_report_type = REPORTER_TYPE_JSON;
static const char* const UNKNOWN_TYPE = "unknown";
static const char* const NODE_SDK_ANALYSIS = "sdkAnalysis";
static const char* const NODE_BASE_ARRAY = "analysisItem";
static const char* const SDK_ANALYSIS_EMPTY_NODE = "{ \"sdkAnalysis\" : { \"osType\": \"%s\", \"version\": \"1.0.0\", \"uploadEnabled\": \"%s\", \"logEnabled\": \"%s\", \"analysisItem\" : [] } }";
static const char* const SDK_ANALYSIS_EMPTY_NODE = "{ \"sdkAnalysis\" : { \"osType\": \"%s\", \"sdkType\": \"%s\", \"version\": \"1.0.0\", \"uploadEnabled\": \"%s\", \"logEnabled\": \"%s\", \"analysisItem\" : [] } }";
static const char* const NODE_OPERATING_SYSTEM = "osType";
static const char* const BINARY_SIZE_JSON_FMT = "{ \"type\": \"ROM\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"layer\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"binarySize\" : \"%s\" }";
static const char* const HEAP_ANALYSIS_JSON_FMT = "{ \"type\": \"RAM\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"layer\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"msgCount\" : %d, \"maxMemory\" : \"%s\", \"currMemory\" : \"%s\", \"numAlloc\" : \"%s\" } }";
static const char* const NETWORK_ANALYSIS_JSON_FMT = "{ \"type\": \"NETWORK\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"msgPayload\" : %d, \"bytesSent\" : \"%s\", \"numSends\" : \"%s\", \"recvBytes\" : \"%s\", \"numRecv\" : \"%s\" } }";
static const char* const BINARY_SIZE_JSON_FMT = "{ \"rpt_type\": \"ROM\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"layer\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"binarySize\" : \"%s\" }";
static const char* const HEAP_ANALYSIS_JSON_FMT = "{ \"rpt_type\": \"RAM\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"layer\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"msgCount\" : %d, \"maxMemory\" : \"%s\", \"currMemory\" : \"%s\", \"numAlloc\" : \"%s\" } }";
static const char* const NETWORK_ANALYSIS_JSON_FMT = "{ \"rpt_type\": \"NETWORK\", \"dateTime\": \"%s\", \"feature\": \"%s\", \"version\": \"%s\", \"transport\" : \"%s\", \"msgPayload\" : %d, \"bytesSent\" : \"%s\", \"numSends\" : \"%s\", \"recvBytes\" : \"%s\", \"numRecv\" : \"%s\" } }";
static const char* const BINARY_SIZE_CSV_FMT = "%s, %s, %s, %s, %s, %s";
static const char* const HEAP_ANALYSIS_CSV_FMT = "%s, %s, %s, %s, %s, %s, %s, %d, %zu, %zu, %zu";
@ -71,7 +71,8 @@ typedef struct CSV_REPORT_INFO_TAG
typedef struct REPORT_INFO_TAG
{
REPORTER_TYPE type;
SDK_TYPE sdk_type;
REPORTER_TYPE rpt_type;
union
{
JSON_REPORT_INFO json_info;
@ -229,13 +230,13 @@ static bool upload_to_azure(const char* connection_string, const char* data)
return result;
}
static int write_to_storage(const char* report_data, const char* output_file, REPORTER_TYPE type)
static int write_to_storage(const char* report_data, const char* output_file, REPORTER_TYPE rpt_type)
{
int result;
if (output_file != NULL)
{
const char* filemode = "a";
if (type == REPORTER_TYPE_JSON)
if (rpt_type == REPORTER_TYPE_JSON)
{
filemode = "w";
}
@ -288,10 +289,10 @@ static const char* get_protocol_name(PROTOCOL_TYPE protocol)
return result;
}
static const char* get_layer_type(FEATURE_TYPE type)
static const char* get_layer_type(FEATURE_TYPE rpt_type)
{
const char* result;
switch (type)
switch (rpt_type)
{
case FEATURE_TELEMETRY_LL:
case FEATURE_C2D_LL:
@ -315,10 +316,10 @@ static const char* get_layer_type(FEATURE_TYPE type)
return result;
}
static const char* get_feature_type(FEATURE_TYPE type)
static const char* get_feature_type(FEATURE_TYPE rpt_type)
{
const char* result;
switch (type)
switch (rpt_type)
{
case FEATURE_TELEMETRY_LL:
case FEATURE_TELEMETRY_UL:
@ -347,10 +348,34 @@ static const char* get_feature_type(FEATURE_TYPE type)
return result;
}
static const char* get_operation_type(OPERATION_TYPE type)
static const char* get_sdk_type(SDK_TYPE sdk_type)
{
const char* result;
switch (type)
switch (sdk_type)
{
case SDK_TYPE_C:
result = "iot-sdk-c";
break;
case SDK_TYPE_CSHARP:
result = "iot-sdk-csharp";
break;
case SDK_TYPE_JAVA:
result = "iot-sdk-java";
break;
case SDK_TYPE_NODE:
result = "iot-sdk-node";
break;
default:
result = UNKNOWN_TYPE;
break;
}
return result;
}
static const char* get_operation_type(OPERATION_TYPE rpt_type)
{
const char* result;
switch (rpt_type)
{
case OPERATION_MEMORY:
result = "memory";
@ -368,13 +393,13 @@ static const char* get_operation_type(OPERATION_TYPE type)
return result;
}
static const char* get_format_value(const REPORT_INFO* report_info, OPERATION_TYPE type)
static const char* get_format_value(const REPORT_INFO* report_info, OPERATION_TYPE rpt_type)
{
const char* result;
switch (type)
switch (rpt_type)
{
case OPERATION_MEMORY:
if (report_info->type == REPORTER_TYPE_CSV)
if (report_info->rpt_type == REPORTER_TYPE_CSV)
{
result = HEAP_ANALYSIS_CSV_FMT;
}
@ -384,7 +409,7 @@ static const char* get_format_value(const REPORT_INFO* report_info, OPERATION_TY
}
break;
case OPERATION_NETWORK:
if (report_info->type == REPORTER_TYPE_CSV)
if (report_info->rpt_type == REPORTER_TYPE_CSV)
{
result = NETWORK_ANALYSIS_CSV_FMT;
}
@ -394,7 +419,7 @@ static const char* get_format_value(const REPORT_INFO* report_info, OPERATION_TY
}
break;
case OPERATION_BINARY_SIZE:
if (report_info->type == REPORTER_TYPE_CSV)
if (report_info->rpt_type == REPORTER_TYPE_CSV)
{
result = BINARY_SIZE_CSV_FMT;
}
@ -410,7 +435,7 @@ static const char* get_format_value(const REPORT_INFO* report_info, OPERATION_TY
return result;
}
REPORT_HANDLE report_initialize(REPORTER_TYPE type)
REPORT_HANDLE report_initialize(REPORTER_TYPE rpt_type, SDK_TYPE sdk_type)
{
REPORT_INFO* result;
if ((result = (REPORT_INFO*)malloc(sizeof(REPORT_INFO))) == NULL)
@ -421,10 +446,11 @@ REPORT_HANDLE report_initialize(REPORTER_TYPE type)
else
{
//JSON_Object* json_object;
result->type = type;
if (result->type == REPORTER_TYPE_JSON)
result->rpt_type = rpt_type;
result->sdk_type = sdk_type;
if (result->rpt_type == REPORTER_TYPE_JSON)
{
STRING_HANDLE json_node = STRING_construct_sprintf(SDK_ANALYSIS_EMPTY_NODE, OS_NAME, UPLOAD_INCLUDED, LOGGING_INCLUDED);
STRING_HANDLE json_node = STRING_construct_sprintf(SDK_ANALYSIS_EMPTY_NODE, OS_NAME, get_sdk_type(result->sdk_type), UPLOAD_INCLUDED, LOGGING_INCLUDED);
if (json_node == NULL)
{
(void)printf("Failure creating Analysis node\r\n");
@ -454,7 +480,7 @@ REPORT_HANDLE report_initialize(REPORTER_TYPE type)
}
STRING_delete(json_node);
}
else if (result->type == REPORTER_TYPE_CSV)
else if (result->rpt_type == REPORTER_TYPE_CSV)
{
if ((result->rpt_value.csv_info.csv_list = STRING_new()) == NULL)
{
@ -478,11 +504,11 @@ void report_deinitialize(REPORT_HANDLE handle)
// Close the file
if (handle != NULL)
{
if (handle->type == REPORTER_TYPE_JSON)
if (handle->rpt_type == REPORTER_TYPE_JSON)
{
json_value_free(handle->rpt_value.json_info.root_value);
}
else if (handle->type == REPORTER_TYPE_CSV)
else if (handle->rpt_type == REPORTER_TYPE_CSV)
{
STRING_delete(handle->rpt_value.csv_info.csv_list);
}
@ -588,7 +614,7 @@ bool report_write(REPORT_HANDLE handle, const char* output_file, const char* con
}
else
{
if (handle->type == REPORTER_TYPE_JSON)
if (handle->rpt_type == REPORTER_TYPE_JSON)
{
char* report_data = json_serialize_to_string_pretty(handle->rpt_value.json_info.root_value);
if (report_data == NULL)
@ -601,7 +627,7 @@ bool report_write(REPORT_HANDLE handle, const char* output_file, const char* con
// Write to a file or print out string
if (output_file != NULL)
{
write_to_storage(report_data, output_file, handle->type);
write_to_storage(report_data, output_file, handle->rpt_type);
}
else
{
@ -620,7 +646,7 @@ bool report_write(REPORT_HANDLE handle, const char* output_file, const char* con
const char* report_data = STRING_c_str(handle->rpt_value.csv_info.csv_list);
if (output_file != NULL)
{
write_to_storage(report_data, output_file, handle->type);
write_to_storage(report_data, output_file, handle->rpt_type);
}
if (conn_string != NULL)
{

11
mem_reporter.h
Просмотреть файл

@ -64,6 +64,14 @@ typedef struct REPORT_INFO_TAG* REPORT_HANDLE;
REPORTER_TYPE_MD
} REPORTER_TYPE;
typedef enum SDK_TYPE_TAG
{
SDK_TYPE_C,
SDK_TYPE_CSHARP,
SDK_TYPE_JAVA,
SDK_TYPE_NODE
} SDK_TYPE;
typedef struct CONNECTION_INFO_TAG
{
char* device_conn_string;
@ -91,9 +99,10 @@ typedef struct REPORT_INFO_TAG* REPORT_HANDLE;
const char* output_file;
const char* azure_conn_string;
bool skip_ul;
SDK_TYPE sdk_type;
} BINARY_INFO;
extern REPORT_HANDLE report_initialize(REPORTER_TYPE type);
extern REPORT_HANDLE report_initialize(REPORTER_TYPE rpt_type, SDK_TYPE sdk_type);
extern void report_deinitialize(REPORT_HANDLE handle);
extern void report_memory_usage(REPORT_HANDLE handle, const MEM_ANALYSIS_INFO* iot_mem_info);

2
memory/mem_analytics.c
Просмотреть файл

@ -331,7 +331,7 @@ int main(int argc, char* argv[])
(void)printf("failed construct dev\r\n");
result = __LINE__;
}
else if ((report_handle = report_initialize(REPORTER_TYPE_JSON)) == NULL)
else if ((report_handle = report_initialize(REPORTER_TYPE_JSON, SDK_TYPE_C)) == NULL)
{
(void)printf("Failure creating report handle\r\n");
free(conn_info.device_conn_string);

2
network/network_analytics.c
Просмотреть файл

@ -305,7 +305,7 @@ int main(int argc, char* argv[])
(void)printf("failed construct dev\r\n");
result = __LINE__;
}
else if ((report_handle = report_initialize(REPORTER_TYPE_JSON)) == NULL)
else if ((report_handle = report_initialize(REPORTER_TYPE_JSON, SDK_TYPE_C)) == NULL)
{
(void)printf("Failure creating report handle\r\n");
free(conn_info.device_conn_string);