Lines Matching refs:s
91 Status s; in DBGet() local
107 s = txn->GetForUpdate(read_options, key, &value); in DBGet()
109 s = txn->Get(read_options, key, &value); in DBGet()
112 s = db->Get(read_options, key, &value); in DBGet()
115 if (s.ok()) { in DBGet()
121 s = Status::Corruption(); in DBGet()
123 } else if (s.IsNotFound()) { in DBGet()
126 s = Status::OK(); in DBGet()
128 return s; in DBGet()
133 Status s; in DoInsert() local
150 s = DBGet(db, txn, read_options_, set_i, rand_key, get_for_update, in DoInsert()
153 if (!s.ok()) { in DoInsert()
156 if (is_optimistic || !(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
158 s.ToString().c_str()); in DoInsert()
164 if (s.ok()) { in DoInsert()
168 s = txn->Put(key, sum); in DoInsert()
169 if (!get_for_update && (s.IsBusy() || s.IsTimedOut())) { in DoInsert()
173 } else if (!s.ok()) { in DoInsert()
176 s.ToString().c_str()); in DoInsert()
188 txn->GetName().c_str(), s.ToString().c_str(), in DoInsert()
194 if (s.ok()) { in DoInsert()
199 s = txn->Prepare(); in DoInsert()
200 assert(s.ok()); in DoInsert()
203 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()
207 s = txn_->GetCommitTimeWriteBatch()->Put("cat", "dog"); in DoInsert()
208 assert(s.ok()); in DoInsert()
214 s = txn->Commit(); in DoInsert()
215 assert(!with_prepare || s.ok()); in DoInsert()
218 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()
221 s = txn->Rollback(); in DoInsert()
224 txn->GetName().c_str(), s.ToString().c_str()); in DoInsert()
225 assert(s.ok()); in DoInsert()
227 assert(is_optimistic || s.ok()); in DoInsert()
229 if (!s.ok()) { in DoInsert()
233 if (!(s.IsBusy() || s.IsTimedOut() || s.IsTryAgain())) { in DoInsert()
240 if (!s.IsExpired()) { in DoInsert()
247 s.ToString().c_str()); in DoInsert()
251 s = db->Write(write_options_, &batch); in DoInsert()
252 if (!s.ok()) { in DoInsert()
255 s.ToString().c_str()); in DoInsert()
262 s.ToString().c_str(), txn->GetName().c_str()); in DoInsert()
266 if (s.ok()) { in DoInsert()
272 last_status_ = s; in DoInsert()
321 Status s = DBGet(db, nullptr, roptions, set_i, k, FOR_UPDATE, in Verify() local
323 assert(s.ok()); in Verify()