Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 79 for sequential (0.29 sec)

  1. docs/contribute/concurrency.md

    This is necessary for bookkeeping when creating new streams. Correct framing requires that stream IDs are sequential on the socket, so we need to bundle assigning the ID with sending the `SYN_STREAM` frame.
    
    ## Connection Pool
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

    package okhttp3.internal.concurrent
    
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.RejectedExecutionException
    import okhttp3.internal.okHttpName
    
    /**
     * A set of tasks that are executed in sequential order.
     *
     * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread
     * for its work; in practice a set of queues may share a set of threads to save resources.
     */
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  3. docs/en/docs/async.md

    For "synchronous" (contrary to "asynchronous") they commonly also use the term "sequential", because the computer / program follows all the steps in sequence before switching to a different task, even if those steps involve waiting.
    
    ### Concurrency and Burgers { #concurrency-and-burgers }
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

    import java.util.concurrent.Executors
    import java.util.concurrent.TimeUnit
    import java.util.logging.Logger
    import okhttp3.TestUtil.threadFactory
    
    /**
     * Runs a [TaskRunner] in a controlled environment so that everything is sequential and
     * deterministic.
     *
     * This class ensures that at most one thread is running at a time. This is initially the JUnit test
     * thread, which yields its execution privilege while calling [runTasks], [runNextTask], or
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11.9K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/Smb2ConstantsTest.java

            void testInfoQuota() {
                assertEquals(4, Smb2Constants.SMB2_0_INFO_QUOTA, "Quota info level must be 4");
            }
    
            @Test
            @DisplayName("All info levels should be sequential")
            void testInfoLevelsSequential() {
                assertEquals(Smb2Constants.SMB2_0_INFO_FILE + 1, Smb2Constants.SMB2_0_INFO_FILESYSTEM, "Filesystem should be File + 1");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  6. cmd/signature-v4-utils.go

    		default:
    			return nil, ErrUnsignedHeaders
    		}
    	}
    	return extractedSignedHeaders, ErrNone
    }
    
    // Trim leading and trailing spaces and replace sequential spaces with one space, following Trimall()
    // in http://docs.aws.amazon.com/general/latest/gr/sigv4-create-canonical-request.html
    func signV4TrimAll(input string) string {
    	// Compress adjacent spaces (a space is determined by
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Nov 25 17:10:22 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/ioctl/SrvCopychunkTest.java

                // Verify reserved section is zero
                assertEquals(0, SMBUtil.readInt4(buffer, 20));
            }
    
            @Test
            @DisplayName("Should handle multiple sequential encodings")
            void testMultipleSequentialEncodings() {
                // Given
                SrvCopychunk chunk1 = new SrvCopychunk(100, 200, 300);
                SrvCopychunk chunk2 = new SrvCopychunk(400, 500, 600);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  8. src/test/java/jcifs/internal/smb2/notify/Smb2ChangeNotifyRequestTest.java

            byte[] readFileId = new byte[16];
            System.arraycopy(buffer, 8, readFileId, 0, 16);
            assertArrayEquals(nullFileId, readFileId);
        }
    
        @Test
        @DisplayName("Should handle sequential operations")
        void testSequentialOperations() {
            // Given
            request.setNotifyFlags(0);
            request.setCompletionFilter(0);
    
            // When - first write
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 17.1K bytes
    - Viewed (0)
  9. src/test/java/jcifs/EmptyIteratorTest.java

        }
    
        @Test
        @DisplayName("EmptyIterator should behave consistently across multiple calls")
        void testConsistentBehavior() {
            // When & Then - test multiple sequential calls
            for (int i = 0; i < 10; i++) {
                assertFalse(emptyIterator.hasNext(), "hasNext should consistently return false");
                assertNull(emptyIterator.next(), "next should consistently return null");
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12K bytes
    - Viewed (0)
  10. src/test/java/jcifs/internal/smb1/trans2/Trans2SetFileInformationResponseTest.java

            assertEquals(SmbComTransaction.TRANS2_SET_FILE_INFORMATION, newResponse.getSubCommand());
        }
    
        @Test
        @DisplayName("Test multiple sequential calls to read/write methods")
        void testMultipleSequentialCalls() {
            byte[] buffer = new byte[200];
    
            // Multiple calls should each return 0
            for (int i = 0; i < 10; i++) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.9K bytes
    - Viewed (0)
Back to top