Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. internal/bucket/bandwidth/monitor.go

    		}
    	}
    }
    
    func (m *Monitor) updateMovingAvg() {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    	for _, bucketMeasurement := range m.bucketsMeasurement {
    		bucketMeasurement.updateExponentialMovingAverage(time.Now())
    	}
    }
    
    func (m *Monitor) init(opts BucketOptions) {
    	m.mlock.Lock()
    	defer m.mlock.Unlock()
    
    	_, ok := m.bucketsMeasurement[opts]
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. cmd/metacache-manager.go

    	m.init.Do(m.initManager)
    	m.mu.Lock()
    	b, ok := m.buckets[bucket]
    	if !ok {
    		m.mu.Unlock()
    		return
    	}
    	delete(m.buckets, bucket)
    	m.mu.Unlock()
    
    	// Since deletes may take some time we try to do it without
    	// holding lock to m all the time.
    	b.mu.Lock()
    	defer b.mu.Unlock()
    	for k, v := range b.caches {
    		if time.Since(v.lastUpdate) > metacacheMaxRunningAge {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  9. 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)
  10. cmd/bucket-targets.go

    	sys.hMutex.Lock()
    	defer sys.hMutex.Unlock()
    	if h, ok := sys.hc[ep.Host]; ok {
    		h.Online = false
    		sys.hc[ep.Host] = h
    	}
    }
    
    func (sys *BucketTargetSys) initHC(ep *url.URL) {
    	sys.hMutex.Lock()
    	sys.hc[ep.Host] = epHealth{
    		Endpoint: ep.Host,
    		Scheme:   ep.Scheme,
    		Online:   true,
    	}
    	sys.hMutex.Unlock()
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top