Search Options

Results per page
Sort
Preferred Languages
Advance

Results 381 - 390 of 814 for cdone (0.03 sec)

  1. guava/src/com/google/common/hash/HashCode.java

       *
       * @since 15.0 (since 12.0 in HashCodes)
       */
      public static HashCode fromBytes(byte[] bytes) {
        checkArgument(bytes.length >= 1, "A HashCode must contain at least 1 byte.");
        return fromBytesNoCopy(bytes.clone());
      }
    
      /**
       * Creates a {@code HashCode} from a byte array. The array is <i>not</i> copied defensively, so it
       * must be handed-off so as to preserve the immutability contract of {@code HashCode}.
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 19:54:59 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  2. cmd/metacache-server-pool.go

    	listCtx, cancelList := context.WithCancel(ctx)
    	filteredResults := o.gatherResults(listCtx, filterCh)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	var listErr error
    
    	go func(o listPathOptions) {
    		defer wg.Done()
    		o.StopDiskAtLimit = true
    		listErr = z.listMerged(listCtx, o, filterCh)
    		o.debugln("listMerged returned with", listErr)
    	}(*o)
    
    	entries, err = filteredResults()
    	cancelList()
    	wg.Wait()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. cmd/common-main.go

    		// Baremetal setups set DNS refresh window up to dnsTTL duration.
    		t := time.NewTicker(dnsTTL)
    		defer t.Stop()
    		for {
    			select {
    			case <-t.C:
    				globalDNSCache.Refresh()
    
    			case <-GlobalContext.Done():
    				return
    			}
    		}
    	}()
    }
    
    type envKV struct {
    	Key   string
    	Value string
    	Skip  bool
    }
    
    func (e envKV) String() string {
    	if e.Skip {
    		return ""
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  4. internal/event/rulesmap_test.go

    	}{
    		{rulesMapCase1, rulesMapToAddCase1},
    		{rulesMapCase2, rulesMapToAddCase2},
    		{rulesMapCase3, rulesMapToAddCase3},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.rulesMap.Clone()
    
    		if !reflect.DeepEqual(result, testCase.rulesMap) {
    			t.Fatalf("test %v: result: expected: %v, got: %v", i+1, testCase.rulesMap, result)
    		}
    
    		result.Add(testCase.rulesMapToAdd)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jan 05 18:43:06 UTC 2024
    - 6.8K bytes
    - Viewed (0)
  5. cmd/object-lambda-handlers.go

    			InputS3URL:  u.String(),
    			OutputRoute: shortuuid.New(),
    			OutputToken: hex.EncodeToString(ckSum[:]),
    		},
    		UserRequest: levent.UserRequest{
    			URL:     r.URL.String(),
    			Headers: r.Header.Clone(),
    		},
    		UserIdentity: levent.Identity{
    			Type:        "IAMUser",
    			PrincipalID: cred.AccessKey,
    			AccessKeyID: cred.SecretKey,
    		},
    	}
    	return eventData, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. internal/lsync/lrwmutex.go

    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	retryCtx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	for {
    		select {
    		case <-retryCtx.Done():
    			// Caller context canceled or we timedout,
    			// return false anyways for both situations.
    			return false
    		default:
    			if lm.lock(id, source, isWriteLock) {
    				return true
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  7. cmd/lock-rest-server.go

    	lkTimer := time.NewTimer(lockMaintenanceInterval)
    	// Stop the timer upon returning.
    	defer lkTimer.Stop()
    
    	for {
    		// Verifies every minute for locks held more than 2 minutes.
    		select {
    		case <-ctx.Done():
    			return
    		case <-lkTimer.C:
    			globalLockServer.expireOldLocks(lockValidityDuration)
    
    			// Reset the timer for next cycle.
    			lkTimer.Reset(lockMaintenanceInterval)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  8. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package mockwebserver3
    
    import okhttp3.ExperimentalOkHttpApi
    
    /**
     * What should be done with the incoming socket.
     *
     * Be careful when using values like [DisconnectAtEnd], [ShutdownInputAtEnd]
     * and [ShutdownOutputAtEnd] that close a socket after a response, and where there are
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. docs/distributed/decom-encrypted-sse-s3.sh

    ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1}
    
    until $(./mc admin decom status myminio/ | grep -q Complete); do
    	echo "waiting for decom to finish..."
    	sleep 1
    done
    
    kill $pid_1
    kill $pid_2
    
    sleep 5
    
    (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) &
    pid=$!
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  10. cni/pkg/repair/netns.go

    	// There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*.
    	// We want the pause container, as the istio-validation one may exit before we are done.
    	// We do this by detecting the longest running process. We could look at `cmdline`, but is likely more reliable to weird platforms.
    	for _, p := range procs {
    		match := false
    		ns := getPidNamespace(p.PID)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 28 19:12:54 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top