| 
					
				 | 
			
			
				@@ -970,7 +970,7 @@ class ChannelData::ClientChannelControlHelper 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       UniquePtr<LoadBalancingPolicy::SubchannelPicker> picker) override { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     grpc_error* disconnect_error = 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         chand_->disconnect_error_.Load(MemoryOrder::ACQUIRE); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       const char* extra = disconnect_error == GRPC_ERROR_NONE 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                               ? "" 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                               : " (ignoring -- channel shutting down)"; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1105,7 +1105,7 @@ ChannelData::ChannelData(grpc_channel_element_args* args, grpc_error** error) 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     grpc_pollset_set_add_pollset_set(resolving_lb_policy_->interested_parties(), 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                                      interested_parties_); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p: created resolving_lb_policy=%p", this, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               resolving_lb_policy_.get()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1136,7 +1136,7 @@ bool ChannelData::ProcessResolverResultLocked( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(arg); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ProcessedResolverResult resolver_result(result); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   char* service_config_json = gpr_strdup(resolver_result.service_config_json()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p: resolver returned service config: \"%s\"", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, service_config_json); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1407,7 +1407,7 @@ void CallData::StartTransportStreamOpBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // If we've previously been cancelled, immediately fail any new batches. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (GPR_UNLIKELY(calld->cancel_error_ != GRPC_ERROR_NONE)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: failing batch with error: %s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               chand, calld, grpc_error_string(calld->cancel_error_)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1426,7 +1426,7 @@ void CallData::StartTransportStreamOpBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     GRPC_ERROR_UNREF(calld->cancel_error_); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     calld->cancel_error_ = 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         GRPC_ERROR_REF(batch->payload->cancel_stream.cancel_error); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: recording cancel_error=%s", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               calld, grpc_error_string(calld->cancel_error_)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1454,7 +1454,7 @@ void CallData::StartTransportStreamOpBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // the channel combiner, which is more efficient (especially for 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // streaming calls). 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (calld->subchannel_call_ != nullptr) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: starting batch on subchannel_call=%p", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               calld, calld->subchannel_call_.get()); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1466,7 +1466,7 @@ void CallData::StartTransportStreamOpBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // For batches containing a send_initial_metadata op, enter the channel 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // combiner to start a pick. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (GPR_LIKELY(batch->send_initial_metadata)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: entering client_channel combiner", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               chand, calld); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1477,7 +1477,7 @@ void CallData::StartTransportStreamOpBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         GRPC_ERROR_NONE); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     // For all other batches, release the call combiner. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: saved batch, yielding call combiner", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               calld); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1535,7 +1535,7 @@ void CallData::MaybeCacheSendOpsForBatch(PendingBatch* pending) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::FreeCachedSendInitialMetadata(ChannelData* chand) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: destroying calld->send_initial_metadata", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1544,7 +1544,7 @@ void CallData::FreeCachedSendInitialMetadata(ChannelData* chand) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::FreeCachedSendMessage(ChannelData* chand, size_t idx) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: destroying calld->send_messages[%" PRIuPTR "]", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this, idx); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1553,7 +1553,7 @@ void CallData::FreeCachedSendMessage(ChannelData* chand, size_t idx) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::FreeCachedSendTrailingMetadata(ChannelData* chand) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: destroying calld->send_trailing_metadata", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1630,7 +1630,7 @@ void CallData::PendingBatchesAdd(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                                  grpc_transport_stream_op_batch* batch) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   const size_t idx = GetBatchIndex(batch); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: adding pending batch at index %" PRIuPTR, chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             this, idx); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1659,7 +1659,7 @@ void CallData::PendingBatchesAdd(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (GPR_UNLIKELY(bytes_buffered_for_retry_ > 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                      chand->per_rpc_retry_buffer_size())) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 "chand=%p calld=%p: exceeded retry buffer size, committing", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 chand, this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1672,7 +1672,7 @@ void CallData::PendingBatchesAdd(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       // If we are not going to retry and have not yet started, pretend 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       // retries are disabled so that we don't bother with retry overhead. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       if (num_attempts_completed_ == 0) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-        if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+        if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				           gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                   "chand=%p calld=%p: disabling retries before first attempt", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                   chand, this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1713,7 +1713,7 @@ void CallData::MaybeClearPendingBatch(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       (!batch->recv_trailing_metadata || 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				        batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready == 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				            nullptr)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: clearing pending batch", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1736,7 +1736,7 @@ void CallData::PendingBatchesFail( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     grpc_call_element* elem, grpc_error* error, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     YieldCallCombinerPredicate yield_call_combiner_predicate) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   GPR_ASSERT(error != GRPC_ERROR_NONE); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     size_t num_batches = 0; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     for (size_t i = 0; i < GPR_ARRAY_SIZE(pending_batches_); ++i) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       if (pending_batches_[i].batch != nullptr) ++num_batches; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1790,7 +1790,7 @@ void CallData::PendingBatchesResume(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     return; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Retries not enabled; send down batches as-is. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     size_t num_batches = 0; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     for (size_t i = 0; i < GPR_ARRAY_SIZE(pending_batches_); ++i) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       if (pending_batches_[i].batch != nullptr) ++num_batches; 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1831,7 +1831,7 @@ CallData::PendingBatch* CallData::PendingBatchFind(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     PendingBatch* pending = &pending_batches_[i]; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     grpc_transport_stream_op_batch* batch = pending->batch; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (batch != nullptr && predicate(batch)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 "chand=%p calld=%p: %s pending batch at index %" PRIuPTR, chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 this, log_message, i); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1851,7 +1851,7 @@ void CallData::RetryCommit(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (retry_committed_) return; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   retry_committed_ = true; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: committing retries", chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (retry_state != nullptr) { 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1886,7 +1886,7 @@ void CallData::DoRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     next_attempt_time = retry_backoff_->NextAttemptTime(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: retrying failed call in %" PRId64 " ms", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             this, next_attempt_time - ExecCtx::Get()->Now()); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1916,7 +1916,7 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     retry_state = static_cast<SubchannelCallRetryState*>( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         batch_data->subchannel_call->GetParentData()); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (retry_state->retry_dispatched) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, "chand=%p calld=%p: retry already dispatched", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1928,14 +1928,14 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (retry_throttle_data_ != nullptr) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       retry_throttle_data_->RecordSuccess(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: call succeeded", chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     return false; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Status is not OK.  Check whether the status is retryable. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (!retry_policy->retryable_status_codes.Contains(status)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: status %s not configured as retryable", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               this, grpc_status_code_to_string(status)); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1951,14 +1951,14 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // checks, so that we don't fail to record failures due to other factors. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (retry_throttle_data_ != nullptr && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !retry_throttle_data_->RecordFailure()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: retries throttled", chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     return false; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Check whether the call is committed. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (retry_committed_) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: retries already committed", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1967,7 +1967,7 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Check whether we have retries remaining. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ++num_attempts_completed_; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (num_attempts_completed_ >= retry_policy->max_attempts) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, "chand=%p calld=%p: exceeded %d retry attempts", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               this, retry_policy->max_attempts); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1975,7 +1975,7 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // If the call was cancelled from the surface, don't retry. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (cancel_error_ != GRPC_ERROR_NONE) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: call cancelled from surface, not retrying", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               chand, this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -1988,14 +1988,14 @@ bool CallData::MaybeRetry(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     // If the value is "-1" or any other unparseable string, we do not retry. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     uint32_t ms; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (!grpc_parse_slice_to_uint32(GRPC_MDVALUE(*server_pushback_md), &ms)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 "chand=%p calld=%p: not retrying due to server push-back", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       return false; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } else { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, "chand=%p calld=%p: server push-back: retry in %u ms", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 chand, this, ms); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2098,7 +2098,7 @@ void CallData::RecvInitialMetadataReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_call_element* elem = batch_data->elem; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: got recv_initial_metadata_ready, error=%s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, calld, grpc_error_string(error)); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2122,7 +2122,7 @@ void CallData::RecvInitialMetadataReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (GPR_UNLIKELY((retry_state->trailing_metadata_available || 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     error != GRPC_ERROR_NONE) && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                    !retry_state->completed_recv_trailing_metadata)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: deferring recv_initial_metadata_ready " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "(Trailers-Only)", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2188,7 +2188,7 @@ void CallData::RecvMessageReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_call_element* elem = batch_data->elem; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: got recv_message_ready, error=%s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, calld, grpc_error_string(error)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2210,7 +2210,7 @@ void CallData::RecvMessageReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (GPR_UNLIKELY( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				           (retry_state->recv_message == nullptr || error != GRPC_ERROR_NONE) && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				           !retry_state->completed_recv_trailing_metadata)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: deferring recv_message_ready (nullptr " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "message and recv_trailing_metadata pending)", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2348,7 +2348,7 @@ void CallData::AddClosuresToFailUnstartedPendingBatches( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   for (size_t i = 0; i < GPR_ARRAY_SIZE(pending_batches_); ++i) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     PendingBatch* pending = &pending_batches_[i]; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     if (PendingBatchIsUnstarted(pending, retry_state)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-      if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+      if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				         gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 "chand=%p calld=%p: failing unstarted pending batch at index " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                 "%" PRIuPTR, 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2394,7 +2394,7 @@ void CallData::RecvTrailingMetadataReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_call_element* elem = batch_data->elem; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: got recv_trailing_metadata_ready, error=%s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, calld, grpc_error_string(error)); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2410,7 +2410,7 @@ void CallData::RecvTrailingMetadataReady(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       batch_data->batch.payload->recv_trailing_metadata.recv_trailing_metadata; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   calld->GetCallStatus(elem, md_batch, GRPC_ERROR_REF(error), &status, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                        &server_pushback_md); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: call finished, status=%s", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             calld, grpc_status_code_to_string(status)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2489,7 +2489,7 @@ void CallData::AddClosuresForReplayOrPendingSendOps( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (have_pending_send_message_ops || have_pending_send_trailing_metadata_op) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: starting next batch for pending send op(s)", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               chand, this); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2508,7 +2508,7 @@ void CallData::OnComplete(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_call_element* elem = batch_data->elem; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     char* batch_str = grpc_transport_stream_op_batch_string(&batch_data->batch); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: got on_complete, error=%s, batch=%s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, calld, grpc_error_string(error), batch_str); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2584,7 +2584,7 @@ void CallData::AddClosureForSubchannelBatch( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   batch->handler_private.extra_arg = subchannel_call_.get(); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   GRPC_CLOSURE_INIT(&batch->handler_private.closure, StartBatchInCallCombiner, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                     batch, grpc_schedule_on_exec_ctx); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     char* batch_str = grpc_transport_stream_op_batch_string(batch); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: starting subchannel batch: %s", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             this, batch_str); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2647,7 +2647,7 @@ void CallData::AddRetriableSendMessageOp(grpc_call_element* elem, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                                          SubchannelCallRetryState* retry_state, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				                                          SubchannelCallBatchData* batch_data) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: starting calld->send_messages[%" PRIuPTR "]", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this, retry_state->started_send_message_count); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2730,7 +2730,7 @@ void CallData::AddRetriableRecvTrailingMetadataOp( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::StartInternalRecvTrailingMetadata(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: call failed but recv_trailing_metadata not " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "started; starting it internally", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2762,7 +2762,7 @@ CallData::MaybeCreateSubchannelBatchForReplay( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (seen_send_initial_metadata_ && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !retry_state->started_send_initial_metadata && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !pending_send_initial_metadata_) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: replaying previously completed " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "send_initial_metadata op", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2778,7 +2778,7 @@ CallData::MaybeCreateSubchannelBatchForReplay( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       retry_state->started_send_message_count == 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				           retry_state->completed_send_message_count && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !pending_send_message_) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: replaying previously completed " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "send_message op", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2798,7 +2798,7 @@ CallData::MaybeCreateSubchannelBatchForReplay( 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       retry_state->started_send_message_count == send_messages_.size() && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !retry_state->started_send_trailing_metadata && 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       !pending_send_trailing_metadata_) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: replaying previously completed " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "send_trailing_metadata op", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2941,7 +2941,7 @@ void CallData::StartRetriableSubchannelBatches(void* arg, grpc_error* ignored) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_call_element* elem = static_cast<grpc_call_element*>(arg); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: constructing retriable batches", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, calld); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2966,7 +2966,7 @@ void CallData::StartRetriableSubchannelBatches(void* arg, grpc_error* ignored) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Now add pending batches. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   calld->AddSubchannelBatchesForPendingBatches(elem, retry_state, &closures); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Start batches on subchannel call. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_call_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_call_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: starting %" PRIuPTR 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             " retriable batches on subchannel_call=%p", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -2992,7 +2992,7 @@ void CallData::CreateSubchannelCall(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   grpc_error* error = GRPC_ERROR_NONE; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   subchannel_call_ = 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       pick_.pick.connected_subchannel->CreateCall(call_args, &error); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: create subchannel_call=%p: error=%s", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this, subchannel_call_.get(), grpc_error_string(error)); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3012,7 +3012,7 @@ void CallData::PickDone(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   CallData* calld = static_cast<CallData*>(elem->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   if (error != GRPC_ERROR_NONE) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: failed to pick subchannel: error=%s", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               calld, grpc_error_string(error)); 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3041,7 +3041,7 @@ class CallData::QueuedPickCanceller { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     auto* self = static_cast<QueuedPickCanceller*>(arg); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     auto* chand = static_cast<ChannelData*>(self->elem_->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     auto* calld = static_cast<CallData*>(self->elem_->call_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-    if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+    if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				       gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "chand=%p calld=%p: cancelling queued pick: " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				               "error=%s self=%p calld->pick_canceller=%p", 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3065,7 +3065,7 @@ class CallData::QueuedPickCanceller { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::RemoveCallFromQueuedPicksLocked(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   auto* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: removing from queued picks list", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3077,7 +3077,7 @@ void CallData::RemoveCallFromQueuedPicksLocked(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::AddCallToQueuedPicksLocked(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   auto* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: adding to queued picks list", chand, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3090,7 +3090,7 @@ void CallData::AddCallToQueuedPicksLocked(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				  
			 | 
		
	
		
			
				 | 
				 | 
			
			
				 void CallData::ApplyServiceConfigToCallLocked(grpc_call_element* elem) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, "chand=%p calld=%p: applying service config to call", 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             chand, this); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   } 
			 | 
		
	
	
		
			
				| 
					
				 | 
			
			
				@@ -3199,7 +3199,7 @@ void CallData::StartPickLocked(void* arg, grpc_error* error) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   // Attempt pick. 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   error = GRPC_ERROR_NONE; 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				   auto pick_result = chand->picker()->Pick(&calld->pick_.pick, &error); 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				-  if (grpc_client_channel_routing_trace.enabled()) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				+  if (GRPC_TRACE_FLAG_ENABLED(grpc_client_channel_routing_trace)) { 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				     gpr_log(GPR_INFO, 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "chand=%p calld=%p: LB pick returned %s (connected_subchannel=%p, " 
			 | 
		
	
		
			
				 | 
				 | 
			
			
				             "error=%s)", 
			 |