Lines Matching refs:cf

220   port::Mutex* GetMutexForKey(int cf, int64_t key) {  in GetMutexForKey()  argument
221 return key_locks_[cf][key >> log2_keys_per_lock_].get(); in GetMutexForKey()
224 void LockColumnFamily(int cf) { in LockColumnFamily() argument
225 for (auto& mutex : key_locks_[cf]) { in LockColumnFamily()
230 void UnlockColumnFamily(int cf) { in UnlockColumnFamily() argument
231 for (auto& mutex : key_locks_[cf]) { in UnlockColumnFamily()
236 std::atomic<uint32_t>& Value(int cf, int64_t key) const { in Value() argument
237 return values_[cf * max_key_ + key]; in Value()
240 void ClearColumnFamily(int cf) { in ClearColumnFamily() argument
241 std::fill(&Value(cf, 0 /* key */), &Value(cf + 1, 0 /* key */), in ClearColumnFamily()
248 void Put(int cf, int64_t key, uint32_t value_base, bool pending) { in Put() argument
253 Value(cf, key).store(pending ? UNKNOWN_SENTINEL : value_base, in Put()
261 uint32_t Get(int cf, int64_t key) const { return Value(cf, key); } in Get() argument
265 bool Delete(int cf, int64_t key, bool pending) { in Delete() argument
266 if (Value(cf, key) == DELETION_SENTINEL) { in Delete()
269 Put(cf, key, DELETION_SENTINEL, pending); in Delete()
275 bool SingleDelete(int cf, int64_t key, bool pending) { in SingleDelete() argument
276 return Delete(cf, key, pending); in SingleDelete()
281 int DeleteRange(int cf, int64_t begin_key, int64_t end_key, bool pending) { in DeleteRange() argument
284 if (Delete(cf, key, pending)) { in DeleteRange()
295 bool Exists(int cf, int64_t key) { in Exists() argument
301 uint32_t expected_value = Value(cf, key).load(); in Exists()