Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 220 for unpack (0.07 sec)

  1. cmd/lock-rest-client.go

    	return c.call(ctx, lockRPCUnlock, &args)
    }
    
    // ForceUnlock calls force unlock handler to forcibly unlock an active lock.
    func (c *lockRESTClient) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCForceUnlock, &args)
    }
    
    func newLockAPI(endpoint Endpoint) dsync.NetLocker {
    	if endpoint.IsLocal {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  2. prepare_stmt.go

    	// 3. g1 tx exec insert, wait for unlock `conn.PrepareContext(ctx, query)` to finish tx and release.
    	stmt, err := conn.PrepareContext(ctx, query)
    	if err != nil {
    		cacheStmt.prepareErr = err
    		db.Mux.Lock()
    		delete(db.Stmts, query)
    		db.Mux.Unlock()
    		return Stmt{}, err
    	}
    
    	db.Mux.Lock()
    	cacheStmt.Stmt = stmt
    	db.Mux.Unlock()
    
    	return cacheStmt, nil
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:02:05 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. internal/dsync/dsync-server_test.go

    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name
    		return false, fmt.Errorf("Unlock attempted on an unlocked entity: %s", args.Resources[0])
    	}
    	if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  4. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. 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: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  6. tensorflow/c/eager/dlpack_test.cc

    limitations under the License.
    ==============================================================================*/
    
    #include "tensorflow/c/eager/dlpack.h"
    
    #include <vector>
    
    #include "absl/strings/str_join.h"
    #include "include/dlpack/dlpack.h"  // from @dlpack
    #include "tensorflow/c/eager/c_api.h"
    #include "tensorflow/core/platform/test.h"
    
    namespace tensorflow {
    namespace {
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Jun 30 03:04:46 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  7. internal/ringbuffer/ring_buffer.go

    func (r *RingBuffer) Reset() {
    	r.mu.Lock()
    	defer r.mu.Unlock()
    
    	// Set error so any readers/writers will return immediately.
    	r.setErr(errors.New("reset called"), true)
    	if r.block {
    		r.readCond.Broadcast()
    		r.writeCond.Broadcast()
    	}
    
    	// Unlock the mutex so readers/writers can finish.
    	r.mu.Unlock()
    	r.wg.Wait()
    	r.mu.Lock()
    	r.r = 0
    	r.w = 0
    	r.err = nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  8. internal/dsync/drwmutex.go

    	// Caller may use this as an indication to call again.
    	return !checkFailedUnlocks(*locks, tolerance)
    }
    
    // Unlock unlocks the write lock.
    //
    // It is a run-time error if dm is not locked on entry to Unlock.
    func (dm *DRWMutex) Unlock(ctx context.Context) {
    	dm.m.Lock()
    	dm.cancelRefresh()
    	dm.m.Unlock()
    
    	restClnts, owner := dm.clnt.GetLockers()
    	// create temp array on stack
    	locks := make([]string, len(restClnts))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  9. cmd/local-locker.go

    	return concat(s, strconv.Itoa(idx))
    }
    
    func (l *localLocker) Unlock(_ context.Context, args dsync.LockArgs) (reply bool, err error) {
    	if len(args.Resources) > maxDeleteList {
    		return false, fmt.Errorf("internal error: localLocker.Unlock called with more than %d resources", maxDeleteList)
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	err = nil
    
    	for _, resource := range args.Resources {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. internal/store/batch.go

    	b.Lock()
    	defer b.Unlock()
    
    	if b.isFull() {
    		if b.store == nil {
    			return ErrBatchFull
    		}
    		// commit batch to store
    		if err := b.commit(); err != nil {
    			return err
    		}
    	}
    
    	b.items = append(b.items, item)
    	return nil
    }
    
    // Len returns the no of items in the batch
    func (b *Batch[_]) Len() int {
    	b.Lock()
    	defer b.Unlock()
    
    	return len(b.items)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top