Coverage Report

Created: 2026-03-19 06:47

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/src/brpc/build/brpc/rtmp.pb.cc
Line
Count
Source
1
// Generated by the protocol buffer compiler.  DO NOT EDIT!
2
// source: brpc/rtmp.proto
3
4
#include "brpc/rtmp.pb.h"
5
6
#include <algorithm>
7
8
#include <google/protobuf/io/coded_stream.h>
9
#include <google/protobuf/extension_set.h>
10
#include <google/protobuf/wire_format_lite.h>
11
#include <google/protobuf/descriptor.h>
12
#include <google/protobuf/generated_message_reflection.h>
13
#include <google/protobuf/reflection_ops.h>
14
#include <google/protobuf/wire_format.h>
15
// @@protoc_insertion_point(includes)
16
#include <google/protobuf/port_def.inc>
17
18
PROTOBUF_PRAGMA_INIT_SEG
19
20
namespace _pb = ::PROTOBUF_NAMESPACE_ID;
21
namespace _pbi = _pb::internal;
22
23
namespace brpc {
24
PROTOBUF_CONSTEXPR RtmpConnectRequest::RtmpConnectRequest(
25
    ::_pbi::ConstantInitialized): _impl_{
26
    /*decltype(_impl_._has_bits_)*/{}
27
  , /*decltype(_impl_._cached_size_)*/{}
28
  , /*decltype(_impl_.app_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
29
  , /*decltype(_impl_.flashver_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
30
  , /*decltype(_impl_.swfurl_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
31
  , /*decltype(_impl_.tcurl_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
32
  , /*decltype(_impl_.pageurl_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
33
  , /*decltype(_impl_.capabilities_)*/0
34
  , /*decltype(_impl_.audiocodecs_)*/0
35
  , /*decltype(_impl_.videocodecs_)*/0
36
  , /*decltype(_impl_.videofunction_)*/0
37
  , /*decltype(_impl_.objectencoding_)*/0
38
  , /*decltype(_impl_.fpad_)*/false
39
  , /*decltype(_impl_.stream_multiplexing_)*/false} {}
40
struct RtmpConnectRequestDefaultTypeInternal {
41
  PROTOBUF_CONSTEXPR RtmpConnectRequestDefaultTypeInternal()
42
0
      : _instance(::_pbi::ConstantInitialized{}) {}
43
0
  ~RtmpConnectRequestDefaultTypeInternal() {}
44
  union {
45
    RtmpConnectRequest _instance;
46
  };
47
};
48
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RtmpConnectRequestDefaultTypeInternal _RtmpConnectRequest_default_instance_;
49
PROTOBUF_CONSTEXPR RtmpConnectResponse::RtmpConnectResponse(
50
    ::_pbi::ConstantInitialized): _impl_{
51
    /*decltype(_impl_._has_bits_)*/{}
52
  , /*decltype(_impl_._cached_size_)*/{}
53
  , /*decltype(_impl_.fmsver_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
54
  , /*decltype(_impl_.capabilities_)*/0
55
  , /*decltype(_impl_.mode_)*/0
56
  , /*decltype(_impl_.create_stream_with_play_or_publish_)*/false} {}
57
struct RtmpConnectResponseDefaultTypeInternal {
58
  PROTOBUF_CONSTEXPR RtmpConnectResponseDefaultTypeInternal()
59
0
      : _instance(::_pbi::ConstantInitialized{}) {}
60
0
  ~RtmpConnectResponseDefaultTypeInternal() {}
61
  union {
62
    RtmpConnectResponse _instance;
63
  };
64
};
65
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RtmpConnectResponseDefaultTypeInternal _RtmpConnectResponse_default_instance_;
66
PROTOBUF_CONSTEXPR RtmpPlay2Options::RtmpPlay2Options(
67
    ::_pbi::ConstantInitialized): _impl_{
68
    /*decltype(_impl_._has_bits_)*/{}
69
  , /*decltype(_impl_._cached_size_)*/{}
70
  , /*decltype(_impl_.oldstreamname_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
71
  , /*decltype(_impl_.streamname_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
72
  , /*decltype(_impl_.transition_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
73
  , /*decltype(_impl_.len_)*/0
74
  , /*decltype(_impl_.offset_)*/0
75
  , /*decltype(_impl_.start_)*/0} {}
76
struct RtmpPlay2OptionsDefaultTypeInternal {
77
  PROTOBUF_CONSTEXPR RtmpPlay2OptionsDefaultTypeInternal()
78
0
      : _instance(::_pbi::ConstantInitialized{}) {}
79
0
  ~RtmpPlay2OptionsDefaultTypeInternal() {}
80
  union {
81
    RtmpPlay2Options _instance;
82
  };
83
};
84
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RtmpPlay2OptionsDefaultTypeInternal _RtmpPlay2Options_default_instance_;
85
PROTOBUF_CONSTEXPR RtmpInfo::RtmpInfo(
86
    ::_pbi::ConstantInitialized): _impl_{
87
    /*decltype(_impl_._has_bits_)*/{}
88
  , /*decltype(_impl_._cached_size_)*/{}
89
  , /*decltype(_impl_.code_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
90
  , /*decltype(_impl_.level_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
91
  , /*decltype(_impl_.description_)*/{&::_pbi::fixed_address_empty_string, ::_pbi::ConstantInitialized{}}
92
  , /*decltype(_impl_.objectencoding_)*/0} {}
93
struct RtmpInfoDefaultTypeInternal {
94
  PROTOBUF_CONSTEXPR RtmpInfoDefaultTypeInternal()
95
0
      : _instance(::_pbi::ConstantInitialized{}) {}
96
0
  ~RtmpInfoDefaultTypeInternal() {}
97
  union {
98
    RtmpInfo _instance;
99
  };
100
};
101
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RtmpInfoDefaultTypeInternal _RtmpInfo_default_instance_;
102
PROTOBUF_CONSTEXPR RtmpEmptyObject::RtmpEmptyObject(
103
    ::_pbi::ConstantInitialized) {}
104
struct RtmpEmptyObjectDefaultTypeInternal {
105
  PROTOBUF_CONSTEXPR RtmpEmptyObjectDefaultTypeInternal()
106
0
      : _instance(::_pbi::ConstantInitialized{}) {}
107
0
  ~RtmpEmptyObjectDefaultTypeInternal() {}
108
  union {
109
    RtmpEmptyObject _instance;
110
  };
111
};
112
PROTOBUF_ATTRIBUTE_NO_DESTROY PROTOBUF_CONSTINIT PROTOBUF_ATTRIBUTE_INIT_PRIORITY1 RtmpEmptyObjectDefaultTypeInternal _RtmpEmptyObject_default_instance_;
113
}  // namespace brpc
114
static ::_pb::Metadata file_level_metadata_brpc_2frtmp_2eproto[5];
115
static constexpr ::_pb::EnumDescriptor const** file_level_enum_descriptors_brpc_2frtmp_2eproto = nullptr;
116
static constexpr ::_pb::ServiceDescriptor const** file_level_service_descriptors_brpc_2frtmp_2eproto = nullptr;
117
118
const uint32_t TableStruct_brpc_2frtmp_2eproto::offsets[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
119
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_._has_bits_),
120
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _internal_metadata_),
121
  ~0u,  // no _extensions_
122
  ~0u,  // no _oneof_case_
123
  ~0u,  // no _weak_field_map_
124
  ~0u,  // no _inlined_string_donated_
125
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.app_),
126
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.flashver_),
127
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.swfurl_),
128
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.tcurl_),
129
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.fpad_),
130
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.capabilities_),
131
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.audiocodecs_),
132
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.videocodecs_),
133
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.videofunction_),
134
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.pageurl_),
135
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.objectencoding_),
136
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectRequest, _impl_.stream_multiplexing_),
137
  0,
138
  1,
139
  2,
140
  3,
141
  10,
142
  5,
143
  6,
144
  7,
145
  8,
146
  4,
147
  9,
148
  11,
149
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _impl_._has_bits_),
150
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _internal_metadata_),
151
  ~0u,  // no _extensions_
152
  ~0u,  // no _oneof_case_
153
  ~0u,  // no _weak_field_map_
154
  ~0u,  // no _inlined_string_donated_
155
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _impl_.fmsver_),
156
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _impl_.capabilities_),
157
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _impl_.mode_),
158
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpConnectResponse, _impl_.create_stream_with_play_or_publish_),
159
  0,
160
  1,
161
  2,
162
  3,
163
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_._has_bits_),
164
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _internal_metadata_),
165
  ~0u,  // no _extensions_
166
  ~0u,  // no _oneof_case_
167
  ~0u,  // no _weak_field_map_
168
  ~0u,  // no _inlined_string_donated_
169
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.len_),
170
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.offset_),
171
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.oldstreamname_),
172
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.start_),
173
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.streamname_),
174
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpPlay2Options, _impl_.transition_),
175
  3,
176
  4,
177
  0,
178
  5,
179
  1,
180
  2,
181
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _impl_._has_bits_),
182
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _internal_metadata_),
183
  ~0u,  // no _extensions_
184
  ~0u,  // no _oneof_case_
185
  ~0u,  // no _weak_field_map_
186
  ~0u,  // no _inlined_string_donated_
187
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _impl_.code_),
188
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _impl_.level_),
189
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _impl_.description_),
190
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpInfo, _impl_.objectencoding_),
191
  0,
192
  1,
193
  2,
194
  3,
195
  ~0u,  // no _has_bits_
196
  PROTOBUF_FIELD_OFFSET(::brpc::RtmpEmptyObject, _internal_metadata_),
197
  ~0u,  // no _extensions_
198
  ~0u,  // no _oneof_case_
199
  ~0u,  // no _weak_field_map_
200
  ~0u,  // no _inlined_string_donated_
201
};
202
static const ::_pbi::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
203
  { 0, 18, -1, sizeof(::brpc::RtmpConnectRequest)},
204
  { 30, 40, -1, sizeof(::brpc::RtmpConnectResponse)},
205
  { 44, 56, -1, sizeof(::brpc::RtmpPlay2Options)},
206
  { 62, 72, -1, sizeof(::brpc::RtmpInfo)},
207
  { 76, -1, -1, sizeof(::brpc::RtmpEmptyObject)},
208
};
209
210
static const ::_pb::Message* const file_default_instances[] = {
211
  &::brpc::_RtmpConnectRequest_default_instance_._instance,
212
  &::brpc::_RtmpConnectResponse_default_instance_._instance,
213
  &::brpc::_RtmpPlay2Options_default_instance_._instance,
214
  &::brpc::_RtmpInfo_default_instance_._instance,
215
  &::brpc::_RtmpEmptyObject_default_instance_._instance,
216
};
217
218
const char descriptor_table_protodef_brpc_2frtmp_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
219
  "\n\017brpc/rtmp.proto\022\004brpc\"\375\001\n\022RtmpConnectR"
220
  "equest\022\013\n\003app\030\001 \001(\t\022\020\n\010flashVer\030\002 \001(\t\022\016\n"
221
  "\006swfUrl\030\003 \001(\t\022\r\n\005tcUrl\030\004 \001(\t\022\014\n\004fpad\030\005 \001"
222
  "(\010\022\024\n\014capabilities\030\006 \001(\001\022\023\n\013audioCodecs\030"
223
  "\007 \001(\001\022\023\n\013videoCodecs\030\010 \001(\001\022\025\n\rvideoFunct"
224
  "ion\030\t \001(\001\022\017\n\007pageUrl\030\n \001(\t\022\026\n\016objectEnco"
225
  "ding\030\013 \001(\001\022\033\n\023stream_multiplexing\030\014 \001(\010\""
226
  "u\n\023RtmpConnectResponse\022\016\n\006fmsVer\030\001 \001(\t\022\024"
227
  "\n\014capabilities\030\002 \001(\001\022\014\n\004mode\030\003 \001(\001\022*\n\"cr"
228
  "eate_stream_with_play_or_publish\030\004 \001(\010\"}"
229
  "\n\020RtmpPlay2Options\022\013\n\003len\030\001 \001(\001\022\016\n\006offse"
230
  "t\030\002 \001(\001\022\025\n\roldStreamName\030\003 \001(\t\022\r\n\005start\030"
