dev/iscsi/iscsi_utils.c

200 get_ccb(connection_t *conn, bool waitok)
203 	session_t *sess = conn->c_session;
236 	ccb->ccb_connection = conn;
238 	mutex_enter(&conn->c_lock);
239 	conn->c_usecount++;
240 	mutex_exit(&conn->c_lock);
242 	DEBC(conn, 15, (
244 		ccb, conn->c_usecount));
260 	connection_t *conn = ccb->ccb_connection;
263 	DEBC(conn, 15, (
265 		ccb, conn->c_usecount-1));
270 	mutex_enter(&conn->c_lock);
271 	conn->c_usecount--;
272 	mutex_exit(&conn->c_lock);
290 		mutex_enter(&conn->c_lock);
292 			TAILQ_REMOVE(&conn->c_pdus_to_send, pdu, pdu_send_chain);
295 		mutex_exit(&conn->c_lock);
370 	connection_t *conn;
372 	conn = ccb->ccb_connection;
373 	KASSERT(conn != NULL);
375 	KASSERT(mutex_owned(&conn->c_lock));
379 		TAILQ_INSERT_TAIL(&conn->c_ccbs_waiting, ccb, ccb_chain);
382 		TAILQ_REMOVE(&conn->c_ccbs_waiting, ccb, ccb_chain);
400 	connection_t *conn;
402 	conn = ccb->ccb_connection;
403 	KASSERT(conn != NULL);
405 	DEBC(conn, 9, ("CCB %d done, ccb = %p, disp = %d\n",
410 	mutex_enter(&conn->c_lock);
413 		(disp == CCBDISP_DEFER && conn->c_state <= ST_WINDING_DOWN)) {
414 		mutex_exit(&conn->c_lock);
425 		cv_broadcast(&conn->c_ccb_cv);
426 	mutex_exit(&conn->c_lock);
440 		DEBC(conn, 1, ("CCB done, ccb = %p, invalid disposition %d", ccb, disp));
455  *          conn     The connection this PDU should be associated with
462 get_pdu(connection_t *conn, bool waitok)
466 	mutex_enter(&conn->c_lock);
468 		pdu = TAILQ_FIRST(&conn->c_pdu_pool);
471 			TAILQ_REMOVE(&conn->c_pdu_pool, pdu, pdu_chain);
472 			conn->c_pducount++;
479 		cv_wait(&conn->c_pdu_cv, &conn->c_lock);
481 	mutex_exit(&conn->c_lock);
489 	pdu->pdu_connection = conn;
492 	DEBC(conn, 15, ("get_pdu: pdu = %p, usecount = %d\n", pdu, conn->c_pducount));
507 	connection_t *conn = pdu->pdu_connection;
510 	DEBC(conn, 15, ("free_pdu: pdu = %p, usecount = %d\n", pdu, conn->c_pducount-1));
515 		DEBC(conn, 0, ("freeing UNUSED pdu\n"));
525 	mutex_enter(&conn->c_lock);
526 	conn->c_pducount--;
527 	TAILQ_INSERT_TAIL(&conn->c_pdu_pool, pdu, pdu_chain);
528 	cv_broadcast(&conn->c_pdu_cv);
529 	mutex_exit(&conn->c_lock);
542 create_pdus(connection_t *conn)
549 	for (i = 0, pdu = conn->c_pdu; i < PDUS_PER_CONNECTION; i++, pdu++) {
550 		TAILQ_INSERT_HEAD(&conn->c_pdu_pool, pdu, pdu_chain);