Lines Matching refs:KSYN_QUEUE_READ
198 #define KSYN_QUEUE_READ 0
1700 error = ksyn_queue_insert(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_READ], lgen, uth, kwe, SEQFIT);
1726 ksyn_queue_removeitem(kwq, &kwq->kw_ksynqueues[KSYN_QUEUE_READ], kwe);
3182 if ((kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count != 0) || ((flags & KW_UNLOCK_PREPOST_READLOCK) != 0)) {
3185 if (kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count != 0) {
3186 kw_fr = kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_firstnum;
3192 lowest[KSYN_QUEUE_READ] = kw_fr;
3197 lowest[KSYN_QUEUE_READ] = 0;
3288 while ((kwe = ksyn_queue_removefirst(&kwq->kw_ksynqueues[KSYN_QUEUE_READ], kwq)) != NULL) {
3316 kq = &kwq->kw_ksynqueues[KSYN_QUEUE_READ];
3366 kq = &kwq->kw_ksynqueues[KSYN_QUEUE_READ];
3422 low_reader = lowest[KSYN_QUEUE_READ];
3502 numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3520 numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3537 numneeded += kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;
3671 numneeded = kwq->kw_ksynqueues[KSYN_QUEUE_READ].ksynq_count;