Lines Matching defs:ACTIVE
945 * Execution control is managed using the ACTIVE ctl bit. We
952 * ACTIVE) that would otherwise race with producers or request()
1005 static final int ACTIVE = 0x01; // consumer task active
1063 (ctl & (ACTIVE | CONSUME)) != (ACTIVE | CONSUME)) ?
1197 else if ((c & ACTIVE) != 0) { // ensure keep-alive
1204 else if (CTL.compareAndSet(this, c, c | (ACTIVE | CONSUME))) {
1210 (c & ACTIVE) != 0 &&
1212 (this, c, c & ~ACTIVE));
1246 else if ((c & ACTIVE) != 0) {
1276 if ((c = ctl) == DISABLED || (c & ACTIVE) == 0)
1278 if (CTL.compareAndSet(this, c, c & ~ACTIVE)) {
1292 c | (ACTIVE | CONSUME | COMPLETE))) {
1293 if ((c & ACTIVE) == 0)
1305 c | (ACTIVE | CONSUME | SUBSCRIBE))) {
1306 if ((c & ACTIVE) == 0)
1322 else if ((c & ACTIVE) != 0) {
1347 else if ((c & ACTIVE) != 0) {
1354 c | (ACTIVE|CONSUME))) {
1506 else if (CTL.compareAndSet(this, c, c & ~ACTIVE))
1520 else if (CTL.compareAndSet(this, c, c & ~ACTIVE))