Lines Matching refs:wrap

1042     struct storage_compact_wrap *wrap = (struct storage_compact_wrap *)io->data;  in _storage_compact_cb()  local
1043 assert(wrap->submitted == true); in _storage_compact_cb()
1046 wrap->miss = true; in _storage_compact_cb()
1048 wrap->done = true; in _storage_compact_cb()
1050 pthread_mutex_unlock(&wrap->lock); in _storage_compact_cb()
1065 struct storage_compact_wrap wrap; in storage_compact_thread() local
1080 pthread_mutex_init(&wrap.lock, NULL); in storage_compact_thread()
1081 wrap.done = false; in storage_compact_thread()
1082 wrap.submitted = false; in storage_compact_thread()
1083 wrap.io.data = &wrap; in storage_compact_thread()
1084 wrap.io.iov = NULL; in storage_compact_thread()
1085 wrap.io.buf = (void *)readback_buf; in storage_compact_thread()
1087 wrap.io.len = settings.ext_wbuf_size; in storage_compact_thread()
1088 wrap.io.mode = OBJ_IO_READ; in storage_compact_thread()
1089 wrap.io.cb = _storage_compact_cb; in storage_compact_thread()
1104 pthread_mutex_lock(&wrap.lock); in storage_compact_thread()
1105 if (page_offset < page_size && !wrap.done && !wrap.submitted) { in storage_compact_thread()
1106 wrap.io.page_version = page_version; in storage_compact_thread()
1107 wrap.io.page_id = page_id; in storage_compact_thread()
1108 wrap.io.offset = page_offset; in storage_compact_thread()
1110 wrap.io.next = NULL; in storage_compact_thread()
1111 wrap.submitted = true; in storage_compact_thread()
1112 wrap.miss = false; in storage_compact_thread()
1114 extstore_submit_bg(storage, &wrap.io); in storage_compact_thread()
1115 } else if (wrap.miss) { in storage_compact_thread()
1118 wrap.done = false; in storage_compact_thread()
1119 wrap.submitted = false; in storage_compact_thread()
1121 } else if (wrap.submitted && wrap.done) { in storage_compact_thread()
1128 wrap.done = false; in storage_compact_thread()
1129 wrap.submitted = false; in storage_compact_thread()
1132 wrap.done = false; in storage_compact_thread()
1133 wrap.submitted = false; in storage_compact_thread()
1140 pthread_mutex_unlock(&wrap.lock); in storage_compact_thread()