Search Options

Results per page
Sort
Preferred Languages
Advance

Results 181 - 190 of 4,372 for dwrite (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go

    	assert.Equal(t, expectedHeader, trw.Header(), "")
    	// Validate Write() for delegate response writer.
    	expectedWrite := []byte("this is a test write string")
    	assert.False(t, trw.written, "written field is before Write()")
    	_, err := trw.Write(expectedWrite)
    	assert.NoError(t, err, "No error expected after Write() on tunneling response writer")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 02:21:50 UTC 2024
    - 22.7K bytes
    - Viewed (0)
  2. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerWriter.kt

      private val path = mutableListOf<String>()
    
      /**
       * False unless we made a recursive call to [write] at the current stack frame. The explicit box
       * adapter can clear this to synthesize non-constructed values that are embedded in octet strings.
       */
      var constructed = false
    
      fun write(
        name: String,
        tagClass: Int,
        tag: Long,
        block: (BufferedSink) -> Unit,
      ) {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java

                    throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e);
                }
            }
    
            public void write(final String line) {
                try {
                    writer.write(line);
                    writer.write(Constants.LINE_SEPARATOR);
                } catch (final IOException e) {
                    throw new DictionaryException("Failed to write: " + line, e);
                }
            }
    
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  4. platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt

            host: Host,
            private val writer: ScopedFingerprintWriter<ConfigurationCacheFingerprint>
        ) : Sink(host) {
            override fun write(value: ConfigurationCacheFingerprint, trace: PropertyTrace?) {
                writer.write(value, trace)
            }
    
            fun initScripts(initScripts: List<File>) {
                capturedFiles.addAll(initScripts)
                write(
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:30 UTC 2024
    - 32.8K bytes
    - Viewed (0)
  5. src/compress/gzip/gzip.go

    }
    
    // NewWriter returns a new [Writer].
    // Writes to the returned writer are compressed and written to w.
    //
    // It is the caller's responsibility to call Close on the [Writer] when done.
    // Writes may be buffered and not flushed until Close.
    //
    // Callers that wish to set the fields in Writer.Header must do so before
    // the first call to Write, Flush, or Close.
    func NewWriter(w io.Writer) *Writer {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 13:32:40 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  6. platforms/core-execution/hashing/src/main/java/org/gradle/internal/hash/HashingOutputStream.java

        }
    
        @Override
        public void write(int b) throws IOException {
            hasher.putByte((byte) b);
            out.write(b);
        }
    
        @Override
        public void write(byte[] bytes, int off, int len) throws IOException {
            hasher.putBytes(bytes, off, len);
            out.write(bytes, off, len);
        }
    
        public HashCode hash() {
            return hasher.hash();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:43:29 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  7. src/runtime/unsafepoint_test.go

    		instructionCount++
    		if unsafe {
    			unsafeCount++
    		}
    
    		// All the instructions inside the write barrier must be unpreemptible.
    		if startedWB && !doneWB && !unsafe {
    			t.Errorf("instruction %s must be marked unsafe, but isn't", parts[1])
    		}
    
    		// Detect whether we're in the write barrier.
    		switch runtime.GOARCH {
    		case "arm64":
    			if parts[3] == "MOVWU" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Aug 11 20:24:56 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go

    // Once Write or WriteHeader is called, Hijack returns an error.
    // Once Hijack is called, Write, WriteHeader, and Hijack return errors.
    type tunnelingResponseWriter struct {
    	// w is used to delegate Header(), WriteHeader(), and Write() calls
    	w http.ResponseWriter
    	// conn is returned from Hijack()
    	conn net.Conn
    	// mu guards writes
    	mu sync.Mutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:10:30 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  9. src/compress/lzw/writer_test.go

    	n, err := w.Write([]byte("asdf"))
    	if n != 4 || err != nil {
    		t.Errorf("got %d, %v, want 4, nil", n, err)
    	}
    }
    
    func TestSmallLitWidth(t *testing.T) {
    	w := NewWriter(io.Discard, LSB, 2)
    	if _, err := w.Write([]byte{0x03}); err != nil {
    		t.Fatalf("write a byte < 1<<2: %v", err)
    	}
    	if _, err := w.Write([]byte{0x04}); err == nil {
    		t.Fatal("write a byte >= 1<<2: got nil error, want non-nil")
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 12 11:00:47 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  10. pkg/kubelet/util/ioutils/ioutils.go

    // applied to the writer interface.
    // LimitWriter returns a Writer that writes to w
    // but stops with EOF after n bytes.
    // The underlying implementation is a *LimitedWriter.
    func LimitWriter(w io.Writer, n int64) io.Writer { return &LimitedWriter{w, n} }
    
    // A LimitedWriter writes to W but limits the amount of
    // data returned to just N bytes. Each call to Write
    // updates N to reflect the new amount remaining.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 16 12:00:49 UTC 2023
    - 1.5K bytes
    - Viewed (0)
Back to top