Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 220 for unpack (0.13 sec)

  1. ci/official/containers/linux_arm64/builder.devtoolset/gcc9-fixups.patch

    +  {
         while (*ep != NULL)
           if (!strncmp (*ep, name, len) && (*ep)[len] == '=')
     	{
    @@ -332,6 +333,7 @@ unsetenv (const char *name)
     	}
           else
     	++ep;
    +  }
     
       UNLOCK;
     
    diff --git a/support/Makefile b/support/Makefile
    index a253698..2f4e2a9 100644
    --- a/support/Makefile
    +++ b/support/Makefile
    @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \
     		-DINSTDIR_PATH=\"$(prefix)\" \
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Sep 18 14:52:45 UTC 2023
    - 8.9K bytes
    - Viewed (0)
  2. internal/event/target/amqp.go

    		}
    
    		if nerr, ok := err.(*net.OpError); ok {
    			return (nerr.Err.Error() == "use of closed network connection")
    		}
    
    		return false
    	}
    
    	target.connMutex.Lock()
    	defer target.connMutex.Unlock()
    
    	if target.conn != nil {
    		ch, err = target.conn.Channel()
    		if err == nil {
    			if target.args.PublisherConfirms {
    				confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  3. docs/changelogs/changelog_1x.md

       it throws an `InterruptedIOException`.
    
    ## Version 1.5.2
    
    _2014-03-17_
    
     * Fix bug where deleting a file that was absent from the `HttpResponseCache`
       caused an IOException.
     * Fix bug in HTTP/2 where our HPACK decoder wasn't emitting entries in
       certain eviction scenarios, leading to dropped response headers.
    
    ## Version 1.5.1
    
    _2014-03-11_
    
     * Fix 1.5.0 regression where connections should not have been recycled.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 6.4K bytes
    - Viewed (0)
  4. 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)
  5. cmd/admin-handlers_test.go

    	if err != nil {
    		return nil, nil, err
    	}
    
    	// Make objLayer available to all internal services via globalObjectAPI.
    	globalObjLayerMutex.Lock()
    	globalObjectAPI = objLayer
    	globalObjLayerMutex.Unlock()
    	return objLayer, erasureDirs, nil
    }
    
    // cmdType - Represents different service subcomands like status, stop
    // and restart.
    type cmdType int
    
    const (
    	restartCmd cmdType = iota
    	stopCmd
    )
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/CompactHashing.java

    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Helper classes and static methods for implementing compact hash-based collections.
     *
     * @author Jon Noack
     */
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class CompactHashing {
      private CompactHashing() {}
    
      /** Indicates blank table entries. */
      static final byte UNSET = 0;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 15:34:52 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top