Lines Matching refs:node
747 QNode node = new QNode(this, phase, true, false, 0L);
748 p = root.internalAwaitAdvance(phase, node);
749 if (node.wasInterrupted)
785 QNode node = new QNode(this, phase, true, true, nanos);
786 p = root.internalAwaitAdvance(phase, node);
787 if (node.wasInterrupted)
1019 * Call only from root node.
1022 * @param node if non-null, the wait node to track interrupt and timeout;
1026 private int internalAwaitAdvance(int phase, QNode node) {
1028 boolean queued = false; // true when node is enqueued
1034 if (node == null) { // spinning in noninterruptible mode
1040 if (interrupted || --spins < 0) { // need node to record intr
1041 node = new QNode(this, phase, false, false, 0L);
1042 node.wasInterrupted = interrupted;
1045 else if (node.isReleasable()) // done or aborted
1049 QNode q = node.next = head.get();
1052 queued = head.compareAndSet(q, node);
1056 ForkJoinPool.managedBlock(node);
1058 node.wasInterrupted = true;
1063 if (node != null) {
1064 if (node.thread != null)
1065 node.thread = null; // avoid need for unpark()
1066 if (node.wasInterrupted && !node.interruptible)