Lines Matching refs:treq
144 typedef void (*queue_rw_t) (td_driver_t *driver, td_request_t treq);
197 static void primary_queue_read(td_driver_t *driver, td_request_t treq);
198 static void primary_queue_write(td_driver_t *driver, td_request_t treq);
201 static void backup_queue_read(td_driver_t *driver, td_request_t treq);
202 static void backup_queue_write(td_driver_t *driver, td_request_t treq);
205 static void unprotected_queue_read(td_driver_t *driver, td_request_t treq);
206 static void unprotected_queue_write(td_driver_t *driver, td_request_t treq);
237 replicated_write_callback(td_request_t treq, int err) in replicated_write_callback() argument
239 struct tdremus_state *s = (struct tdremus_state *) treq.cb_data; in replicated_write_callback()
243 vreq = (td_vbd_request_t *) treq.private; in replicated_write_callback()
257 start = treq.sec; in replicated_write_callback()
258 for (i = 0; i < treq.secs; i++) { in replicated_write_callback()
262 free(treq.buf); in replicated_write_callback()
272 td_request_t treq; in create_write_request() local
275 treq.op = TD_OP_WRITE; in create_write_request()
276 treq.buf = buf; in create_write_request()
277 treq.sec = sec; in create_write_request()
278 treq.secs = secs; in create_write_request()
279 treq.image = remus_image; in create_write_request()
280 treq.cb = replicated_write_callback; in create_write_request()
281 treq.cb_data = state; in create_write_request()
282 treq.id = 0; in create_write_request()
283 treq.sidx = 0; in create_write_request()
286 treq.private = vreq; in create_write_request()
293 tapdisk_vbd_move_request(treq.private, &device_vbd->pending_requests); in create_write_request()
297 td_forward_request(treq); in create_write_request()
831 static void primary_queue_read(td_driver_t *driver, td_request_t treq) in primary_queue_read() argument
834 td_forward_request(treq); in primary_queue_read()
844 static void primary_queue_write(td_driver_t *driver, td_request_t treq) in primary_queue_write() argument
860 *sectors = treq.secs; in primary_queue_write()
861 *sector = treq.sec; in primary_queue_write()
868 if (mwrite(s->stream_fd.fd, treq.buf, treq.secs * driver->info.sector_size) < 0) in primary_queue_write()
871 td_forward_request(treq); in primary_queue_write()
879 td_complete_request(treq, -EBUSY); in primary_queue_write()
1150 void backup_queue_read(td_driver_t *driver, td_request_t treq) in backup_queue_read() argument
1155 remus_image = treq.image; in backup_queue_read()
1158 if (ramdisk_read(&s->ramdisk, treq.sec, treq.secs, treq.buf)) { in backup_queue_read()
1160 td_forward_request(treq); in backup_queue_read()
1163 td_complete_request(treq, 0); in backup_queue_read()
1168 void backup_queue_write(td_driver_t *driver, td_request_t treq) in backup_queue_write() argument
1179 td_complete_request(treq, -EBUSY); in backup_queue_write()
1302 void unprotected_queue_read(td_driver_t *driver, td_request_t treq) in unprotected_queue_read() argument
1315 td_complete_request(treq, -EBUSY); in unprotected_queue_read()
1319 td_forward_request(treq); in unprotected_queue_read()
1324 void unprotected_queue_write(td_driver_t *driver, td_request_t treq) in unprotected_queue_write() argument
1333 td_complete_request(treq, -EBUSY); in unprotected_queue_write()
1338 td_forward_request(treq); in unprotected_queue_write()