Lines Matching refs:icd
1140 static void lat_fatal(struct thread_data *td, struct io_completion_data *icd,
1146 icd->error = ETIMEDOUT;
1558 struct io_completion_data *icd,
1564 lusec = utime_since(&io_u->issue_time, &icd->time);
1569 tusec = utime_since(&io_u->start_time, &icd->time);
1576 icd->error = ops->io_u_lat(td, tusec);
1580 lat_fatal(td, icd, tusec, td->o.max_latency);
1583 lat_fatal(td, icd, tusec, td->o.latency_target);
1593 add_bw_sample(td, idx, bytes, &icd->time);
1596 add_iops_sample(td, idx, bytes, &icd->time);
1611 struct io_completion_data *icd)
1678 account_io_completion(td, io_u, icd, idx, bytes);
1691 icd->bytes_done[idx] += bytes;
1695 if (ret && !icd->error)
1696 icd->error = ret;
1699 icd->error = io_u->error;
1702 if (icd->error) {
1703 enum error_type_bit eb = td_error_type(io_u->ddir, icd->error);
1704 if (!td_non_fatal_error(td, eb, icd->error))
1710 update_error_count(td, icd->error);
1712 icd->error = 0;
1717 static void init_icd(struct thread_data *td, struct io_completion_data *icd,
1723 fio_gettime(&icd->time, NULL);
1725 icd->nr = nr;
1727 icd->error = 0;
1729 icd->bytes_done[ddir] = 0;
1733 struct io_completion_data *icd)
1738 for (i = 0; i < icd->nr; i++) {
1741 io_completed(td, io_u, icd);
1754 struct io_completion_data icd;
1756 init_icd(td, &icd, 1);
1757 io_completed(td, io_u, &icd);
1762 if (icd.error) {
1763 td_verror(td, icd.error, "io_u_sync_complete");
1771 bytes[ddir] += icd.bytes_done[ddir];
1783 struct io_completion_data icd;
1800 init_icd(td, &icd, ret);
1801 ios_completed(td, &icd);
1802 if (icd.error) {
1803 td_verror(td, icd.error, "io_u_queued_complete");
1811 bytes[ddir] += icd.bytes_done[ddir];
