Cross Reference: /illumos-gate/usr/src/lib/smbsrv/libmlsvc/common/smb

Lines Matching defs:ad_queue
184 static smb_shr_pqueue_t ad_queue;
1820 	(void) mutex_lock(&ad_queue.spq_mtx);
1821 	switch (ad_queue.spq_state) {
1826 		(void) mutex_unlock(&ad_queue.spq_mtx);
1829 	(void) mutex_unlock(&ad_queue.spq_mtx);
1839 	(void) mutex_lock(&ad_queue.spq_mtx);
1840 	list_insert_tail(&ad_queue.spq_list, item);
1841 	(void) cond_signal(&ad_queue.spq_cv);
1842 	(void) mutex_unlock(&ad_queue.spq_mtx);
1859 	(void) mutex_lock(&ad_queue.spq_mtx);
1860 	if (ad_queue.spq_state != SMB_SHR_PQS_NOQUEUE) {
1861 		(void) mutex_unlock(&ad_queue.spq_mtx);
1866 	list_create(&ad_queue.spq_list, sizeof (smb_shr_pitem_t),
1868 	ad_queue.spq_state = SMB_SHR_PQS_READY;
1869 	(void) mutex_unlock(&ad_queue.spq_mtx);
1885 	(void) mutex_lock(&ad_queue.spq_mtx);
1886 	switch (ad_queue.spq_state) {
1889 		ad_queue.spq_state = SMB_SHR_PQS_STOPPING;
1890 		(void) cond_signal(&ad_queue.spq_cv);
1895 	(void) mutex_unlock(&ad_queue.spq_mtx);
1917 	(void) mutex_lock(&ad_queue.spq_mtx);
1918 	if (ad_queue.spq_state != SMB_SHR_PQS_READY) {
1919 		(void) mutex_unlock(&ad_queue.spq_mtx);
1922 	ad_queue.spq_state = SMB_SHR_PQS_PUBLISHING;
1923 	(void) mutex_unlock(&ad_queue.spq_mtx);
1932 		(void) mutex_lock(&ad_queue.spq_mtx);
1934 		while (list_is_empty(&ad_queue.spq_list) &&
1935 		    (ad_queue.spq_state == SMB_SHR_PQS_PUBLISHING)) {
1937 				(void) cond_wait(&ad_queue.spq_cv,
1938 				    &ad_queue.spq_mtx);
1942 				(void) cond_reltimedwait(&ad_queue.spq_cv,
1943 				    &ad_queue.spq_mtx, &pubretry);
1948 		if (ad_queue.spq_state != SMB_SHR_PQS_PUBLISHING) {
1949 			(void) mutex_unlock(&ad_queue.spq_mtx);
1957 		while ((shr = list_head(&ad_queue.spq_list)) != NULL) {
1958 			list_remove(&ad_queue.spq_list, shr);
1962 		(void) mutex_unlock(&ad_queue.spq_mtx);
1970 	(void) mutex_lock(&ad_queue.spq_mtx);
1971 	smb_shr_publisher_flush(&ad_queue.spq_list);
1972 	list_destroy(&ad_queue.spq_list);
1973 	ad_queue.spq_state = SMB_SHR_PQS_NOQUEUE;
1974 	(void) mutex_unlock(&ad_queue.spq_mtx);
1990 		(void) mutex_lock(&ad_queue.spq_mtx);
1991 		if (ad_queue.spq_state != SMB_SHR_PQS_PUBLISHING) {
1992 			(void) mutex_unlock(&ad_queue.spq_mtx);
1995 		(void) mutex_unlock(&ad_queue.spq_mtx);