Lines Matching refs:query

102   QuerySync* GetSync(QueryTracker::Query* query) {
103 return query->info_.sync;
106 QuerySyncManager::Bucket* GetBucket(QueryTracker::Query* query) {
107 return query->info_.bucket;
123 QueryTracker::Query* query = query_tracker_->CreateQuery(
125 ASSERT_TRUE(query != NULL);
127 EXPECT_EQ(query, query_tracker_->GetQuery(kId1));
128 // Check we get nothing for a non-existent query.
130 // Check we can delete the query.
132 // Check we get nothing for a non-existent query.
142 QueryTracker::Query* query = query_tracker_->CreateQuery(
144 ASSERT_TRUE(query != NULL);
145 EXPECT_TRUE(query->NeverUsed());
146 EXPECT_FALSE(query->Pending());
147 EXPECT_EQ(0, query->token());
148 EXPECT_EQ(0, query->submit_count());
151 query->MarkAsActive();
152 EXPECT_FALSE(query->NeverUsed());
153 EXPECT_FALSE(query->Pending());
154 EXPECT_EQ(0, query->token());
155 EXPECT_EQ(1, query->submit_count());
158 query->MarkAsPending(kToken);
159 EXPECT_FALSE(query->NeverUsed());
160 EXPECT_TRUE(query->Pending());
161 EXPECT_EQ(kToken, query->token());
162 EXPECT_EQ(1, query->submit_count());
165 EXPECT_FALSE(query->CheckResultsAvailable(helper_.get()));
166 EXPECT_FALSE(query->NeverUsed());
167 EXPECT_TRUE(query->Pending());
175 query->MarkAsPending(kToken);
176 EXPECT_TRUE(query->Pending());
179 EXPECT_FALSE(query->CheckResultsAvailable(helper_.get()));
183 EXPECT_FALSE(query->CheckResultsAvailable(helper_.get()));
186 EXPECT_FALSE(query->CheckResultsAvailable(helper_.get()));
191 QuerySync* sync = GetSync(query);
192 sync->process_count = query->submit_count();
196 EXPECT_TRUE(query->CheckResultsAvailable(helper_.get()));
197 EXPECT_EQ(kResult, query->GetResult());
198 EXPECT_FALSE(query->NeverUsed());
199 EXPECT_FALSE(query->Pending());
208 QueryTracker::Query* query = query_tracker_->CreateQuery(
210 ASSERT_TRUE(query != NULL);
212 QuerySyncManager::Bucket* bucket = GetBucket(query);
215 query->MarkAsActive();
216 query->MarkAsPending(kToken);
219 // Check we get nothing for a non-existent query.
226 QuerySync* sync = GetSync(query);
227 sync->process_count = query->submit_count();