231
  "\004 \001(\001\022\022\n\nstreamName\030\005 \001(\t\022\022\n\ntransition\030"
232
  "\006 \001(\t\"T\n\010RtmpInfo\022\014\n\004code\030\001 \001(\t\022\r\n\005level"
233
  "\030\002 \001(\t\022\023\n\013description\030\003 \001(\t\022\026\n\016objectEnc"
234
  "oding\030\004 \001(\001\"\021\n\017RtmpEmptyObject"
235
  ;
236
static ::_pbi::once_flag descriptor_table_brpc_2frtmp_2eproto_once;
237
const ::_pbi::DescriptorTable descriptor_table_brpc_2frtmp_2eproto = {
238
    false, false, 630, descriptor_table_protodef_brpc_2frtmp_2eproto,
239
    "brpc/rtmp.proto",
240
    &descriptor_table_brpc_2frtmp_2eproto_once, nullptr, 0, 5,
241
    schemas, file_default_instances, TableStruct_brpc_2frtmp_2eproto::offsets,
242
    file_level_metadata_brpc_2frtmp_2eproto, file_level_enum_descriptors_brpc_2frtmp_2eproto,
243
    file_level_service_descriptors_brpc_2frtmp_2eproto,
244
};
245
0
PROTOBUF_ATTRIBUTE_WEAK const ::_pbi::DescriptorTable* descriptor_table_brpc_2frtmp_2eproto_getter() {
246
0
  return &descriptor_table_brpc_2frtmp_2eproto;
247
0
}
248
249
// Force running AddDescriptors() at dynamic initialization time.
250
PROTOBUF_ATTRIBUTE_INIT_PRIORITY2 static ::_pbi::AddDescriptorsRunner dynamic_init_dummy_brpc_2frtmp_2eproto(&descriptor_table_brpc_2frtmp_2eproto);
251
namespace brpc {
252
253
// ===================================================================
254
255
class RtmpConnectRequest::_Internal {
256
 public:
257
  using HasBits = decltype(std::declval<RtmpConnectRequest>()._impl_._has_bits_);
258
0
  static void set_has_app(HasBits* has_bits) {
259
0
    (*has_bits)[0] |= 1u;
260
0
  }
261
0
  static void set_has_flashver(HasBits* has_bits) {
262
0
    (*has_bits)[0] |= 2u;
263
0
  }
264
0
  static void set_has_swfurl(HasBits* has_bits) {
265
0
    (*has_bits)[0] |= 4u;
266
0
  }
267
0
  static void set_has_tcurl(HasBits* has_bits) {
268
0
    (*has_bits)[0] |= 8u;
269
0
  }
270
0
  static void set_has_fpad(HasBits* has_bits) {
271
0
    (*has_bits)[0] |= 1024u;
272
0
  }
273
0
  static void set_has_capabilities(HasBits* has_bits) {
274
0
    (*has_bits)[0] |= 32u;
275
0
  }
276
0
  static void set_has_audiocodecs(HasBits* has_bits) {
277
0
    (*has_bits)[0] |= 64u;
278
0
  }
279
0
  static void set_has_videocodecs(HasBits* has_bits) {
280
0
    (*has_bits)[0] |= 128u;
281
0
  }
282
0
  static void set_has_videofunction(HasBits* has_bits) {
283
0
    (*has_bits)[0] |= 256u;
284
0
  }
285
0
  static void set_has_pageurl(HasBits* has_bits) {
286
0
    (*has_bits)[0] |= 16u;
287
0
  }
288
0
  static void set_has_objectencoding(HasBits* has_bits) {
289
0
    (*has_bits)[0] |= 512u;
290
0
  }
291
0
  static void set_has_stream_multiplexing(HasBits* has_bits) {
292
0
    (*has_bits)[0] |= 2048u;
293
0
  }
294
};
295
296
RtmpConnectRequest::RtmpConnectRequest(::PROTOBUF_NAMESPACE_ID::Arena* arena,
297
                         bool is_message_owned)
298
0
  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
299
0
  SharedCtor(arena, is_message_owned);
300
  // @@protoc_insertion_point(arena_constructor:brpc.RtmpConnectRequest)
301
0
}
302
RtmpConnectRequest::RtmpConnectRequest(const RtmpConnectRequest& from)
303
0
  : ::PROTOBUF_NAMESPACE_ID::Message() {
304
0
  RtmpConnectRequest* const _this = this; (void)_this;
305
0
  new (&_impl_) Impl_{
306
0
      decltype(_impl_._has_bits_){from._impl_._has_bits_}
307
0
    , /*decltype(_impl_._cached_size_)*/{}
308
0
    , decltype(_impl_.app_){}
309
0
    , decltype(_impl_.flashver_){}
310
0
    , decltype(_impl_.swfurl_){}
311
0
    , decltype(_impl_.tcurl_){}
312
0
    , decltype(_impl_.pageurl_){}
313
0
    , decltype(_impl_.capabilities_){}
314
0
    , decltype(_impl_.audiocodecs_){}
315
0
    , decltype(_impl_.videocodecs_){}
316
0
    , decltype(_impl_.videofunction_){}
317
0
    , decltype(_impl_.objectencoding_){}
318
0
    , decltype(_impl_.fpad_){}
319
0
    , decltype(_impl_.stream_multiplexing_){}};
320
321
0
  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
322
0
  _impl_.app_.InitDefault();
323
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
324
    _impl_.app_.Set("", GetArenaForAllocation());
325
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
326
0
  if (from._internal_has_app()) {
327
0
    _this->_impl_.app_.Set(from._internal_app(), 
328
0
      _this->GetArenaForAllocation());
329
0
  }
330
0
  _impl_.flashver_.InitDefault();
331
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
332
    _impl_.flashver_.Set("", GetArenaForAllocation());
333
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
334
0
  if (from._internal_has_flashver()) {
335
0
    _this->_impl_.flashver_.Set(from._internal_flashver(), 
336
0
      _this->GetArenaForAllocation());
337
0
  }
338
0
  _impl_.swfurl_.InitDefault();
339
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
340
    _impl_.swfurl_.Set("", GetArenaForAllocation());
341
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
342
0
  if (from._internal_has_swfurl()) {
343
0
    _this->_impl_.swfurl_.Set(from._internal_swfurl(), 
344
0
      _this->GetArenaForAllocation());
345
0
  }
346
0
  _impl_.tcurl_.InitDefault();
347
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
348
    _impl_.tcurl_.Set("", GetArenaForAllocation());
349
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
350
0
  if (from._internal_has_tcurl()) {
351
0
    _this->_impl_.tcurl_.Set(from._internal_tcurl(), 
352
0
      _this->GetArenaForAllocation());
353
0
  }
354
0
  _impl_.pageurl_.InitDefault();
355
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
356
    _impl_.pageurl_.Set("", GetArenaForAllocation());
357
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
358
0
  if (from._internal_has_pageurl()) {
359
0
    _this->_impl_.pageurl_.Set(from._internal_pageurl(), 
360
0
      _this->GetArenaForAllocation());
361
0
  }
362
0
  ::memcpy(&_impl_.capabilities_, &from._impl_.capabilities_,
363
0
    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.stream_multiplexing_) -
364
0
    reinterpret_cast<char*>(&_impl_.capabilities_)) + sizeof(_impl_.stream_multiplexing_));
365
  // @@protoc_insertion_point(copy_constructor:brpc.RtmpConnectRequest)
366
0
}
367
368
inline void RtmpConnectRequest::SharedCtor(
369
0
    ::_pb::Arena* arena, bool is_message_owned) {
370
0
  (void)arena;
371
0
  (void)is_message_owned;
372
0
  new (&_impl_) Impl_{
373
0
      decltype(_impl_._has_bits_){}
374
0
    , /*decltype(_impl_._cached_size_)*/{}
375
0
    , decltype(_impl_.app_){}
376
0
    , decltype(_impl_.flashver_){}
377
0
    , decltype(_impl_.swfurl_){}
378
0
    , decltype(_impl_.tcurl_){}
379
0
    , decltype(_impl_.pageurl_){}
380
0
    , decltype(_impl_.capabilities_){0}
381
0
    , decltype(_impl_.audiocodecs_){0}
382
0
    , decltype(_impl_.videocodecs_){0}
383
0
    , decltype(_impl_.videofunction_){0}
384
0
    , decltype(_impl_.objectencoding_){0}
385
0
    , decltype(_impl_.fpad_){false}
386
0
    , decltype(_impl_.stream_multiplexing_){false}
387
0
  };
388
0
  _impl_.app_.InitDefault();
389
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
390
    _impl_.app_.Set("", GetArenaForAllocation());
391
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
392
0
  _impl_.flashver_.InitDefault();
393
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
394
    _impl_.flashver_.Set("", GetArenaForAllocation());
395
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
396
0
  _impl_.swfurl_.InitDefault();
397
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
398
    _impl_.swfurl_.Set("", GetArenaForAllocation());
399
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
400
0
  _impl_.tcurl_.InitDefault();
401
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
402
    _impl_.tcurl_.Set("", GetArenaForAllocation());
403
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
404
0
  _impl_.pageurl_.InitDefault();
405
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
406
    _impl_.pageurl_.Set("", GetArenaForAllocation());
407
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
408
0
}
409
410
0
RtmpConnectRequest::~RtmpConnectRequest() {
411
  // @@protoc_insertion_point(destructor:brpc.RtmpConnectRequest)
412
0
  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
413
0
  (void)arena;
414
0
    return;
415
0
  }
416
0
  SharedDtor();
417
0
}
418
419
0
inline void RtmpConnectRequest::SharedDtor() {
420
0
  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
421
0
  _impl_.app_.Destroy();
422
0
  _impl_.flashver_.Destroy();
423
0
  _impl_.swfurl_.Destroy();
424
0
  _impl_.tcurl_.Destroy();
425
0
  _impl_.pageurl_.Destroy();
426
0
}
427
428
0
void RtmpConnectRequest::SetCachedSize(int size) const {
429
0
  _impl_._cached_size_.Set(size);
430
0
}
431
432
0
void RtmpConnectRequest::Clear() {
433
// @@protoc_insertion_point(message_clear_start:brpc.RtmpConnectRequest)
434
0
  uint32_t cached_has_bits = 0;
435
  // Prevent compiler warnings about cached_has_bits being unused
436
0
  (void) cached_has_bits;
437
438
0
  cached_has_bits = _impl_._has_bits_[0];
439
0
  if (cached_has_bits & 0x0000001fu) {
440
0
    if (cached_has_bits & 0x00000001u) {
441
0
      _impl_.app_.ClearNonDefaultToEmpty();
442
0
    }
443
0
    if (cached_has_bits & 0x00000002u) {
444
0
      _impl_.flashver_.ClearNonDefaultToEmpty();
445
0
    }
446
0
    if (cached_has_bits & 0x00000004u) {
447
0
      _impl_.swfurl_.ClearNonDefaultToEmpty();
448
0
    }
449
0
    if (cached_has_bits & 0x00000008u) {
450
0
      _impl_.tcurl_.ClearNonDefaultToEmpty();
451
0
    }
452
0
    if (cached_has_bits & 0x00000010u) {
453
0
      _impl_.pageurl_.ClearNonDefaultToEmpty();
454
0
    }
455
0
  }
456
0
  if (cached_has_bits & 0x000000e0u) {
457
0
    ::memset(&_impl_.capabilities_, 0, static_cast<size_t>(
458
0
        reinterpret_cast<char*>(&_impl_.videocodecs_) -
459
0
        reinterpret_cast<char*>(&_impl_.capabilities_)) + sizeof(_impl_.videocodecs_));
460
0
  }
461
0
  if (cached_has_bits & 0x00000f00u) {
462
0
    ::memset(&_impl_.videofunction_, 0, static_cast<size_t>(
463
0
        reinterpret_cast<char*>(&_impl_.stream_multiplexing_) -
464
0
        reinterpret_cast<char*>(&_impl_.videofunction_)) + sizeof(_impl_.stream_multiplexing_));
465
0
  }
466
0
  _impl_._has_bits_.Clear();
467
0
  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
468
0
}
469
470
0
const char* RtmpConnectRequest::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
471
0
#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
472
0
  _Internal::HasBits has_bits{};
