| /system/core/trusty/storage/proxy/ |
| D | storage.h | 22 struct watcher;
33 struct watcher* watcher);
36 struct watcher* watcher);
39 struct watcher* watcher);
42 struct watcher* watcher);
45 struct watcher* watcher);
48 struct watcher* watcher);
51 struct watcher* watcher);
54 struct watcher* watcher);
59 int storage_sync_checkpoint(struct watcher* watcher);
|
| D | watchdog.cpp | 27 struct watcher { struct
28 watcher(const char* id, const struct storage_msg* request);
47 watcher::watcher(const char* id, const struct storage_msg* request) in watcher() function in watcher
57 void watcher::SetState(const char* new_state) { in SetState()
62 void watcher::LogTimeout() { in LogTimeout()
76 void watcher::LogFinished() { in LogFinished()
82 std::chrono::milliseconds watcher::Elapsed(watcher::clock::time_point end) { in Elapsed()
96 struct watcher* RegisterWatch(const char* id, const struct storage_msg* request);
97 void AddProgress(struct watcher* watcher, const char* state);
98 void UnRegisterWatch(struct watcher* watcher);
[all …]
|
| D | watchdog.h | 25 struct watcher;
36 struct watcher* watch_start(const char* id, const struct storage_msg* request);
45 void watch_progress(struct watcher* watcher, const char* state);
55 void watch_finish(struct watcher* watcher);
|
| D | storage.c | 275 struct watcher* watcher) { in storage_file_delete() argument
301 watch_progress(watcher, "unlinking file"); in storage_file_delete()
325 static void sync_parent(const char* path, struct watcher* watcher) { in sync_parent() argument
327 watch_progress(watcher, "syncing parent"); in sync_parent()
337 watch_progress(watcher, "done syncing parent"); in sync_parent()
402 struct watcher* watcher) { in storage_file_open() argument
465 sync_parent(parent_path, watcher); in storage_file_open()
510 sync_parent(path, watcher); in storage_file_open()
541 struct watcher* watcher) { in storage_file_close() argument
554 watch_progress(watcher, "fsyncing before file close"); in storage_file_close()
[all …]
|
| D | proxy.c | 126 struct watcher* watcher = watch_start("request", msg); in handle_req() local
140 rc = storage_sync_checkpoint(watcher); in handle_req()
164 rc = storage_file_delete(msg, req, req_len, watcher); in handle_req()
168 rc = storage_file_open(msg, req, req_len, watcher); in handle_req()
172 rc = storage_file_close(msg, req, req_len, watcher); in handle_req()
176 rc = storage_file_write(msg, req, req_len, watcher); in handle_req()
180 rc = storage_file_read(msg, req, req_len, watcher); in handle_req()
184 rc = storage_file_get_size(msg, req, req_len, watcher); in handle_req()
188 rc = storage_file_set_size(msg, req, req_len, watcher); in handle_req()
192 rc = storage_file_get_max_size(msg, req, req_len, watcher); in handle_req()
[all …]
|
| D | rpmb.c | 325 struct watcher* watcher) { in send_mmc_rpmb_req() argument
379 watch_progress(watcher, "rpmb mmc ioctl"); in send_mmc_rpmb_req()
381 watch_progress(watcher, "rpmb mmc ioctl done"); in send_mmc_rpmb_req()
389 struct watcher* watcher) { in send_ufs_rpmb_req() argument
425 watch_progress(watcher, "rpmb ufs reliable write"); in send_ufs_rpmb_req()
427 watch_progress(watcher, "rpmb ufs reliable write done"); in send_ufs_rpmb_req()
452 watch_progress(watcher, "rpmb ufs write"); in send_ufs_rpmb_req()
454 watch_progress(watcher, "rpmb ufs write done"); in send_ufs_rpmb_req()
469 watch_progress(watcher, "rpmb ufs read"); in send_ufs_rpmb_req()
471 watch_progress(watcher, "rpmb ufs read done"); in send_ufs_rpmb_req()
[all …]
|
| D | rpmb.h | 26 int rpmb_send(struct storage_msg* msg, const void* r, size_t req_len, struct watcher* watcher);
|
| /system/librustutils/ |
| D | system_properties_fuzzer.rs | 87 … if let Ok(mut watcher) = system_properties::PropertyWatcher::new(&prop.to_string()) {
88 watcher.read(|_n, v| Ok(v.to_string()));
101 Ok(mut watcher) => watcher.wait(None),
|
| /system/update_engine/common/ |
| D | subprocess_unittest.cc | 275 unique_ptr<base::FileDescriptorWatcher::Controller>* watcher, in TEST_F()
285 *watcher = nullptr; in TEST_F()
|