| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/executor/ |
| H A D | Executor.scala | 163 def killTask(taskId: Long, interruptThread: Boolean): Unit = {
170 case Some(existingReaper) => interruptThread && !existingReaper.interruptThread
173 val taskReaper = new TaskReaper(taskRunner, interruptThread = interruptThread)
183 taskRunner.kill(interruptThread = interruptThread)
194 def killAllTasks(interruptThread: Boolean) : Unit = {
195 runningTasks.keys().asScala.foreach(t => killTask(t, interruptThread = interruptThread))
245 def kill(interruptThread: Boolean): Unit = {
251 task.kill(interruptThread)
499 val interruptThread: Boolean) constant
520 taskRunner.kill(interruptThread = interruptThread)
|
| H A D | CoarseGrainedExecutorBackend.scala | 101 case KillTask(taskId, _, interruptThread) =>
105 executor.killTask(taskId, interruptThread)
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/local/ |
| H A D | LocalSchedulerBackend.scala | 37 private case class KillTask(taskId: Long, interruptThread: Boolean)
73 case KillTask(taskId, interruptThread) =>
74 executor.killTask(taskId, interruptThread)
147 override def killTask(taskId: Long, executorId: String, interruptThread: Boolean) {
148 localEndpoint.send(KillTask(taskId, interruptThread))
|
| /dports/www/wt/wt-4.6.1/src/web/ |
| H A D | SocketNotifier.C | 92 interruptThread(); in ~SocketNotifier()
259 void SocketNotifier::interruptThread() in interruptThread() function
384 interruptThread(); in addReadSocket()
391 interruptThread(); in addWriteSocket()
398 interruptThread(); in addExceptSocket()
409 interruptThread(); in removeReadSocket()
421 interruptThread(); in removeWriteSocket()
429 interruptThread(); in removeExceptSocket()
|
| H A D | SocketNotifier.h | 36 void interruptThread();
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(stdcxx::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/www/fabio/fabio-1.5.14/vendor/github.com/apache/thrift/thrift-da1169d75b15/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(stdcxx::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-c_glib/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift-cpp/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/apache/thrift/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/node-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/py-thrift/thrift-0.14.0/lib/cpp/test/ |
| H A D | TPipeInterruptTest.cpp | 74 boost::thread interruptThread(std::bind(interruptWorker, &pipeServer)); in BOOST_AUTO_TEST_CASE() local
84 interruptThread.join(); in BOOST_AUTO_TEST_CASE()
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/ |
| H A D | Task.scala | 92 kill(interruptThread = false)
193 def kill(interruptThread: Boolean) {
198 if (interruptThread && taskThread != null) {
|
| H A D | SchedulerBackend.scala | 33 def killTask(taskId: Long, executorId: String, interruptThread: Boolean): Unit =
|
| H A D | TaskScheduler.scala | 55 def cancelTasks(stageId: Int, interruptThread: Boolean): Unit
|
| H A D | TaskSchedulerImpl.scala | 215 override def cancelTasks(stageId: Int, interruptThread: Boolean): Unit = synchronized {
227 backend.killTask(tid, execId, interruptThread)
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/scheduler/cluster/ |
| H A D | CoarseGrainedSchedulerBackend.scala | 140 case KillTask(taskId, executorId, interruptThread) =>
143 executorInfo.executorEndpoint.send(KillTask(taskId, executorId, interruptThread))
409 override def killTask(taskId: Long, executorId: String, interruptThread: Boolean) {
410 driverEndpoint.send(KillTask(taskId, executorId, interruptThread))
|
| H A D | CoarseGrainedClusterMessage.scala | 43 case class KillTask(taskId: Long, executor: String, interruptThread: Boolean)
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/activation/ |
| H A D | ProcessMonitorThread.java | 102 static void interruptThread( ) { in interruptThread() method in ProcessMonitorThread
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/corba/src/share/classes/com/sun/corba/se/impl/activation/ |
| H A D | ProcessMonitorThread.java | 102 static void interruptThread( ) { in interruptThread() method in ProcessMonitorThread
|
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
| H A D | ExternalClusterManagerSuite.scala | 81 override def cancelTasks(stageId: Int, interruptThread: Boolean): Unit = {}
|
| /dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/executor/ |
| H A D | MesosExecutorBackend.scala | 108 executor.killTask(t.getValue.toLong, interruptThread = false)
|
| /dports/devel/spark/spark-2.1.1/mesos/src/main/scala/org/apache/spark/scheduler/cluster/mesos/ |
| H A D | MesosFineGrainedSchedulerBackend.scala | 435 override def killTask(taskId: Long, executorId: String, interruptThread: Boolean): Unit = {
|