- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 158 for Channel (0.03 sec)
-
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) -
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) -
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) -
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) -
.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) -
.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) -
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) -
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) -
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) -
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)