Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 227 for unpack (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

          readControlFrame()
        }
      }
    
      /**
       * Reads a message body into across one or more frames. Control frames that occur between
       * fragments will be processed. If the message payload is masked this will unmask as it's being
       * processed.
       */
      @Throws(IOException::class)
      private fun readMessage() {
        while (true) {
          if (closed) throw IOException("closed")
    
          if (frameLength > 0L) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return nil, err
    			}
    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. cmd/erasure-healing.go

    				if isReservedOrInvalidBucket(volInfo.Name, false) {
    					continue
    				}
    				mu.Lock()
    				if _, ok := healBuckets[volInfo.Name]; !ok {
    					healBuckets[volInfo.Name] = volInfo
    				}
    				mu.Unlock()
    			}
    			return nil
    		}, index)
    	}
    	return reduceReadQuorumErrs(ctx, g.Wait(), bucketMetadataOpIgnoredErrs, readQuorum)
    }
    
    var errLegacyXLMeta = errors.New("legacy XL meta")
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  4. 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)
  5. tensorflow/BUILD

        "@platforms//:__subpackages__",
        "@snappy//:__subpackages__",
        "@upb//:__subpackages__",
        "@zlib//:__subpackages__",
        "@dlpack//:__subpackages__",
        "@arm_neon_2_x86_sse//:__subpackages__",
        "@cpuinfo//:__subpackages__",
        "@ruy//:__subpackages__",
        "@XNNPACK//:__subpackages__",
        "@pthreadpool//:__subpackages__",
        "@FXdiv//:__subpackages__",
        "@FP16//:__subpackages__",
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Oct 16 05:28:35 UTC 2024
    - 53.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top