Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 1,665 for writeFn (0.1 sec)

  1. doc/go_mem.html

    <p>
    Note that if there are no read-write or write-write data races on memory location <i>x</i>,
    then any read <i>r</i> on <i>x</i> has only one possible <i>W</i>(<i>r</i>):
    the single <i>w</i> that immediately precedes it in the happens before order.
    </p>
    
    <p>
    More generally, it can be shown that any Go program that is data-race-free,
    meaning it has no program executions with read-write or write-write data races,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  2. src/archive/zip/writer_test.go

    	dw, err := w.Create("dir/")
    	if err != nil {
    		t.Fatal(err)
    	}
    	if _, err := dw.Write(nil); err != nil {
    		t.Errorf("Write(nil) to directory: got %v, want nil", err)
    	}
    	if _, err := dw.Write([]byte("hello")); err == nil {
    		t.Error(`Write("hello") to directory: got nil error, want non-nil`)
    	}
    }
    
    func TestWriterDirAttributes(t *testing.T) {
    	var buf bytes.Buffer
    	w := NewWriter(&buf)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. cmd/batch-expire_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BatchJobExpirePurge) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 1
    	// write "RetainVersions"
    	err = en.Append(0x81, 0xae, 0x52, 0x65, 0x74, 0x61, 0x69, 0x6e, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x73)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.RetainVersions)
    	if err != nil {
    		err = msgp.WrapError(err, "RetainVersions")
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 01 12:53:30 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *PoolStatus) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 4
    	// write "id"
    	err = en.Append(0x84, 0xa2, 0x69, 0x64)
    	if err != nil {
    		return
    	}
    	err = en.WriteInt(z.ID)
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "cl"
    	err = en.Append(0xa2, 0x63, 0x6c)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb1/smb1/SmbFileOutputStream.java

            file.close();
            tmp = null;
        }
    
    /**
     * Writes the specified byte to this file output stream.
     *
     * @throws IOException if a network error occurs
     */
    
        public void write( int b ) throws IOException {
            tmp[0] = (byte)b;
            write( tmp, 0, 1 );
        }
    
    /**
     * Writes b.length bytes from the specified byte array to this
     * file output stream.
     *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 9.2K bytes
    - Viewed (0)
  6. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt

        }
    
        return result
      }
    
      override fun toDer(
        writer: DerWriter,
        value: T,
      ) {
        if (typeHint) {
          writer.typeHint = value
        }
    
        if (isOptional && value == defaultValue) {
          // Nothing to write!
          return
        }
    
        writer.write(name, tagClass, tag) {
          codec.encode(writer, value)
        }
      }
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/io/SourceSinkFactories.java

        public CharSink createSink() throws IOException {
          File file = createFile();
          if (initialString != null) {
            Writer writer = new OutputStreamWriter(new FileOutputStream(file), UTF_8);
            try {
              writer.write(initialString);
            } finally {
              writer.close();
            }
            return Files.asCharSink(file, UTF_8, FileWriteMode.APPEND);
          }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 17.7K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    			inlineBuffers[i] = bytes.NewBuffer(buf[:0])
    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          }
          if (associatedStreamId == 0) {
            writer.headers(outFinished, streamId, requestHeaders)
          } else {
            require(!client) { "client streams shouldn't have associated stream IDs" }
            // HTTP/2 has a PUSH_PROMISE frame.
            writer.pushPromise(associatedStreamId, streamId, requestHeaders)
          }
        }
    
        if (flushHeaders) {
          writer.flush()
        }
    
        return stream
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http2/HpackTest.kt

        // Use a new Writer because we don't support change the dynamic table
        // size after Writer constructed.
        val writer = Hpack.Writer(110, false, bytesOut)
        writer.writeHeaders(headerBlock)
        assertThat(bytesOut).isEqualTo(bytesIn)
        assertThat(writer.headerCount).isEqualTo(2)
        val tableLength = writer.dynamicTable.size
        var entry = writer.dynamicTable[tableLength - 1]!!
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 38.2K bytes
    - Viewed (0)
Back to top