Lines Matching refs:iop
124 static inline void dip_update_q(struct d_info *dip, struct io *iop) in dip_update_q() argument
127 update_lq(&dip->last_q, &dip->avgs.q2q_dm, iop->t.time); in dip_update_q()
129 update_lq(&dip->last_q, &dip->avgs.q2q, iop->t.time); in dip_update_q()
130 update_qregion(&dip->regions, iop->t.time); in dip_update_q()
135 struct io *iop = malloc(sizeof(*iop)); in io_alloc() local
137 memset(iop, 0, sizeof(struct io)); in io_alloc()
138 list_add_tail(&iop->a_head, &all_ios); in io_alloc()
140 return iop; in io_alloc()
143 static inline void io_free(struct io *iop) in io_free() argument
145 list_del(&iop->a_head); in io_free()
146 free(iop); in io_free()
151 struct io *iop; in io_free_all() local
155 iop = list_entry(p, struct io, a_head); in io_free_all()
156 free(iop); in io_free_all()
160 static inline int io_setup(struct io *iop, enum iop_type type) in io_setup() argument
162 iop->type = type; in io_setup()
163 iop->dip = dip_alloc(iop->t.device, iop); in io_setup()
164 if (iop->linked) { in io_setup()
165 iop->pip = find_process(iop->t.pid, NULL); in io_setup()
166 iop->bytes_left = iop->t.bytes; in io_setup()
169 return iop->linked; in io_setup()
172 static inline void io_release(struct io *iop) in io_release() argument
174 if (iop->linked) in io_release()
175 iop_rem_dip(iop); in io_release()
176 if (iop->pdu) in io_release()
177 free(iop->pdu); in io_release()
179 io_free(iop); in io_release()
200 static inline void update_q2c(struct io *iop, __u64 c_time) in update_q2c() argument
202 if (remapper_dev(iop->dip->device)) in update_q2c()
203 UPDATE_AVGS(q2c_dm, iop, iop->pip, c_time); in update_q2c()
205 UPDATE_AVGS(q2c, iop, iop->pip, c_time); in update_q2c()
208 static inline void update_q2a(struct io *iop, __u64 a_time) in update_q2a() argument
210 if (remapper_dev(iop->dip->device)) in update_q2a()
211 UPDATE_AVGS(q2a_dm, iop, iop->pip, a_time); in update_q2a()
213 UPDATE_AVGS(q2a, iop, iop->pip, a_time); in update_q2a()
216 static inline void update_q2g(struct io *iop, __u64 g_time) in update_q2g() argument
218 UPDATE_AVGS(q2g, iop, iop->pip, g_time); in update_q2g()
221 static inline void update_s2g(struct io *iop, __u64 g_time) in update_s2g() argument
223 UPDATE_AVGS(s2g, iop, iop->pip, g_time); in update_s2g()
226 static inline void unupdate_q2g(struct io *iop, __u64 g_time) in unupdate_q2g() argument
228 UNUPDATE_AVGS(q2g, iop, iop->pip, g_time); in unupdate_q2g()
231 static inline void update_g2i(struct io *iop, __u64 i_time) in update_g2i() argument
233 UPDATE_AVGS(g2i, iop, iop->pip, i_time); in update_g2i()
236 static inline void unupdate_g2i(struct io *iop, __u64 i_time) in unupdate_g2i() argument
238 UNUPDATE_AVGS(g2i, iop, iop->pip, i_time); in unupdate_g2i()
241 static inline void update_q2m(struct io *iop, __u64 m_time) in update_q2m() argument
243 UPDATE_AVGS(q2m, iop, iop->pip, m_time); in update_q2m()
246 static inline void unupdate_q2m(struct io *iop, __u64 m_time) in unupdate_q2m() argument
248 UNUPDATE_AVGS(q2m, iop, iop->pip, m_time); in unupdate_q2m()
251 static inline void update_i2d(struct io *iop, __u64 d_time) in update_i2d() argument
253 UPDATE_AVGS(i2d, iop, iop->pip, d_time); in update_i2d()
256 static inline void unupdate_i2d(struct io *iop, __u64 d_time) in unupdate_i2d() argument
258 UNUPDATE_AVGS(i2d, iop, iop->pip, d_time); in unupdate_i2d()
261 static inline void update_m2d(struct io *iop, __u64 d_time) in update_m2d() argument
263 UPDATE_AVGS(m2d, iop, iop->pip, d_time); in update_m2d()
266 static inline void unupdate_m2d(struct io *iop, __u64 d_time) in unupdate_m2d() argument
268 UNUPDATE_AVGS(m2d, iop, iop->pip, d_time); in unupdate_m2d()
271 static inline void update_d2c(struct io *iop, __u64 c_time) in update_d2c() argument
273 UPDATE_AVGS(d2c, iop, iop->pip, c_time); in update_d2c()
276 static inline void update_blks(struct io *iop) in update_blks() argument
278 __u64 nblks = iop->t.bytes >> 9; in update_blks()
280 avg_update(&iop->dip->avgs.blks, nblks); in update_blks()
281 if (iop->pip) in update_blks()
282 avg_update(&iop->pip->avgs.blks, nblks); in update_blks()
291 static inline int dip_rb_ins(struct d_info *dip, struct io *iop) in dip_rb_ins() argument
293 return rb_insert(__get_root(dip, iop->type), iop); in dip_rb_ins()
296 static inline void dip_rb_rem(struct io *iop) in dip_rb_rem() argument
298 rb_erase(&iop->rb_node, __get_root(iop->dip, iop->type)); in dip_rb_rem()
302 struct io *iop, in dip_rb_fe() argument
303 void (*fnc)(struct io *iop, struct io *this), in dip_rb_fe() argument
306 rb_foreach(__get_root(dip, type)->rb_node, iop, fnc, head); in dip_rb_fe()
364 static inline void __dump_iop(FILE *ofp, struct io *iop, int extra_nl) in __dump_iop() argument
367 (int)SECONDS(iop->t.time), in __dump_iop()
368 (unsigned long)NANO_SECONDS(iop->t.time), in __dump_iop()
369 MAJOR(iop->t.device), MINOR(iop->t.device), type2c(iop->type), in __dump_iop()
370 (unsigned long long)iop->t.sector, t_sec(&iop->t)); in __dump_iop()