- Sort Score
- Result 10 results
- Languages All
Results 661 - 670 of 842 for buffers (0.06 sec)
-
docs/ko/docs/async.md
```Python hl_lines="1" async def get_burgers(number: int): # Do some asynchronous stuff to create the burgers return burgers ``` ...`def`를 사용하는 대신: ```Python hl_lines="2" # This is not asynchronous def get_sequential_burgers(number: int): # Do some sequential stuff to create the burgers return burgers ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Aug 06 04:48:30 UTC 2024 - 26.7K bytes - Viewed (0) -
internal/grid/connection.go
queue := make([][]byte, 0, maxMergeMessages) merged := make([]byte, 0, writeBufferSize) var queueSize int var buf bytes.Buffer var wsw wsWriter var lastSetDeadline time.Time // Helper to write everything in buf. // Return false if an error occurred and the connection is unusable. // Buffer will be reset empty when returning successfully. writeBuffer := func() (ok bool) { now := time.Now()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/info/Smb2QueryDirectoryRequest.java
} /** * {@inheritDoc} * * @see jcifs.internal.smb2.ServerMessageBlock2#readBytesWireFormat(byte[], int) */ @Override protected int readBytesWireFormat ( byte[] buffer, int bufferIndex ) { return 0; }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 14 10:41:31 UTC 2021 - 6K bytes - Viewed (0) -
internal/s3select/select_benchmark_test.go
b := make([]byte, length) for i := range b { b[i] = charset[randSrc.Intn(len(charset))] } return string(b) } func genSampleCSVData(count int) []byte { buf := &bytes.Buffer{} csvWriter := csv.NewWriter(buf) csvWriter.Write([]string{"id", "name", "age", "city"}) for i := 0; i < count; i++ { csvWriter.Write([]string{ strconv.Itoa(i), newRandString(10), newRandString(5),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 14 13:54:47 UTC 2022 - 5K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java
} @Override protected int doReceiveFragment ( byte[] buf ) throws IOException { if ( buf.length < getMaxRecv() ) { throw new IllegalArgumentException("buffer too small"); } int off = this.handle.recv(buf, 0, buf.length); if ( buf[ 0 ] != 5 || buf[ 1 ] != 0 ) { throw new IOException("Unexpected DCERPC PDU header"); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jan 26 11:51:07 UTC 2020 - 5.2K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.9K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/JoinerBenchmark.java
delim = DELIMITER_STRING; } dummy ^= sb.toString().length(); } return dummy; } /** * Always append the delimiter after the component, and in the very end shortens the buffer to get * rid of the extra trailing delimiter. */ @Benchmark int alwaysAppendThenBackUp(int reps) { int dummy = 0; for (int i = 0; i < reps; i++) { StringBuilder sb = new StringBuilder();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 4.9K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
return res, err } defer func() { if err == nil && !skipAccessChecks(dstVolume) { p.storage.setWriteAttribute(p.totalWrites.Add(1)) } done(0, &err) }() // Copy inline data to a new buffer to function with deadlines. if len(fi.Data) > 0 { fi.Data = append(grid.GetByteBufferCap(len(fi.Data))[:0], fi.Data...) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:56:26 UTC 2024 - 34.5K bytes - Viewed (0) -
cmd/metacache-stream.go
} // temporary name buffer. tmp := make([]byte, 0, 256) for { if more, err := r.mr.ReadBool(); !more { switch err { case nil: r.err = io.EOF return io.EOF case io.EOF: r.err = io.ErrUnexpectedEOF return io.ErrUnexpectedEOF } r.err = err return err } // Read name without allocating more than 1 buffer. sz, err := r.mr.ReadStringHeader()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 19.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt
import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.io.FaultyFileSystem import okio.FileSystem import okio.Path import okio.Path.Companion.toPath import okio.Source import okio.buffer import okio.fakefilesystem.FakeFileSystem import org.junit.jupiter.api.AfterEach import org.junit.jupiter.api.Assumptions import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Timeout
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 14:55:09 UTC 2024 - 75.8K bytes - Viewed (0)