Lines Matching refs:state

344 void FaultInjectionTestEnv::WritableFileClosed(const FileState& state) {  in WritableFileClosed()  argument
346 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileClosed()
347 db_file_state_[state.filename_] = state; in WritableFileClosed()
348 open_files_.erase(state.filename_); in WritableFileClosed()
352 void FaultInjectionTestEnv::WritableFileSynced(const FileState& state) { in WritableFileSynced() argument
354 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileSynced()
355 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileSynced()
356 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileSynced()
358 db_file_state_[state.filename_] = state; in WritableFileSynced()
363 void FaultInjectionTestEnv::WritableFileAppended(const FileState& state) { in WritableFileAppended() argument
365 if (open_files_.find(state.filename_) != open_files_.end()) { in WritableFileAppended()
366 if (db_file_state_.find(state.filename_) == db_file_state_.end()) { in WritableFileAppended()
367 db_file_state_.insert(std::make_pair(state.filename_, state)); in WritableFileAppended()
369 db_file_state_[state.filename_] = state; in WritableFileAppended()
383 const FileState& state = it->second; in DropFileData() local
384 if (!state.IsFullySynced()) { in DropFileData()
385 s = func(target(), state); in DropFileData()
392 return DropFileData([&](Env* env, const FileState& state) { in DropUnsyncedFileData() argument
393 return state.DropUnsyncedData(env); in DropUnsyncedFileData()
398 return DropFileData([&](Env* env, const FileState& state) { in DropRandomUnsyncedFileData() argument
399 return state.DropRandomUnsyncedData(env, rnd); in DropRandomUnsyncedFileData()