473
0
  while (!ctx->Done(&ptr)) {
474
0
    uint32_t tag;
475
0
    ptr = ::_pbi::ReadTag(ptr, &tag);
476
0
    switch (tag >> 3) {
477
      // optional string app = 1;
478
0
      case 1:
479
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 10)) {
480
0
          auto str = _internal_mutable_app();
481
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
482
0
          CHK_(ptr);
483
0
          #ifndef NDEBUG
484
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectRequest.app");
485
0
          #endif  // !NDEBUG
486
0
        } else
487
0
          goto handle_unusual;
488
0
        continue;
489
      // optional string flashVer = 2;
490
0
      case 2:
491
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
492
0
          auto str = _internal_mutable_flashver();
493
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
494
0
          CHK_(ptr);
495
0
          #ifndef NDEBUG
496
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectRequest.flashVer");
497
0
          #endif  // !NDEBUG
498
0
        } else
499
0
          goto handle_unusual;
500
0
        continue;
501
      // optional string swfUrl = 3;
502
0
      case 3:
503
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 26)) {
504
0
          auto str = _internal_mutable_swfurl();
505
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
506
0
          CHK_(ptr);
507
0
          #ifndef NDEBUG
508
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectRequest.swfUrl");
509
0
          #endif  // !NDEBUG
510
0
        } else
511
0
          goto handle_unusual;
512
0
        continue;
513
      // optional string tcUrl = 4;
514
0
      case 4:
515
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 34)) {
516
0
          auto str = _internal_mutable_tcurl();
517
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
518
0
          CHK_(ptr);
519
0
          #ifndef NDEBUG
520
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectRequest.tcUrl");
521
0
          #endif  // !NDEBUG
522
0
        } else
523
0
          goto handle_unusual;
524
0
        continue;
525
      // optional bool fpad = 5;
526
0
      case 5:
527
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 40)) {
528
0
          _Internal::set_has_fpad(&has_bits);
529
0
          _impl_.fpad_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
530
0
          CHK_(ptr);
531
0
        } else
532
0
          goto handle_unusual;
533
0
        continue;
534
      // optional double capabilities = 6;
535
0
      case 6:
536
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 49)) {
537
0
          _Internal::set_has_capabilities(&has_bits);
538
0
          _impl_.capabilities_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
539
0
          ptr += sizeof(double);
540
0
        } else
541
0
          goto handle_unusual;
542
0
        continue;
543
      // optional double audioCodecs = 7;
544
0
      case 7:
545
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 57)) {
546
0
          _Internal::set_has_audiocodecs(&has_bits);
547
0
          _impl_.audiocodecs_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
548
0
          ptr += sizeof(double);
549
0
        } else
550
0
          goto handle_unusual;
551
0
        continue;
552
      // optional double videoCodecs = 8;
553
0
      case 8:
554
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 65)) {
555
0
          _Internal::set_has_videocodecs(&has_bits);
556
0
          _impl_.videocodecs_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
557
0
          ptr += sizeof(double);
558
0
        } else
559
0
          goto handle_unusual;
560
0
        continue;
561
      // optional double videoFunction = 9;
562
0
      case 9:
563
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 73)) {
564
0
          _Internal::set_has_videofunction(&has_bits);
565
0
          _impl_.videofunction_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
566
0
          ptr += sizeof(double);
567
0
        } else
568
0
          goto handle_unusual;
569
0
        continue;
570
      // optional string pageUrl = 10;
571
0
      case 10:
572
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 82)) {
573
0
          auto str = _internal_mutable_pageurl();
574
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
575
0
          CHK_(ptr);
576
0
          #ifndef NDEBUG
577
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectRequest.pageUrl");
578
0
          #endif  // !NDEBUG
579
0
        } else
580
0
          goto handle_unusual;
581
0
        continue;
582
      // optional double objectEncoding = 11;
583
0
      case 11:
584
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 89)) {
585
0
          _Internal::set_has_objectencoding(&has_bits);
586
0
          _impl_.objectencoding_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
587
0
          ptr += sizeof(double);
588
0
        } else
589
0
          goto handle_unusual;
590
0
        continue;
591
      // optional bool stream_multiplexing = 12;
592
0
      case 12:
593
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 96)) {
594
0
          _Internal::set_has_stream_multiplexing(&has_bits);
595
0
          _impl_.stream_multiplexing_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
596
0
          CHK_(ptr);
597
0
        } else
598
0
          goto handle_unusual;
599
0
        continue;
600
0
      default:
601
0
        goto handle_unusual;
602
0
    }  // switch
603
0
  handle_unusual:
604
0
    if ((tag == 0) || ((tag & 7) == 4)) {
605
0
      CHK_(ptr);
606
0
      ctx->SetLastTag(tag);
607
0
      goto message_done;
608
0
    }
609
0
    ptr = UnknownFieldParse(
610
0
        tag,
611
0
        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
612
0
        ptr, ctx);
613
0
    CHK_(ptr != nullptr);
614
0
  }  // while
615
0
message_done:
616
0
  _impl_._has_bits_.Or(has_bits);
617
0
  return ptr;
618
0
failure:
619
0
  ptr = nullptr;
620
0
  goto message_done;
621
0
#undef CHK_
622
0
}
623
624
uint8_t* RtmpConnectRequest::_InternalSerialize(
625
0
    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
626
  // @@protoc_insertion_point(serialize_to_array_start:brpc.RtmpConnectRequest)
627
0
  uint32_t cached_has_bits = 0;
628
0
  (void) cached_has_bits;
629
630
0
  cached_has_bits = _impl_._has_bits_[0];
631
  // optional string app = 1;
632
0
  if (cached_has_bits & 0x00000001u) {
633
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
634
0
      this->_internal_app().data(), static_cast<int>(this->_internal_app().length()),
635
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
636
0
      "brpc.RtmpConnectRequest.app");
637
0
    target = stream->WriteStringMaybeAliased(
638
0
        1, this->_internal_app(), target);
639
0
  }
640
641
  // optional string flashVer = 2;
642
0
  if (cached_has_bits & 0x00000002u) {
643
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
644
0
      this->_internal_flashver().data(), static_cast<int>(this->_internal_flashver().length()),
645
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
646
0
      "brpc.RtmpConnectRequest.flashVer");
647
0
    target = stream->WriteStringMaybeAliased(
648
0
        2, this->_internal_flashver(), target);
649
0
  }
650
651
  // optional string swfUrl = 3;
652
0
  if (cached_has_bits & 0x00000004u) {
653
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
654
0
      this->_internal_swfurl().data(), static_cast<int>(this->_internal_swfurl().length()),
655
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
656
0
      "brpc.RtmpConnectRequest.swfUrl");
657
0
    target = stream->WriteStringMaybeAliased(
658
0
        3, this->_internal_swfurl(), target);
659
0
  }
660
661
  // optional string tcUrl = 4;
662
0
  if (cached_has_bits & 0x00000008u) {
663
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
664
0
      this->_internal_tcurl().data(), static_cast<int>(this->_internal_tcurl().length()),
665
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
666
0
      "brpc.RtmpConnectRequest.tcUrl");
667
0
    target = stream->WriteStringMaybeAliased(
668
0
        4, this->_internal_tcurl(), target);
669
0
  }
670
671
  // optional bool fpad = 5;
672
0
  if (cached_has_bits & 0x00000400u) {
673
0
    target = stream->EnsureSpace(target);
674
0
    target = ::_pbi::WireFormatLite::WriteBoolToArray(5, this->_internal_fpad(), target);
675
0
  }
676
677
  // optional double capabilities = 6;
678
0
  if (cached_has_bits & 0x00000020u) {
679
0
    target = stream->EnsureSpace(target);
680
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(6, this->_internal_capabilities(), target);
681
0
  }
682
683
  // optional double audioCodecs = 7;
684
0
  if (cached_has_bits & 0x00000040u) {
685
0
    target = stream->EnsureSpace(target);
686
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(7, this->_internal_audiocodecs(), target);
687
0
  }
688
689
  // optional double videoCodecs = 8;
690
0
  if (cached_has_bits & 0x00000080u) {
691
0
    target = stream->EnsureSpace(target);
692
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(8, this->_internal_videocodecs(), target);
693
0
  }
694
695
  // optional double videoFunction = 9;
696
0
  if (cached_has_bits & 0x00000100u) {
697
0
    target = stream->EnsureSpace(target);
698
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(9, this->_internal_videofunction(), target);
699
0
  }
700
701
  // optional string pageUrl = 10;
702
0
  if (cached_has_bits & 0x00000010u) {
703
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
704
0
      this->_internal_pageurl().data(), static_cast<int>(this->_internal_pageurl().length()),
705
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
706
0
      "brpc.RtmpConnectRequest.pageUrl");
707
0
    target = stream->WriteStringMaybeAliased(
708
0
        10, this->_internal_pageurl(), target);
709
0
  }
710
711
  // optional double objectEncoding = 11;
712
0
  if (cached_has_bits & 0x00000200u) {
713
0
    target = stream->EnsureSpace(target);
714
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(11, this->_internal_objectencoding(), target);
715
0
  }
716
717
  // optional bool stream_multiplexing = 12;
718
0
  if (cached_has_bits & 0x00000800u) {
719
0
    target = stream->EnsureSpace(target);
720
0
    target = ::_pbi::WireFormatLite::WriteBoolToArray(12, this->_internal_stream_multiplexing(), target);
721
0
  }
722
723
0
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
724
0
    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
725
0
        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
726
0
  }
727
  // @@protoc_insertion_point(serialize_to_array_end:brpc.RtmpConnectRequest)
728
0
  return target;
729
0
}
730
731
0
size_t RtmpConnectRequest::ByteSizeLong() const {
732
// @@protoc_insertion_point(message_byte_size_start:brpc.RtmpConnectRequest)
733
0
  size_t total_size = 0;
734
735
0
  uint32_t cached_has_bits = 0;
736
  // Prevent compiler warnings about cached_has_bits being unused
737
0
  (void) cached_has_bits;
738
739
0
  cached_has_bits = _impl_._has_bits_[0];
740
0
  if (cached_has_bits & 0x000000ffu) {
741
    // optional string app = 1;
742
0
    if (cached_has_bits & 0x00000001u) {
743
0
      total_size += 1 +
744
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
745
0
          this->_internal_app());
746
0
    }
747
748
    // optional string flashVer = 2;
749
0
    if (cached_has_bits & 0x00000002u) {
750
0
      total_size += 1 +
751
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
752
0
          this->_internal_flashver());
753
0
    }
754
755
    // optional string swfUrl = 3;
756
0
    if (cached_has_bits & 0x00000004u) {
757
0
      total_size += 1 +
758
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
759
0
          this->_internal_swfurl());
760
0
    }
761
762
    // optional string tcUrl = 4;
763
0
    if (cached_has_bits & 0x00000008u) {
764
0
      total_size += 1 +
765
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
766
0
          this->_internal_tcurl());
767
0
    }
768
769
    // optional string pageUrl = 10;
770
0
    if (cached_has_bits & 0x00000010u) {
771
0
      total_size += 1 +
772
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
773
0
          this->_internal_pageurl());
774
0
    }
775
776
    // optional double capabilities = 6;
777
0
    if (cached_has_bits & 0x00000020u) {
778
0
      total_size += 1 + 8;
779
0
    }
780
781
    // optional double audioCodecs = 7;
782
0
    if (cached_has_bits & 0x00000040u) {
783
0
      total_size += 1 + 8;
784
0
    }
785
786
    // optional double videoCodecs = 8;
787
0
    if (cached_has_bits & 0x00000080u) {
788
0
      total_size += 1 + 8;
789
0
    }
790
791
0
  }
792
0
  if (cached_has_bits & 0x00000f00u) {
793
    // optional double videoFunction = 9;
794
0
    if (cached_has_bits & 0x00000100u) {
795
0
      total_size += 1 + 8;
796
0
    }
797
798
    // optional double objectEncoding = 11;
799
0
    if (cached_has_bits & 0x00000200u) {
800
0
      total_size += 1 + 8;
801
0
    }
802
803
    // optional bool fpad = 5;
804
0
    if (cached_has_bits & 0x00000400u) {
805
0
      total_size += 1 + 1;
806
0
    }
807
808
    // optional bool stream_multiplexing = 12;
809
0
    if (cached_has_bits & 0x00000800u) {
810
0
      total_size += 1 + 1;
811
0
    }
812
813
0
  }
