- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 838 for srcEnd (0.17 seconds)
-
src/main/java/jcifs/DialectVersion.java
return ordinal() <= v.ordinal(); } /** * Get the minimum of two dialect versions * * @param a the first version to compare * @param b the second version to compare * @return smaller of the two versions */ public static DialectVersion min(final DialectVersion a, final DialectVersion b) { if (a.atMost(b)) { return a; }
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 4.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/info/Smb2QueryDirectoryResponseTest.java
System.arraycopy(file1, 0, buffer, 102, file1.length); // Write second FileBothDirectoryInfo at 8 + 104 = 112 int secondOffset = 112; SMBUtil.writeInt4(0, buffer, secondOffset); // NextEntryOffset (0 = last) SMBUtil.writeInt4(1, buffer, secondOffset + 4); // FileIndex // ... rest of second entry fields (zeros for simplicity) for (int i = 8; i < 94; i++) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 23.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
} /** * Test to ensure we throw a read timeout on responses that are progressing too slowly. For this * case, we take a 2KiB body and throttle it to 1KiB/second. We set the read timeout to half a * second. If our implementation is acting correctly, it will throw, as a byte doesn't arrive in * time. */ @Test fun readTimeoutOnSlowConnection() { val body = repeat('y', 2048)
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 67.5K bytes - Click Count (0) -
internal/grid/grid_test.go
t.Run("testStreamRoundtrip", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamRoundtrip(t, local, remote) assertNoActive(t, connRemoteLocal) assertNoActive(t, connLocalToRemote) }) t.Run("testStreamCancel", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamCancel(t, local, remote) assertNoActive(t, connRemoteLocal)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 36.1K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb1/com/SmbComQueryInformationTest.java
assertEquals(2, used, "Null path should result in command byte + NUL"); assertEquals(0x04, buffer[0] & 0xFF, "First byte must still be 0x04"); assertEquals(0, buffer[1], "Second byte must be null terminator"); } @Test @DisplayName("writeBytesWireFormat handles empty string gracefully") void testWriteEmptyString() {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.9K bytes - Click Count (0) -
soft_delete.go
if c, ok := stmt.Clauses["WHERE"]; ok { if where, ok := c.Expression.(clause.Where); ok && len(where.Exprs) >= 1 { for _, expr := range where.Exprs { if orCond, ok := expr.(clause.OrConditions); ok && len(orCond.Exprs) == 1 { where.Exprs = []clause.Expression{clause.And(where.Exprs...)} c.Expression = where stmt.Clauses["WHERE"] = c break } } } }
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Wed Feb 01 06:40:55 GMT 2023 - 4.5K bytes - Click Count (1) -
tests/test_response_dependency.py
) -> Response: response.headers["X-Second"] = "2" return response @app.get("/") def endpoint(response: Annotated[Response, Depends(second_modifier)]): return {"status": "ok"} client = TestClient(app) resp = client.get("/") assert resp.status_code == 200 assert resp.headers.get("X-First") == "1" assert resp.headers.get("X-Second") == "2"Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Feb 05 18:23:16 GMT 2026 - 5.2K bytes - Click Count (0) -
cmd/bucket-quota.go
func (sys *BucketQuotaSys) Init(objAPI ObjectLayer) { bucketStorageCache.InitOnce(10*time.Second, cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (DataUsageInfo, error) { if objAPI == nil { return DataUsageInfo{}, errServerNotInitialized } ctx, done := context.WithTimeout(ctx, 2*time.Second) defer done() return loadDataUsageFromBackend(ctx, objAPI) }, ) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.4K bytes - Click Count (0) -
docs/ja/docs/advanced/additional-responses.md
```Python old_dict = { "old key": "old value", "second old key": "second old value", } new_dict = {**old_dict, "new key": "new value"} ``` ここでは、`new_dict` には `old_dict` のすべてのキーと値に加え、新しいキーと値が含まれます: ```Python { "old key": "old value", "second old key": "second old value", "new key": "new value", } ```Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Mar 20 14:07:17 GMT 2026 - 10K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt
server.listener.assertClosed(1000, "Hi!") taskFaker.runTasks() assertThat(client.closed).isTrue() server.listener.assertExhausted() // Client should not have sent second close. client.listener.assertExhausted() // Server should not have sent second close. } @Test fun serverCloseBreaksReadMessageLoop() { server.webSocket!!.send("Hello!") server.webSocket!!.close(1000, "Bye!")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 18.7K bytes - Click Count (0)