Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 227 for unpack (0.15 sec)

  1. 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)
  2. tensorflow/c/eager/parallel_device/parallel_device.cc

            status, TF_UNIMPLEMENTED,
            absl::StrCat(
                "Trying to copy a tensor out of a parallel device. Since there "
                "are multiple components to parallel tensors, they must be "
                "unpacked explicitly.\n",
                tensorflow::unwrap(tensor)->DebugString())
                .c_str());
        return nullptr;
      }
    }
    
    // For TFE_CustomDevice::execute in the parallel device registration.
    //
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  3. 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)
  4. 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 (2)
  5. 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)
  6. 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)
  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. 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)
  9. 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)
  10. internal/grid/muxclient.go

    	}
    	if m.subroute != nil {
    		msg.Flags |= FlagSubroute
    	}
    	ch := make(chan Response, 1)
    	m.respMu.Lock()
    	if m.closed {
    		m.respMu.Unlock()
    		return nil, ErrDisconnected
    	}
    	m.respWait = ch
    	m.respMu.Unlock()
    	ctx := m.ctx
    
    	// Add deadline if none.
    	if msg.DeadlineMS == 0 {
    		msg.DeadlineMS = uint32(defaultSingleRequestTimeout / time.Millisecond)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
Back to top