Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 220 for unpack (0.07 sec)

  1. tensorflow/c/eager/c_api.cc

            TFE_DeleteTensorHandle(outputs[i]);
          }
        }
        return status.status;
      }
    
      absl::Status Pack(absl::Span<ImmediateExecutionTensorHandle*> handles,
                        ImmediateExecutionTensorHandle** result) override {
        TF_Status status;
        *result = tensorflow::unwrap(device_.pack(context_,
                                                  tensorflow::wrap(handles.data()),
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  2. cmd/sftp-server-driver.go

    	buffer map[int64][]byte
    	err    error
    
    	nextOffset int64
    	m          sync.Mutex
    }
    
    func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) {
    	w.m.Lock()
    	defer w.m.Unlock()
    
    	if w.nextOffset == offset {
    		n, err = w.w.Write(b)
    		w.nextOffset += int64(n)
    	} else {
    		if offset > w.nextOffset+ftpMaxWriteOffset {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. src/archive/tar/writer.go

    	// Check if we can use USTAR prefix/suffix splitting.
    	var namePrefix string
    	if prefix, suffix, ok := splitUSTARPath(hdr.Name); ok {
    		namePrefix, hdr.Name = prefix, suffix
    	}
    
    	// Pack the main header.
    	var f formatter
    	blk := tw.templateV7Plus(hdr, f.formatString, f.formatOctal)
    	f.formatString(blk.toUSTAR().prefix(), namePrefix)
    	blk.setFormat(FormatUSTAR)
    	if f.err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  4. internal/config/storageclass/storage-class.go

    	}
    	return sCfg.Optimize == "availability" || sCfg.Optimize == ""
    }
    
    // Update update storage-class with new config
    func (sCfg *Config) Update(newCfg Config) {
    	ConfigLock.Lock()
    	defer ConfigLock.Unlock()
    	sCfg.RRS = newCfg.RRS
    	sCfg.Standard = newCfg.Standard
    	sCfg.Optimize = newCfg.Optimize
    	sCfg.inlineBlock = newCfg.inlineBlock
    	sCfg.initialized = true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  5. cmd/local-locker_test.go

    	for i, names := range wResources {
    		arg := dsync.LockArgs{
    			UID:       wUIDs[i],
    			Resources: names[:],
    			Source:    "minio",
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.Unlock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    	}
    
    	// All should be gone now...
    	// Each Lock has m entries
    	if len(l.lockMap) != 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  6. cmd/bucket-policy-handlers_test.go

    				if _, ok := err.(BucketExists); !ok {
    					t.Logf("unexpected error: %T: %v", err, err)
    					return
    				}
    				mu.Lock()
    				errs++
    				mu.Unlock()
    				return
    			}
    			mu.Lock()
    			ok++
    			mu.Unlock()
    		}()
    	}
    	close(start)
    	wg.Wait()
    	if ok != 1 {
    		t.Fatalf("want 1 ok, got %d", ok)
    	}
    	if errs != n-1 {
    		t.Fatalf("want %d errors, got %d", n-1, errs)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  7. cmd/erasure-healing_test.go

    		copy(disks, newDisks)
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    	}
    	getDisk := func(n int) StorageAPI {
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock()
    		disk := disks[n]
    		objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock()
    		return disk
    	}
    
    	// Remove 4 disks.
    	setDisks(nil, nil, nil, nil)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Headers.kt

      /**
       * Returns the number of bytes required to encode these headers using HTTP/1.1. This is also the
       * approximate size of HTTP/2 headers before they are compressed with HPACK. This value is
       * intended to be used as a metric: smaller headers are more efficient to encode and transmit.
       */
      fun byteCount(): Long {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. cmd/batch-rotate.go

    	lock := api.NewNSLock(r.Bucket, objInfo.Name)
    	lkctx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return err
    	}
    	ctx = lkctx.Context()
    	defer lock.Unlock(lkctx)
    
    	opts := ObjectOptions{
    		VersionID:        objInfo.VersionID,
    		Versioned:        versioned,
    		VersionSuspended: versionSuspended,
    		NoLock:           true,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  10. cmd/utils.go

    // Returns current profile data, returns error if there is no active
    // profiling in progress. Stops an active profile.
    func getProfileData() (map[string][]byte, error) {
    	globalProfilerMu.Lock()
    	defer globalProfilerMu.Unlock()
    
    	if len(globalProfiler) == 0 {
    		return nil, errors.New("profiler not enabled")
    	}
    
    	dst := make(map[string][]byte, len(globalProfiler))
    	for typ, prof := range globalProfiler {
    		// Stop the profiler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
Back to top