test/core/util/debugger_macros.cc

   1 /*
   2  *
   3  * Copyright 2016 gRPC authors.
   4  *
   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
   8  *
   9  *     http://www.apache.org/licenses/LICENSE-2.0
  10  *
  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.
  16  *
  17  */
  18
  19 /*
  20  * A collection of 'macros' that help navigating the grpc object hierarchy
  21  * Not intended to be robust for main-line code, often cuts across abstraction
  22  * boundaries.
  23  */
  24 #include <stdio.h>
  25
  26 #include "src/core/ext/filters/client_channel/client_channel.h"
  27 #include "src/core/ext/transport/chttp2/transport/internal.h"
  28 #include "src/core/lib/channel/connected_channel.h"
  29 #include "src/core/lib/surface/call.h"
  30
  31 grpc_stream* grpc_transport_stream_from_call(grpc_call* call) {
  32   grpc_call_stack* cs = grpc_call_get_call_stack(call);
  33   for (;;) {
  34     grpc_call_element* el = grpc_call_stack_element(cs, cs->count - 1);
  35     if (el->filter == &grpc_client_channel_filter) {
  36       grpc_core::RefCountedPtr<grpc_core::SubchannelCall> scc =
  37           grpc_client_channel_get_subchannel_call(el);
  38       if (scc == nullptr) {
  39         fprintf(stderr, "No subchannel-call");
  40         fflush(stderr);
  41         return nullptr;
  42       }
  43       cs = scc->GetCallStack();
  44     } else if (el->filter == &grpc_connected_filter) {
  45       return grpc_connected_channel_get_stream(el);
  46     } else {
  47       fprintf(stderr, "Unrecognized filter: %s", el->filter->name);
  48       fflush(stderr);
  49       return nullptr;
  50     }
  51   }
  52 }
  53
  54 grpc_chttp2_stream* grpc_chttp2_stream_from_call(grpc_call* call) {
  55   return reinterpret_cast<grpc_chttp2_stream*>(
  56       grpc_transport_stream_from_call(call));
  57 }