- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SortedClients (0.24 sec)
-
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) -
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) -
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)