814
0
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
815
0
}
816
817
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData RtmpConnectRequest::_class_data_ = {
818
    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
819
    RtmpConnectRequest::MergeImpl
820
};
821
0
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*RtmpConnectRequest::GetClassData() const { return &_class_data_; }
822
823
824
0
void RtmpConnectRequest::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
825
0
  auto* const _this = static_cast<RtmpConnectRequest*>(&to_msg);
826
0
  auto& from = static_cast<const RtmpConnectRequest&>(from_msg);
827
  // @@protoc_insertion_point(class_specific_merge_from_start:brpc.RtmpConnectRequest)
828
0
  GOOGLE_DCHECK_NE(&from, _this);
829
0
  uint32_t cached_has_bits = 0;
830
0
  (void) cached_has_bits;
831
832
0
  cached_has_bits = from._impl_._has_bits_[0];
833
0
  if (cached_has_bits & 0x000000ffu) {
834
0
    if (cached_has_bits & 0x00000001u) {
835
0
      _this->_internal_set_app(from._internal_app());
836
0
    }
837
0
    if (cached_has_bits & 0x00000002u) {
838
0
      _this->_internal_set_flashver(from._internal_flashver());
839
0
    }
840
0
    if (cached_has_bits & 0x00000004u) {
841
0
      _this->_internal_set_swfurl(from._internal_swfurl());
842
0
    }
843
0
    if (cached_has_bits & 0x00000008u) {
844
0
      _this->_internal_set_tcurl(from._internal_tcurl());
845
0
    }
846
0
    if (cached_has_bits & 0x00000010u) {
847
0
      _this->_internal_set_pageurl(from._internal_pageurl());
848
0
    }
849
0
    if (cached_has_bits & 0x00000020u) {
850
0
      _this->_impl_.capabilities_ = from._impl_.capabilities_;
851
0
    }
852
0
    if (cached_has_bits & 0x00000040u) {
853
0
      _this->_impl_.audiocodecs_ = from._impl_.audiocodecs_;
854
0
    }
855
0
    if (cached_has_bits & 0x00000080u) {
856
0
      _this->_impl_.videocodecs_ = from._impl_.videocodecs_;
857
0
    }
858
0
    _this->_impl_._has_bits_[0] |= cached_has_bits;
859
0
  }
860
0
  if (cached_has_bits & 0x00000f00u) {
861
0
    if (cached_has_bits & 0x00000100u) {
862
0
      _this->_impl_.videofunction_ = from._impl_.videofunction_;
863
0
    }
864
0
    if (cached_has_bits & 0x00000200u) {
865
0
      _this->_impl_.objectencoding_ = from._impl_.objectencoding_;
866
0
    }
867
0
    if (cached_has_bits & 0x00000400u) {
868
0
      _this->_impl_.fpad_ = from._impl_.fpad_;
869
0
    }
870
0
    if (cached_has_bits & 0x00000800u) {
871
0
      _this->_impl_.stream_multiplexing_ = from._impl_.stream_multiplexing_;
872
0
    }
873
0
    _this->_impl_._has_bits_[0] |= cached_has_bits;
874
0
  }
875
0
  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
876
0
}
877
878
0
void RtmpConnectRequest::CopyFrom(const RtmpConnectRequest& from) {
879
// @@protoc_insertion_point(class_specific_copy_from_start:brpc.RtmpConnectRequest)
880
0
  if (&from == this) return;
881
0
  Clear();
882
0
  MergeFrom(from);
883
0
}
884
885
0
bool RtmpConnectRequest::IsInitialized() const {
886
0
  return true;
887
0
}
888
889
0
void RtmpConnectRequest::InternalSwap(RtmpConnectRequest* other) {
890
0
  using std::swap;
891
0
  auto* lhs_arena = GetArenaForAllocation();
892
0
  auto* rhs_arena = other->GetArenaForAllocation();
893
0
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
894
0
  swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]);
895
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
896
0
      &_impl_.app_, lhs_arena,
897
0
      &other->_impl_.app_, rhs_arena
898
0
  );
899
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
900
0
      &_impl_.flashver_, lhs_arena,
901
0
      &other->_impl_.flashver_, rhs_arena
902
0
  );
903
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
904
0
      &_impl_.swfurl_, lhs_arena,
905
0
      &other->_impl_.swfurl_, rhs_arena
906
0
  );
907
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
908
0
      &_impl_.tcurl_, lhs_arena,
909
0
      &other->_impl_.tcurl_, rhs_arena
910
0
  );
911
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
912
0
      &_impl_.pageurl_, lhs_arena,
913
0
      &other->_impl_.pageurl_, rhs_arena
914
0
  );
915
0
  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
916
0
      PROTOBUF_FIELD_OFFSET(RtmpConnectRequest, _impl_.stream_multiplexing_)
917
0
      + sizeof(RtmpConnectRequest::_impl_.stream_multiplexing_)
918
0
      - PROTOBUF_FIELD_OFFSET(RtmpConnectRequest, _impl_.capabilities_)>(
919
0
          reinterpret_cast<char*>(&_impl_.capabilities_),
920
0
          reinterpret_cast<char*>(&other->_impl_.capabilities_));
921
0
}
922
923
0
::PROTOBUF_NAMESPACE_ID::Metadata RtmpConnectRequest::GetMetadata() const {
924
0
  return ::_pbi::AssignDescriptors(
925
0
      &descriptor_table_brpc_2frtmp_2eproto_getter, &descriptor_table_brpc_2frtmp_2eproto_once,
926
0
      file_level_metadata_brpc_2frtmp_2eproto[0]);
927
0
}
928
929
// ===================================================================
930
931
class RtmpConnectResponse::_Internal {
932
 public:
933
  using HasBits = decltype(std::declval<RtmpConnectResponse>()._impl_._has_bits_);
934
0
  static void set_has_fmsver(HasBits* has_bits) {
935
0
    (*has_bits)[0] |= 1u;
936
0
  }
937
0
  static void set_has_capabilities(HasBits* has_bits) {
938
0
    (*has_bits)[0] |= 2u;
939
0
  }
940
0
  static void set_has_mode(HasBits* has_bits) {
941
0
    (*has_bits)[0] |= 4u;
942
0
  }
943
0
  static void set_has_create_stream_with_play_or_publish(HasBits* has_bits) {
944
0
    (*has_bits)[0] |= 8u;
945
0
  }
946
};
947
948
RtmpConnectResponse::RtmpConnectResponse(::PROTOBUF_NAMESPACE_ID::Arena* arena,
949
                         bool is_message_owned)
950
0
  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
951
0
  SharedCtor(arena, is_message_owned);
952
  // @@protoc_insertion_point(arena_constructor:brpc.RtmpConnectResponse)
953
0
}
954
RtmpConnectResponse::RtmpConnectResponse(const RtmpConnectResponse& from)
955
0
  : ::PROTOBUF_NAMESPACE_ID::Message() {
956
0
  RtmpConnectResponse* const _this = this; (void)_this;
957
0
  new (&_impl_) Impl_{
958
0
      decltype(_impl_._has_bits_){from._impl_._has_bits_}
959
0
    , /*decltype(_impl_._cached_size_)*/{}
960
0
    , decltype(_impl_.fmsver_){}
961
0
    , decltype(_impl_.capabilities_){}
962
0
    , decltype(_impl_.mode_){}
963
0
    , decltype(_impl_.create_stream_with_play_or_publish_){}};
964
965
0
  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
966
0
  _impl_.fmsver_.InitDefault();
967
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
968
    _impl_.fmsver_.Set("", GetArenaForAllocation());
969
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
970
0
  if (from._internal_has_fmsver()) {
971
0
    _this->_impl_.fmsver_.Set(from._internal_fmsver(), 
972
0
      _this->GetArenaForAllocation());
973
0
  }
974
0
  ::memcpy(&_impl_.capabilities_, &from._impl_.capabilities_,
975
0
    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.create_stream_with_play_or_publish_) -
976
0
    reinterpret_cast<char*>(&_impl_.capabilities_)) + sizeof(_impl_.create_stream_with_play_or_publish_));
977
  // @@protoc_insertion_point(copy_constructor:brpc.RtmpConnectResponse)
978
0
}
979
980
inline void RtmpConnectResponse::SharedCtor(
981
0
    ::_pb::Arena* arena, bool is_message_owned) {
982
0
  (void)arena;
983
0
  (void)is_message_owned;
984
0
  new (&_impl_) Impl_{
985
0
      decltype(_impl_._has_bits_){}
986
0
    , /*decltype(_impl_._cached_size_)*/{}
987
0
    , decltype(_impl_.fmsver_){}
988
0
    , decltype(_impl_.capabilities_){0}
989
0
    , decltype(_impl_.mode_){0}
990
0
    , decltype(_impl_.create_stream_with_play_or_publish_){false}
991
0
  };
992
0
  _impl_.fmsver_.InitDefault();
993
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
994
    _impl_.fmsver_.Set("", GetArenaForAllocation());
995
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
996
0
}
997
998
0
RtmpConnectResponse::~RtmpConnectResponse() {
999
  // @@protoc_insertion_point(destructor:brpc.RtmpConnectResponse)
1000
0
  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
1001
0
  (void)arena;
1002
0
    return;
1003
0
  }
1004
0
  SharedDtor();
1005
0
}
1006
1007
0
inline void RtmpConnectResponse::SharedDtor() {
1008
0
  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1009
0
  _impl_.fmsver_.Destroy();
1010
0
}
1011
1012
0
void RtmpConnectResponse::SetCachedSize(int size) const {
1013
0
  _impl_._cached_size_.Set(size);
1014
0
}
1015
1016
0
void RtmpConnectResponse::Clear() {
1017
// @@protoc_insertion_point(message_clear_start:brpc.RtmpConnectResponse)
1018
0
  uint32_t cached_has_bits = 0;
1019
  // Prevent compiler warnings about cached_has_bits being unused
1020
0
  (void) cached_has_bits;
1021
1022
0
  cached_has_bits = _impl_._has_bits_[0];
1023
0
  if (cached_has_bits & 0x00000001u) {
1024
0
    _impl_.fmsver_.ClearNonDefaultToEmpty();
1025
0
  }
1026
0
  if (cached_has_bits & 0x0000000eu) {
1027
0
    ::memset(&_impl_.capabilities_, 0, static_cast<size_t>(
1028
0
        reinterpret_cast<char*>(&_impl_.create_stream_with_play_or_publish_) -
1029
0
        reinterpret_cast<char*>(&_impl_.capabilities_)) + sizeof(_impl_.create_stream_with_play_or_publish_));
1030
0
  }
1031
0
  _impl_._has_bits_.Clear();
1032
0
  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1033
0
}
1034
1035
0
const char* RtmpConnectResponse::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1036
0
#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1037
0
  _Internal::HasBits has_bits{};
1038
0
  while (!ctx->Done(&ptr)) {
1039
0
    uint32_t tag;
1040
0
    ptr = ::_pbi::ReadTag(ptr, &tag);
1041
0
    switch (tag >> 3) {
1042
      // optional string fmsVer = 1;
1043
0
      case 1:
1044
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 10)) {
1045
0
          auto str = _internal_mutable_fmsver();
1046
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1047
0
          CHK_(ptr);
1048
0
          #ifndef NDEBUG
1049
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpConnectResponse.fmsVer");
1050
0
          #endif  // !NDEBUG
1051
0
        } else
1052
0
          goto handle_unusual;
1053
0
        continue;
1054
      // optional double capabilities = 2;
1055
0
      case 2:
1056
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 17)) {
1057
0
          _Internal::set_has_capabilities(&has_bits);
1058
0
          _impl_.capabilities_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1059
0
          ptr += sizeof(double);
1060
0
        } else
1061
0
          goto handle_unusual;
1062
0
        continue;
1063
      // optional double mode = 3;
1064
0
      case 3:
