- Sort Score
- Result 10 results
- Languages All
Results 511 - 520 of 806 for lasta (0.17 sec)
-
internal/s3select/json/preader.go
if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes and // return the buffer until the next newline occurs. // The last block will be sent along with an io.EOF. func (r *PReader) nextSplit(skip int, dst []byte) ([]byte, error) { if cap(dst) < skip { dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0) -
tests/sql_builder_test.go
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Mon Jul 21 02:46:58 UTC 2025 - 16.7K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
// One 16 MiB is a reasonable max limit. // // Then we read the signature and payload data. We compute the SHA256 checksum // of the payload and verify that it matches the expected signature value. // // The last chunk is *always* 0-sized. So, we must only return io.EOF if we have encountered // a chunk with a chunk size = 0. However, this chunk still has a signature and we must // verify it. const maxChunkSize = 16 << 20 // 16 MiB
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 18.2K bytes - Viewed (0) -
internal/event/target/mqtt.go
} // Do not send if the connection is not active. _, err := target.isActive() if err != nil { return err } eventData, err := target.store.Get(key) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) { return nil }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-replication.go
ReplicaStatus = "replica-status" // ReplicaTimestamp - the last time a replica was received by this cluster for this object version ReplicaTimestamp = "replica-timestamp" // TaggingTimestamp - the last time a tag metadata modification happened on this cluster for this object version TaggingTimestamp = "tagging-timestamp"
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 118.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java
// This tests that it.remove() above actually changed the order. It // indicates that the value 40 was stored in forgetMeNot, so it is // returned in the last call to it.next(). Without it, 30 should be the last // item returned by the iterator. Integer lastItem = 0; for (Integer tmp : mmHeap) { lastItem = tmp; } assertEquals((Integer) 30, lastItem); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 28 16:03:47 UTC 2025 - 36.1K bytes - Viewed (0) -
docs/es/docs/environment-variables.md
Por ejemplo, cuando escribes `python` en la terminal, el sistema operativo busca un programa llamado `python` en el **primer directorio** de esa lista. Si lo encuentra, entonces lo **utilizará**. De lo contrario, continúa buscando en los **otros directorios**. ### Instalando Python y Actualizando el `PATH` { #installing-python-and-updating-the-path }Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Tue Dec 16 16:33:45 UTC 2025 - 8.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/idn/IdnaMappingTable.kt
* * * **b2a**: b2 + 0x80 * * **b3a**: b3 + 0x80 * * **b2b3**: (b2 << 7) + b3 * * b0 * -- * * The inclusive start of the range. We get the first 14 bits of this code point from the section * and the last 7 bits from this byte. * * The end of the range is not encoded, but can be inferred by looking at the start of the range * that follows. * * b1 * -- *
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 9K bytes - Viewed (0) -
src/test/java/jcifs/smb/NtlmUtilTest.java
// Assert assertEquals(24, resp.length, "LMv2 response length must be 24"); assertArrayEquals(clientChallenge, Arrays.copyOfRange(resp, 16, 24), "Client challenge must be copied to last 8 bytes"); assertFalse(Arrays.equals(new byte[24], resp), "Response must not be all zeros"); } @Test @DisplayName("getLMv2Response(byte[]): empty client data allowed")Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 12K bytes - Viewed (1) -
cmd/handler-api.go
// Only replace if needed. // Existing requests will use the previous limit, // but new requests will use the new limit. // There will be a short overlap window, // but this shouldn't last long. t.requestsPool = make(chan struct{}, apiRequestsMaxPerNode) } listQuorum := cfg.ListQuorum if listQuorum == "" { listQuorum = "strict" } t.listQuorum = listQuorum
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 10.4K bytes - Viewed (0)