Home
last modified time | relevance | path

Searched refs:receiveScheduler (Results 1 – 16 of 16) sorted by relevance

/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
336 receiveScheduler.stop(); in closeInput()
659 while (!receiveScheduler.isStopped()) { in run()
674 receiveScheduler.stop(); in run()
695 receiveScheduler.stop(); in run()
703 receiveScheduler.stop(); in run()
708 receiveScheduler.stop(); in run()
766 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
334 receiveScheduler.stop(); in closeInput()
655 while (!receiveScheduler.isStopped()) { in run()
670 receiveScheduler.stop(); in run()
691 receiveScheduler.stop(); in run()
699 receiveScheduler.stop(); in run()
704 receiveScheduler.stop(); in run()
762 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.net.http/share/classes/jdk/internal/net/http/websocket/
H A DTransportImpl.java74 private final SequentialScheduler receiveScheduler; field in TransportImpl
96 receiveScheduler = new SequentialScheduler(new ReceiveTask()); in TransportImpl()
288 receiveScheduler.runOrSchedule(); in request()
336 receiveScheduler.stop(); in closeInput()
659 while (!receiveScheduler.isStopped()) { in run()
674 receiveScheduler.stop(); in run()
695 receiveScheduler.stop(); in run()
703 receiveScheduler.stop(); in run()
708 receiveScheduler.stop(); in run()
766 receiveScheduler.runOrSchedule(); in handle()
H A DWebSocketImpl.java115 private final SequentialScheduler receiveScheduler field in WebSocketImpl
359 receiveScheduler.runOrSchedule(); in request()
385 receiveScheduler.stop(); in abort()
423 while (!receiveScheduler.isStopped()) { in run()
483 receiveScheduler.stop(); in processError()
511 receiveScheduler.stop(); in processClose()
705 receiveScheduler.runOrSchedule(); in signalOpen()
837 receiveScheduler.runOrSchedule(); in trySetState()
853 receiveScheduler.runOrSchedule(); in tryChangeState()