Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,074 for Unlock1 (0.22 sec)

  1. src/runtime/metrics_test.go

    // and a Lock call.
    type locker2 interface {
    	Lock1()
    	Unlock1()
    	Lock2()
    	Unlock2()
    }
    
    type mutex struct {
    	mu sync.Mutex
    }
    
    func (m *mutex) Lock1()   { m.mu.Lock() }
    func (m *mutex) Unlock1() { m.mu.Unlock() }
    func (m *mutex) Lock2()   { m.mu.Lock() }
    func (m *mutex) Unlock2() { m.mu.Unlock() }
    
    type rwmutexWrite struct {
    	mu sync.RWMutex
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:52:17 UTC 2024
    - 45K bytes
    - Viewed (0)
  2. src/cmd/go/internal/lockedfile/lockedfile_test.go

    		t.Logf("unlock2()")
    		unlock2()
    	})
    
    	t.Logf("unlock()")
    	unlock()
    	wait(t)
    }
    
    func TestReadWaitsForLock(t *testing.T) {
    	t.Parallel()
    
    	dir, remove := mustTempDir(t)
    	defer remove()
    
    	path := filepath.Join(dir, "timestamp.txt")
    
    	f, err := lockedfile.Create(path)
    	if err != nil {
    		t.Fatalf("Create: %v", err)
    	}
    	defer f.Close()
    
    	const (
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 05 23:35:29 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  3. src/sync/mutex_test.go

    		},
    	},
    	{
    		"Mutex.Unlock2",
    		func() {
    			var mu Mutex
    			mu.Lock()
    			mu.Unlock()
    			mu.Unlock()
    		},
    	},
    	{
    		"RWMutex.Unlock",
    		func() {
    			var mu RWMutex
    			mu.Unlock()
    		},
    	},
    	{
    		"RWMutex.Unlock2",
    		func() {
    			var mu RWMutex
    			mu.RLock()
    			mu.Unlock()
    		},
    	},
    	{
    		"RWMutex.Unlock3",
    		func() {
    			var mu RWMutex
    			mu.Lock()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 16 21:25:35 UTC 2022
    - 5.9K bytes
    - Viewed (0)
  4. src/cmd/go/internal/lockedfile/internal/filelock/filelock_fcntl.go

    	}
    
    	if err != nil {
    		unlock(f)
    		return &fs.PathError{
    			Op:   lt.String(),
    			Path: f.Name(),
    			Err:  err,
    		}
    	}
    
    	return nil
    }
    
    func unlock(f File) error {
    	var owner File
    
    	mu.Lock()
    	ino, ok := inodes[f]
    	if ok {
    		owner = locks[ino].owner
    	}
    	mu.Unlock()
    
    	if owner != f {
    		panic("unlock called on a file that is not locked")
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 17 02:24:35 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java

        protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) throws SMBProtocolDecodingException {
            int start = bufferIndex;
            for ( int i = 0; i < this.unlocks.length; i++ ) {
                this.unlocks[ i ] = createLockRange();
                bufferIndex += this.unlocks[ i ].decode(buffer, bufferIndex, buffer.length);
            }
    
            for ( int i = 0; i < this.locks.length; i++ ) {
                this.locks[ i ] = createLockRange();
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 4.9K bytes
    - Viewed (0)
  6. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy

            true        | false       | RETRY
            false       | true        | RETRY
            false       | false       | FINISHED
        }
    
        def "can unlock resources with unlock"() {
            def lock1 = resourceLock("lock1", lock1Locked, true)
            def lock2 = resourceLock("lock1", lock2Locked, true)
    
            when:
            def disposition = null
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  7. src/runtime/chan.go

    	gp.parkingOnChan.Store(false)
    	// Make sure we unlock after setting activeStackChans and
    	// unsetting parkingOnChan. The moment we unlock chanLock
    	// we risk gp getting readied by a channel operation and
    	// so gp could continue running before everything before
    	// the unlock is visible (even to gp itself).
    	unlock((*mutex)(chanLock))
    	return true
    }
    
    // compiler implements
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:50 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        Lock lockB = factory.newReentrantLock(OtherOrder.SECOND);
    
        lockA.lock();
        lockA.lock();
        lockB.lock();
        lockB.lock();
        lockA.unlock();
        lockA.unlock();
        lockB.unlock();
        lockB.unlock();
      }
    
      public void testExplicitOrdering_acquiringMultipleLocksWithSameRank() {
        CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        Lock lockB = factory.newReentrantLock(OtherOrder.SECOND);
    
        lockA.lock();
        lockA.lock();
        lockB.lock();
        lockB.lock();
        lockA.unlock();
        lockA.unlock();
        lockB.unlock();
        lockB.unlock();
      }
    
      public void testExplicitOrdering_acquiringMultipleLocksWithSameRank() {
        CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  10. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java

            return tryLock(Arrays.asList(resourceLocks));
        }
    
        /**
         * Unlocks the provided resource locks.
         */
        public static InternalTransformer<ResourceLockState.Disposition, ResourceLockState> unlock(Iterable<? extends ResourceLock> resourceLocks) {
            return new ReleaseLocks(resourceLocks);
        }
    
        /**
         * Unlocks the provided resource locks.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 17:16:10 UTC 2024
    - 11.9K bytes
    - Viewed (0)
Back to top