Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 158 for Channel (0.04 sec)

  1. cmd/metrics-v2_test.go

    		},
    	}
    	ticker := time.NewTicker(1 * time.Millisecond)
    	defer ticker.Stop()
    	for _, obs := range observations {
    		// Send observations once every 1ms, to simulate delay between
    		// observations. This is to test the channel based
    		// synchronization used internally.
    		<-ticker.C
    		ttfbHist.With(prometheus.Labels{"api": obs.label}).Observe(obs.val)
    	}
    
    	metrics := getHistogramMetrics(ttfbHist, getBucketTTFBDistributionMD(), false, false)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 6.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/io/ByteSink.java

     *       typically implemented by opening a stream using one of the methods in the first category,
     *       doing something and finally closing the stream or channel that was opened.
     * </ul>
     *
     * @since 14.0
     * @author Colin Decker
     */
    @J2ktIncompatible
    @GwtIncompatible
    public abstract class ByteSink {
    
      /** Constructor for use by subclasses. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/io/ByteSink.java

     *       typically implemented by opening a stream using one of the methods in the first category,
     *       doing something and finally closing the stream or channel that was opened.
     * </ul>
     *
     * @since 14.0
     * @author Colin Decker
     */
    @J2ktIncompatible
    @GwtIncompatible
    public abstract class ByteSink {
    
      /** Constructor for use by subclasses. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/io/CopyUtil.java

            assertArgumentNotNull("out", out);
    
            final FileOutputStream os = OutputStreamUtil.create(out);
            try {
                final FileChannel channel = os.getChannel();
                final ByteBuffer buffer = ByteBuffer.wrap(in);
                return ChannelUtil.write(channel, buffer);
            } finally {
                CloseableUtil.close(os);
            }
        }
    
        /**
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 45.2K bytes
    - Viewed (0)
  5. .teamcity/src/main/kotlin/configurations/PerformanceTest.kt

                        description = "The baselines you want to run performance tests against. Empty means default baseline.",
                    )
                    param("env.PERFORMANCE_CHANNEL", performanceTestBuildSpec.channel())
                    param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                    when (os) {
                        Os.WINDOWS -> param("env.PATH", "%env.PATH%;C:/Program Files/7-zip")
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 5.9K bytes
    - Viewed (0)
  6. .teamcity/src/main/kotlin/configurations/PerformanceTestsPass.kt

                    param("env.PERFORMANCE_DB_PASSWORD_TCAGENT", "%performance.db.password.tcagent%")
                    param("performance.db.username", "tcagent")
                    param("env.PERFORMANCE_CHANNEL", performanceTestSpec.channel())
                }
    
                features {
                    publishBuildStatusToGithub(model)
                }
    
                val performanceResultsDir = "perf-results"
    Registered: Wed Sep 10 11:36:15 UTC 2025
    - Last Modified: Wed Feb 12 09:12:03 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/Smb2ConstantsTest.java

            }
    
            @Test
            @DisplayName("Multi-channel capability should be 0x8")
            void testGlobalCapMultiChannel() {
                assertEquals(0x8, Smb2Constants.SMB2_GLOBAL_CAP_MULTI_CHANNEL, "Multi-channel capability must be 0x8");
            }
    
            @Test
            @DisplayName("Persistent handles capability should be 0x10")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  8. CONTRIBUTING.md

    ```
    
    ### Test MinIO server changes
    
    After your code changes, make sure
    
    - To add test cases for the new code. If you have questions about how to do it, please ask on our [Slack](https://slack.min.io) channel.
    - To run `make verifiers`
    - To squash your commits into a single commit. `git rebase -i`. It's okay to force update your pull request.
    - To run `make test` and `make build` completes.
    
    ### Commit changes
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Aug 05 18:35:53 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/rdma/Smb2RdmaTransform.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.smb2.rdma;
    
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 RDMA Transform structure for READ/WRITE channel info.
     *
     * As per MS-SMB2 2.2.13.1.1 and 2.2.21.1.1
     */
    public class Smb2RdmaTransform {
    
        // SMB_DIRECT_BUFFER_DESCRIPTOR_V1 structure
        private long offset; // 8 bytes: Offset within registered buffer
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 3K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

      @Throws(IOException::class)
      override fun sendUrgentData(value: Int) {
        delegate!!.sendUrgentData(value)
      }
    
      override fun getChannel(): SocketChannel = delegate!!.channel
    
      override fun getHandshakeSession(): SSLSession = delegate!!.handshakeSession
    
      override fun getApplicationProtocol(): String = delegate!!.applicationProtocol
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 7.4K bytes
    - Viewed (0)
Back to top