Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 611 for channels (0.97 sec)

  1. src/main/java/jcifs/internal/smb2/Smb2Constants.java

         */
        public static final long UNSPECIFIED_SESSIONID = 0xFFFFFFFFFFFFFFFFL;
    
        /**
         * SMB2 Channel constant for RDMA V1
         * Used in SMB2 READ and WRITE requests to indicate RDMA channel
         */
        public static final int SMB2_CHANNEL_RDMA_V1 = 0x00000001;
    
        /**
         * SMB2 Channel constant for RDMA V1 invalidate
         * Used to indicate RDMA with invalidation
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  2. src/test/java/jcifs/smb/MultiChannelManagerBasicTest.java

            // This should fail because localhost doesn't support SMB multi-channel
            // but the method should not throw NullPointerException
            try {
                method.invoke(multiChannelManager, localhost, loopback);
                // If it doesn't throw, that's unexpected for localhost
                fail("Expected CIFSException for localhost multi-channel attempt");
            } catch (java.lang.reflect.InvocationTargetException e) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 4K bytes
    - Viewed (0)
  3. internal/grid/stream.go

    // If the call is canceled through the context,
    // the appropriate error will be returned.
    type Stream struct {
    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// All responses *must* be read by the caller until either an error is returned or the channel is closed.
    	// Canceling the context will cause the context cancellation error to be returned.
    	responses <-chan Response
    	cancel    context.CancelCauseFunc
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. cmd/service.go

    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    			if ch, ok := val.(chan struct{}); ok && ch != nil {
    				// Close previous non-nil channel.
    				xioutil.SafeClose(ch)
    			}
    		}
    		globalServiceFreezeCnt = 0 // Don't risk going negative.
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/AcceptedApiChangesTest.groovy

            """])
    
            then:
            changes.acceptedChanges.size() == 1
            def acceptedChange = changes.acceptedChanges.entrySet().iterator().next()
            def change = acceptedChange.key
            change.type == "org.gradle.api.initialization.ConfigurableIncludedBuild"
            change.member == "Implemented interface org.gradle.api.initialization.IncludedBuild"
            change.changes == ["Interface has been removed"]
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Tue Jun 04 14:00:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  6. build-logic/binary-compatibility/src/test/kotlin/gradlebuild/binarycompatibility/SortAcceptedApiChangesTaskIntegrationTest.kt

    import org.junit.jupiter.api.Test
    
    
    class SortAcceptedApiChangesTaskIntegrationTest : AbstractAcceptedApiChangesMaintenanceTaskIntegrationTest() {
        @Test
        fun `verify misordered changes can be sorted`() {
            //language=JSON
            firstAcceptedApiChangesFile.writeText(
                """
                    {
                        "acceptedApiChanges": [
                            {
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Fri Mar 14 02:17:00 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  7. internal/logger/help.go

    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for webhook targets",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueDir,
    			Description: `staging dir for undelivered logger messages e.g. '/home/logger-events'`,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  8. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val defaultBaselines: String = "",
        val channel: String,
        val extraParameters: String = "",
    ) {
        PER_COMMIT(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_DAY(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_WEEK(
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Wed Nov 05 13:00:26 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  9. README.md

    - **Network & I/O** (`org.codelibs.core.net`, `org.codelibs.core.nio`) - URL utilities, UUID generation, MIME type detection, and NIO channel operations
    
    ## 🚀 Getting Started
    
    ### Requirements
    - **Java 21 or higher** (Required for modern language features)
    - **Maven 3.6+** or **Gradle 7+** for build management
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Sun Aug 31 02:56:02 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  10. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainSocketFactory.java

      public UnixDomainSocketFactory(File path) {
        this.path = path;
      }
    
      @Override public Socket createSocket() throws IOException {
        UnixSocketChannel channel = UnixSocketChannel.open();
        return new TunnelingUnixSocket(path, channel);
      }
    
      @Override public Socket createSocket(String host, int port) throws IOException {
        Socket result = createSocket();
    
        try {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Dec 03 21:33:52 UTC 2023
    - 2.1K bytes
    - Viewed (0)
Back to top