Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 2,136 for writes (0.1 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/format/formatting.go

    	var buf bytes.Buffer
    	BufferPriorityLevelConfigurationSpec(&buf, plSpec)
    	return buf.String()
    }
    
    // BufferPriorityLevelConfigurationSpec writes a golang source
    // expression for the given value to the given buffer
    func BufferPriorityLevelConfigurationSpec(buf *bytes.Buffer, plSpec *flowcontrol.PriorityLevelConfigurationSpec) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  2. src/runtime/profbuf.go

    //
    // If the writer gets ahead of the reader, so that the buffer fills,
    // future writes are discarded and replaced in the output stream by an
    // overflow entry, which has size 2+hdrsize+1, time set to the time of
    // the first discarded write, a header of all zeroed words, and a "stack"
    // containing one word, the number of discarded writes.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/phases/kubelet/config.go

    	"k8s.io/kubernetes/cmd/kubeadm/app/util/patches"
    )
    
    // WriteConfigToDisk writes the kubelet config object down to a file
    // Used at "kubeadm init" and "kubeadm upgrade" time
    func WriteConfigToDisk(cfg *kubeadmapi.ClusterConfiguration, kubeletDir, patchesDir string, output io.Writer) error {
    	kubeletCfg, ok := cfg.ComponentConfigs[componentconfigs.KubeletGroup]
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 02 12:34:30 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. src/cmd/distpack/pack.go

    // Copyright 2023 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Distpack creates the tgz and zip files for a Go distribution.
    // It writes into GOROOT/pkg/distpack:
    //
    //   - a binary distribution (tgz or zip) for the current GOOS and GOARCH
    //   - a source distribution that is independent of GOOS/GOARCH
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 19:41:17 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  5. platforms/core-runtime/internal-instrumentation-processor/src/main/java/org/gradle/internal/instrumentation/extensions/types/InstrumentedTypesResourceGenerator.java

                @Override
                public void write(OutputStream outputStream) {
                    String types = filteredRequests.stream()
                        .map(request -> request.getInterceptedCallable().getOwner().getType().getClassName().replace(".", "/"))
                        .distinct()
                        .sorted()
                        .collect(Collectors.joining("\n"));
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:40 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  6. src/cmd/internal/pgo/serialize.go

    const serializationHeader = "GO PREPROFILE V1\n"
    
    // WriteTo writes a serialized representation of Profile to w.
    //
    // FromSerialized can parse the format back to Profile.
    //
    // WriteTo implements io.WriterTo.Write.
    func (d *Profile) WriteTo(w io.Writer) (int64, error) {
    	bw := bufio.NewWriter(w)
    
    	var written int64
    
    	// Header
    	n, err := bw.WriteString(serializationHeader)
    	written += int64(n)
    	if err != nil {
    		return written, err
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Mar 27 20:20:01 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/phases/kubelet/flags.go

    		nodeName = cfg.Name
    	}
    	if name, idx := kubeadmapi.GetArgValue(cfg.KubeletExtraArgs, "hostname-override", -1); idx > -1 {
    		nodeName = name
    	}
    	return nodeName, hostname, err
    }
    
    // WriteKubeletDynamicEnvFile writes an environment file with dynamic flags to the kubelet.
    // Used at "kubeadm init" and "kubeadm join" time.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 10:27:05 UTC 2023
    - 5K bytes
    - Viewed (0)
  8. src/vendor/golang.org/x/crypto/cryptobyte/builder.go

    // buffer. This builder does not reallocate the output buffer. Writes that
    // would exceed the buffer's capacity are treated as an error.
    func NewFixedBuilder(buffer []byte) *Builder {
    	return &Builder{
    		result:    buffer,
    		fixedSize: true,
    	}
    }
    
    // SetError sets the value to be returned as the error from Bytes. Writes
    // performed after calling SetError are ignored.
    func (b *Builder) SetError(err error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 10 16:32:44 UTC 2023
    - 9.9K bytes
    - Viewed (0)
  9. platforms/core-runtime/serialization/src/main/java/org/gradle/internal/serialize/Serializer.java

         */
        T read(Decoder decoder) throws EOFException, Exception;
    
        /**
         * Writes the given object to the given stream. The implementation must not perform any buffering.
         */
        void write(Encoder encoder, T value) throws Exception;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Apr 15 16:06:56 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  10. platforms/software/platform-base/src/main/java/org/gradle/platform/base/internal/toolchain/ToolSearchResult.java

     */
    
    package org.gradle.platform.base.internal.toolchain;
    
    import org.gradle.internal.logging.text.DiagnosticsVisitor;
    
    public interface ToolSearchResult {
        boolean isAvailable();
    
        /**
         * Writes some diagnostics about why the tool is not available.
         */
        void explain(DiagnosticsVisitor visitor);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Oct 11 12:16:09 UTC 2023
    - 928 bytes
    - Viewed (0)
Back to top