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
  25 #include <stdio.h>
  26
  27 #include "src/core/ext/filters/client_channel/client_channel.h"
  28 #include "src/core/ext/transport/chttp2/transport/internal.h"
  29 #include "src/core/lib/channel/connected_channel.h"
  30 #include "src/core/lib/surface/call.h"
  31
  32 void grpc_summon_debugger_macros() {}
  33
  34 grpc_stream* grpc_transport_stream_from_call(grpc_call* call) {
  35   grpc_call_stack* cs = grpc_call_get_call_stack(call);
  36   for (;;) {
  37     grpc_call_element* el = grpc_call_stack_element(cs, cs->count - 1);
  38     if (el->filter == &grpc_client_channel_filter) {
  39       grpc_core::RefCountedPtr<grpc_core::SubchannelCall> scc =
  40           grpc_client_channel_get_subchannel_call(el);
  41       if (scc == nullptr) {
  42         fprintf(stderr, "No subchannel-call");
  43         fflush(stderr);
  44         return nullptr;
  45       }
  46       cs = scc->GetCallStack();
  47     } else if (el->filter == &grpc_connected_filter) {
  48       return grpc_connected_channel_get_stream(el);
  49     } else {
  50       fprintf(stderr, "Unrecognized filter: %s", el->filter->name);
  51       fflush(stderr);
  52       return nullptr;
  53     }
  54   }
  55 }
  56
  57 grpc_chttp2_stream* grpc_chttp2_stream_from_call(grpc_call* call) {
  58   return reinterpret_cast<grpc_chttp2_stream*>(
  59       grpc_transport_stream_from_call(call));
  60 }