Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 141 - 150 of 838 for srcEnd (0.04 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top