Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 202 for IMMEDIATE (0.15 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/binder.go

    				return podVolumeClaims, err
    			}
    			// Prebound PVCs are treated as unbound immediate binding
    			if delayBindingMode && pvc.Spec.VolumeName == "" {
    				// Scheduler path
    				podVolumeClaims.unboundClaimsDelayBinding = append(podVolumeClaims.unboundClaimsDelayBinding, pvc)
    			} else {
    				// !delayBindingMode || pvc.Spec.VolumeName != ""
    				// Immediate binding should have already been bound
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  2. src/cmd/link/doc.go

    	-asan
    		Link with C/C++ address sanitizer support.
    	-aslr
    		Enable ASLR for buildmode=c-shared on windows (default true).
    	-bindnow
    		Mark a dynamically linked ELF object for immediate function binding (default false).
    	-buildid id
    		Record id as Go toolchain build id.
    	-buildmode mode
    		Set build mode (default exe).
    	-c
    		Dump call graphs.
    	-compressdwarf
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 15 16:11:52 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. src/internal/chacha8rand/chacha8.go

    func (s *State) Init64(seed [4]uint64) {
    	s.seed = seed
    	block(&s.seed, &s.buf, 0)
    	s.c = 0
    	s.i = 0
    	s.n = chunk
    }
    
    // Refill refills the state with more random values.
    // After a call to Refill, an immediate call to Next will succeed
    // (unless multiple goroutines are incorrectly sharing a state).
    func (s *State) Refill() {
    	s.c += ctrInc
    	if s.c == ctrMax {
    		// Reseed with generated uint64s for forward secrecy.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 21:47:29 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  4. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

       * is exhausted.
       *
       * See [SocketPolicy] for reasons why this can cause test flakiness and how to avoid it.
       */
      object DisconnectAtEnd : SocketPolicy
    
      /**
       * Request immediate close of connection without even reading the request. Use to simulate buggy
       * SSL servers closing connections in response to unrecognized TLS extensions.
       */
      object DisconnectAtStart : SocketPolicy
    
      /**
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook.go

    // or apierrors.SuggestsClientDelay() returns true, then the function advises a retry.
    // Otherwise it returns false for an immediate fail.
    func DefaultShouldRetry(err error) bool {
    	// these errors indicate a transient error that should be retried.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 20 19:02:55 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  6. src/net/http/http.go

    // maxInt64 is the effective "infinite" value for the Server and
    // Transport's byte-limiting readers.
    const maxInt64 = 1<<63 - 1
    
    // aLongTimeAgo is a non-zero time, far in the past, used for
    // immediate cancellation of network operations.
    var aLongTimeAgo = time.Unix(1, 0)
    
    // omitBundledHTTP2 is set by omithttp2.go when the nethttpomithttp2
    // build tag is set. That means h2_bundle.go isn't compiled in and we
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  7. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/Codec.kt

        val sharedIdentities: ReadIdentities
    
        override val isolate: ReadIsolate
    
        val classLoader: ClassLoader
    
        fun beanStateReaderFor(beanType: Class<*>): BeanStateReader
    
        /**
         * When in immediate mode, [read] calls are NOT suspending.
         * Useful for bridging with non-suspending serialization protocols such as [java.io.Serializable].
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. cmd/bitrot-streaming.go

    	// sequent of operations:
    	// 1) pipe.Write()
    	// 2) pipe.Close()
    	// Now pipe.Close() can return before the data is read on the other end of the pipe and written to the disk
    	// Hence an immediate Read() on the file can return incorrect data.
    	if b.canClose != nil {
    		b.canClose.Wait()
    	}
    
    	// Recycle the buffer.
    	if b.byteBuf != nil {
    		globalBytePoolCap.Load().Put(b.byteBuf)
    		b.byteBuf = nil
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 15 00:11:04 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. pkg/util/filesystem/watcher.go

    // errorHandler() is invoked (if non-nil) whenever an error occurs initializing or watching the specified path.
    //
    // If path is a directory, only the directory and immediate children are watched.
    //
    // If path does not exist or cannot be watched, an error is passed to errorHandler() and eventHandler() is called at pollInterval.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 23:09:15 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  10. src/net/http/cgi/integration_test.go

    				t.Errorf("got a Content-Type of %q; expected it to start with %q", got, tt.wantCT)
    			}
    		})
    	}
    }
    
    // golang.org/issue/7198
    func Test500WithNoHeaders(t *testing.T)     { want500Test(t, "/immediate-disconnect") }
    func Test500WithNoContentType(t *testing.T) { want500Test(t, "/no-content-type") }
    func Test500WithEmptyHeaders(t *testing.T)  { want500Test(t, "/empty-headers") }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 07 18:42:44 UTC 2023
    - 5.5K bytes
    - Viewed (0)
Back to top