shutdown all configured cluster monitors.
1874
@Override
	public void shutdownClusterMonitors() {
		for (String clusterName : clustersProvider.getClusterNames()) {
			ClusterMonitor<AggDataFromCluster> clusterMonitor = (ClusterMonitor<AggDataFromCluster>) AggregateClusterMonitor
					.findOrRegisterAggregateMonitor(clusterName);
			clusterMonitor.stopMonitor();
			clusterMonitor.getDispatcher().stopDispatcher();
		}
	}
998893
public static void shutdown() {
		UdpResources resources = udpResources.getAndSet(null);
		if (resources != null) {
			resources._dispose();
		}
	}
421617
private function shutdown(): void
    {
        $this->connectionPool->shutdown();

        foreach ($this->connectionHandlers as $connectionHandler) {
            $connectionHandler->shutdown();
        }

        while ($this->connectionPool->count() > 0) {
            $this->processConnectionPool();
        }

        $this->connectionPool->close();
    }
387024
def shutdown(self, exitcode=0):
        """"""
        logger.info("shutting down system stats and metadata service")
        self._system_stats.shutdown()
        self._meta.shutdown()

        if self._cloud:
            logger.info("stopping streaming files and file change observer")
            self._stop_file_observer()
            self._end_file_syncing(exitcode)

        self._run.history.close()
604013
private function shutDownEverything()
    {
        foreach ($this->clients as $client) {
            $this->disconnect($client);
        }
        $this->masterSocket->close();
        unset(
            $this->hooks,
            $this->address,
            $this->port,
            $this->timeout,
            $this->domain,
            $this->masterSocket,
            $this->maxClients,
            $this->maxRead,
            $this->clients,
            $this->readType
        );
    }
632914
def teardown(self):
        '''
        
        '''
        self.monitor_thread.stop()
        self.monitor_thread = None
        super(BaseMonitor, self).teardown()
992981
public synchronized void shutdown() {
    // mark this as no longer running
    active = false;

    if (rThread != null) {
      rThread.interrupt();
      rThread = null;
    }
    doShutdown();
  }
1263385
@Override
  public void stop(ShutdownModeAmp mode)
    throws Exception
  {
    super.stop(mode);
    
    Alarm alarm = _alarm;
    _alarm = null;

    if (alarm != null) {
      alarm.dequeue();
    }

    for (PortTcp port : _ports) {
      try {
        port.close();
      } catch (Throwable e) {
        log.log(Level.WARNING, e.toString(), e);
      }
    }
    
    _clusterService.stop();
  }
629590
def shutdown(self):
        
        log.debug('Shutting down %s' % self)
        self.disconnect_all()
        self._looping.clear()
189287
public static void shutdownCluster(Cluster cluster) {
    synchronized (clusters) {
      String clusterName = cluster.getName();
      if (clusters.get(clusterName) != null ) {
        cluster.getConnectionManager().shutdown();
        clusters.remove(clusterName);
      }
    }
  }
1195708
public void close() {
    reactor.stopAsync();
    if (runner != null) {
      runner.stopAsync();
    }
    metrics.supervisorClosed();
    monitor.close();
  }
1007450
public function shutdownProcesses()
    {
        foreach ($this->processes as $pid => $process) {
            unset($this->processes[$pid]);
    
            posix_kill($pid, SIGUSR1);
        }
    
        exit;
    }
690048
def shutdown(self):
        """"""
        for ware in self.middleware:
            ware.preshutdown()
            self._shutdown()
            ware.postshutdown()
944003
def shutdown(self):
        
        with self._lock:
            for cid in list(self.connections.keys()):
                if self.connections[cid].executing:
                    raise ConnectionBusyError(cid)
                if self.connections[cid].locked:
                    self.connections[cid].free()
                self.connections[cid].close()
                del self.connections[cid]
1163814
public void shutdown() {
        for (Entry<OpsSelector, OpsAgent> entry : m_agents.entrySet()) {
            try {
                entry.getValue().shutdown();
            }
            catch (InterruptedException e) {}
        }
        m_agents.clear();
    }
1099481
def shutdown(self):
        """"""
        for wsock in self.wsocks:
            wsock.shutdown()
        for api in self.apis:
            api.shutdown()
1067507
public void shutDownNow() throws InterruptedException {
        synchronized (CassandraEmbeddedServer.SEMAPHORE) {
            LOGGER.info("Calling stop on Embedded Cassandra server");
            cassandraDaemonRef.get().stop();

            LOGGER.info("Calling shutdown on all Cluster instances");
            // First call shutdown on all registered Java driver Cluster instances
            orderedShutdownHook.callShutDown();

            LOGGER.info("Shutting down embedded Cassandra server");
            // Then shutdown the server
            executor.shutdownNow();
            CassandraEmbeddedServer.embeddedServerStarted = false;
        }
    }