murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 1 | /* |
| 2 | * |
Jan Tattermusch | 7897ae9 | 2017-06-07 22:57:36 +0200 | [diff] [blame] | 3 | * Copyright 2015 gRPC authors. |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 4 | * |
Jan Tattermusch | 7897ae9 | 2017-06-07 22:57:36 +0200 | [diff] [blame] | 5 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 6 | * you may not use this file except in compliance with the License. |
| 7 | * You may obtain a copy of the License at |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 8 | * |
Jan Tattermusch | 7897ae9 | 2017-06-07 22:57:36 +0200 | [diff] [blame] | 9 | * http://www.apache.org/licenses/LICENSE-2.0 |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 10 | * |
Jan Tattermusch | 7897ae9 | 2017-06-07 22:57:36 +0200 | [diff] [blame] | 11 | * Unless required by applicable law or agreed to in writing, software |
| 12 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 13 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 14 | * See the License for the specific language governing permissions and |
| 15 | * limitations under the License. |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 16 | * |
| 17 | */ |
| 18 | |
Craig Tiller | 9533d04 | 2016-03-25 17:11:06 -0700 | [diff] [blame] | 19 | #include "src/core/lib/surface/call.h" |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 20 | |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 21 | #include <grpc/support/alloc.h> |
Masood Malekghassemi | 701af60 | 2015-06-03 15:01:17 -0700 | [diff] [blame] | 22 | #include <grpc/support/string_util.h> |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 23 | #include "src/core/lib/slice/slice_string_helpers.h" |
Craig Tiller | 9533d04 | 2016-03-25 17:11:06 -0700 | [diff] [blame] | 24 | #include "src/core/lib/support/string.h" |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 25 | |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 26 | static void add_metadata(gpr_strvec *b, const grpc_metadata *md, size_t count) { |
| 27 | size_t i; |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 28 | if (md == NULL) { |
| 29 | gpr_strvec_add(b, gpr_strdup("(nil)")); |
| 30 | return; |
| 31 | } |
Craig Tiller | d6c98df | 2015-08-18 09:33:44 -0700 | [diff] [blame] | 32 | for (i = 0; i < count; i++) { |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 33 | gpr_strvec_add(b, gpr_strdup("\nkey=")); |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 34 | gpr_strvec_add(b, grpc_slice_to_c_string(md[i].key)); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 35 | |
| 36 | gpr_strvec_add(b, gpr_strdup(" value=")); |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 37 | gpr_strvec_add(b, |
| 38 | grpc_dump_slice(md[i].value, GPR_DUMP_HEX | GPR_DUMP_ASCII)); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 39 | } |
| 40 | } |
| 41 | |
| 42 | char *grpc_op_string(const grpc_op *op) { |
| 43 | char *tmp; |
| 44 | char *out; |
| 45 | |
| 46 | gpr_strvec b; |
| 47 | gpr_strvec_init(&b); |
| 48 | |
| 49 | switch (op->op) { |
| 50 | case GRPC_OP_SEND_INITIAL_METADATA: |
| 51 | gpr_strvec_add(&b, gpr_strdup("SEND_INITIAL_METADATA")); |
| 52 | add_metadata(&b, op->data.send_initial_metadata.metadata, |
| 53 | op->data.send_initial_metadata.count); |
| 54 | break; |
| 55 | case GRPC_OP_SEND_MESSAGE: |
Mark D. Roth | 448c1f0 | 2017-01-25 10:44:30 -0800 | [diff] [blame] | 56 | gpr_asprintf(&tmp, "SEND_MESSAGE ptr=%p", |
| 57 | op->data.send_message.send_message); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 58 | gpr_strvec_add(&b, tmp); |
| 59 | break; |
| 60 | case GRPC_OP_SEND_CLOSE_FROM_CLIENT: |
| 61 | gpr_strvec_add(&b, gpr_strdup("SEND_CLOSE_FROM_CLIENT")); |
| 62 | break; |
| 63 | case GRPC_OP_SEND_STATUS_FROM_SERVER: |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 64 | gpr_asprintf(&tmp, "SEND_STATUS_FROM_SERVER status=%d details=", |
| 65 | op->data.send_status_from_server.status); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 66 | gpr_strvec_add(&b, tmp); |
Craig Tiller | 7c70b6c | 2017-01-23 07:48:42 -0800 | [diff] [blame] | 67 | if (op->data.send_status_from_server.status_details != NULL) { |
| 68 | gpr_strvec_add(&b, grpc_dump_slice( |
| 69 | *op->data.send_status_from_server.status_details, |
| 70 | GPR_DUMP_ASCII)); |
| 71 | } else { |
| 72 | gpr_strvec_add(&b, gpr_strdup("(null)")); |
| 73 | } |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 74 | add_metadata(&b, op->data.send_status_from_server.trailing_metadata, |
| 75 | op->data.send_status_from_server.trailing_metadata_count); |
| 76 | break; |
| 77 | case GRPC_OP_RECV_INITIAL_METADATA: |
| 78 | gpr_asprintf(&tmp, "RECV_INITIAL_METADATA ptr=%p", |
Mark D. Roth | 448c1f0 | 2017-01-25 10:44:30 -0800 | [diff] [blame] | 79 | op->data.recv_initial_metadata.recv_initial_metadata); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 80 | gpr_strvec_add(&b, tmp); |
| 81 | break; |
| 82 | case GRPC_OP_RECV_MESSAGE: |
Mark D. Roth | 448c1f0 | 2017-01-25 10:44:30 -0800 | [diff] [blame] | 83 | gpr_asprintf(&tmp, "RECV_MESSAGE ptr=%p", |
| 84 | op->data.recv_message.recv_message); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 85 | gpr_strvec_add(&b, tmp); |
| 86 | break; |
| 87 | case GRPC_OP_RECV_STATUS_ON_CLIENT: |
| 88 | gpr_asprintf(&tmp, |
| 89 | "RECV_STATUS_ON_CLIENT metadata=%p status=%p details=%p", |
| 90 | op->data.recv_status_on_client.trailing_metadata, |
| 91 | op->data.recv_status_on_client.status, |
| 92 | op->data.recv_status_on_client.status_details); |
| 93 | gpr_strvec_add(&b, tmp); |
| 94 | break; |
| 95 | case GRPC_OP_RECV_CLOSE_ON_SERVER: |
| 96 | gpr_asprintf(&tmp, "RECV_CLOSE_ON_SERVER cancelled=%p", |
| 97 | op->data.recv_close_on_server.cancelled); |
| 98 | gpr_strvec_add(&b, tmp); |
| 99 | } |
| 100 | out = gpr_strvec_flatten(&b, NULL); |
| 101 | gpr_strvec_destroy(&b); |
| 102 | |
| 103 | return out; |
| 104 | } |
| 105 | |
| 106 | void grpc_call_log_batch(char *file, int line, gpr_log_severity severity, |
| 107 | grpc_call *call, const grpc_op *ops, size_t nops, |
| 108 | void *tag) { |
| 109 | char *tmp; |
| 110 | size_t i; |
Craig Tiller | d6c98df | 2015-08-18 09:33:44 -0700 | [diff] [blame] | 111 | for (i = 0; i < nops; i++) { |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 112 | tmp = grpc_op_string(&ops[i]); |
Yuchen Zeng | 64c0e8d | 2016-06-10 11:19:51 -0700 | [diff] [blame] | 113 | gpr_log(file, line, severity, "ops[%" PRIuPTR "]: %s", i, tmp); |
murgatroid99 | d47946b | 2015-03-09 14:27:07 -0700 | [diff] [blame] | 114 | gpr_free(tmp); |
| 115 | } |
| 116 | } |