- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 611 for channels (0.12 sec)
-
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) -
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) -
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.CancelCauseFuncRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
.teamcity/src/main/kotlin/model/CIBuildModel.kt
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Nov 05 13:00:26 UTC 2025 - 27.5K bytes - Viewed (0) -
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) -
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)