Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 72 for consuming (1.88 sec)

  1. src/crypto/tls/key_schedule.go

    		// NOTE: another reasonable approach here might be to return a
    		// randomized slice if we encounter an error, which would break the
    		// connection, but avoid panicking. This would perhaps be safer but
    		// significantly more confusing to users.
    		panic(fmt.Errorf("failed to construct HKDF label: %s", err))
    	}
    	out := make([]byte, length)
    	n, err := hkdf.Expand(c.hash.New, secret, hkdfLabelBytes).Read(out)
    	if err != nil || n != length {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 14:56:25 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. src/crypto/internal/hpke/hpke.go

    	nonce := s.seqNum.bytes()[16-s.aead.NonceSize():]
    	for i := range s.baseNonce {
    		nonce[i] ^= s.baseNonce[i]
    	}
    	// Message limit is, according to the RFC, 2^95+1, which
    	// is somewhat confusing, but we do as we're told.
    	if s.seqNum.bitLen() >= (s.aead.NonceSize()*8)-1 {
    		panic("message limit reached")
    	}
    	s.seqNum = s.seqNum.addOne()
    	return nonce
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:33:33 UTC 2024
    - 7K bytes
    - Viewed (0)
  3. src/runtime/proc.go

    	// if disableMemoryProfiling is set, update MemProfileRate to 0 to turn off memprofile.
    	// Note: parsedebugvars may update MemProfileRate, but when disableMemoryProfiling is
    	// set to true by the linker, it means that nothing is consuming the profile, it is
    	// safe to set MemProfileRate to 0.
    	if disableMemoryProfiling {
    		MemProfileRate = 0
    	}
    
    	// mcommoninit runs before parsedebugvars, so init profstacks again.
    	mProfStackInit(gp.m)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  4. pilot/pkg/simulation/traffic.go

    		t.Errorf("want listener matched %q got %q", want.ListenerMatched, r.ListenerMatched)
    	} else {
    		// Populate each field in case we did not care about it. This avoids confusing errors when we have fields
    		// we don't care about in the test that are present in the result.
    		want.ListenerMatched = r.ListenerMatched
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. ChangeLog.md

    - [`KT-67489`](https://youtrack.jetbrains.com/issue/KT-67489) JsPlainObjects Plugin: Method not found when consuming
    - [`KT-63607`](https://youtrack.jetbrains.com/issue/KT-63607) Migrate kotlin-power-assert into Kotlin repository
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Mon May 27 17:14:23 UTC 2024
    - 292.1K bytes
    - Viewed (0)
  6. cni/pkg/nodeagent/informers.go

    			pods = append(pods, pod)
    		}
    	}
    	return pods
    }
    
    // EnqueueNamespace takes a Namespace and enqueues all Pod objects that make need an update
    // TODO it is sort of pointless/confusing/implicit to populate Old and New with the same reference here
    func (s *InformerHandlers) enqueueNamespace(o controllers.Object) {
    	namespace := o.GetName()
    	labels := o.GetLabels()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

            }
            message += " ";
          }
          if (shouldShowExtraNanos) {
            message += overWaitLeftoverNanos + " nanoseconds ";
          }
    
          message += "delay)";
        }
        // It's confusing to see a completed future in a timeout message; if isDone() returns false,
        // then we know it must have given a pending toString value earlier. If not, then the future
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Jun 07 22:25:23 UTC 2024
    - 63.1K bytes
    - Viewed (1)
  8. src/runtime/runtime_test.go

    				stop := applyGCLoad(b)
    				runOne(b)
    				// Make sure to stop the timer before we wait! The load created above
    				// is very heavy-weight and not easy to stop, so we could end up
    				// confusing the benchmarking framework for small b.N.
    				b.StopTimer()
    				stop()
    			})
    		}
    	}
    
    	// Measure the cost of counting goroutines
    	b.Run("small-nil", run(func() bool {
    		GoroutineProfile(nil)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. src/net/http/h2_bundle.go

    // is the number of flow control bytes available on the stream. Consume returns
    // 0, 1, or 2 frames, where the integer return value gives the number of frames
    // returned.
    //
    // If flow control prevents consuming any bytes, this returns (_, _, 0). If
    // the entire frame was consumed, this returns (wr, _, 1). Otherwise, this
    // returns (consumed, rest, 2), where 'consumed' contains the consumed bytes and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  10. src/crypto/tls/bogo_config.json

            "KyberKeyShareIncludedSecond": "we always send the Kyber key share first",
            "KyberKeyShareIncludedThird": "we always send the Kyber key share first",
            "SkipNewSessionTicket": "TODO confusing? maybe bug",
            "SendUserCanceledAlerts*": "TODO may be a real bug?",
            "GREASE-Server-TLS13": "TODO ???",
            "GarbageCertificate*": "TODO ask davidben, alertDecode vs alertBadCertificate",
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 15:52:42 UTC 2024
    - 19.3K bytes
    - Viewed (0)
Back to top