1065
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 25)) {
1066
0
          _Internal::set_has_mode(&has_bits);
1067
0
          _impl_.mode_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1068
0
          ptr += sizeof(double);
1069
0
        } else
1070
0
          goto handle_unusual;
1071
0
        continue;
1072
      // optional bool create_stream_with_play_or_publish = 4;
1073
0
      case 4:
1074
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 32)) {
1075
0
          _Internal::set_has_create_stream_with_play_or_publish(&has_bits);
1076
0
          _impl_.create_stream_with_play_or_publish_ = ::PROTOBUF_NAMESPACE_ID::internal::ReadVarint64(&ptr);
1077
0
          CHK_(ptr);
1078
0
        } else
1079
0
          goto handle_unusual;
1080
0
        continue;
1081
0
      default:
1082
0
        goto handle_unusual;
1083
0
    }  // switch
1084
0
  handle_unusual:
1085
0
    if ((tag == 0) || ((tag & 7) == 4)) {
1086
0
      CHK_(ptr);
1087
0
      ctx->SetLastTag(tag);
1088
0
      goto message_done;
1089
0
    }
1090
0
    ptr = UnknownFieldParse(
1091
0
        tag,
1092
0
        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
1093
0
        ptr, ctx);
1094
0
    CHK_(ptr != nullptr);
1095
0
  }  // while
1096
0
message_done:
1097
0
  _impl_._has_bits_.Or(has_bits);
1098
0
  return ptr;
1099
0
failure:
1100
0
  ptr = nullptr;
1101
0
  goto message_done;
1102
0
#undef CHK_
1103
0
}
1104
1105
uint8_t* RtmpConnectResponse::_InternalSerialize(
1106
0
    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1107
  // @@protoc_insertion_point(serialize_to_array_start:brpc.RtmpConnectResponse)
1108
0
  uint32_t cached_has_bits = 0;
1109
0
  (void) cached_has_bits;
1110
1111
0
  cached_has_bits = _impl_._has_bits_[0];
1112
  // optional string fmsVer = 1;
1113
0
  if (cached_has_bits & 0x00000001u) {
1114
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1115
0
      this->_internal_fmsver().data(), static_cast<int>(this->_internal_fmsver().length()),
1116
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1117
0
      "brpc.RtmpConnectResponse.fmsVer");
1118
0
    target = stream->WriteStringMaybeAliased(
1119
0
        1, this->_internal_fmsver(), target);
1120
0
  }
1121
1122
  // optional double capabilities = 2;
1123
0
  if (cached_has_bits & 0x00000002u) {
1124
0
    target = stream->EnsureSpace(target);
1125
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(2, this->_internal_capabilities(), target);
1126
0
  }
1127
1128
  // optional double mode = 3;
1129
0
  if (cached_has_bits & 0x00000004u) {
1130
0
    target = stream->EnsureSpace(target);
1131
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(3, this->_internal_mode(), target);
1132
0
  }
1133
1134
  // optional bool create_stream_with_play_or_publish = 4;
1135
0
  if (cached_has_bits & 0x00000008u) {
1136
0
    target = stream->EnsureSpace(target);
1137
0
    target = ::_pbi::WireFormatLite::WriteBoolToArray(4, this->_internal_create_stream_with_play_or_publish(), target);
1138
0
  }
1139
1140
0
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1141
0
    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
1142
0
        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
1143
0
  }
1144
  // @@protoc_insertion_point(serialize_to_array_end:brpc.RtmpConnectResponse)
1145
0
  return target;
1146
0
}
1147
1148
0
size_t RtmpConnectResponse::ByteSizeLong() const {
1149
// @@protoc_insertion_point(message_byte_size_start:brpc.RtmpConnectResponse)
1150
0
  size_t total_size = 0;
1151
1152
0
  uint32_t cached_has_bits = 0;
1153
  // Prevent compiler warnings about cached_has_bits being unused
1154
0
  (void) cached_has_bits;
1155
1156
0
  cached_has_bits = _impl_._has_bits_[0];
1157
0
  if (cached_has_bits & 0x0000000fu) {
1158
    // optional string fmsVer = 1;
1159
0
    if (cached_has_bits & 0x00000001u) {
1160
0
      total_size += 1 +
1161
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1162
0
          this->_internal_fmsver());
1163
0
    }
1164
1165
    // optional double capabilities = 2;
1166
0
    if (cached_has_bits & 0x00000002u) {
1167
0
      total_size += 1 + 8;
1168
0
    }
1169
1170
    // optional double mode = 3;
1171
0
    if (cached_has_bits & 0x00000004u) {
1172
0
      total_size += 1 + 8;
1173
0
    }
1174
1175
    // optional bool create_stream_with_play_or_publish = 4;
1176
0
    if (cached_has_bits & 0x00000008u) {
1177
0
      total_size += 1 + 1;
1178
0
    }
1179
1180
0
  }
1181
0
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
1182
0
}
1183
1184
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData RtmpConnectResponse::_class_data_ = {
1185
    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
1186
    RtmpConnectResponse::MergeImpl
1187
};
1188
0
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*RtmpConnectResponse::GetClassData() const { return &_class_data_; }
1189
1190
1191
0
void RtmpConnectResponse::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
1192
0
  auto* const _this = static_cast<RtmpConnectResponse*>(&to_msg);
1193
0
  auto& from = static_cast<const RtmpConnectResponse&>(from_msg);
1194
  // @@protoc_insertion_point(class_specific_merge_from_start:brpc.RtmpConnectResponse)
1195
0
  GOOGLE_DCHECK_NE(&from, _this);
1196
0
  uint32_t cached_has_bits = 0;
1197
0
  (void) cached_has_bits;
1198
1199
0
  cached_has_bits = from._impl_._has_bits_[0];
1200
0
  if (cached_has_bits & 0x0000000fu) {
1201
0
    if (cached_has_bits & 0x00000001u) {
1202
0
      _this->_internal_set_fmsver(from._internal_fmsver());
1203
0
    }
1204
0
    if (cached_has_bits & 0x00000002u) {
1205
0
      _this->_impl_.capabilities_ = from._impl_.capabilities_;
1206
0
    }
1207
0
    if (cached_has_bits & 0x00000004u) {
1208
0
      _this->_impl_.mode_ = from._impl_.mode_;
1209
0
    }
1210
0
    if (cached_has_bits & 0x00000008u) {
1211
0
      _this->_impl_.create_stream_with_play_or_publish_ = from._impl_.create_stream_with_play_or_publish_;
1212
0
    }
1213
0
    _this->_impl_._has_bits_[0] |= cached_has_bits;
1214
0
  }
1215
0
  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
1216
0
}
1217
1218
0
void RtmpConnectResponse::CopyFrom(const RtmpConnectResponse& from) {
1219
// @@protoc_insertion_point(class_specific_copy_from_start:brpc.RtmpConnectResponse)
1220
0
  if (&from == this) return;
1221
0
  Clear();
1222
0
  MergeFrom(from);
1223
0
}
1224
1225
0
bool RtmpConnectResponse::IsInitialized() const {
1226
0
  return true;
1227
0
}
1228
1229
0
void RtmpConnectResponse::InternalSwap(RtmpConnectResponse* other) {
1230
0
  using std::swap;
1231
0
  auto* lhs_arena = GetArenaForAllocation();
1232
0
  auto* rhs_arena = other->GetArenaForAllocation();
1233
0
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1234
0
  swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]);
1235
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1236
0
      &_impl_.fmsver_, lhs_arena,
1237
0
      &other->_impl_.fmsver_, rhs_arena
1238
0
  );
1239
0
  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
1240
0
      PROTOBUF_FIELD_OFFSET(RtmpConnectResponse, _impl_.create_stream_with_play_or_publish_)
1241
0
      + sizeof(RtmpConnectResponse::_impl_.create_stream_with_play_or_publish_)
1242
0
      - PROTOBUF_FIELD_OFFSET(RtmpConnectResponse, _impl_.capabilities_)>(
1243
0
          reinterpret_cast<char*>(&_impl_.capabilities_),
1244
0
          reinterpret_cast<char*>(&other->_impl_.capabilities_));
1245
0
}
1246
1247
0
::PROTOBUF_NAMESPACE_ID::Metadata RtmpConnectResponse::GetMetadata() const {
1248
0
  return ::_pbi::AssignDescriptors(
1249
0
      &descriptor_table_brpc_2frtmp_2eproto_getter, &descriptor_table_brpc_2frtmp_2eproto_once,
1250
0
      file_level_metadata_brpc_2frtmp_2eproto[1]);
1251
0
}
1252
1253
// ===================================================================
1254
1255
class RtmpPlay2Options::_Internal {
1256
 public:
1257
  using HasBits = decltype(std::declval<RtmpPlay2Options>()._impl_._has_bits_);
1258
0
  static void set_has_len(HasBits* has_bits) {
1259
0
    (*has_bits)[0] |= 8u;
1260
0
  }
1261
0
  static void set_has_offset(HasBits* has_bits) {
1262
0
    (*has_bits)[0] |= 16u;
1263
0
  }
1264
0
  static void set_has_oldstreamname(HasBits* has_bits) {
1265
0
    (*has_bits)[0] |= 1u;
1266
0
  }
1267
0
  static void set_has_start(HasBits* has_bits) {
1268
0
    (*has_bits)[0] |= 32u;
1269
0
  }
1270
0
  static void set_has_streamname(HasBits* has_bits) {
1271
0
    (*has_bits)[0] |= 2u;
1272
0
  }
1273
0
  static void set_has_transition(HasBits* has_bits) {
1274
0
    (*has_bits)[0] |= 4u;
1275
0
  }
1276
};
1277
1278
RtmpPlay2Options::RtmpPlay2Options(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1279
                         bool is_message_owned)
1280
0
  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
1281
0
  SharedCtor(arena, is_message_owned);
1282
  // @@protoc_insertion_point(arena_constructor:brpc.RtmpPlay2Options)
1283
0
}
1284
RtmpPlay2Options::RtmpPlay2Options(const RtmpPlay2Options& from)
1285
0
  : ::PROTOBUF_NAMESPACE_ID::Message() {
1286
0
  RtmpPlay2Options* const _this = this; (void)_this;
1287
0
  new (&_impl_) Impl_{
1288
0
      decltype(_impl_._has_bits_){from._impl_._has_bits_}
1289
0
    , /*decltype(_impl_._cached_size_)*/{}
1290
0
    , decltype(_impl_.oldstreamname_){}
1291
0
    , decltype(_impl_.streamname_){}
1292
0
    , decltype(_impl_.transition_){}
1293
0
    , decltype(_impl_.len_){}
1294
0
    , decltype(_impl_.offset_){}
1295
0
    , decltype(_impl_.start_){}};
1296
1297
0
  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
1298
0
  _impl_.oldstreamname_.InitDefault();
1299
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1300
    _impl_.oldstreamname_.Set("", GetArenaForAllocation());
1301
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1302
0
  if (from._internal_has_oldstreamname()) {
1303
0
    _this->_impl_.oldstreamname_.Set(from._internal_oldstreamname(), 
1304
0
      _this->GetArenaForAllocation());
1305
0
  }
1306
0
  _impl_.streamname_.InitDefault();
1307
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1308
    _impl_.streamname_.Set("", GetArenaForAllocation());
1309
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1310
0
  if (from._internal_has_streamname()) {
1311
0
    _this->_impl_.streamname_.Set(from._internal_streamname(), 
1312
0
      _this->GetArenaForAllocation());
1313
0
  }
1314
0
  _impl_.transition_.InitDefault();
1315
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1316
    _impl_.transition_.Set("", GetArenaForAllocation());
1317
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1318
0
  if (from._internal_has_transition()) {
1319
0
    _this->_impl_.transition_.Set(from._internal_transition(), 
1320
0
      _this->GetArenaForAllocation());
1321
0
  }
1322
0
  ::memcpy(&_impl_.len_, &from._impl_.len_,
1323
0
    static_cast<size_t>(reinterpret_cast<char*>(&_impl_.start_) -
1324
0
    reinterpret_cast<char*>(&_impl_.len_)) + sizeof(_impl_.start_));
1325
  // @@protoc_insertion_point(copy_constructor:brpc.RtmpPlay2Options)
1326
0
}
1327
1328
inline void RtmpPlay2Options::SharedCtor(
1329
0
    ::_pb::Arena* arena, bool is_message_owned) {
1330
0
  (void)arena;
1331
0
  (void)is_message_owned;
1332
0
  new (&_impl_) Impl_{
1333
0
      decltype(_impl_._has_bits_){}
1334
0
    , /*decltype(_impl_._cached_size_)*/{}
1335
0
    , decltype(_impl_.oldstreamname_){}
1336
0
    , decltype(_impl_.streamname_){}
1337
0
    , decltype(_impl_.transition_){}
1338
0
    , decltype(_impl_.len_){0}
1339
0
    , decltype(_impl_.offset_){0}
1340
0
    , decltype(_impl_.start_){0}
1341
0
  };
1342
0
  _impl_.oldstreamname_.InitDefault();
1343
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1344
    _impl_.oldstreamname_.Set("", GetArenaForAllocation());
1345
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1346
0
  _impl_.streamname_.InitDefault();
1347
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1348
    _impl_.streamname_.Set("", GetArenaForAllocation());
1349
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1350
0
  _impl_.transition_.InitDefault();
1351
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1352
    _impl_.transition_.Set("", GetArenaForAllocation());
1353
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1354
0
}
1355
1356
0
RtmpPlay2Options::~RtmpPlay2Options() {
1357
  // @@protoc_insertion_point(destructor:brpc.RtmpPlay2Options)
1358
0
  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
1359
0
  (void)arena;
1360
0
    return;
1361
0
  }
