Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 227 for unpack (0.06 sec)

  1. cmd/erasure-decode.go

    				}
    				p.readers[i] = nil
    
    				// Since ReadAt returned error, trigger another read.
    				readTriggerCh <- true
    				return
    			}
    			newBufLK.Lock()
    			newBuf[bufIdx] = p.buf[bufIdx][:n]
    			newBufLK.Unlock()
    			// Since ReadAt returned success, there is no need to trigger another read.
    			readTriggerCh <- false
    		}(readerIndex)
    		readerIndex++
    	}
    	wg.Wait()
    	if p.canDecode(newBuf) {
    		p.offset += p.shardSize
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. tensorflow/c/eager/parallel_device/parallel_device_test.cc

          Multiply(context.get(), second_combined_value.get(),
                   second_negative_one.get(), status.get()));
      ASSERT_EQ(TF_GetCode(status.get()), TF_OK) << TF_Message(status.get());
    
      // Un-pack the parallel tensor to verify that the operation was
      // successful. The resulting structure should be:
      //   second_device{first_device{1. * 3., 2. * 3.}, 3. * 3.}.
      std::array<TensorHandlePtr, 2> second_components;
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  3. internal/logger/target/kafka/kafka.go

    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    
    	if h.producer != nil {
    		h.producer.Close()
    		h.client.Close()
    	}
    
    	// Wait for messages to be sent...
    	h.wg.Wait()
    }
    
    // New initializes a new logger target which
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. 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)
  5. cmd/iam-object-store.go

    }
    
    func (iamOS *IAMObjectStore) runlock() {
    	iamOS.RUnlock()
    }
    
    func (iamOS *IAMObjectStore) lock() *iamCache {
    	iamOS.Lock()
    	return iamOS.iamCache
    }
    
    func (iamOS *IAMObjectStore) unlock() {
    	iamOS.Unlock()
    }
    
    func (iamOS *IAMObjectStore) getUsersSysType() UsersSysType {
    	return iamOS.usersSysType
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_3x.md

        had an off-by-one bug in our HPACK encoder. This bug could have caused the
        wrong headers to be emitted after a sequence of HTTP/2 requests! Everyone
        who is using OkHttp 3.4.0 or 3.4.0-RC1 should upgrade for this bug fix.
    
    
    ## Version 3.4.0
    
    _2016-07-08_
    
     *  New: Support dynamic table size changes to HPACK Encoder.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top