Lines Matching defs:icd
1293 static void lat_fatal(struct thread_data *td, struct io_completion_data *icd,
1299 icd->error = ETIMEDOUT;
1728 struct io_completion_data *icd,
1741 lusec = utime_since(&io_u->issue_time, &icd->time);
1746 tusec = utime_since(&io_u->start_time, &icd->time);
1753 icd->error = ops->io_u_lat(td, tusec);
1757 lat_fatal(td, icd, tusec, td->o.max_latency);
1760 lat_fatal(td, icd, tusec, td->o.latency_target);
1814 struct io_completion_data *icd)
1868 account_io_completion(td, io_u, icd, ddir, bytes);
1870 icd->bytes_done[ddir] += bytes;
1875 if (ret && !icd->error)
1876 icd->error = ret;
1879 icd->error = io_u->error;
1882 if (icd->error) {
1883 enum error_type_bit eb = td_error_type(ddir, icd->error);
1885 if (!td_non_fatal_error(td, eb, icd->error))
1892 update_error_count(td, icd->error);
1894 icd->error = 0;
1900 static void init_icd(struct thread_data *td, struct io_completion_data *icd,
1906 fio_gettime(&icd->time, NULL);
1908 icd->nr = nr;
1910 icd->error = 0;
1912 icd->bytes_done[ddir] = 0;
1916 struct io_completion_data *icd)
1921 for (i = 0; i < icd->nr; i++) {
1924 io_completed(td, &io_u, icd);
1936 struct io_completion_data icd;
1939 init_icd(td, &icd, 1);
1940 io_completed(td, &io_u, &icd);
1945 if (icd.error) {
1946 td_verror(td, icd.error, "io_u_sync_complete");
1951 td->bytes_done[ddir] += icd.bytes_done[ddir];
1961 struct io_completion_data icd;
1982 init_icd(td, &icd, ret);
1983 ios_completed(td, &icd);
1984 if (icd.error) {
1985 td_verror(td, icd.error, "io_u_queued_complete");
1990 td->bytes_done[ddir] += icd.bytes_done[ddir];