@@ -96,6 +96,7 @@ const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_firestore_2flocal_2ftarget_2ep
96
96
PROTOBUF_FIELD_OFFSET (::firestore::client::Target, last_listen_sequence_number_),
97
97
offsetof (::firestore::client::TargetDefaultTypeInternal, query_),
98
98
offsetof (::firestore::client::TargetDefaultTypeInternal, documents_),
99
+ PROTOBUF_FIELD_OFFSET (::firestore::client::Target, last_limbo_free_snapshot_version_),
99
100
PROTOBUF_FIELD_OFFSET (::firestore::client::Target, target_type_),
100
101
~0u , // no _has_bits_
101
102
PROTOBUF_FIELD_OFFSET (::firestore::client::TargetGlobal, _internal_metadata_),
@@ -109,7 +110,7 @@ const ::PROTOBUF_NAMESPACE_ID::uint32 TableStruct_firestore_2flocal_2ftarget_2ep
109
110
};
110
111
static const ::PROTOBUF_NAMESPACE_ID::internal::MigrationSchema schemas[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) = {
111
112
{ 0 , -1 , sizeof (::firestore::client::Target)},
112
- { 12 , -1 , sizeof (::firestore::client::TargetGlobal)},
113
+ { 13 , -1 , sizeof (::firestore::client::TargetGlobal)},
113
114
};
114
115
115
116
static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] = {
@@ -120,20 +121,22 @@ static ::PROTOBUF_NAMESPACE_ID::Message const * const file_default_instances[] =
120
121
const char descriptor_table_protodef_firestore_2flocal_2ftarget_2eproto[] PROTOBUF_SECTION_VARIABLE(protodesc_cold) =
121
122
" \n\034 firestore/local/target.proto\022\020 firestor"
122
123
" e.client\032 #google/firestore/v1/firestore."
123
- " proto\032\037 google/protobuf/timestamp.proto\"\227 "
124
+ " proto\032\037 google/protobuf/timestamp.proto\"\335 "
124
125
" \002\n\006 Target\022\021\n\t target_id\030\001 \001 (\005\022 4\n\020 snapshot"
125
126
" _version\030\002 \001 (\013 2\032 .google.protobuf.Timesta"
126
127
" mp\022\024\n\014 resume_token\030\003 \001 (\014\022 #\n\033 last_listen_"
127
128
" sequence_number\030\004 \001 (\003\022 8\n\005 query\030\005 \001 (\013 2\' .g"
128
129
" oogle.firestore.v1.Target.QueryTargetH\000\022 "
129
130
" @\n\t documents\030\006 \001 (\013 2+.google.firestore.v1"
130
- " .Target.DocumentsTargetH\000 B\r\n\013 target_type"
131
- " \"\251\001\n\014 TargetGlobal\022\031\n\021 highest_target_id\030\001 "
132
- " \001 (\005\022 &\n\036 highest_listen_sequence_number\030\002 "
133
- " \001 (\003\022 @\n\034 last_remote_snapshot_version\030\003 \001 "
134
- " (\013 2\032 .google.protobuf.Timestamp\022\024\n\014 target"
135
- " _count\030\004 \001 (\005 B/\n #com.google.firebase.fire"
136
- " store.protoP\001\242\002\005 FSTPBb\006 proto3"
131
+ " .Target.DocumentsTargetH\000\022 D\n last_limbo_"
132
+ " free_snapshot_version\030\007 \001 (\013 2\032 .google.pro"
133
+ " tobuf.TimestampB\r\n\013 target_type\"\251\001\n\014 Targe"
134
+ " tGlobal\022\031\n\021 highest_target_id\030\001 \001 (\005\022 &\n\036 hi"
135
+ " ghest_listen_sequence_number\030\002 \001 (\003\022 @\n\034 la"
136
+ " st_remote_snapshot_version\030\003 \001 (\013 2\032 .googl"
137
+ " e.protobuf.Timestamp\022\024\n\014 target_count\030\004 \001 "
138
+ " (\005 B/\n #com.google.firebase.firestore.prot"
139
+ " oP\001\242\002\005 FSTPBb\006 proto3"
137
140
;
138
141
static const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable*const descriptor_table_firestore_2flocal_2ftarget_2eproto_deps[2 ] = {
139
142
&::descriptor_table_google_2ffirestore_2fv1_2ffirestore_2eproto,
@@ -146,7 +149,7 @@ static ::PROTOBUF_NAMESPACE_ID::internal::SCCInfoBase*const descriptor_table_fir
146
149
static ::PROTOBUF_NAMESPACE_ID::internal::once_flag descriptor_table_firestore_2flocal_2ftarget_2eproto_once;
147
150
static bool descriptor_table_firestore_2flocal_2ftarget_2eproto_initialized = false ;
148
151
const ::PROTOBUF_NAMESPACE_ID::internal::DescriptorTable descriptor_table_firestore_2flocal_2ftarget_2eproto = {
149
- &descriptor_table_firestore_2flocal_2ftarget_2eproto_initialized, descriptor_table_protodef_firestore_2flocal_2ftarget_2eproto, " firestore/local/target.proto" , 629 ,
152
+ &descriptor_table_firestore_2flocal_2ftarget_2eproto_initialized, descriptor_table_protodef_firestore_2flocal_2ftarget_2eproto, " firestore/local/target.proto" , 699 ,
150
153
&descriptor_table_firestore_2flocal_2ftarget_2eproto_once, descriptor_table_firestore_2flocal_2ftarget_2eproto_sccs, descriptor_table_firestore_2flocal_2ftarget_2eproto_deps, 2 , 2 ,
151
154
schemas, file_default_instances, TableStruct_firestore_2flocal_2ftarget_2eproto::offsets,
152
155
file_level_metadata_firestore_2flocal_2ftarget_2eproto, 2 , file_level_enum_descriptors_firestore_2flocal_2ftarget_2eproto, file_level_service_descriptors_firestore_2flocal_2ftarget_2eproto,
@@ -166,12 +169,15 @@ void Target::InitAsDefaultInstance() {
166
169
::google::firestore::v1::Target_QueryTarget::internal_default_instance ());
167
170
::firestore::client::_Target_default_instance_.documents_ = const_cast < ::google::firestore::v1::Target_DocumentsTarget*>(
168
171
::google::firestore::v1::Target_DocumentsTarget::internal_default_instance ());
172
+ ::firestore::client::_Target_default_instance_._instance .get_mutable ()->last_limbo_free_snapshot_version_ = const_cast < PROTOBUF_NAMESPACE_ID::Timestamp*>(
173
+ PROTOBUF_NAMESPACE_ID::Timestamp::internal_default_instance ());
169
174
}
170
175
class Target ::_Internal {
171
176
public:
172
177
static const PROTOBUF_NAMESPACE_ID::Timestamp& snapshot_version (const Target* msg);
173
178
static const ::google::firestore::v1::Target_QueryTarget& query (const Target* msg);
174
179
static const ::google::firestore::v1::Target_DocumentsTarget& documents (const Target* msg);
180
+ static const PROTOBUF_NAMESPACE_ID::Timestamp& last_limbo_free_snapshot_version (const Target* msg);
175
181
};
176
182
177
183
const PROTOBUF_NAMESPACE_ID::Timestamp&
@@ -186,6 +192,10 @@ const ::google::firestore::v1::Target_DocumentsTarget&
186
192
Target::_Internal::documents (const Target* msg) {
187
193
return *msg->target_type_ .documents_ ;
188
194
}
195
+ const PROTOBUF_NAMESPACE_ID::Timestamp&
196
+ Target::_Internal::last_limbo_free_snapshot_version (const Target* msg) {
197
+ return *msg->last_limbo_free_snapshot_version_ ;
198
+ }
189
199
void Target::clear_snapshot_version () {
190
200
if (GetArenaNoVirtual () == nullptr && snapshot_version_ != nullptr ) {
191
201
delete snapshot_version_;
@@ -232,6 +242,12 @@ void Target::clear_documents() {
232
242
clear_has_target_type ();
233
243
}
234
244
}
245
+ void Target::clear_last_limbo_free_snapshot_version () {
246
+ if (GetArenaNoVirtual () == nullptr && last_limbo_free_snapshot_version_ != nullptr ) {
247
+ delete last_limbo_free_snapshot_version_;
248
+ }
249
+ last_limbo_free_snapshot_version_ = nullptr ;
250
+ }
235
251
Target::Target ()
236
252
: ::PROTOBUF_NAMESPACE_ID::Message(), _internal_metadata_(nullptr ) {
237
253
SharedCtor ();
@@ -250,6 +266,11 @@ Target::Target(const Target& from)
250
266
} else {
251
267
snapshot_version_ = nullptr ;
252
268
}
269
+ if (from.has_last_limbo_free_snapshot_version ()) {
270
+ last_limbo_free_snapshot_version_ = new PROTOBUF_NAMESPACE_ID::Timestamp (*from.last_limbo_free_snapshot_version_ );
271
+ } else {
272
+ last_limbo_free_snapshot_version_ = nullptr ;
273
+ }
253
274
::memcpy (&last_listen_sequence_number_, &from.last_listen_sequence_number_,
254
275
static_cast <size_t >(reinterpret_cast <char *>(&target_id_) -
255
276
reinterpret_cast<char*>(&last_listen_sequence_number_)) + sizeof(target_id_));
@@ -287,6 +308,7 @@ Target::~Target() {
287
308
void Target::SharedDtor () {
288
309
resume_token_.DestroyNoArena (&::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited ());
289
310
if (this != internal_default_instance ()) delete snapshot_version_;
311
+ if (this != internal_default_instance ()) delete last_limbo_free_snapshot_version_;
290
312
if (has_target_type ()) {
291
313
clear_target_type ();
292
314
}
@@ -331,6 +353,10 @@ void Target::Clear() {
331
353
delete snapshot_version_;
332
354
}
333
355
snapshot_version_ = nullptr ;
356
+ if (GetArenaNoVirtual () == nullptr && last_limbo_free_snapshot_version_ != nullptr ) {
357
+ delete last_limbo_free_snapshot_version_;
358
+ }
359
+ last_limbo_free_snapshot_version_ = nullptr ;
334
360
::memset (&last_listen_sequence_number_, 0 , static_cast <size_t >(
335
361
reinterpret_cast <char *>(&target_id_) -
336
362
reinterpret_cast<char*>(&last_listen_sequence_number_)) + sizeof(target_id_));
@@ -388,6 +414,13 @@ const char* Target::_InternalParse(const char* ptr, ::PROTOBUF_NAMESPACE_ID::int
388
414
CHK_ (ptr);
389
415
} else goto handle_unusual;
390
416
continue ;
417
+ // .google.protobuf.Timestamp last_limbo_free_snapshot_version = 7;
418
+ case 7 :
419
+ if (PROTOBUF_PREDICT_TRUE (static_cast <::PROTOBUF_NAMESPACE_ID::uint8>(tag) == 58 )) {
420
+ ptr = ctx->ParseMessage (mutable_last_limbo_free_snapshot_version (), ptr);
421
+ CHK_ (ptr);
422
+ } else goto handle_unusual;
423
+ continue ;
391
424
default : {
392
425
handle_unusual:
393
426
if ((tag & 7 ) == 4 || tag == 0 ) {
@@ -488,6 +521,17 @@ bool Target::MergePartialFromCodedStream(
488
521
break ;
489
522
}
490
523
524
+ // .google.protobuf.Timestamp last_limbo_free_snapshot_version = 7;
525
+ case 7 : {
526
+ if (static_cast < ::PROTOBUF_NAMESPACE_ID::uint8>(tag) == (58 & 0xFF )) {
527
+ DO_ (::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::ReadMessage (
528
+ input, mutable_last_limbo_free_snapshot_version ()));
529
+ } else {
530
+ goto handle_unusual;
531
+ }
532
+ break ;
533
+ }
534
+
491
535
default : {
492
536
handle_unusual:
493
537
if (tag == 0 ) {
@@ -549,6 +593,12 @@ void Target::SerializeWithCachedSizes(
549
593
6 , _Internal::documents(this ), output);
550
594
}
551
595
596
+ // .google.protobuf.Timestamp last_limbo_free_snapshot_version = 7;
597
+ if (this ->has_last_limbo_free_snapshot_version ()) {
598
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::WriteMessageMaybeToArray (
599
+ 7 , _Internal::last_limbo_free_snapshot_version(this ), output);
600
+ }
601
+
552
602
if (_internal_metadata_.have_unknown_fields ()) {
553
603
::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFields (
554
604
_internal_metadata_.unknown_fields(), output);
@@ -600,6 +650,13 @@ ::PROTOBUF_NAMESPACE_ID::uint8* Target::InternalSerializeWithCachedSizesToArray(
600
650
6 , _Internal::documents (this ), target);
601
651
}
602
652
653
+ // .google.protobuf.Timestamp last_limbo_free_snapshot_version = 7;
654
+ if (this ->has_last_limbo_free_snapshot_version ()) {
655
+ target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::
656
+ InternalWriteMessageToArray (
657
+ 7 , _Internal::last_limbo_free_snapshot_version (this ), target);
658
+ }
659
+
603
660
if (_internal_metadata_.have_unknown_fields ()) {
604
661
target = ::PROTOBUF_NAMESPACE_ID::internal::WireFormat::SerializeUnknownFieldsToArray (
605
662
_internal_metadata_.unknown_fields (), target);
@@ -635,6 +692,13 @@ size_t Target::ByteSizeLong() const {
635
692
*snapshot_version_);
636
693
}
637
694
695
+ // .google.protobuf.Timestamp last_limbo_free_snapshot_version = 7;
696
+ if (this ->has_last_limbo_free_snapshot_version ()) {
697
+ total_size += 1 +
698
+ ::PROTOBUF_NAMESPACE_ID::internal::WireFormatLite::MessageSize (
699
+ *last_limbo_free_snapshot_version_);
700
+ }
701
+
638
702
// int64 last_listen_sequence_number = 4;
639
703
if (this ->last_listen_sequence_number () != 0) {
640
704
total_size += 1 +
@@ -702,6 +766,9 @@ void Target::MergeFrom(const Target& from) {
702
766
if (from.has_snapshot_version ()) {
703
767
mutable_snapshot_version ()->PROTOBUF_NAMESPACE_ID ::Timestamp::MergeFrom (from.snapshot_version ());
704
768
}
769
+ if (from.has_last_limbo_free_snapshot_version ()) {
770
+ mutable_last_limbo_free_snapshot_version ()->PROTOBUF_NAMESPACE_ID ::Timestamp::MergeFrom (from.last_limbo_free_snapshot_version ());
771
+ }
705
772
if (from.last_listen_sequence_number () != 0 ) {
706
773
set_last_listen_sequence_number (from.last_listen_sequence_number ());
707
774
}
@@ -747,6 +814,7 @@ void Target::InternalSwap(Target* other) {
747
814
resume_token_.Swap (&other->resume_token_ , &::PROTOBUF_NAMESPACE_ID::internal::GetEmptyStringAlreadyInited (),
748
815
GetArenaNoVirtual ());
749
816
swap (snapshot_version_, other->snapshot_version_ );
817
+ swap (last_limbo_free_snapshot_version_, other->last_limbo_free_snapshot_version_ );
750
818
swap (last_listen_sequence_number_, other->last_listen_sequence_number_ );
751
819
swap (target_id_, other->target_id_ );
752
820
swap (target_type_, other->target_type_ );
0 commit comments