Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 577 for rest (0.02 sec)

  1. cmd/lock-rest-server.go

    	ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall)
    	defer cancel()
    
    	resp := lockRPCRefresh.NewResponse()
    	refreshed, err := l.ll.Refresh(ctx, *args)
    	if err != nil {
    		return l.makeResp(resp, err)
    	}
    	if !refreshed {
    		return l.makeResp(resp, errLockNotFound)
    	}
    	return l.makeResp(resp, err)
    }
    
    // LockHandler - Acquires a lock.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jan 31 19:54:34 UTC 2025
    - 6.3K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	res := make([]*MetricV2, 0, len(resourceMetricsGroups))
    	populateAndPublish(resourceMetricsGroups, func(m MetricV2) bool {
    		if m.VariableLabels == nil {
    			m.VariableLabels = make(map[string]string, 1)
    		}
    		m.VariableLabels[serverName] = globalLocalNodeName
    		res = append(res, &m)
    		return true
    	})
    	return aoMetricsGroup.NewWith(res), nil
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	})
    	if err != nil {
    		return cache, toStorageErr(err)
    	}
    	var final *dataUsageCache
    	err = st.Results(func(resp *nsScannerResp) error {
    		if resp.Update != nil {
    			select {
    			case <-ctx.Done():
    			case updates <- *resp.Update:
    			}
    		}
    		if resp.Final != nil {
    			final = resp.Final
    		}
    		// We can't reuse the response since it is sent upstream.
    		return nil
    	})
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  4. cmd/storage-rest-server.go

    		for update := range updates {
    			resp := storageNSScannerRPC.NewResponse()
    			resp.Update = &update
    			out <- resp
    		}
    	}()
    	ui, err := s.getStorage().NSScanner(ctx, *params.Cache, updates, madmin.HealScanMode(params.ScanMode), nil)
    	wg.Wait()
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    	// Send final response.
    	resp := storageNSScannerRPC.NewResponse()
    	resp.Final = &ui
    	out <- resp
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  5. cmd/lock-rest-client_test.go

    Harshavardhana <******@****.***> 1744208919 -0700
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2K bytes
    - Viewed (0)
  6. cmd/lock-rest-server-common_test.go

    		},
    	}
    	creds := globalActiveCred
    	token, err := authenticateNode(creds.AccessKey, creds.SecretKey)
    	if err != nil {
    		t.Fatal(err)
    	}
    	return fsDir, locker, token
    }
    
    // Test function to remove lock entries from map based on name & uid combination
    func TestLockRpcServerRemoveEntry(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/base/Joiner.java

      }
    
      private static Iterable<@Nullable Object> iterable(
          @Nullable Object first, @Nullable Object second, @Nullable Object[] rest) {
        checkNotNull(rest);
        return new AbstractList<@Nullable Object>() {
          @Override
          public int size() {
            return rest.length + 2;
          }
    
          @Override
          public @Nullable Object get(int index) {
            switch (index) {
              case 0:
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 19.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/ReverseOrdering.java

        return forwardOrder.max(a, b);
      }
    
      @Override
      public <E extends T> E min(
          @ParametricNullness E a, @ParametricNullness E b, @ParametricNullness E c, E... rest) {
        return forwardOrder.max(a, b, c, rest);
      }
    
      @Override
      public <E extends T> E min(Iterator<E> iterator) {
        return forwardOrder.max(iterator);
      }
    
      @Override
      public <E extends T> E min(Iterable<E> iterable) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jun 04 13:03:16 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ReverseOrdering.java

        return forwardOrder.max(a, b);
      }
    
      @Override
      public <E extends T> E min(
          @ParametricNullness E a, @ParametricNullness E b, @ParametricNullness E c, E... rest) {
        return forwardOrder.max(a, b, c, rest);
      }
    
      @Override
      public <E extends T> E min(Iterator<E> iterator) {
        return forwardOrder.max(iterator);
      }
    
      @Override
      public <E extends T> E min(Iterable<E> iterable) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jun 04 13:03:16 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/primitives/ImmutableLongArray.java

       *
       * <p>The array {@code rest} must not be longer than {@code Integer.MAX_VALUE - 1}.
       */
      // Use (first, rest) so that `of(someLongArray)` won't compile (they should use copyOf), which is
      // okay since we have to copy the just-created array anyway.
      public static ImmutableLongArray of(long first, long... rest) {
        checkArgument(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 22K bytes
    - Viewed (0)
Back to top