Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 62 for getLoc (0.2 sec)

  1. internal/lsync/lrwmutex_test.go

    	// fmt.Println("Getting initial write lock")
    	if !lrwm.GetLock(ctx, "", "", time.Second) {
    		panic("Failed to acquire initial write lock")
    	}
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.Unlock()
    		// fmt.Println("Initial write lock released, waiting...")
    	}()
    
    	// fmt.Println("Trying to acquire 2nd write lock, waiting...")
    	locked = lrwm.GetLock(ctx, "", "", duration)
    	if locked {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  2. internal/dsync/drwmutex_test.go

    	}()
    
    	drwm3 := NewDRWMutex(ds, "simplelock")
    	// fmt.Println("Trying to acquire write lock, waiting...")
    	ctx3, cancel3 := context.WithCancel(context.Background())
    	locked = drwm3.GetLock(ctx3, cancel3, id, source, Options{Timeout: duration})
    	if locked {
    		// fmt.Println("Write lock acquired, waiting...")
    		time.Sleep(testDrwMutexAcquireTimeout)
    
    		drwm3.Unlock(context.Background())
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 24 03:49:07 UTC 2022
    - 9.7K bytes
    - Viewed (0)
  3. cmd/shared-lock.go

    	lockContext chan LockContext
    }
    
    func (ld sharedLock) backgroundRoutine(ctx context.Context, objAPI ObjectLayer, lockName string) {
    	for {
    		locker := objAPI.NewNSLock(minioMetaBucket, lockName)
    		lkctx, err := locker.GetLock(ctx, sharedLockTimeout)
    		if err != nil {
    			continue
    		}
    
    	keepLock:
    		for {
    			select {
    			case <-ctx.Done():
    				return
    			case <-lkctx.Context().Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/core/beans/util/BeanUtilTest.java

             */
            public void setBbb(final String bbb) {
                this.bbb = bbb;
            }
    
            /**
             * @return Returns the ccc.
             */
            public String getCcc() {
                return ccc;
            }
    
            /**
             * @param ccc
             *            The ccc to set.
             */
            public void setCcc(final String ccc) {
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/pac/kerberos/KerberosPacAuthData.java

        private Pac pac;
    
    
        public KerberosPacAuthData ( byte[] token, Map<Integer, KerberosKey> keys ) throws PACDecodingException {
            this.pac = new Pac(token, keys);
        }
    
    
        public Pac getPac () {
            return this.pac;
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.2K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/OperatingSystemProfileActivator.java

            Activation activation = profile.getActivation();
    
            if (activation == null) {
                return false;
            }
    
            ActivationOS os = activation.getOs();
    
            if (os == null) {
                return false;
            }
    
            boolean active = ensureAtLeastOneNonNull(os);
    
            String actualOsName = context.getSystemProperties()
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultMavenExecutionRequestPopulator.java

            }
        }
    
        private void baseDirectory(MavenExecutionRequest request) {
            if (request.getBaseDirectory() == null && request.getPom() != null) {
                request.setBaseDirectory(request.getPom().getAbsoluteFile().getParentFile());
            }
        }
    
        /*if_not[MAVEN4]*/
    
        @Override
        @Deprecated
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/lsync/lrwmutex.go

    func (lm *LRWMutex) Lock() {
    	const isWriteLock = true
    	lm.lockLoop(context.Background(), lm.id, lm.source, math.MaxInt64, isWriteLock)
    }
    
    // GetLock tries to get a write lock on lm before the timeout occurs.
    func (lm *LRWMutex) GetLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) {
    	const isWriteLock = true
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/profiles/activation/OperatingSystemProfileActivator.java

            Activation activation = profile.getActivation();
            return activation != null && activation.getOs() != null;
        }
    
        public boolean isActive(Profile profile) {
            Activation activation = profile.getActivation();
            ActivationOS os = activation.getOs();
    
            boolean result = ensureAtLeastOneNonNull(os);
    
            if (result && os.getFamily() != null) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/core/log/JclLoggerAdapter.java

        protected final String sourceClass;
    
        protected final Log logger;
    
        public JclLoggerAdapter(final Class<?> clazz) {
            sourceClass = clazz.getName();
            logger = LogFactory.getLog(clazz);
        }
    
        @Override
        public boolean isFatalEnabled() {
            return logger.isFatalEnabled();
        }
    
        @Override
        public void fatal(final String message) {
            logger.fatal(message);
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 2.6K bytes
    - Viewed (0)
Back to top