aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/memory_usage
diff options
context:
space:
mode:
authorGravatar Noah Eisen <ncteisen@google.com>2018-02-09 09:34:04 -0800
committerGravatar Noah Eisen <ncteisen@google.com>2018-02-09 09:34:04 -0800
commit4d20a666850b732cf1562487fb5f46ab9654105f (patch)
tree9059162d0f125e02780f506c2476d5d9bbc0eb7d /test/core/memory_usage
parentcddf6f838aa48c8d5c9f75cee5a8ed8abdcb25b9 (diff)
Run clang fmt
Diffstat (limited to 'test/core/memory_usage')
-rw-r--r--test/core/memory_usage/client.cc61
-rw-r--r--test/core/memory_usage/server.cc12
2 files changed, 42 insertions, 31 deletions
diff --git a/test/core/memory_usage/client.cc b/test/core/memory_usage/client.cc
index 96ff7ca721..3c3fa53b51 100644
--- a/test/core/memory_usage/client.cc
+++ b/test/core/memory_usage/client.cc
@@ -155,16 +155,20 @@ static struct grpc_memory_counters send_snapshot_request(int call_idx,
struct grpc_memory_counters snapshot;
snapshot.total_size_absolute =
- (reinterpret_cast<struct grpc_memory_counters*>GRPC_SLICE_START_PTR(response))
+ (reinterpret_cast<struct grpc_memory_counters*> GRPC_SLICE_START_PTR(
+ response))
->total_size_absolute;
snapshot.total_allocs_absolute =
- (reinterpret_cast<struct grpc_memory_counters*>GRPC_SLICE_START_PTR(response))
+ (reinterpret_cast<struct grpc_memory_counters*> GRPC_SLICE_START_PTR(
+ response))
->total_allocs_absolute;
snapshot.total_size_relative =
- (reinterpret_cast<struct grpc_memory_counters*>GRPC_SLICE_START_PTR(response))
+ (reinterpret_cast<struct grpc_memory_counters*> GRPC_SLICE_START_PTR(
+ response))
->total_size_relative;
snapshot.total_allocs_relative =
- (reinterpret_cast<struct grpc_memory_counters*>GRPC_SLICE_START_PTR(response))
+ (reinterpret_cast<struct grpc_memory_counters*> GRPC_SLICE_START_PTR(
+ response))
->total_allocs_relative;
grpc_metadata_array_destroy(&calls[call_idx].initial_metadata_recv);
@@ -284,10 +288,11 @@ int main(int argc, char** argv) {
grpc_shutdown();
gpr_log(GPR_INFO, "---------client stats--------");
- gpr_log(GPR_INFO, "client call memory usage: %f bytes per call",
- static_cast<double>(client_calls_inflight.total_size_relative -
- client_benchmark_calls_start.total_size_relative) /
- benchmark_iterations);
+ gpr_log(
+ GPR_INFO, "client call memory usage: %f bytes per call",
+ static_cast<double>(client_calls_inflight.total_size_relative -
+ client_benchmark_calls_start.total_size_relative) /
+ benchmark_iterations);
gpr_log(GPR_INFO, "client channel memory usage %zi bytes",
client_channel_end.total_size_relative -
client_channel_start.total_size_relative);
@@ -296,10 +301,11 @@ int main(int argc, char** argv) {
gpr_log(GPR_INFO, "server create: %zi bytes",
after_server_create.total_size_relative -
before_server_create.total_size_relative);
- gpr_log(GPR_INFO, "server call memory usage: %f bytes per call",
- static_cast<double>(server_calls_inflight.total_size_relative -
- server_benchmark_calls_start.total_size_relative) /
- benchmark_iterations);
+ gpr_log(
+ GPR_INFO, "server call memory usage: %f bytes per call",
+ static_cast<double>(server_calls_inflight.total_size_relative -
+ server_benchmark_calls_start.total_size_relative) /
+ benchmark_iterations);
gpr_log(GPR_INFO, "server channel memory usage %zi bytes",
server_calls_end.total_size_relative -
after_server_create.total_size_relative);
@@ -309,21 +315,22 @@ int main(int argc, char** argv) {
if (csv) {
char* env_build = gpr_getenv("BUILD_NUMBER");
char* env_job = gpr_getenv("JOB_NAME");
- fprintf(csv, "%f,%zi,%zi,%f,%zi,%s,%s\n",
- static_cast<double>(client_calls_inflight.total_size_relative -
- client_benchmark_calls_start.total_size_relative) /
- benchmark_iterations,
- client_channel_end.total_size_relative -
- client_channel_start.total_size_relative,
- after_server_create.total_size_relative -
- before_server_create.total_size_relative,
- static_cast<double>(server_calls_inflight.total_size_relative -
- server_benchmark_calls_start.total_size_relative) /
- benchmark_iterations,
- server_calls_end.total_size_relative -
- after_server_create.total_size_relative,
- env_build == nullptr ? "" : env_build,
- env_job == nullptr ? "" : env_job);
+ fprintf(
+ csv, "%f,%zi,%zi,%f,%zi,%s,%s\n",
+ static_cast<double>(client_calls_inflight.total_size_relative -
+ client_benchmark_calls_start.total_size_relative) /
+ benchmark_iterations,
+ client_channel_end.total_size_relative -
+ client_channel_start.total_size_relative,
+ after_server_create.total_size_relative -
+ before_server_create.total_size_relative,
+ static_cast<double>(server_calls_inflight.total_size_relative -
+ server_benchmark_calls_start.total_size_relative) /
+ benchmark_iterations,
+ server_calls_end.total_size_relative -
+ after_server_create.total_size_relative,
+ env_build == nullptr ? "" : env_build,
+ env_job == nullptr ? "" : env_job);
fclose(csv);
gpr_log(GPR_INFO, "Summary written to %s", csv_file);
}
diff --git a/test/core/memory_usage/server.cc b/test/core/memory_usage/server.cc
index f016fb248d..3e7bb7e11f 100644
--- a/test/core/memory_usage/server.cc
+++ b/test/core/memory_usage/server.cc
@@ -84,7 +84,8 @@ static void request_call_unary(int call_idx) {
}
static void send_initial_metadata_unary(void* tag) {
- grpc_metadata_array_init(&(*static_cast<fling_call*>(tag)).initial_metadata_send);
+ grpc_metadata_array_init(
+ &(*static_cast<fling_call*>(tag)).initial_metadata_send);
metadata_ops[0].op = GRPC_OP_SEND_INITIAL_METADATA;
metadata_ops[0].data.send_initial_metadata.count = 0;
@@ -111,7 +112,8 @@ static void send_snapshot(void* tag, struct grpc_memory_counters* snapshot) {
grpc_slice snapshot_slice =
grpc_slice_new(snapshot, sizeof(*snapshot), gpr_free);
payload_buffer = grpc_raw_byte_buffer_create(&snapshot_slice, 1);
- grpc_metadata_array_init(&(*static_cast<fling_call*>(tag)).initial_metadata_send);
+ grpc_metadata_array_init(
+ &(*static_cast<fling_call*>(tag)).initial_metadata_send);
op = snapshot_ops;
op->op = GRPC_OP_SEND_INITIAL_METADATA;
@@ -204,7 +206,8 @@ int main(int argc, char** argv) {
addr = addr_buf = nullptr;
// initialize call instances
- for (int i = 0; i < static_cast<int>(sizeof(calls) / sizeof(fling_call)); i++) {
+ for (int i = 0; i < static_cast<int>(sizeof(calls) / sizeof(fling_call));
+ i++) {
grpc_call_details_init(&calls[i].call_details);
calls[i].state = FLING_SERVER_NEW_REQUEST;
}
@@ -281,7 +284,8 @@ int main(int argc, char** argv) {
grpc_metadata_array_destroy(&s->request_metadata_recv);
break;
case FLING_SERVER_BATCH_SEND_STATUS_FLING_CALL:
- for (int k = 0; k < static_cast<int>(sizeof(calls) / sizeof(fling_call));
+ for (int k = 0;
+ k < static_cast<int>(sizeof(calls) / sizeof(fling_call));
++k) {
if (calls[k].state == FLING_SERVER_WAIT_FOR_DESTROY) {
calls[k].state = FLING_SERVER_SEND_STATUS_FLING_CALL;