Lines Matching defs:sess
193 * sess The session containing this CCB
203 session_t *sess = conn->c_session;
205 mutex_enter(&sess->s_lock);
207 ccb = TAILQ_FIRST(&sess->s_ccb_pool);
212 TAILQ_REMOVE(&sess->s_ccb_pool, ccb, ccb_chain);
219 cv_wait(&sess->s_ccb_cv, &sess->s_lock);
221 mutex_exit(&sess->s_lock);
259 session_t *sess = ccb->ccb_session;
299 mutex_enter(&sess->s_lock);
300 TAILQ_INSERT_TAIL(&sess->s_ccb_pool, ccb, ccb_chain);
301 cv_broadcast(&sess->s_ccb_cv);
302 mutex_exit(&sess->s_lock);
315 create_ccbs(session_t *sess)
319 int sid = sess->s_id << 8;
323 for (i = 0, ccb = sess->s_ccb; i < CCBS_PER_SESSION; i++, ccb++) {
325 ccb->ccb_session = sess;
331 TAILQ_INSERT_HEAD(&sess->s_ccb_pool, ccb, ccb_chain);
343 destroy_ccbs(session_t *sess)
350 for (i = 0, ccb = sess->s_ccb; i < CCBS_PER_SESSION; i++, ccb++) {
359 TAILQ_REMOVE(&sess->s_ccb_pool, ccb, ccb_chain);
692 get_sernum(session_t *sess, pdu_t *pdu)
696 KASSERT(mutex_owned(&sess->s_lock));
698 sn = sess->s_CmdSN;
700 atomic_inc_32(&sess->s_CmdSN);
710 sernum_in_window(session_t *sess)
713 KASSERT(mutex_owned(&sess->s_lock));
714 return sn_a_le_b(sess->s_CmdSN, sess->s_MaxCmdSN);
722 window_size(session_t *sess, int limit)
726 KASSERT(mutex_owned(&sess->s_lock));
729 if (sn_a_le_b(sess->s_CmdSN, sess->s_MaxCmdSN))
730 win = sess->s_MaxCmdSN - sess->s_CmdSN + 1;