Searched refs:num_server_changes_remaining (Results 1 – 10 of 10) sorted by relevance
109 int64 num_server_changes_remaining, in SyncSessionSnapshot() argument122 num_server_changes_remaining(num_server_changes_remaining), in SyncSessionSnapshot()147 static_cast<int>(num_server_changes_remaining)); in ToValue()349 num_server_changes_remaining(dirty_flag, 0), in AllModelTypeState()
115 int64 num_server_changes_remaining,133 const int64 num_server_changes_remaining; member290 DirtyOnWrite<int64> num_server_changes_remaining; member
112 int64 num_server_changes_remaining() const { in num_server_changes_remaining() function113 return shared_.num_server_changes_remaining.value(); in num_server_changes_remaining()
92 if (shared_.num_server_changes_remaining.value() != changes_remaining) in set_num_server_changes_remaining()93 *(shared_.num_server_changes_remaining.mutate()) = changes_remaining; in set_num_server_changes_remaining()
41 ASSERT_EQ(0U, session->status_controller()->num_server_changes_remaining()); in SimulateSuccess()
128 EXPECT_EQ(13, status.num_server_changes_remaining()); in TEST_F()216 status.num_server_changes_remaining(); in TEST_F()
81 status_controller_->num_server_changes_remaining(), in TakeSnapshot()
68 status.updates_available += snapshot->num_server_changes_remaining; in CalcSyncing()
398 if (status->num_server_changes_remaining() > 0) { in LogAndSignalIfConflictStuck()
617 old_job.session->status_controller()->num_server_changes_remaining() > 0 in ScheduleNextSync()