1 // This file is generated by rust-protobuf 2.28.0. Do not edit
2 // @generated
3
4 // https://github.com/rust-lang/rust-clippy/issues/702
5 #![allow(unknown_lints)]
6 #![allow(clippy::all)]
7
8 #![allow(unused_attributes)]
9 #![cfg_attr(rustfmt, rustfmt::skip)]
10
11 #![allow(box_pointers)]
12 #![allow(dead_code)]
13 #![allow(missing_docs)]
14 #![allow(non_camel_case_types)]
15 #![allow(non_snake_case)]
16 #![allow(non_upper_case_globals)]
17 #![allow(trivial_casts)]
18 #![allow(unused_imports)]
19 #![allow(unused_results)]
20 //! Generated file from `packet_streamer.proto`
21
22 /// Generated files are compatible only with the same version
23 /// of protobuf runtime.
24 // const _PROTOBUF_VERSION_CHECK: () = ::protobuf::VERSION_2_28_0;
25
26 #[derive(PartialEq,Clone,Default)]
27 #[cfg_attr(feature = "with-serde", derive(::serde::Serialize, ::serde::Deserialize))]
28 pub struct StreamPacketsRequest {
29 // message oneof groups
30 pub request_type: ::std::option::Option<StreamPacketsRequest_oneof_request_type>,
31 // special fields
32 #[cfg_attr(feature = "with-serde", serde(skip))]
33 pub unknown_fields: ::protobuf::UnknownFields,
34 #[cfg_attr(feature = "with-serde", serde(skip))]
35 pub cached_size: ::protobuf::CachedSize,
36 }
37
38 impl<'a> ::std::default::Default for &'a StreamPacketsRequest {
default() -> &'a StreamPacketsRequest39 fn default() -> &'a StreamPacketsRequest {
40 <StreamPacketsRequest as ::protobuf::Message>::default_instance()
41 }
42 }
43
44 #[derive(Clone,PartialEq,Debug)]
45 #[cfg_attr(feature = "with-serde", derive(::serde::Serialize, ::serde::Deserialize))]
46 pub enum StreamPacketsRequest_oneof_request_type {
47 initial_info(super::startup::ChipInfo),
48 hci_packet(super::hci_packet::HCIPacket),
49 packet(::std::vec::Vec<u8>),
50 }
51
52 impl StreamPacketsRequest {
new() -> StreamPacketsRequest53 pub fn new() -> StreamPacketsRequest {
54 ::std::default::Default::default()
55 }
56
57 // .netsim.startup.ChipInfo initial_info = 1;
58
59
get_initial_info(&self) -> &super::startup::ChipInfo60 pub fn get_initial_info(&self) -> &super::startup::ChipInfo {
61 match self.request_type {
62 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(ref v)) => v,
63 _ => <super::startup::ChipInfo as ::protobuf::Message>::default_instance(),
64 }
65 }
clear_initial_info(&mut self)66 pub fn clear_initial_info(&mut self) {
67 self.request_type = ::std::option::Option::None;
68 }
69
has_initial_info(&self) -> bool70 pub fn has_initial_info(&self) -> bool {
71 match self.request_type {
72 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(..)) => true,
73 _ => false,
74 }
75 }
76
77 // Param is passed by value, moved
set_initial_info(&mut self, v: super::startup::ChipInfo)78 pub fn set_initial_info(&mut self, v: super::startup::ChipInfo) {
79 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(v))
80 }
81
82 // Mutable pointer to the field.
mut_initial_info(&mut self) -> &mut super::startup::ChipInfo83 pub fn mut_initial_info(&mut self) -> &mut super::startup::ChipInfo {
84 if let ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(_)) = self.request_type {
85 } else {
86 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(super::startup::ChipInfo::new()));
87 }
88 match self.request_type {
89 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(ref mut v)) => v,
90 _ => panic!(),
91 }
92 }
93
94 // Take field
take_initial_info(&mut self) -> super::startup::ChipInfo95 pub fn take_initial_info(&mut self) -> super::startup::ChipInfo {
96 if self.has_initial_info() {
97 match self.request_type.take() {
98 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(v)) => v,
99 _ => panic!(),
100 }
101 } else {
102 super::startup::ChipInfo::new()
103 }
104 }
105
106 // .netsim.packet.HCIPacket hci_packet = 2;
107
108
get_hci_packet(&self) -> &super::hci_packet::HCIPacket109 pub fn get_hci_packet(&self) -> &super::hci_packet::HCIPacket {
110 match self.request_type {
111 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(ref v)) => v,
112 _ => <super::hci_packet::HCIPacket as ::protobuf::Message>::default_instance(),
113 }
114 }
clear_hci_packet(&mut self)115 pub fn clear_hci_packet(&mut self) {
116 self.request_type = ::std::option::Option::None;
117 }
118
has_hci_packet(&self) -> bool119 pub fn has_hci_packet(&self) -> bool {
120 match self.request_type {
121 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(..)) => true,
122 _ => false,
123 }
124 }
125
126 // Param is passed by value, moved
set_hci_packet(&mut self, v: super::hci_packet::HCIPacket)127 pub fn set_hci_packet(&mut self, v: super::hci_packet::HCIPacket) {
128 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(v))
129 }
130
131 // Mutable pointer to the field.
mut_hci_packet(&mut self) -> &mut super::hci_packet::HCIPacket132 pub fn mut_hci_packet(&mut self) -> &mut super::hci_packet::HCIPacket {
133 if let ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(_)) = self.request_type {
134 } else {
135 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(super::hci_packet::HCIPacket::new()));
136 }
137 match self.request_type {
138 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(ref mut v)) => v,
139 _ => panic!(),
140 }
141 }
142
143 // Take field
take_hci_packet(&mut self) -> super::hci_packet::HCIPacket144 pub fn take_hci_packet(&mut self) -> super::hci_packet::HCIPacket {
145 if self.has_hci_packet() {
146 match self.request_type.take() {
147 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(v)) => v,
148 _ => panic!(),
149 }
150 } else {
151 super::hci_packet::HCIPacket::new()
152 }
153 }
154
155 // bytes packet = 3;
156
157
get_packet(&self) -> &[u8]158 pub fn get_packet(&self) -> &[u8] {
159 match self.request_type {
160 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(ref v)) => v,
161 _ => &[],
162 }
163 }
clear_packet(&mut self)164 pub fn clear_packet(&mut self) {
165 self.request_type = ::std::option::Option::None;
166 }
167
has_packet(&self) -> bool168 pub fn has_packet(&self) -> bool {
169 match self.request_type {
170 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(..)) => true,
171 _ => false,
172 }
173 }
174
175 // Param is passed by value, moved
set_packet(&mut self, v: ::std::vec::Vec<u8>)176 pub fn set_packet(&mut self, v: ::std::vec::Vec<u8>) {
177 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(v))
178 }
179
180 // Mutable pointer to the field.
mut_packet(&mut self) -> &mut ::std::vec::Vec<u8>181 pub fn mut_packet(&mut self) -> &mut ::std::vec::Vec<u8> {
182 if let ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(_)) = self.request_type {
183 } else {
184 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(::std::vec::Vec::new()));
185 }
186 match self.request_type {
187 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(ref mut v)) => v,
188 _ => panic!(),
189 }
190 }
191
192 // Take field
take_packet(&mut self) -> ::std::vec::Vec<u8>193 pub fn take_packet(&mut self) -> ::std::vec::Vec<u8> {
194 if self.has_packet() {
195 match self.request_type.take() {
196 ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(v)) => v,
197 _ => panic!(),
198 }
199 } else {
200 ::std::vec::Vec::new()
201 }
202 }
203 }
204
205 impl ::protobuf::Message for StreamPacketsRequest {
is_initialized(&self) -> bool206 fn is_initialized(&self) -> bool {
207 if let Some(StreamPacketsRequest_oneof_request_type::initial_info(ref v)) = self.request_type {
208 if !v.is_initialized() {
209 return false;
210 }
211 }
212 if let Some(StreamPacketsRequest_oneof_request_type::hci_packet(ref v)) = self.request_type {
213 if !v.is_initialized() {
214 return false;
215 }
216 }
217 true
218 }
219
merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()>220 fn merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()> {
221 while !is.eof()? {
222 let (field_number, wire_type) = is.read_tag_unpack()?;
223 match field_number {
224 1 => {
225 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
226 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
227 }
228 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::initial_info(is.read_message()?));
229 },
230 2 => {
231 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
232 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
233 }
234 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::hci_packet(is.read_message()?));
235 },
236 3 => {
237 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
238 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
239 }
240 self.request_type = ::std::option::Option::Some(StreamPacketsRequest_oneof_request_type::packet(is.read_bytes()?));
241 },
242 _ => {
243 ::protobuf::rt::read_unknown_or_skip_group(field_number, wire_type, is, self.mut_unknown_fields())?;
244 },
245 };
246 }
247 ::std::result::Result::Ok(())
248 }
249
250 // Compute sizes of nested messages
251 #[allow(unused_variables)]
compute_size(&self) -> u32252 fn compute_size(&self) -> u32 {
253 let mut my_size = 0;
254 if let ::std::option::Option::Some(ref v) = self.request_type {
255 match v {
256 &StreamPacketsRequest_oneof_request_type::initial_info(ref v) => {
257 let len = v.compute_size();
258 my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
259 },
260 &StreamPacketsRequest_oneof_request_type::hci_packet(ref v) => {
261 let len = v.compute_size();
262 my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
263 },
264 &StreamPacketsRequest_oneof_request_type::packet(ref v) => {
265 my_size += ::protobuf::rt::bytes_size(3, &v);
266 },
267 };
268 }
269 my_size += ::protobuf::rt::unknown_fields_size(self.get_unknown_fields());
270 self.cached_size.set(my_size);
271 my_size
272 }
273
write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()>274 fn write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()> {
275 if let ::std::option::Option::Some(ref v) = self.request_type {
276 match v {
277 &StreamPacketsRequest_oneof_request_type::initial_info(ref v) => {
278 os.write_tag(1, ::protobuf::wire_format::WireTypeLengthDelimited)?;
279 os.write_raw_varint32(v.get_cached_size())?;
280 v.write_to_with_cached_sizes(os)?;
281 },
282 &StreamPacketsRequest_oneof_request_type::hci_packet(ref v) => {
283 os.write_tag(2, ::protobuf::wire_format::WireTypeLengthDelimited)?;
284 os.write_raw_varint32(v.get_cached_size())?;
285 v.write_to_with_cached_sizes(os)?;
286 },
287 &StreamPacketsRequest_oneof_request_type::packet(ref v) => {
288 os.write_bytes(3, v)?;
289 },
290 };
291 }
292 os.write_unknown_fields(self.get_unknown_fields())?;
293 ::std::result::Result::Ok(())
294 }
295
get_cached_size(&self) -> u32296 fn get_cached_size(&self) -> u32 {
297 self.cached_size.get()
298 }
299
get_unknown_fields(&self) -> &::protobuf::UnknownFields300 fn get_unknown_fields(&self) -> &::protobuf::UnknownFields {
301 &self.unknown_fields
302 }
303
mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields304 fn mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields {
305 &mut self.unknown_fields
306 }
307
as_any(&self) -> &dyn (::std::any::Any)308 fn as_any(&self) -> &dyn (::std::any::Any) {
309 self as &dyn (::std::any::Any)
310 }
as_any_mut(&mut self) -> &mut dyn (::std::any::Any)311 fn as_any_mut(&mut self) -> &mut dyn (::std::any::Any) {
312 self as &mut dyn (::std::any::Any)
313 }
into_any(self: ::std::boxed::Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)>314 fn into_any(self: ::std::boxed::Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)> {
315 self
316 }
317
descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor318 fn descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor {
319 Self::descriptor_static()
320 }
321
new() -> StreamPacketsRequest322 fn new() -> StreamPacketsRequest {
323 StreamPacketsRequest::new()
324 }
325
descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor326 fn descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor {
327 static descriptor: ::protobuf::rt::LazyV2<::protobuf::reflect::MessageDescriptor> = ::protobuf::rt::LazyV2::INIT;
328 descriptor.get(|| {
329 let mut fields = ::std::vec::Vec::new();
330 fields.push(::protobuf::reflect::accessor::make_singular_message_accessor::<_, super::startup::ChipInfo>(
331 "initial_info",
332 StreamPacketsRequest::has_initial_info,
333 StreamPacketsRequest::get_initial_info,
334 ));
335 fields.push(::protobuf::reflect::accessor::make_singular_message_accessor::<_, super::hci_packet::HCIPacket>(
336 "hci_packet",
337 StreamPacketsRequest::has_hci_packet,
338 StreamPacketsRequest::get_hci_packet,
339 ));
340 fields.push(::protobuf::reflect::accessor::make_singular_bytes_accessor::<_>(
341 "packet",
342 StreamPacketsRequest::has_packet,
343 StreamPacketsRequest::get_packet,
344 ));
345 ::protobuf::reflect::MessageDescriptor::new_pb_name::<StreamPacketsRequest>(
346 "StreamPacketsRequest",
347 fields,
348 file_descriptor_proto()
349 )
350 })
351 }
352
default_instance() -> &'static StreamPacketsRequest353 fn default_instance() -> &'static StreamPacketsRequest {
354 static instance: ::protobuf::rt::LazyV2<StreamPacketsRequest> = ::protobuf::rt::LazyV2::INIT;
355 instance.get(StreamPacketsRequest::new)
356 }
357 }
358
359 impl ::protobuf::Clear for StreamPacketsRequest {
clear(&mut self)360 fn clear(&mut self) {
361 self.request_type = ::std::option::Option::None;
362 self.request_type = ::std::option::Option::None;
363 self.request_type = ::std::option::Option::None;
364 self.unknown_fields.clear();
365 }
366 }
367
368 impl ::std::fmt::Debug for StreamPacketsRequest {
fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result369 fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
370 ::protobuf::text_format::fmt(self, f)
371 }
372 }
373
374 impl ::protobuf::reflect::ProtobufValue for StreamPacketsRequest {
as_ref(&self) -> ::protobuf::reflect::ReflectValueRef375 fn as_ref(&self) -> ::protobuf::reflect::ReflectValueRef {
376 ::protobuf::reflect::ReflectValueRef::Message(self)
377 }
378 }
379
380 #[derive(PartialEq,Clone,Default)]
381 #[cfg_attr(feature = "with-serde", derive(::serde::Serialize, ::serde::Deserialize))]
382 pub struct StreamPacketsResponse {
383 // message oneof groups
384 pub response_type: ::std::option::Option<StreamPacketsResponse_oneof_response_type>,
385 // special fields
386 #[cfg_attr(feature = "with-serde", serde(skip))]
387 pub unknown_fields: ::protobuf::UnknownFields,
388 #[cfg_attr(feature = "with-serde", serde(skip))]
389 pub cached_size: ::protobuf::CachedSize,
390 }
391
392 impl<'a> ::std::default::Default for &'a StreamPacketsResponse {
default() -> &'a StreamPacketsResponse393 fn default() -> &'a StreamPacketsResponse {
394 <StreamPacketsResponse as ::protobuf::Message>::default_instance()
395 }
396 }
397
398 #[derive(Clone,PartialEq,Debug)]
399 #[cfg_attr(feature = "with-serde", derive(::serde::Serialize, ::serde::Deserialize))]
400 pub enum StreamPacketsResponse_oneof_response_type {
401 error(::std::string::String),
402 hci_packet(super::hci_packet::HCIPacket),
403 packet(::std::vec::Vec<u8>),
404 }
405
406 impl StreamPacketsResponse {
new() -> StreamPacketsResponse407 pub fn new() -> StreamPacketsResponse {
408 ::std::default::Default::default()
409 }
410
411 // string error = 1;
412
413
get_error(&self) -> &str414 pub fn get_error(&self) -> &str {
415 match self.response_type {
416 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(ref v)) => v,
417 _ => "",
418 }
419 }
clear_error(&mut self)420 pub fn clear_error(&mut self) {
421 self.response_type = ::std::option::Option::None;
422 }
423
has_error(&self) -> bool424 pub fn has_error(&self) -> bool {
425 match self.response_type {
426 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(..)) => true,
427 _ => false,
428 }
429 }
430
431 // Param is passed by value, moved
set_error(&mut self, v: ::std::string::String)432 pub fn set_error(&mut self, v: ::std::string::String) {
433 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(v))
434 }
435
436 // Mutable pointer to the field.
mut_error(&mut self) -> &mut ::std::string::String437 pub fn mut_error(&mut self) -> &mut ::std::string::String {
438 if let ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(_)) = self.response_type {
439 } else {
440 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(::std::string::String::new()));
441 }
442 match self.response_type {
443 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(ref mut v)) => v,
444 _ => panic!(),
445 }
446 }
447
448 // Take field
take_error(&mut self) -> ::std::string::String449 pub fn take_error(&mut self) -> ::std::string::String {
450 if self.has_error() {
451 match self.response_type.take() {
452 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(v)) => v,
453 _ => panic!(),
454 }
455 } else {
456 ::std::string::String::new()
457 }
458 }
459
460 // .netsim.packet.HCIPacket hci_packet = 2;
461
462
get_hci_packet(&self) -> &super::hci_packet::HCIPacket463 pub fn get_hci_packet(&self) -> &super::hci_packet::HCIPacket {
464 match self.response_type {
465 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(ref v)) => v,
466 _ => <super::hci_packet::HCIPacket as ::protobuf::Message>::default_instance(),
467 }
468 }
clear_hci_packet(&mut self)469 pub fn clear_hci_packet(&mut self) {
470 self.response_type = ::std::option::Option::None;
471 }
472
has_hci_packet(&self) -> bool473 pub fn has_hci_packet(&self) -> bool {
474 match self.response_type {
475 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(..)) => true,
476 _ => false,
477 }
478 }
479
480 // Param is passed by value, moved
set_hci_packet(&mut self, v: super::hci_packet::HCIPacket)481 pub fn set_hci_packet(&mut self, v: super::hci_packet::HCIPacket) {
482 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(v))
483 }
484
485 // Mutable pointer to the field.
mut_hci_packet(&mut self) -> &mut super::hci_packet::HCIPacket486 pub fn mut_hci_packet(&mut self) -> &mut super::hci_packet::HCIPacket {
487 if let ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(_)) = self.response_type {
488 } else {
489 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(super::hci_packet::HCIPacket::new()));
490 }
491 match self.response_type {
492 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(ref mut v)) => v,
493 _ => panic!(),
494 }
495 }
496
497 // Take field
take_hci_packet(&mut self) -> super::hci_packet::HCIPacket498 pub fn take_hci_packet(&mut self) -> super::hci_packet::HCIPacket {
499 if self.has_hci_packet() {
500 match self.response_type.take() {
501 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(v)) => v,
502 _ => panic!(),
503 }
504 } else {
505 super::hci_packet::HCIPacket::new()
506 }
507 }
508
509 // bytes packet = 3;
510
511
get_packet(&self) -> &[u8]512 pub fn get_packet(&self) -> &[u8] {
513 match self.response_type {
514 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(ref v)) => v,
515 _ => &[],
516 }
517 }
clear_packet(&mut self)518 pub fn clear_packet(&mut self) {
519 self.response_type = ::std::option::Option::None;
520 }
521
has_packet(&self) -> bool522 pub fn has_packet(&self) -> bool {
523 match self.response_type {
524 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(..)) => true,
525 _ => false,
526 }
527 }
528
529 // Param is passed by value, moved
set_packet(&mut self, v: ::std::vec::Vec<u8>)530 pub fn set_packet(&mut self, v: ::std::vec::Vec<u8>) {
531 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(v))
532 }
533
534 // Mutable pointer to the field.
mut_packet(&mut self) -> &mut ::std::vec::Vec<u8>535 pub fn mut_packet(&mut self) -> &mut ::std::vec::Vec<u8> {
536 if let ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(_)) = self.response_type {
537 } else {
538 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(::std::vec::Vec::new()));
539 }
540 match self.response_type {
541 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(ref mut v)) => v,
542 _ => panic!(),
543 }
544 }
545
546 // Take field
take_packet(&mut self) -> ::std::vec::Vec<u8>547 pub fn take_packet(&mut self) -> ::std::vec::Vec<u8> {
548 if self.has_packet() {
549 match self.response_type.take() {
550 ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(v)) => v,
551 _ => panic!(),
552 }
553 } else {
554 ::std::vec::Vec::new()
555 }
556 }
557 }
558
559 impl ::protobuf::Message for StreamPacketsResponse {
is_initialized(&self) -> bool560 fn is_initialized(&self) -> bool {
561 if let Some(StreamPacketsResponse_oneof_response_type::hci_packet(ref v)) = self.response_type {
562 if !v.is_initialized() {
563 return false;
564 }
565 }
566 true
567 }
568
merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()>569 fn merge_from(&mut self, is: &mut ::protobuf::CodedInputStream<'_>) -> ::protobuf::ProtobufResult<()> {
570 while !is.eof()? {
571 let (field_number, wire_type) = is.read_tag_unpack()?;
572 match field_number {
573 1 => {
574 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
575 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
576 }
577 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::error(is.read_string()?));
578 },
579 2 => {
580 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
581 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
582 }
583 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::hci_packet(is.read_message()?));
584 },
585 3 => {
586 if wire_type != ::protobuf::wire_format::WireTypeLengthDelimited {
587 return ::std::result::Result::Err(::protobuf::rt::unexpected_wire_type(wire_type));
588 }
589 self.response_type = ::std::option::Option::Some(StreamPacketsResponse_oneof_response_type::packet(is.read_bytes()?));
590 },
591 _ => {
592 ::protobuf::rt::read_unknown_or_skip_group(field_number, wire_type, is, self.mut_unknown_fields())?;
593 },
594 };
595 }
596 ::std::result::Result::Ok(())
597 }
598
599 // Compute sizes of nested messages
600 #[allow(unused_variables)]
compute_size(&self) -> u32601 fn compute_size(&self) -> u32 {
602 let mut my_size = 0;
603 if let ::std::option::Option::Some(ref v) = self.response_type {
604 match v {
605 &StreamPacketsResponse_oneof_response_type::error(ref v) => {
606 my_size += ::protobuf::rt::string_size(1, &v);
607 },
608 &StreamPacketsResponse_oneof_response_type::hci_packet(ref v) => {
609 let len = v.compute_size();
610 my_size += 1 + ::protobuf::rt::compute_raw_varint32_size(len) + len;
611 },
612 &StreamPacketsResponse_oneof_response_type::packet(ref v) => {
613 my_size += ::protobuf::rt::bytes_size(3, &v);
614 },
615 };
616 }
617 my_size += ::protobuf::rt::unknown_fields_size(self.get_unknown_fields());
618 self.cached_size.set(my_size);
619 my_size
620 }
621
write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()>622 fn write_to_with_cached_sizes(&self, os: &mut ::protobuf::CodedOutputStream<'_>) -> ::protobuf::ProtobufResult<()> {
623 if let ::std::option::Option::Some(ref v) = self.response_type {
624 match v {
625 &StreamPacketsResponse_oneof_response_type::error(ref v) => {
626 os.write_string(1, v)?;
627 },
628 &StreamPacketsResponse_oneof_response_type::hci_packet(ref v) => {
629 os.write_tag(2, ::protobuf::wire_format::WireTypeLengthDelimited)?;
630 os.write_raw_varint32(v.get_cached_size())?;
631 v.write_to_with_cached_sizes(os)?;
632 },
633 &StreamPacketsResponse_oneof_response_type::packet(ref v) => {
634 os.write_bytes(3, v)?;
635 },
636 };
637 }
638 os.write_unknown_fields(self.get_unknown_fields())?;
639 ::std::result::Result::Ok(())
640 }
641
get_cached_size(&self) -> u32642 fn get_cached_size(&self) -> u32 {
643 self.cached_size.get()
644 }
645
get_unknown_fields(&self) -> &::protobuf::UnknownFields646 fn get_unknown_fields(&self) -> &::protobuf::UnknownFields {
647 &self.unknown_fields
648 }
649
mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields650 fn mut_unknown_fields(&mut self) -> &mut ::protobuf::UnknownFields {
651 &mut self.unknown_fields
652 }
653
as_any(&self) -> &dyn (::std::any::Any)654 fn as_any(&self) -> &dyn (::std::any::Any) {
655 self as &dyn (::std::any::Any)
656 }
as_any_mut(&mut self) -> &mut dyn (::std::any::Any)657 fn as_any_mut(&mut self) -> &mut dyn (::std::any::Any) {
658 self as &mut dyn (::std::any::Any)
659 }
into_any(self: ::std::boxed::Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)>660 fn into_any(self: ::std::boxed::Box<Self>) -> ::std::boxed::Box<dyn (::std::any::Any)> {
661 self
662 }
663
descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor664 fn descriptor(&self) -> &'static ::protobuf::reflect::MessageDescriptor {
665 Self::descriptor_static()
666 }
667
new() -> StreamPacketsResponse668 fn new() -> StreamPacketsResponse {
669 StreamPacketsResponse::new()
670 }
671
descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor672 fn descriptor_static() -> &'static ::protobuf::reflect::MessageDescriptor {
673 static descriptor: ::protobuf::rt::LazyV2<::protobuf::reflect::MessageDescriptor> = ::protobuf::rt::LazyV2::INIT;
674 descriptor.get(|| {
675 let mut fields = ::std::vec::Vec::new();
676 fields.push(::protobuf::reflect::accessor::make_singular_string_accessor::<_>(
677 "error",
678 StreamPacketsResponse::has_error,
679 StreamPacketsResponse::get_error,
680 ));
681 fields.push(::protobuf::reflect::accessor::make_singular_message_accessor::<_, super::hci_packet::HCIPacket>(
682 "hci_packet",
683 StreamPacketsResponse::has_hci_packet,
684 StreamPacketsResponse::get_hci_packet,
685 ));
686 fields.push(::protobuf::reflect::accessor::make_singular_bytes_accessor::<_>(
687 "packet",
688 StreamPacketsResponse::has_packet,
689 StreamPacketsResponse::get_packet,
690 ));
691 ::protobuf::reflect::MessageDescriptor::new_pb_name::<StreamPacketsResponse>(
692 "StreamPacketsResponse",
693 fields,
694 file_descriptor_proto()
695 )
696 })
697 }
698
default_instance() -> &'static StreamPacketsResponse699 fn default_instance() -> &'static StreamPacketsResponse {
700 static instance: ::protobuf::rt::LazyV2<StreamPacketsResponse> = ::protobuf::rt::LazyV2::INIT;
701 instance.get(StreamPacketsResponse::new)
702 }
703 }
704
705 impl ::protobuf::Clear for StreamPacketsResponse {
clear(&mut self)706 fn clear(&mut self) {
707 self.response_type = ::std::option::Option::None;
708 self.response_type = ::std::option::Option::None;
709 self.response_type = ::std::option::Option::None;
710 self.unknown_fields.clear();
711 }
712 }
713
714 impl ::std::fmt::Debug for StreamPacketsResponse {
fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result715 fn fmt(&self, f: &mut ::std::fmt::Formatter<'_>) -> ::std::fmt::Result {
716 ::protobuf::text_format::fmt(self, f)
717 }
718 }
719
720 impl ::protobuf::reflect::ProtobufValue for StreamPacketsResponse {
as_ref(&self) -> ::protobuf::reflect::ReflectValueRef721 fn as_ref(&self) -> ::protobuf::reflect::ReflectValueRef {
722 ::protobuf::reflect::ReflectValueRef::Message(self)
723 }
724 }
725
726 static file_descriptor_proto_data: &'static [u8] = b"\
727 \n\x15packet_streamer.proto\x12\rnetsim.packet\x1a\x10hci_packet.proto\
728 \x1a\rstartup.proto\"\xba\x01\n\x14StreamPacketsRequest\x12=\n\x0cinitia\
729 l_info\x18\x01\x20\x01(\x0b2\x18.netsim.startup.ChipInfoH\0R\x0binitialI\
730 nfo\x129\n\nhci_packet\x18\x02\x20\x01(\x0b2\x18.netsim.packet.HCIPacket\
731 H\0R\thciPacket\x12\x18\n\x06packet\x18\x03\x20\x01(\x0cH\0R\x06packetB\
732 \x0e\n\x0crequest_type\"\x95\x01\n\x15StreamPacketsResponse\x12\x16\n\
733 \x05error\x18\x01\x20\x01(\tH\0R\x05error\x129\n\nhci_packet\x18\x02\x20\
734 \x01(\x0b2\x18.netsim.packet.HCIPacketH\0R\thciPacket\x12\x18\n\x06packe\
735 t\x18\x03\x20\x01(\x0cH\0R\x06packetB\x0f\n\rresponse_type2p\n\x0ePacket\
736 Streamer\x12^\n\rStreamPackets\x12#.netsim.packet.StreamPacketsRequest\
737 \x1a$.netsim.packet.StreamPacketsResponse(\x010\x01b\x06proto3\
738 ";
739
740 static file_descriptor_proto_lazy: ::protobuf::rt::LazyV2<::protobuf::descriptor::FileDescriptorProto> = ::protobuf::rt::LazyV2::INIT;
741
parse_descriptor_proto() -> ::protobuf::descriptor::FileDescriptorProto742 fn parse_descriptor_proto() -> ::protobuf::descriptor::FileDescriptorProto {
743 ::protobuf::Message::parse_from_bytes(file_descriptor_proto_data).unwrap()
744 }
745
file_descriptor_proto() -> &'static ::protobuf::descriptor::FileDescriptorProto746 pub fn file_descriptor_proto() -> &'static ::protobuf::descriptor::FileDescriptorProto {
747 file_descriptor_proto_lazy.get(|| {
748 parse_descriptor_proto()
749 })
750 }
751