Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 220 for unpack (0.11 sec)

  1. cmd/untar.go

    	mu sync.Mutex
    }
    
    func (d *disconnectReader) Read(p []byte) (n int, err error) {
    	d.mu.Lock()
    	defer d.mu.Unlock()
    	if d.r != nil {
    		return d.r.Read(p)
    	}
    	return 0, errors.New("reader closed")
    }
    
    func (d *disconnectReader) Close() error {
    	d.mu.Lock()
    	d.r = nil
    	d.mu.Unlock()
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. internal/http/server.go

    	if srv.listener == nil {
    		srv.listenerMutex.Unlock()
    		return http.ErrServerClosed
    	}
    	srv.listenerMutex.Unlock()
    
    	if atomic.AddUint32(&srv.inShutdown, 1) > 1 {
    		// shutdown in progress
    		return http.ErrServerClosed
    	}
    
    	// Close underneath HTTP listener.
    	srv.listenerMutex.Lock()
    	err := srv.listener.Close()
    	srv.listenerMutex.Unlock()
    	if err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. internal/store/queuestore.go

    		entryLimit: limit,
    		fileExt:    ext,
    		entries:    make(map[string]int64, limit),
    	}
    }
    
    // Open - Creates the directory if not present.
    func (store *QueueStore[_]) Open() error {
    	store.Lock()
    	defer store.Unlock()
    
    	if err := os.MkdirAll(store.directory, os.FileMode(0o770)); err != nil {
    		return err
    	}
    
    	files, err := store.list()
    	if err != nil {
    		return err
    	}
    
    	for _, file := range files {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. cmd/site-replication-utils.go

    						}()
    					}
    				}
    				wg.Wait()
    				sm.Unlock()
    			}
    			sTimer.Reset(siteResyncSaveInterval)
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    // update overall site resync state
    func (sm *siteResyncMetrics) updateState(s SiteResyncStatus) error {
    	if !globalSiteReplicationSys.isEnabled() {
    		return nil
    	}
    	sm.Lock()
    	defer sm.Unlock()
    	switch s.Status {
    	case ResyncStarted:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. cmd/http-stats.go

    	if stats == nil {
    		return
    	}
    	stats.Lock()
    	defer stats.Unlock()
    	if stats.apiStats == nil {
    		stats.apiStats = make(map[string]int)
    	}
    	stats.apiStats[api]++
    }
    
    // Dec increments the api stats counter.
    func (stats *HTTPAPIStats) Dec(api string) {
    	if stats == nil {
    		return
    	}
    	stats.Lock()
    	defer stats.Unlock()
    	if val, ok := stats.apiStats[api]; ok && val > 0 {
    		stats.apiStats[api]--
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. tensorflow/c/eager/BUILD

        srcs = [
            "c_api_experimental_reader.h",
        ],
        visibility = ["//tensorflow:__subpackages__"],
    )
    
    cc_library(
        name = "dlpack",
        srcs = ["dlpack.cc"],
        hdrs = ["dlpack.h"],
        copts = tf_copts() + [
            "-fexceptions",
            "-fno-strict-aliasing",
        ],
        features = ["-use_header_modules"],
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 11 23:52:39 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  7. cmd/bucket-metadata-sys.go

    		sys.group.Forget(bucket)
    		delete(sys.metadataMap, bucket)
    		globalBucketMonitor.DeleteBucket(bucket)
    	}
    	sys.Unlock()
    }
    
    // RemoveStaleBuckets removes all stale buckets in memory that are not on disk.
    func (sys *BucketMetadataSys) RemoveStaleBuckets(diskBuckets set.StringSet) {
    	sys.Lock()
    	defer sys.Unlock()
    
    	for bucket := range sys.metadataMap {
    		if diskBuckets.Contains(bucket) {
    			continue
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ForwardingLock.java

      }
    
      @Override
      public boolean tryLock(long time, TimeUnit unit) throws InterruptedException {
        return delegate().tryLock(time, unit);
      }
    
      @Override
      public void unlock() {
        delegate().unlock();
      }
    
      @Override
      public Condition newCondition() {
        return delegate().newCondition();
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  9. internal/lock/lock.go

    // IsClosed - Check if the rlocked file is already closed.
    func (r *RLockedFile) IsClosed() bool {
    	r.mutex.Lock()
    	defer r.mutex.Unlock()
    	return r.refs == 0
    }
    
    // IncLockRef - is used by called to indicate lock refs.
    func (r *RLockedFile) IncLockRef() {
    	r.mutex.Lock()
    	r.refs++
    	r.mutex.Unlock()
    }
    
    // Close - this closer implements a special closer
    // closes the underlying fd only when the refs
    // reach zero.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. internal/event/targetlist.go

    	list.statLock.Lock()
    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    		stats = targetStat{}
    	}
    
    	stats.currentSendCalls++
    	list.targetStats[id] = stats
    	return
    }
    
    func (list *TargetList) decCurrentSendCalls(id TargetID) {
    	list.statLock.Lock()
    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
Back to top