Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 640 for Oplock (0.24 seconds)

  1. src/main/java/org/codelibs/core/exception/IllegalBlockSizeRuntimeException.java

     */
    package org.codelibs.core.exception;
    
    import javax.crypto.IllegalBlockSizeException;
    
    /**
     * Signals that this exception has been thrown when a block cipher is supplied with input data whose length is not a multiple of the cipher's block size, or that has been padded to the wrong length.
     * @author shinsuke
     */
    public class IllegalBlockSizeRuntimeException extends ClRuntimeException {
    
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Jul 05 00:11:05 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  2. cmd/erasure-object_test.go

    		t.Fatal(err)
    	}
    
    	erasureDisks := xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		for i := range erasureDisks[:6] {
    			erasureDisks[i] = newNaughtyDisk(erasureDisks[i], nil, errFaultyDisk)
    		}
    		return erasureDisks
    	}
    
    	z.serverPools[0].erasureDisksMu.Unlock()
    	_, err = obj.DeleteObject(ctx, bucket, object, ObjectOptions{})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.3K bytes
    - Click Count (0)
  3. build-logic/build-update-utils/src/main/kotlin/gradlebuild/buildutils/runtimes/CheckTargetRuntimes.kt

                    val lines = listOf("""
                        Failed to automatically fix project build files.
                        Make sure each project has a gradleModule.computedRuntimes block directly below the dependencies block:
    
                        ```
                        dependencies {
                            // ...
                        }
    
                        gradleModule {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Wed Mar 11 22:40:18 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  4. internal/dsync/locked_rand.go

    func (r *lockedRandSource) Int63() (n int64) {
    	r.lk.Lock()
    	n = r.src.Int63()
    	r.lk.Unlock()
    	return n
    }
    
    // Seed uses the provided seed value to initialize the generator to a
    // deterministic state.
    func (r *lockedRandSource) Seed(seed int64) {
    	r.lk.Lock()
    	r.src.Seed(seed)
    	r.lk.Unlock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  5. docs/debugging/xl-meta/main.go

    				combineShared := combineSharedBlocks[block]
    			nextAttempt:
    				fmt.Printf("Block %d, Base version %q. Part %d. Files %d\n", block+1, key, part, len(file))
    				m, err := readAndMap(file, part, block)
    				if err != nil {
    					return err
    				}
    				if exportedSizes[m.objSize] {
    					fmt.Println("Skipping version", key, "as it has already been exported.")
    					continue nextFile
    				}
    				addedFiles := 0
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.4K bytes
    - Click Count (0)
  6. tests/query_test.go

    func TestPluck(t *testing.T) {
    	users := []*User{
    		GetUser("pluck-user1", Config{}),
    		GetUser("pluck-user2", Config{}),
    		GetUser("pluck-user3", Config{}),
    	}
    
    	DB.Create(&users)
    
    	var names []string
    	if err := DB.Model(User{}).Where("name like ?", "pluck-user%").Order("name").Pluck("name", &names).Error; err != nil {
    		t.Errorf("got error when pluck name: %v", err)
    	}
    
    	var names2 []string
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Jul 22 06:21:04 GMT 2025
    - 51K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

          }
        }
    
        @Override
        public void signal() {
          lock.lock();
          try {
            condition.signal();
          } finally {
            lock.unlock();
          }
        }
    
        @Override
        public void signalAll() {
          lock.lock();
          try {
            condition.signalAll();
          } finally {
            lock.unlock();
          }
        }
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 38.1K bytes
    - Click Count (0)
  8. cmd/bucket-replication-stats.go

    		case <-ctx.Done():
    			return
    		case <-r.wTimer.C:
    			r.wlock.Lock()
    			r.workers.update()
    			r.wlock.Unlock()
    		}
    	}
    }
    
    func (r *ReplicationStats) collectQueueMetrics(ctx context.Context) {
    	if r == nil {
    		return
    	}
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-r.qTimer.C:
    			r.qCache.update()
    		}
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 13.6K bytes
    - Click Count (0)
  9. cmd/test-utils_test.go

    func resetGlobalObjectAPI() {
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = nil
    	globalObjLayerMutex.Unlock()
    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  10. cmd/globals.go

    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    	globalAuthPluginMutex.Lock()
    	globalAuthNPlugin = authn
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Sep 03 18:23:41 GMT 2024
    - 16.2K bytes
    - Click Count (1)
Back to Top