1362
0
  SharedDtor();
1363
0
}
1364
1365
0
inline void RtmpPlay2Options::SharedDtor() {
1366
0
  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1367
0
  _impl_.oldstreamname_.Destroy();
1368
0
  _impl_.streamname_.Destroy();
1369
0
  _impl_.transition_.Destroy();
1370
0
}
1371
1372
0
void RtmpPlay2Options::SetCachedSize(int size) const {
1373
0
  _impl_._cached_size_.Set(size);
1374
0
}
1375
1376
0
void RtmpPlay2Options::Clear() {
1377
// @@protoc_insertion_point(message_clear_start:brpc.RtmpPlay2Options)
1378
0
  uint32_t cached_has_bits = 0;
1379
  // Prevent compiler warnings about cached_has_bits being unused
1380
0
  (void) cached_has_bits;
1381
1382
0
  cached_has_bits = _impl_._has_bits_[0];
1383
0
  if (cached_has_bits & 0x00000007u) {
1384
0
    if (cached_has_bits & 0x00000001u) {
1385
0
      _impl_.oldstreamname_.ClearNonDefaultToEmpty();
1386
0
    }
1387
0
    if (cached_has_bits & 0x00000002u) {
1388
0
      _impl_.streamname_.ClearNonDefaultToEmpty();
1389
0
    }
1390
0
    if (cached_has_bits & 0x00000004u) {
1391
0
      _impl_.transition_.ClearNonDefaultToEmpty();
1392
0
    }
1393
0
  }
1394
0
  if (cached_has_bits & 0x00000038u) {
1395
0
    ::memset(&_impl_.len_, 0, static_cast<size_t>(
1396
0
        reinterpret_cast<char*>(&_impl_.start_) -
1397
0
        reinterpret_cast<char*>(&_impl_.len_)) + sizeof(_impl_.start_));
1398
0
  }
1399
0
  _impl_._has_bits_.Clear();
1400
0
  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1401
0
}
1402
1403
0
const char* RtmpPlay2Options::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1404
0
#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1405
0
  _Internal::HasBits has_bits{};
1406
0
  while (!ctx->Done(&ptr)) {
1407
0
    uint32_t tag;
1408
0
    ptr = ::_pbi::ReadTag(ptr, &tag);
1409
0
    switch (tag >> 3) {
1410
      // optional double len = 1;
1411
0
      case 1:
1412
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 9)) {
1413
0
          _Internal::set_has_len(&has_bits);
1414
0
          _impl_.len_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1415
0
          ptr += sizeof(double);
1416
0
        } else
1417
0
          goto handle_unusual;
1418
0
        continue;
1419
      // optional double offset = 2;
1420
0
      case 2:
1421
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 17)) {
1422
0
          _Internal::set_has_offset(&has_bits);
1423
0
          _impl_.offset_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1424
0
          ptr += sizeof(double);
1425
0
        } else
1426
0
          goto handle_unusual;
1427
0
        continue;
1428
      // optional string oldStreamName = 3;
1429
0
      case 3:
1430
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 26)) {
1431
0
          auto str = _internal_mutable_oldstreamname();
1432
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1433
0
          CHK_(ptr);
1434
0
          #ifndef NDEBUG
1435
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpPlay2Options.oldStreamName");
1436
0
          #endif  // !NDEBUG
1437
0
        } else
1438
0
          goto handle_unusual;
1439
0
        continue;
1440
      // optional double start = 4;
1441
0
      case 4:
1442
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 33)) {
1443
0
          _Internal::set_has_start(&has_bits);
1444
0
          _impl_.start_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1445
0
          ptr += sizeof(double);
1446
0
        } else
1447
0
          goto handle_unusual;
1448
0
        continue;
1449
      // optional string streamName = 5;
1450
0
      case 5:
1451
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 42)) {
1452
0
          auto str = _internal_mutable_streamname();
1453
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1454
0
          CHK_(ptr);
1455
0
          #ifndef NDEBUG
1456
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpPlay2Options.streamName");
1457
0
          #endif  // !NDEBUG
1458
0
        } else
1459
0
          goto handle_unusual;
1460
0
        continue;
1461
      // optional string transition = 6;
1462
0
      case 6:
1463
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 50)) {
1464
0
          auto str = _internal_mutable_transition();
1465
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1466
0
          CHK_(ptr);
1467
0
          #ifndef NDEBUG
1468
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpPlay2Options.transition");
1469
0
          #endif  // !NDEBUG
1470
0
        } else
1471
0
          goto handle_unusual;
1472
0
        continue;
1473
0
      default:
1474
0
        goto handle_unusual;
1475
0
    }  // switch
1476
0
  handle_unusual:
1477
0
    if ((tag == 0) || ((tag & 7) == 4)) {
1478
0
      CHK_(ptr);
1479
0
      ctx->SetLastTag(tag);
1480
0
      goto message_done;
1481
0
    }
1482
0
    ptr = UnknownFieldParse(
1483
0
        tag,
1484
0
        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
1485
0
        ptr, ctx);
1486
0
    CHK_(ptr != nullptr);
1487
0
  }  // while
1488
0
message_done:
1489
0
  _impl_._has_bits_.Or(has_bits);
1490
0
  return ptr;
1491
0
failure:
1492
0
  ptr = nullptr;
1493
0
  goto message_done;
1494
0
#undef CHK_
1495
0
}
1496
1497
uint8_t* RtmpPlay2Options::_InternalSerialize(
1498
0
    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1499
  // @@protoc_insertion_point(serialize_to_array_start:brpc.RtmpPlay2Options)
1500
0
  uint32_t cached_has_bits = 0;
1501
0
  (void) cached_has_bits;
1502
1503
0
  cached_has_bits = _impl_._has_bits_[0];
1504
  // optional double len = 1;
1505
0
  if (cached_has_bits & 0x00000008u) {
1506
0
    target = stream->EnsureSpace(target);
1507
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(1, this->_internal_len(), target);
1508
0
  }
1509
1510
  // optional double offset = 2;
1511
0
  if (cached_has_bits & 0x00000010u) {
1512
0
    target = stream->EnsureSpace(target);
1513
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(2, this->_internal_offset(), target);
1514
0
  }
1515
1516
  // optional string oldStreamName = 3;
1517
0
  if (cached_has_bits & 0x00000001u) {
1518
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1519
0
      this->_internal_oldstreamname().data(), static_cast<int>(this->_internal_oldstreamname().length()),
1520
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1521
0
      "brpc.RtmpPlay2Options.oldStreamName");
1522
0
    target = stream->WriteStringMaybeAliased(
1523
0
        3, this->_internal_oldstreamname(), target);
1524
0
  }
1525
1526
  // optional double start = 4;
1527
0
  if (cached_has_bits & 0x00000020u) {
1528
0
    target = stream->EnsureSpace(target);
1529
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(4, this->_internal_start(), target);
1530
0
  }
1531
1532
  // optional string streamName = 5;
1533
0
  if (cached_has_bits & 0x00000002u) {
1534
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1535
0
      this->_internal_streamname().data(), static_cast<int>(this->_internal_streamname().length()),
1536
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1537
0
      "brpc.RtmpPlay2Options.streamName");
1538
0
    target = stream->WriteStringMaybeAliased(
1539
0
        5, this->_internal_streamname(), target);
1540
0
  }
1541
1542
  // optional string transition = 6;
1543
0
  if (cached_has_bits & 0x00000004u) {
1544
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1545
0
      this->_internal_transition().data(), static_cast<int>(this->_internal_transition().length()),
1546
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1547
0
      "brpc.RtmpPlay2Options.transition");
1548
0
    target = stream->WriteStringMaybeAliased(
1549
0
        6, this->_internal_transition(), target);
1550
0
  }
1551
1552
0
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1553
0
    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
1554
0
        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
1555
0
  }
1556
  // @@protoc_insertion_point(serialize_to_array_end:brpc.RtmpPlay2Options)
1557
0
  return target;
1558
0
}
1559
1560
0
size_t RtmpPlay2Options::ByteSizeLong() const {
1561
// @@protoc_insertion_point(message_byte_size_start:brpc.RtmpPlay2Options)
1562
0
  size_t total_size = 0;
1563
1564
0
  uint32_t cached_has_bits = 0;
1565
  // Prevent compiler warnings about cached_has_bits being unused
1566
0
  (void) cached_has_bits;
1567
1568
0
  cached_has_bits = _impl_._has_bits_[0];
1569
0
  if (cached_has_bits & 0x0000003fu) {
1570
    // optional string oldStreamName = 3;
1571
0
    if (cached_has_bits & 0x00000001u) {
1572
0
      total_size += 1 +
1573
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1574
0
          this->_internal_oldstreamname());
1575
0
    }
1576
1577
    // optional string streamName = 5;
1578
0
    if (cached_has_bits & 0x00000002u) {
1579
0
      total_size += 1 +
1580
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1581
0
          this->_internal_streamname());
1582
0
    }
1583
1584
    // optional string transition = 6;
1585
0
    if (cached_has_bits & 0x00000004u) {
1586
0
      total_size += 1 +
1587
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1588
0
          this->_internal_transition());
1589
0
    }
1590
1591
    // optional double len = 1;
1592
0
    if (cached_has_bits & 0x00000008u) {
1593
0
      total_size += 1 + 8;
1594
0
    }
1595
1596
    // optional double offset = 2;
1597
0
    if (cached_has_bits & 0x00000010u) {
1598
0
      total_size += 1 + 8;
1599
0
    }
1600
1601
    // optional double start = 4;
1602
0
    if (cached_has_bits & 0x00000020u) {
1603
0
      total_size += 1 + 8;
1604
0
    }
1605
1606
0
  }
1607
0
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
1608
0
}
1609
1610
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData RtmpPlay2Options::_class_data_ = {
1611
    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
1612
    RtmpPlay2Options::MergeImpl
1613
};
1614
0
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*RtmpPlay2Options::GetClassData() const { return &_class_data_; }
1615
1616
1617
0
void RtmpPlay2Options::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
1618
0
  auto* const _this = static_cast<RtmpPlay2Options*>(&to_msg);
1619
0
  auto& from = static_cast<const RtmpPlay2Options&>(from_msg);
1620
  // @@protoc_insertion_point(class_specific_merge_from_start:brpc.RtmpPlay2Options)
1621
0
  GOOGLE_DCHECK_NE(&from, _this);
1622
0
  uint32_t cached_has_bits = 0;
1623
0
  (void) cached_has_bits;
1624
1625
0
  cached_has_bits = from._impl_._has_bits_[0];
