Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 191 for Locks (0.02 seconds)

  1. .teamcity/src/main/kotlin/promotion/BasePromotionBuildType.kt

                // we only allow 1 promotion job running at the same time to avoid website xml conflicts
                feature {
                    type = "JetBrains.SharedResources"
                    param("locks-param", "WebsiteReleasesXml writeLock")
                }
            }
        }
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 30 04:44:29 GMT 2026
    - 2.2K bytes
    - Click Count (0)
  2. internal/dsync/lock-args.go

    	Resources []string
    
    	// Owner represents unique ID for this instance, an owner who originally requested
    	// the locked resource, useful primarily in figuring out stale locks.
    	Owner string
    
    	// Source contains the line number, function and file name of the code
    	// on the client node that requested the lock.
    	Source string `msgp:"omitempty"`
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jul 24 10:24:01 GMT 2024
    - 1.8K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java

    import jcifs.internal.smb2.ServerMessageBlock2Response;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Lock response message. This response acknowledges the successful
     * acquisition or release of byte-range locks.
     *
     * @author mbechler
     *
     */
    public class Smb2LockResponse extends ServerMessageBlock2Response {
    
        /**
         * Constructs an SMB2 lock response with the given configuration.
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  4. cmd/local-locker.go

    	}
    	// Wait for mutex
    	defer l.getMutex()()
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    	if !l.canTakeLock(args.Resources...) {
    		// Not all locks can be taken on resources,
    		// reject it completely.
    		return false, nil
    	}
    
    	// No locks held on the all resources, so claim write
    	// lock on all resources at once.
    	now := UTCNow()
    	for i, resource := range args.Resources {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12K bytes
    - Click Count (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Call.kt

       * to all callers.
       *
       * If computing multiple values is problematic, use an appropriate concurrency mechanism in your
       * [computeIfAbsent] implementation. No locks are held while calling this function.
       */
      fun <T : Any> tag(
        type: KClass<T>,
        computeIfAbsent: () -> T,
      ): T
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Nov 05 18:28:35 GMT 2025
    - 6.8K bytes
    - Click Count (0)
  6. internal/lock/lock.go

    // RLockedFile represents a read locked file, implements a special
    // closer which only closes the associated *os.File when the ref count.
    // has reached zero, i.e when all the readers have given up their locks.
    type RLockedFile struct {
    	*LockedFile
    	mutex sync.Mutex
    	refs  int // Holds read lock refs.
    }
    
    // IsClosed - Check if the rlocked file is already closed.
    func (r *RLockedFile) IsClosed() bool {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.5K bytes
    - Click Count (0)
  7. cmd/admin-handlers_test.go

    			UID:    uuid,
    			Owner:  owners[i%len(owners)],
    			Group:  true,
    			Quorum: 3,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = []lockRequesterInfo{lri}
    	}
    
    	// Add a few concurrent read locks to the mix
    	for i := range 50 {
    		resource := fmt.Sprintf("bucket/get-object-%d", i)
    		lri := lockRequesterInfo{
    			Name:   resource,
    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.9K bytes
    - Click Count (1)
  8. src/main/java/jcifs/SmbResourceException.java

                return "Free up disk space or use a different location";
            case QUOTA:
                return "Contact administrator to increase quota limits";
            case LOCK:
                return "Release existing locks or wait for them to be released";
            case BUFFER:
                return "Reduce buffer usage or increase buffer pool size";
            case THREAD_POOL:
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  9. cmd/namespace-lock_test.go

    		//    a new entry in lockMap and acquires a lock for the same resource.
    
    		<-lk2ch
    		lk3ok := <-lk3ch
    		lk4ok := <-lk4ch
    
    		if lk3ok && lk4ok {
    			t.Fatalf("multiple locks acquired; iteration=%d, lk3=%t, lk4=%t", i, lk3ok, lk4ok)
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  10. doc/godebug.md

    distribution that disables transparent huge pages altogether.
    
    Go 1.22 added contention on runtime-internal locks to the [`mutex`
    profile](/pkg/runtime/pprof#Profile). Contention on these locks is always
    reported at `runtime._LostContendedRuntimeLock`. Complete stack traces of
    runtime locks can be enabled with the [`runtimecontentionstacks`
    setting](/pkg/runtime#hdr-Environment_Variables). These stack traces have
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Fri Mar 20 15:49:10 GMT 2026
    - 26K bytes
    - Click Count (0)
Back to Top