Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SortedClients (0.24 sec)

  1. platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java

            synchronized (lock) {
                List<WorkerDaemonClient> sortedClients = CollectionUtils.sort(idleClients, comparingInt(WorkerDaemonClient::getUses));
                List<WorkerDaemonClient> clientsToStop = selectionFunction.transform(new ArrayList<>(sortedClients));
                if (!clientsToStop.isEmpty()) {
                    stopWorkers(clientsToStop);
                }
            }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 30 19:54:37 UTC 2024
    - 10K bytes
    - Viewed (0)
  2. pilot/pkg/xds/debug.go

    func (s *DiscoveryServer) Syncz(w http.ResponseWriter, req *http.Request) {
    	namespace := req.URL.Query().Get("namespace")
    
    	syncz := make([]SyncStatus, 0)
    	for _, con := range s.SortedClients() {
    		node := con.proxy
    		if node != nil && (namespace == "" || node.GetNamespace() == namespace) {
    			syncz = append(syncz, SyncStatus{
    				ProxyID:              node.ID,
    				ProxyType:            node.Type,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. pilot/pkg/xds/discovery.go

    			// Initialization not complete, skip
    			continue
    		}
    		clients = append(clients, con)
    	}
    	return clients
    }
    
    // SortedClients returns all currently connected clients in an ordered manner.
    // Sorting order priority is as follows: ClusterID, Namespace, ID.
    func (s *DiscoveryServer) SortedClients() []*Connection {
    	clients := s.Clients()
    	sort.Slice(clients, func(i, j int) bool {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 20:21:09 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top