1626
0
  if (cached_has_bits & 0x0000003fu) {
1627
0
    if (cached_has_bits & 0x00000001u) {
1628
0
      _this->_internal_set_oldstreamname(from._internal_oldstreamname());
1629
0
    }
1630
0
    if (cached_has_bits & 0x00000002u) {
1631
0
      _this->_internal_set_streamname(from._internal_streamname());
1632
0
    }
1633
0
    if (cached_has_bits & 0x00000004u) {
1634
0
      _this->_internal_set_transition(from._internal_transition());
1635
0
    }
1636
0
    if (cached_has_bits & 0x00000008u) {
1637
0
      _this->_impl_.len_ = from._impl_.len_;
1638
0
    }
1639
0
    if (cached_has_bits & 0x00000010u) {
1640
0
      _this->_impl_.offset_ = from._impl_.offset_;
1641
0
    }
1642
0
    if (cached_has_bits & 0x00000020u) {
1643
0
      _this->_impl_.start_ = from._impl_.start_;
1644
0
    }
1645
0
    _this->_impl_._has_bits_[0] |= cached_has_bits;
1646
0
  }
1647
0
  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
1648
0
}
1649
1650
0
void RtmpPlay2Options::CopyFrom(const RtmpPlay2Options& from) {
1651
// @@protoc_insertion_point(class_specific_copy_from_start:brpc.RtmpPlay2Options)
1652
0
  if (&from == this) return;
1653
0
  Clear();
1654
0
  MergeFrom(from);
1655
0
}
1656
1657
0
bool RtmpPlay2Options::IsInitialized() const {
1658
0
  return true;
1659
0
}
1660
1661
0
void RtmpPlay2Options::InternalSwap(RtmpPlay2Options* other) {
1662
0
  using std::swap;
1663
0
  auto* lhs_arena = GetArenaForAllocation();
1664
0
  auto* rhs_arena = other->GetArenaForAllocation();
1665
0
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
1666
0
  swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]);
1667
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1668
0
      &_impl_.oldstreamname_, lhs_arena,
1669
0
      &other->_impl_.oldstreamname_, rhs_arena
1670
0
  );
1671
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1672
0
      &_impl_.streamname_, lhs_arena,
1673
0
      &other->_impl_.streamname_, rhs_arena
1674
0
  );
1675
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
1676
0
      &_impl_.transition_, lhs_arena,
1677
0
      &other->_impl_.transition_, rhs_arena
1678
0
  );
1679
0
  ::PROTOBUF_NAMESPACE_ID::internal::memswap<
1680
0
      PROTOBUF_FIELD_OFFSET(RtmpPlay2Options, _impl_.start_)
1681
0
      + sizeof(RtmpPlay2Options::_impl_.start_)
1682
0
      - PROTOBUF_FIELD_OFFSET(RtmpPlay2Options, _impl_.len_)>(
1683
0
          reinterpret_cast<char*>(&_impl_.len_),
1684
0
          reinterpret_cast<char*>(&other->_impl_.len_));
1685
0
}
1686
1687
0
::PROTOBUF_NAMESPACE_ID::Metadata RtmpPlay2Options::GetMetadata() const {
1688
0
  return ::_pbi::AssignDescriptors(
1689
0
      &descriptor_table_brpc_2frtmp_2eproto_getter, &descriptor_table_brpc_2frtmp_2eproto_once,
1690
0
      file_level_metadata_brpc_2frtmp_2eproto[2]);
1691
0
}
1692
1693
// ===================================================================
1694
1695
class RtmpInfo::_Internal {
1696
 public:
1697
  using HasBits = decltype(std::declval<RtmpInfo>()._impl_._has_bits_);
1698
0
  static void set_has_code(HasBits* has_bits) {
1699
0
    (*has_bits)[0] |= 1u;
1700
0
  }
1701
0
  static void set_has_level(HasBits* has_bits) {
1702
0
    (*has_bits)[0] |= 2u;
1703
0
  }
1704
0
  static void set_has_description(HasBits* has_bits) {
1705
0
    (*has_bits)[0] |= 4u;
1706
0
  }
1707
0
  static void set_has_objectencoding(HasBits* has_bits) {
1708
0
    (*has_bits)[0] |= 8u;
1709
0
  }
1710
};
1711
1712
RtmpInfo::RtmpInfo(::PROTOBUF_NAMESPACE_ID::Arena* arena,
1713
                         bool is_message_owned)
1714
0
  : ::PROTOBUF_NAMESPACE_ID::Message(arena, is_message_owned) {
1715
0
  SharedCtor(arena, is_message_owned);
1716
  // @@protoc_insertion_point(arena_constructor:brpc.RtmpInfo)
1717
0
}
1718
RtmpInfo::RtmpInfo(const RtmpInfo& from)
1719
0
  : ::PROTOBUF_NAMESPACE_ID::Message() {
1720
0
  RtmpInfo* const _this = this; (void)_this;
1721
0
  new (&_impl_) Impl_{
1722
0
      decltype(_impl_._has_bits_){from._impl_._has_bits_}
1723
0
    , /*decltype(_impl_._cached_size_)*/{}
1724
0
    , decltype(_impl_.code_){}
1725
0
    , decltype(_impl_.level_){}
1726
0
    , decltype(_impl_.description_){}
1727
0
    , decltype(_impl_.objectencoding_){}};
1728
1729
0
  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
1730
0
  _impl_.code_.InitDefault();
1731
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1732
    _impl_.code_.Set("", GetArenaForAllocation());
1733
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1734
0
  if (from._internal_has_code()) {
1735
0
    _this->_impl_.code_.Set(from._internal_code(), 
1736
0
      _this->GetArenaForAllocation());
1737
0
  }
1738
0
  _impl_.level_.InitDefault();
1739
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1740
    _impl_.level_.Set("", GetArenaForAllocation());
1741
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1742
0
  if (from._internal_has_level()) {
1743
0
    _this->_impl_.level_.Set(from._internal_level(), 
1744
0
      _this->GetArenaForAllocation());
1745
0
  }
1746
0
  _impl_.description_.InitDefault();
1747
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1748
    _impl_.description_.Set("", GetArenaForAllocation());
1749
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1750
0
  if (from._internal_has_description()) {
1751
0
    _this->_impl_.description_.Set(from._internal_description(), 
1752
0
      _this->GetArenaForAllocation());
1753
0
  }
1754
0
  _this->_impl_.objectencoding_ = from._impl_.objectencoding_;
1755
  // @@protoc_insertion_point(copy_constructor:brpc.RtmpInfo)
1756
0
}
1757
1758
inline void RtmpInfo::SharedCtor(
1759
0
    ::_pb::Arena* arena, bool is_message_owned) {
1760
0
  (void)arena;
1761
0
  (void)is_message_owned;
1762
0
  new (&_impl_) Impl_{
1763
0
      decltype(_impl_._has_bits_){}
1764
0
    , /*decltype(_impl_._cached_size_)*/{}
1765
0
    , decltype(_impl_.code_){}
1766
0
    , decltype(_impl_.level_){}
1767
0
    , decltype(_impl_.description_){}
1768
0
    , decltype(_impl_.objectencoding_){0}
1769
0
  };
1770
0
  _impl_.code_.InitDefault();
1771
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1772
    _impl_.code_.Set("", GetArenaForAllocation());
1773
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1774
0
  _impl_.level_.InitDefault();
1775
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1776
    _impl_.level_.Set("", GetArenaForAllocation());
1777
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1778
0
  _impl_.description_.InitDefault();
1779
  #ifdef PROTOBUF_FORCE_COPY_DEFAULT_STRING
1780
    _impl_.description_.Set("", GetArenaForAllocation());
1781
  #endif // PROTOBUF_FORCE_COPY_DEFAULT_STRING
1782
0
}
1783
1784
0
RtmpInfo::~RtmpInfo() {
1785
  // @@protoc_insertion_point(destructor:brpc.RtmpInfo)
1786
0
  if (auto *arena = _internal_metadata_.DeleteReturnArena<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>()) {
1787
0
  (void)arena;
1788
0
    return;
1789
0
  }
1790
0
  SharedDtor();
1791
0
}
1792
1793
0
inline void RtmpInfo::SharedDtor() {
1794
0
  GOOGLE_DCHECK(GetArenaForAllocation() == nullptr);
1795
0
  _impl_.code_.Destroy();
1796
0
  _impl_.level_.Destroy();
1797
0
  _impl_.description_.Destroy();
1798
0
}
1799
1800
0
void RtmpInfo::SetCachedSize(int size) const {
1801
0
  _impl_._cached_size_.Set(size);
1802
0
}
1803
1804
0
void RtmpInfo::Clear() {
1805
// @@protoc_insertion_point(message_clear_start:brpc.RtmpInfo)
1806
0
  uint32_t cached_has_bits = 0;
1807
  // Prevent compiler warnings about cached_has_bits being unused
1808
0
  (void) cached_has_bits;
1809
1810
0
  cached_has_bits = _impl_._has_bits_[0];
1811
0
  if (cached_has_bits & 0x00000007u) {
1812
0
    if (cached_has_bits & 0x00000001u) {
1813
0
      _impl_.code_.ClearNonDefaultToEmpty();
1814
0
    }
1815
0
    if (cached_has_bits & 0x00000002u) {
1816
0
      _impl_.level_.ClearNonDefaultToEmpty();
1817
0
    }
1818
0
    if (cached_has_bits & 0x00000004u) {
1819
0
      _impl_.description_.ClearNonDefaultToEmpty();
1820
0
    }
1821
0
  }
1822
0
  _impl_.objectencoding_ = 0;
1823
0
  _impl_._has_bits_.Clear();
1824
0
  _internal_metadata_.Clear<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>();
1825
0
}
1826
1827
0
const char* RtmpInfo::_InternalParse(const char* ptr, ::_pbi::ParseContext* ctx) {
1828
0
#define CHK_(x) if (PROTOBUF_PREDICT_FALSE(!(x))) goto failure
1829
0
  _Internal::HasBits has_bits{};
1830
0
  while (!ctx->Done(&ptr)) {
1831
0
    uint32_t tag;
1832
0
    ptr = ::_pbi::ReadTag(ptr, &tag);
1833
0
    switch (tag >> 3) {
1834
      // optional string code = 1;
1835
0
      case 1:
1836
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 10)) {
1837
0
          auto str = _internal_mutable_code();
1838
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1839
0
          CHK_(ptr);
1840
0
          #ifndef NDEBUG
1841
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpInfo.code");
1842
0
          #endif  // !NDEBUG
1843
0
        } else
1844
0
          goto handle_unusual;
1845
0
        continue;
1846
      // optional string level = 2;
1847
0
      case 2:
1848
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 18)) {
1849
0
          auto str = _internal_mutable_level();
1850
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1851
0
          CHK_(ptr);
1852
0
          #ifndef NDEBUG
1853
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpInfo.level");
1854
0
          #endif  // !NDEBUG
1855
0
        } else
1856
0
          goto handle_unusual;
1857
0
        continue;
1858
      // optional string description = 3;
1859
0
      case 3:
1860
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 26)) {
1861
0
          auto str = _internal_mutable_description();
1862
0
          ptr = ::_pbi::InlineGreedyStringParser(str, ptr, ctx);
1863
0
          CHK_(ptr);
1864
0
          #ifndef NDEBUG
1865
0
          ::_pbi::VerifyUTF8(str, "brpc.RtmpInfo.description");
1866
0
          #endif  // !NDEBUG
1867
0
        } else
1868
0
          goto handle_unusual;
1869
0
        continue;
1870
      // optional double objectEncoding = 4;
1871
0
      case 4:
1872
0
        if (PROTOBUF_PREDICT_TRUE(static_cast<uint8_t>(tag) == 33)) {
1873
0
          _Internal::set_has_objectencoding(&has_bits);
1874
0
          _impl_.objectencoding_ = ::PROTOBUF_NAMESPACE_ID::internal::UnalignedLoad<double>(ptr);
1875
0
          ptr += sizeof(double);
1876
0
        } else
1877
0
          goto handle_unusual;
1878
0
        continue;
1879
0
      default:
1880
0
        goto handle_unusual;
1881
0
    }  // switch
1882
0
  handle_unusual:
