Searched refs:spins (Results 1 – 6 of 6) sorted by relevance
1035 for (int spins = -1;;) { // spin while enqueuing in acquireWrite()1041 else if (spins < 0) in acquireWrite()1042 spins = (m == WBIT && wtail == whead) ? SPINS : 0; in acquireWrite()1043 else if (spins > 0) { in acquireWrite()1045 --spins; in acquireWrite()1063 for (int spins = -1;;) { in acquireWrite()1066 if (spins < 0) in acquireWrite()1067 spins = HEAD_SPINS; in acquireWrite()1068 else if (spins < MAX_HEAD_SPINS) in acquireWrite()1069 spins <<= 1; in acquireWrite()[all …]
378 for (int h = p.hash, spins = SPINS;;) { in arenaExchange()386 else if (spins > 0) { in arenaExchange()391 (--spins & ((SPINS >>> 1) - 1)) == 0) in arenaExchange()395 spins = SPINS; // releaser hasn't set match yet in arenaExchange()486 int spins = (NCPU > 1) ? SPINS : 1; in slotExchange() local489 if (spins > 0) { in slotExchange()493 else if (h < 0 && (--spins & ((SPINS >>> 1) - 1)) == 0) in slotExchange()497 spins = SPINS; in slotExchange()
438 int spins = shouldSpin(s) in awaitFulfill() local454 if (spins > 0) in awaitFulfill()455 spins = shouldSpin(s) ? (spins - 1) : 0; in awaitFulfill()739 int spins = (head.next == s) in awaitFulfill() local755 if (spins > 0) in awaitFulfill()756 --spins; in awaitFulfill()
1036 int spins = SPINS_PER_ARRIVAL; in internalAwaitAdvance() local1044 spins += SPINS_PER_ARRIVAL; in internalAwaitAdvance()1046 if (interrupted || --spins < 0) { // need node to record intr in internalAwaitAdvance()
696 int spins = -1; // initialized after first item and cancel checks in awaitMatch() local712 else if (spins < 0) { // establish spins at/near front in awaitMatch()713 if ((spins = spinsFor(pred, s.isData)) > 0) in awaitMatch()716 else if (spins > 0) { // spin in awaitMatch()717 --spins; in awaitMatch()
1739 int spins = SPINS; in waitingGet() local1742 if (spins > 0) { in waitingGet()1744 --spins; in waitingGet()