bsd/kern/pthread_support.c

495 void update_low_high(ksyn_wait_queue_t kwq, uint32_t lockseq);
506 ksyn_waitq_element_t ksyn_queue_find_signalseq(ksyn_wait_queue_t kwq, ksyn_queue_t kq, uint32_t toseq, uint32_t lockseq);
767 	uint32_t lockseq, updatebits=0;
783 	lockseq = (uap->mgen & PTHRW_COUNT_MASK);
811                 (is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
824 	if ((kwq->kw_pre_rwwc != 0) && ((ins_flags == FIRSTFIT) || ((lockseq & PTHRW_COUNT_MASK) == (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK) ))) {
831 				updatebits = lockseq | (PTH_RWL_KBIT | PTH_RWL_EBIT);
1243 	uint32_t lockseq, updatebits=0;
1263 	lockseq = (cgen & PTHRW_COUNT_MASK);
1269 	if (is_seqhigher_eq((csgen & PTHRW_COUNT_MASK), lockseq) != 0) {
1313 	kwe = ksyn_queue_find_cvpreposeq(kq, lockseq);
1328 			if ((kwe->kwe_lockseq & PTHRW_COUNT_MASK) == lockseq) {
1388 	kwe->kwe_lockseq = lockseq;
1587 	uint32_t lockseq = 0, updatebits = 0, preseq = 0, prerw_wc = 0;
1607 	lockseq = lgen  & PTHRW_COUNT_MASK;
1635 		(is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
1668 	if ((kwq->kw_pre_rwwc != 0) && (is_seqlower_eq(lockseq, (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK)) != 0)) {
1765 	uint32_t lockseq = 0, updatebits = 0, preseq = 0, prerw_wc = 0;
1776 	lockseq = (lgen & PTHRW_COUNT_MASK);
1803 		(is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
1814 	if ((kwq->kw_pre_rwwc != 0) && (is_seqlower_eq(lockseq, (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK)) != 0)) {
1907 	uint32_t lockseq = 0, updatebits = 0, preseq = 0, prerw_wc = 0;
1922 	lockseq = (lgen & PTHRW_COUNT_MASK);
1951 		(is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
1962 	if ((kwq->kw_pre_rwwc != 0) && (is_seqlower_eq(lockseq, (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK)) != 0)) {
2068 	uint32_t lockseq = 0, updatebits = 0, preseq = 0, prerw_wc = 0;
2076 	lockseq = (lgen & PTHRW_COUNT_MASK);
2103 		(is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
2113 	if ((kwq->kw_pre_rwwc != 0) && (is_seqlower_eq(lockseq, (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK)) != 0)) {
2321 	uint32_t lockseq = 0, updatebits = 0, preseq = 0;
2335 	lockseq = (lgen & PTHRW_COUNT_MASK);
2362 		(is_seqlower_eq(lockseq, (kwq->kw_pre_intrseq & PTHRW_COUNT_MASK)) != 0)) {
2372 	if ((kwq->kw_pre_rwwc != 0) && (is_seqlower_eq(lockseq, (kwq->kw_pre_lockseq & PTHRW_COUNT_MASK)) != 0)) {
3858 	uint32_t lockseq = mgen & PTHRW_COUNT_MASK;
3865 		kq->ksynq_firstnum = lockseq;
3866 		kq->ksynq_lastnum = lockseq;
3874 		if (is_seqlower (lockseq, kq->ksynq_firstnum) != 0)
3875 			kq->ksynq_firstnum = lockseq;
3876 		if (is_seqhigher (lockseq, kq->ksynq_lastnum) != 0)
3877 			kq->ksynq_lastnum = lockseq;
3881 	if ((lockseq == kq->ksynq_firstnum) || (lockseq == kq->ksynq_lastnum)) {
3884 			q_kwe = ksyn_queue_find_seq(kwq, kq, lockseq, 0);
3891 				__FAILEDUSERTEST__("ksyn_queue_insert: two threads with same lockseq ");
3896 			__FAILEDUSERTEST__("ksyn_queue_insert: two threads with same lockseq ");
3903 	if (is_seqlower(kq->ksynq_lastnum, lockseq) != 0) {
3905 		kq->ksynq_lastnum = lockseq;
3909 	if (is_seqlower(lockseq, kq->ksynq_firstnum) != 0) {
3911 		kq->ksynq_firstnum = lockseq;
3917 		if (is_seqhigher(q_kwe->kwe_lockseq, lockseq) != 0) {
3932 	update_low_high(kwq, lockseq);
4053 /* look for a thread at lockseq, a  */
4169 update_low_high(ksyn_wait_queue_t kwq, uint32_t lockseq)
4172 		kwq->kw_lowseq = lockseq;
4173 		kwq->kw_highseq = lockseq;
4175 		if (is_seqlower(lockseq, kwq->kw_lowseq) != 0)
4176 			kwq->kw_lowseq = lockseq;
4177 		if (is_seqhigher(lockseq, kwq->kw_highseq) != 0)
4178 			kwq->kw_highseq = lockseq;