@@ -56,17 +56,17 @@ bqueue_init(bqueue_t *q, uint_t fill_fraction, size_t size, size_t node_offset)
56
56
}
57
57
list_create (& q -> bq_list , node_offset + sizeof (bqueue_node_t ),
58
58
node_offset + offsetof(bqueue_node_t , bqn_node ));
59
- list_create (& q -> bq_deqing_list , node_offset + sizeof (bqueue_node_t ),
59
+ list_create (& q -> bq_dequeuing_list , node_offset + sizeof (bqueue_node_t ),
60
60
node_offset + offsetof(bqueue_node_t , bqn_node ));
61
- list_create (& q -> bq_enqing_list , node_offset + sizeof (bqueue_node_t ),
61
+ list_create (& q -> bq_enqueuing_list , node_offset + sizeof (bqueue_node_t ),
62
62
node_offset + offsetof(bqueue_node_t , bqn_node ));
63
63
cv_init (& q -> bq_add_cv , NULL , CV_DEFAULT , NULL );
64
64
cv_init (& q -> bq_pop_cv , NULL , CV_DEFAULT , NULL );
65
65
mutex_init (& q -> bq_lock , NULL , MUTEX_DEFAULT , NULL );
66
66
q -> bq_node_offset = node_offset ;
67
67
q -> bq_size = 0 ;
68
- q -> bq_deqing_size = 0 ;
69
- q -> bq_enqing_size = 0 ;
68
+ q -> bq_dequeuing_size = 0 ;
69
+ q -> bq_enqueuing_size = 0 ;
70
70
q -> bq_maxsize = size ;
71
71
q -> bq_fill_fraction = fill_fraction ;
72
72
return (0 );
@@ -82,13 +82,13 @@ bqueue_destroy(bqueue_t *q)
82
82
{
83
83
mutex_enter (& q -> bq_lock );
84
84
ASSERT0 (q -> bq_size );
85
- ASSERT0 (q -> bq_deqing_size );
86
- ASSERT0 (q -> bq_enqing_size );
85
+ ASSERT0 (q -> bq_dequeuing_size );
86
+ ASSERT0 (q -> bq_enqueuing_size );
87
87
cv_destroy (& q -> bq_add_cv );
88
88
cv_destroy (& q -> bq_pop_cv );
89
89
list_destroy (& q -> bq_list );
90
- list_destroy (& q -> bq_deqing_list );
91
- list_destroy (& q -> bq_enqing_list );
90
+ list_destroy (& q -> bq_dequeuing_list );
91
+ list_destroy (& q -> bq_enqueuing_list );
92
92
mutex_exit (& q -> bq_lock );
93
93
mutex_destroy (& q -> bq_lock );
94
94
}
@@ -100,19 +100,19 @@ bqueue_enqueue_impl(bqueue_t *q, void *data, size_t item_size, boolean_t flush)
100
100
ASSERT3U (item_size , <=, q -> bq_maxsize );
101
101
102
102
obj2node (q , data )-> bqn_size = item_size ;
103
- q -> bq_enqing_size += item_size ;
104
- list_insert_tail (& q -> bq_enqing_list , data );
103
+ q -> bq_enqueuing_size += item_size ;
104
+ list_insert_tail (& q -> bq_enqueuing_list , data );
105
105
106
106
if (flush ||
107
- q -> bq_enqing_size >= q -> bq_maxsize / q -> bq_fill_fraction ) {
107
+ q -> bq_enqueuing_size >= q -> bq_maxsize / q -> bq_fill_fraction ) {
108
108
/* Append the enquing list to the shared list. */
109
109
mutex_enter (& q -> bq_lock );
110
110
while (q -> bq_size > q -> bq_maxsize ) {
111
111
cv_wait_sig (& q -> bq_add_cv , & q -> bq_lock );
112
112
}
113
- q -> bq_size += q -> bq_enqing_size ;
114
- list_move_tail (& q -> bq_list , & q -> bq_enqing_list );
115
- q -> bq_enqing_size = 0 ;
113
+ q -> bq_size += q -> bq_enqueuing_size ;
114
+ list_move_tail (& q -> bq_list , & q -> bq_enqueuing_list );
115
+ q -> bq_enqueuing_size = 0 ;
116
116
cv_broadcast (& q -> bq_pop_cv );
117
117
mutex_exit (& q -> bq_lock );
118
118
}
@@ -150,7 +150,7 @@ bqueue_enqueue_flush(bqueue_t *q, void *data, size_t item_size)
150
150
void *
151
151
bqueue_dequeue (bqueue_t * q )
152
152
{
153
- void * ret = list_remove_head (& q -> bq_deqing_list );
153
+ void * ret = list_remove_head (& q -> bq_dequeuing_list );
154
154
if (ret == NULL ) {
155
155
/*
156
156
* Dequeuing list is empty. Wait for there to be something on
@@ -161,15 +161,15 @@ bqueue_dequeue(bqueue_t *q)
161
161
while (q -> bq_size == 0 ) {
162
162
cv_wait_sig (& q -> bq_pop_cv , & q -> bq_lock );
163
163
}
164
- ASSERT0 (q -> bq_deqing_size );
165
- ASSERT (list_is_empty (& q -> bq_deqing_list ));
166
- list_move_tail (& q -> bq_deqing_list , & q -> bq_list );
167
- q -> bq_deqing_size = q -> bq_size ;
164
+ ASSERT0 (q -> bq_dequeuing_size );
165
+ ASSERT (list_is_empty (& q -> bq_dequeuing_list ));
166
+ list_move_tail (& q -> bq_dequeuing_list , & q -> bq_list );
167
+ q -> bq_dequeuing_size = q -> bq_size ;
168
168
q -> bq_size = 0 ;
169
169
cv_broadcast (& q -> bq_add_cv );
170
170
mutex_exit (& q -> bq_lock );
171
- ret = list_remove_head (& q -> bq_deqing_list );
171
+ ret = list_remove_head (& q -> bq_dequeuing_list );
172
172
}
173
- q -> bq_deqing_size -= obj2node (q , ret )-> bqn_size ;
173
+ q -> bq_dequeuing_size -= obj2node (q , ret )-> bqn_size ;
174
174
return (ret );
175
175
}
0 commit comments