1883
0
    if ((tag == 0) || ((tag & 7) == 4)) {
1884
0
      CHK_(ptr);
1885
0
      ctx->SetLastTag(tag);
1886
0
      goto message_done;
1887
0
    }
1888
0
    ptr = UnknownFieldParse(
1889
0
        tag,
1890
0
        _internal_metadata_.mutable_unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(),
1891
0
        ptr, ctx);
1892
0
    CHK_(ptr != nullptr);
1893
0
  }  // while
1894
0
message_done:
1895
0
  _impl_._has_bits_.Or(has_bits);
1896
0
  return ptr;
1897
0
failure:
1898
0
  ptr = nullptr;
1899
0
  goto message_done;
1900
0
#undef CHK_
1901
0
}
1902
1903
uint8_t* RtmpInfo::_InternalSerialize(
1904
0
    uint8_t* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const {
1905
  // @@protoc_insertion_point(serialize_to_array_start:brpc.RtmpInfo)
1906
0
  uint32_t cached_has_bits = 0;
1907
0
  (void) cached_has_bits;
1908
1909
0
  cached_has_bits = _impl_._has_bits_[0];
1910
  // optional string code = 1;
1911
0
  if (cached_has_bits & 0x00000001u) {
1912
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1913
0
      this->_internal_code().data(), static_cast<int>(this->_internal_code().length()),
1914
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1915
0
      "brpc.RtmpInfo.code");
1916
0
    target = stream->WriteStringMaybeAliased(
1917
0
        1, this->_internal_code(), target);
1918
0
  }
1919
1920
  // optional string level = 2;
1921
0
  if (cached_has_bits & 0x00000002u) {
1922
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1923
0
      this->_internal_level().data(), static_cast<int>(this->_internal_level().length()),
1924
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1925
0
      "brpc.RtmpInfo.level");
1926
0
    target = stream->WriteStringMaybeAliased(
1927
0
        2, this->_internal_level(), target);
1928
0
  }
1929
1930
  // optional string description = 3;
1931
0
  if (cached_has_bits & 0x00000004u) {
1932
0
    ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::VerifyUTF8StringNamedField(
1933
0
      this->_internal_description().data(), static_cast<int>(this->_internal_description().length()),
1934
0
      ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SERIALIZE,
1935
0
      "brpc.RtmpInfo.description");
1936
0
    target = stream->WriteStringMaybeAliased(
1937
0
        3, this->_internal_description(), target);
1938
0
  }
1939
1940
  // optional double objectEncoding = 4;
1941
0
  if (cached_has_bits & 0x00000008u) {
1942
0
    target = stream->EnsureSpace(target);
1943
0
    target = ::_pbi::WireFormatLite::WriteDoubleToArray(4, this->_internal_objectencoding(), target);
1944
0
  }
1945
1946
0
  if (PROTOBUF_PREDICT_FALSE(_internal_metadata_.have_unknown_fields())) {
1947
0
    target = ::_pbi::WireFormat::InternalSerializeUnknownFieldsToArray(
1948
0
        _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream);
1949
0
  }
1950
  // @@protoc_insertion_point(serialize_to_array_end:brpc.RtmpInfo)
1951
0
  return target;
1952
0
}
1953
1954
0
size_t RtmpInfo::ByteSizeLong() const {
1955
// @@protoc_insertion_point(message_byte_size_start:brpc.RtmpInfo)
1956
0
  size_t total_size = 0;
1957
1958
0
  uint32_t cached_has_bits = 0;
1959
  // Prevent compiler warnings about cached_has_bits being unused
1960
0
  (void) cached_has_bits;
1961
1962
0
  cached_has_bits = _impl_._has_bits_[0];
1963
0
  if (cached_has_bits & 0x0000000fu) {
1964
    // optional string code = 1;
1965
0
    if (cached_has_bits & 0x00000001u) {
1966
0
      total_size += 1 +
1967
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1968
0
          this->_internal_code());
1969
0
    }
1970
1971
    // optional string level = 2;
1972
0
    if (cached_has_bits & 0x00000002u) {
1973
0
      total_size += 1 +
1974
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1975
0
          this->_internal_level());
1976
0
    }
1977
1978
    // optional string description = 3;
1979
0
    if (cached_has_bits & 0x00000004u) {
1980
0
      total_size += 1 +
1981
0
        ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::StringSize(
1982
0
          this->_internal_description());
1983
0
    }
1984
1985
    // optional double objectEncoding = 4;
1986
0
    if (cached_has_bits & 0x00000008u) {
1987
0
      total_size += 1 + 8;
1988
0
    }
1989
1990
0
  }
1991
0
  return MaybeComputeUnknownFieldsSize(total_size, &_impl_._cached_size_);
1992
0
}
1993
1994
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData RtmpInfo::_class_data_ = {
1995
    ::PROTOBUF_NAMESPACE_ID::Message::CopyWithSourceCheck,
1996
    RtmpInfo::MergeImpl
1997
};
1998
0
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*RtmpInfo::GetClassData() const { return &_class_data_; }
1999
2000
2001
0
void RtmpInfo::MergeImpl(::PROTOBUF_NAMESPACE_ID::Message& to_msg, const ::PROTOBUF_NAMESPACE_ID::Message& from_msg) {
2002
0
  auto* const _this = static_cast<RtmpInfo*>(&to_msg);
2003
0
  auto& from = static_cast<const RtmpInfo&>(from_msg);
2004
  // @@protoc_insertion_point(class_specific_merge_from_start:brpc.RtmpInfo)
2005
0
  GOOGLE_DCHECK_NE(&from, _this);
2006
0
  uint32_t cached_has_bits = 0;
2007
0
  (void) cached_has_bits;
2008
2009
0
  cached_has_bits = from._impl_._has_bits_[0];
2010
0
  if (cached_has_bits & 0x0000000fu) {
2011
0
    if (cached_has_bits & 0x00000001u) {
2012
0
      _this->_internal_set_code(from._internal_code());
2013
0
    }
2014
0
    if (cached_has_bits & 0x00000002u) {
2015
0
      _this->_internal_set_level(from._internal_level());
2016
0
    }
2017
0
    if (cached_has_bits & 0x00000004u) {
2018
0
      _this->_internal_set_description(from._internal_description());
2019
0
    }
2020
0
    if (cached_has_bits & 0x00000008u) {
2021
0
      _this->_impl_.objectencoding_ = from._impl_.objectencoding_;
2022
0
    }
2023
0
    _this->_impl_._has_bits_[0] |= cached_has_bits;
2024
0
  }
2025
0
  _this->_internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
2026
0
}
2027
2028
0
void RtmpInfo::CopyFrom(const RtmpInfo& from) {
2029
// @@protoc_insertion_point(class_specific_copy_from_start:brpc.RtmpInfo)
2030
0
  if (&from == this) return;
2031
0
  Clear();
2032
0
  MergeFrom(from);
2033
0
}
2034
2035
0
bool RtmpInfo::IsInitialized() const {
2036
0
  return true;
2037
0
}
2038
2039
0
void RtmpInfo::InternalSwap(RtmpInfo* other) {
2040
0
  using std::swap;
2041
0
  auto* lhs_arena = GetArenaForAllocation();
2042
0
  auto* rhs_arena = other->GetArenaForAllocation();
2043
0
  _internal_metadata_.InternalSwap(&other->_internal_metadata_);
2044
0
  swap(_impl_._has_bits_[0], other->_impl_._has_bits_[0]);
2045
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2046
0
      &_impl_.code_, lhs_arena,
2047
0
      &other->_impl_.code_, rhs_arena
2048
0
  );
2049
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2050
0
      &_impl_.level_, lhs_arena,
2051
0
      &other->_impl_.level_, rhs_arena
2052
0
  );
2053
0
  ::PROTOBUF_NAMESPACE_ID::internal::ArenaStringPtr::InternalSwap(
2054
0
      &_impl_.description_, lhs_arena,
2055
0
      &other->_impl_.description_, rhs_arena
2056
0
  );
2057
0
  swap(_impl_.objectencoding_, other->_impl_.objectencoding_);
2058
0
}
2059
2060
0
::PROTOBUF_NAMESPACE_ID::Metadata RtmpInfo::GetMetadata() const {
2061
0
  return ::_pbi::AssignDescriptors(
2062
0
      &descriptor_table_brpc_2frtmp_2eproto_getter, &descriptor_table_brpc_2frtmp_2eproto_once,
2063
0
      file_level_metadata_brpc_2frtmp_2eproto[3]);
2064
0
}
2065
2066
// ===================================================================
2067
2068
class RtmpEmptyObject::_Internal {
2069
 public:
2070
};
2071
2072
RtmpEmptyObject::RtmpEmptyObject(::PROTOBUF_NAMESPACE_ID::Arena* arena,
2073
                         bool is_message_owned)
2074
0
  : ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase(arena, is_message_owned) {
2075
  // @@protoc_insertion_point(arena_constructor:brpc.RtmpEmptyObject)
2076
0
}
2077
RtmpEmptyObject::RtmpEmptyObject(const RtmpEmptyObject& from)
2078
0
  : ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase() {
2079
0
  RtmpEmptyObject* const _this = this; (void)_this;
2080
0
  _internal_metadata_.MergeFrom<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(from._internal_metadata_);
2081
  // @@protoc_insertion_point(copy_constructor:brpc.RtmpEmptyObject)
2082
0
}
2083
2084
2085
2086
2087
2088
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData RtmpEmptyObject::_class_data_ = {
2089
    ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::CopyImpl,
2090
    ::PROTOBUF_NAMESPACE_ID::internal::ZeroFieldsBase::MergeImpl,
2091
};
2092
0
const ::PROTOBUF_NAMESPACE_ID::Message::ClassData*RtmpEmptyObject::GetClassData() const { return &_class_data_; }
2093
2094
2095
2096
2097
2098
2099
2100
0
::PROTOBUF_NAMESPACE_ID::Metadata RtmpEmptyObject::GetMetadata() const {
2101
0
  return ::_pbi::AssignDescriptors(
2102
0
      &descriptor_table_brpc_2frtmp_2eproto_getter, &descriptor_table_brpc_2frtmp_2eproto_once,
2103
0
      file_level_metadata_brpc_2frtmp_2eproto[4]);
2104
0
}
2105
2106
// @@protoc_insertion_point(namespace_scope)
2107
}  // namespace brpc
2108
PROTOBUF_NAMESPACE_OPEN
2109
template<> PROTOBUF_NOINLINE ::brpc::RtmpConnectRequest*
2110
0
Arena::CreateMaybeMessage< ::brpc::RtmpConnectRequest >(Arena* arena) {
2111
0
  return Arena::CreateMessageInternal< ::brpc::RtmpConnectRequest >(arena);
2112
0
}
2113
template<> PROTOBUF_NOINLINE ::brpc::RtmpConnectResponse*
2114
0
Arena::CreateMaybeMessage< ::brpc::RtmpConnectResponse >(Arena* arena) {
2115
0
  return Arena::CreateMessageInternal< ::brpc::RtmpConnectResponse >(arena);
2116
0
}
2117
template<> PROTOBUF_NOINLINE ::brpc::RtmpPlay2Options*
2118
0
Arena::CreateMaybeMessage< ::brpc::RtmpPlay2Options >(Arena* arena) {
2119
0
  return Arena::CreateMessageInternal< ::brpc::RtmpPlay2Options >(arena);
2120
0
}
2121
template<> PROTOBUF_NOINLINE ::brpc::RtmpInfo*
2122
0
Arena::CreateMaybeMessage< ::brpc::RtmpInfo >(Arena* arena) {
2123
0
  return Arena::CreateMessageInternal< ::brpc::RtmpInfo >(arena);
2124
0
}
2125
template<> PROTOBUF_NOINLINE ::brpc::RtmpEmptyObject*
2126
0
Arena::CreateMaybeMessage< ::brpc::RtmpEmptyObject >(Arena* arena) {
2127
0
  return Arena::CreateMessageInternal< ::brpc::RtmpEmptyObject >(arena);
2128
0
}
2129
PROTOBUF_NAMESPACE_CLOSE
2130
2131
// @@protoc_insertion_point(global_scope)
2132
#include <google/protobuf/port_undef.inc>