- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for newEndpoint (0.2 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueueTest.groovy
queue.queue(message2) queue.queue(message3) when: def messages1 = [] def messages2 = [] queue.getChannel(id1).newEndpoint().take(messages1) queue.getChannel(id2).newEndpoint().take(messages2) then: messages1 == [message1, message3] messages2 == [message2] } def "forwards channel message to channel queue"() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueueTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/grpc_service_unix_test.go
"k8s.io/apimachinery/pkg/util/uuid" ) type testSocket struct { path string endpoint string } // newEndpoint constructs a unique name for a Linux Abstract Socket to be used in a test. // This package uses Linux Domain Sockets to remove the need for clean-up of socket files. func newEndpoint() *testSocket { p := fmt.Sprintf("@%s.sock", uuid.NewUUID()) return &testSocket{ path: p,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 10K bytes - Viewed (0) -
cmd/lock-rest-client_test.go
) // Tests lock rpc client. func TestLockRESTlient(t *testing.T) { // These should not be connectable. endpoint, err := NewEndpoint("http://localhost:9876") if err != nil { t.Fatalf("unexpected error %v", err) } endpointLocal, err := NewEndpoint("http://localhost:9012") if err != nil { t.Fatalf("unexpected error %v", err) } endpointLocal.IsLocal = true
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/kmsv2/grpc_service_unix_test.go
const ( testProviderName = "providerName" ) type testSocket struct { path string endpoint string } // newEndpoint constructs a unique name for a Linux Abstract Socket to be used in a test. // This package uses Linux Domain Sockets to remove the need for clean-up of socket files. func newEndpoint() *testSocket { p := fmt.Sprintf("@%s.sock", uuid.NewUUID()) return &testSocket{ path: p,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 19:25:52 UTC 2023 - 12.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/ConnectionSetTest.groovy
def channel = new ChannelIdentifier("channel") def outgoingMessage = new ChannelMessage(channel, "payload") given: def incoming = incomingQueue.getChannel(channel).newEndpoint() outgoingQueue.dispatch(outgoingMessage) when: connections.noFurtherConnections() def messages = [] incoming.take(messages) then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3K bytes - Viewed (0) -
pkg/test/echo/server/instance.go
if err != nil { return err } for _, ip := range getBindAddresses(ip) { ep, err := s.newEndpoint(p, ip, "") if err != nil { return err } s.endpoints = append(s.endpoints, ep) } } if len(s.UDSServer) > 0 { ep, err := s.newEndpoint(nil, "", s.UDSServer) if err != nil { return err } s.endpoints = append(s.endpoints, ep) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 7.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/ConnectionSet.java
} /** * Adds a new incoming connection. */ public ConnectionState add(RemoteConnection<InterHubMessage> connection) { EndPointQueue queue = outgoingQueue.newEndpoint(); ConnectionState state = new ConnectionState(this, connection, queue); connections.add(state); return state; } /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiEndPointQueue.java
default: throw new IllegalArgumentException("Unknown delivery type: " + message.getDelivery()); } } } public EndPointQueue newEndpoint() { EndPointQueue endPointQueue = new EndPointQueue(this, lock.newCondition()); endpoints.add(endPointQueue); initializer.onQueueAdded(endPointQueue); return endPointQueue; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 3.9K bytes - Viewed (0) -
cmd/storage-rest_test.go
if err != nil { t.Fatalf("unexpected error %v", err) } url.Path = t.TempDir() globalMinioHost, globalMinioPort = mustSplitHostPort(url.Host) endpoint, err := NewEndpoint(url.String()) if err != nil { t.Fatalf("NewEndpoint failed %v", endpoint) } if err = endpoint.UpdateIsLocal(); err != nil { t.Fatalf("UpdateIsLocal failed %v", err) } endpoint.PoolIdx = 0 endpoint.SetIdx = 0
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.4K bytes - Viewed (0)