Lines Matching refs:dsnglp

216 	struct fc_data *dsnglp = (struct fc_data *)queuep;  in dsngl_enque()  local
220 que_objp = dsnglp->ds_queobjp; in dsngl_enque()
221 tgcom_objp = dsnglp->ds_tgcomobjp; in dsngl_enque()
225 mutex_enter(&dsnglp->ds_mutex); in dsngl_enque()
226 if (dsnglp->ds_bp || dsnglp->ds_outcnt) { in dsngl_enque()
228 if (dsnglp->ds_kstat) { in dsngl_enque()
229 kstat_waitq_enter(KSTAT_IO_PTR(dsnglp->ds_kstat)); in dsngl_enque()
231 mutex_exit(&dsnglp->ds_mutex); in dsngl_enque()
234 if (dsnglp->ds_kstat) { in dsngl_enque()
235 kstat_waitq_enter(KSTAT_IO_PTR(dsnglp->ds_kstat)); in dsngl_enque()
238 (caddr_t)dsnglp) != DDI_SUCCESS) { in dsngl_enque()
240 dsnglp->ds_bp = in_bp; in dsngl_enque()
241 mutex_exit(&dsnglp->ds_mutex); in dsngl_enque()
244 dsnglp->ds_outcnt++; in dsngl_enque()
245 if (dsnglp->ds_kstat) in dsngl_enque()
246 kstat_waitq_to_runq(KSTAT_IO_PTR(dsnglp->ds_kstat)); in dsngl_enque()
247 mutex_exit(&dsnglp->ds_mutex); in dsngl_enque()
255 struct fc_data *dsnglp = (struct fc_data *)queuep; in dsngl_deque() local
260 que_objp = dsnglp->ds_queobjp; in dsngl_deque()
261 tgcom_objp = dsnglp->ds_tgcomobjp; in dsngl_deque()
263 mutex_enter(&dsnglp->ds_mutex); in dsngl_deque()
265 dsnglp->ds_outcnt--; in dsngl_deque()
266 if (dsnglp->ds_kstat) { in dsngl_deque()
268 KSTAT_IO_PTR(dsnglp->ds_kstat)->reads++; in dsngl_deque()
269 KSTAT_IO_PTR(dsnglp->ds_kstat)->nread += in dsngl_deque()
272 KSTAT_IO_PTR(dsnglp->ds_kstat)->writes++; in dsngl_deque()
273 KSTAT_IO_PTR(dsnglp->ds_kstat)->nwritten += in dsngl_deque()
276 kstat_runq_exit(KSTAT_IO_PTR(dsnglp->ds_kstat)); in dsngl_deque()
280 if (!dsnglp->ds_bp) in dsngl_deque()
281 dsnglp->ds_bp = QUE_DEL(que_objp); in dsngl_deque()
282 if (!dsnglp->ds_bp || in dsngl_deque()
283 (TGCOM_PKT(tgcom_objp, dsnglp->ds_bp, dsngl_restart, in dsngl_deque()
284 (caddr_t)dsnglp) != DDI_SUCCESS) || in dsngl_deque()
285 dsnglp->ds_outcnt) { in dsngl_deque()
286 mutex_exit(&dsnglp->ds_mutex); in dsngl_deque()
289 dsnglp->ds_outcnt++; in dsngl_deque()
290 bp = dsnglp->ds_bp; in dsngl_deque()
291 dsnglp->ds_bp = QUE_DEL(que_objp); in dsngl_deque()
292 if (dsnglp->ds_kstat) in dsngl_deque()
293 kstat_waitq_to_runq(KSTAT_IO_PTR(dsnglp->ds_kstat)); in dsngl_deque()
294 mutex_exit(&dsnglp->ds_mutex); in dsngl_deque()
298 if (!mutex_tryenter(&dsnglp->ds_mutex)) in dsngl_deque()
304 dsngl_restart(struct fc_data *dsnglp) in dsngl_restart() argument
306 (void) dsngl_deque(dsnglp, NULL); in dsngl_restart()