Lines Matching refs:eqp
3924 esb_queue_t *eqp;
3929 eqp = system_esbq_array;
3930 if (eqp != NULL) {
3931 eqp += qindex;
3938 eqp = system_esbq_array;
3939 if (eqp != NULL)
3940 eqp += qindex;
3942 eqp = &system_esbq;
3955 mutex_enter(&eqp->eq_lock);
3957 if (eqp->eq_head == NULL) {
3958 eqp->eq_head = eqp->eq_tail = mp;
3960 eqp->eq_tail->b_next = mp;
3961 eqp->eq_tail = mp;
3963 eqp->eq_len++;
3966 if (eqp->eq_len >= esbq_max_qlen &&
3967 !(eqp->eq_flags & ESBQ_PROCESSING))
3968 esballoc_process_queue(eqp);
3970 esballoc_set_timer(eqp, esbq_timeout);
3971 mutex_exit(&eqp->eq_lock);
3975 esballoc_process_queue(esb_queue_t *eqp)
3979 ASSERT(MUTEX_HELD(&eqp->eq_lock));
3981 eqp->eq_flags |= ESBQ_PROCESSING;
3987 mp = eqp->eq_head;
3988 eqp->eq_tail->b_next = NULL;
3989 eqp->eq_head = eqp->eq_tail = NULL;
3990 eqp->eq_len = 0;
3991 mutex_exit(&eqp->eq_lock);
3997 mutex_enter(&eqp->eq_lock);
3998 } while ((eqp->eq_len >= esbq_max_qlen) && (eqp->eq_len > 0));
4000 eqp->eq_flags &= ~ESBQ_PROCESSING;
4045 esb_queue_t *eqp = arg;
4047 mutex_enter(&eqp->eq_lock);
4048 eqp->eq_flags &= ~ESBQ_TIMER;
4050 if (!(eqp->eq_flags & ESBQ_PROCESSING) &&
4051 eqp->eq_len > 0)
4052 esballoc_process_queue(eqp);
4054 esballoc_set_timer(eqp, esbq_timeout);
4055 mutex_exit(&eqp->eq_lock);
4059 esballoc_set_timer(esb_queue_t *eqp, clock_t eq_timeout)
4061 ASSERT(MUTEX_HELD(&eqp->eq_lock));
4063 if (eqp->eq_len > 0 && !(eqp->eq_flags & ESBQ_TIMER)) {
4064 (void) timeout(esballoc_timer, eqp, eq_timeout);
4065 eqp->eq_flags |= ESBQ_TIMER;