Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 530 for channel (0.3 sec)

  1. src/main/java/org/codelibs/core/nio/ChannelUtil.java

         * @param channel
         *            ファイルチャネル。{@literal null}であってはいけません
         * @param mode
         *            モード。{@literal null}であってはいけません
         * @return ファイルチャネルをメモリにマップした{@link ByteBuffer}
         */
        public static ByteBuffer map(final FileChannel channel, final MapMode mode) {
            assertArgumentNotNull("channel", channel);
            assertArgumentNotNull("mode", mode);
    
            try {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/io/Smb2ReadRequest.java

         * 
         */
        public static byte SMB2_READFLAG_READ_UNBUFFERED = 0x1;
        /**
         * 
         */
        public static int SMB2_CHANNEL_NONE = 0x0;
        /**
         * 
         */
        public static int SMB2_CHANNEL_RDMA_V1 = 0x1;
        /**
         * 
         */
        public static int SMB2_CHANNEL_RDMA_V1_INVALIDATE = 0x2;
    
        private byte[] fileId;
        private final byte[] outputBuffer;
        private final int outputBufferOffset;
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 5.2K bytes
    - Viewed (0)
  3. 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.
    	}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  4. doc/next/6-stdlib/1-time.md

    now unbuffered, with capacity 0.
    The main effect of this change is that Go now guarantees
    that for any call to a `Reset` or `Stop` method, no stale values
    prepared before that call will be sent or received after the call.
    Earlier versions of Go used channels with a one-element buffer,
    making it difficult to use `Reset` and `Stop` correctly.
    A visible effect of this change is that `len` and `cap` of timer channels
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Apr 12 20:57:18 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  5. .teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt

            assertEquals(
                (
                    listOf(
                        "clean",
                        ":performance:largeTestProjectPerformanceTest --channel %performance.channel% ",
                        ":performance:smallTestProjectPerformanceTest --channel %performance.channel% ",
                        "extraParameters"
                    ) + expectedRunnerParams
                    ).joinToString(" "),
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Wed Apr 24 08:17:56 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  6. samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/TunnelingUnixSocket.java

      private final File path;
      private InetSocketAddress inetSocketAddress;
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel) {
        super(channel);
        this.path = path;
      }
    
      TunnelingUnixSocket(File path, UnixSocketChannel channel, InetSocketAddress address) {
        this(path, channel);
        this.inetSocketAddress = address;
      }
    
      @Override public void connect(SocketAddress endpoint) throws IOException {
    Java
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Feb 12 16:33:52 GMT 2019
    - 1.9K bytes
    - Viewed (1)
  7. .teamcity/src/main/kotlin/model/PerformanceTestSpec.kt

        fun asConfigurationId(model: CIBuildModel, bucket: String): String
        fun channel(): String
    }
    
    interface PerformanceTestProjectSpec {
        val type: PerformanceTestType
        val failsStage: Boolean
    
        fun asConfigurationId(model: CIBuildModel): String
        fun asName(): String
        fun channel(): String
    }
    
    data class PerformanceTestPartialTrigger(
        val triggerName: String,
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Mon Dec 13 07:00:20 GMT 2021
    - 3.7K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/SocketChannelTest.kt

                listOf(Channel, Standard).flatMap { socketMode ->
                  listOf(DISABLED, STANDARD).map { tlsExtensionMode ->
                    TlsInstance(provider, protocol, tlsVersion, socketMode, tlsExtensionMode)
                  }
                }
              }
            }
          } + Channel + Standard
      }
    }
    
    sealed class SocketMode
    
    object Channel : SocketMode() {
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8K bytes
    - Viewed (0)
  9. .teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt

                )
                param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                param("performance.db.username", "tcagent")
                param("performance.channel", performanceTestSpec.channel())
            }
    
            features {
                publishBuildStatusToGithub(model)
            }
    
            val performanceResultsDir = "perf-results"
            val performanceProjectName = "performance"
    
    Plain Text
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Thu Apr 04 07:21:42 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  10. manifests/charts/base/templates/validatingadmissionpolicy.yaml

              )
            )
    ---
    apiVersion: admissionregistration.k8s.io/v1
    kind: ValidatingAdmissionPolicyBinding
    metadata:
      name: "stable-channel-default-policy-binding.istio.io"
    spec:
      policyName: "stable-channel-default-policy.istio.io"
      validationActions: [Deny]
    Others
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 22:00:40 GMT 2024
    - 1.6K bytes
    - Viewed (0)
Back to top