- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 386 for channel2 (0.15 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueueTest.groovy
def "adds and caches channel queue on first lookup"() { def id1 = new ChannelIdentifier("channel1") def id2 = new ChannelIdentifier("channel2") expect: def channelQueue = queue.getChannel(id1) channelQueue == queue.getChannel(id1) channelQueue != queue.getChannel(id2) } def "adds channel queue when channel message added"() {
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/integTest/groovy/org/gradle/internal/remote/internal/hub/MessageHubIntegrationTest.groovy
client2.connectTo(server) server.addHandler("channel", serverHandler) client1.addHandler("channel", client1Handler) client2.addHandler("channel", client2Handler) def serverDispatch = server.createOutgoing("channel") def client1Dispatch = client1.createOutgoing("channel") def client2Dispatch = client2.createOutgoing("channel") when: serverDispatch.dispatch("message 1")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 9K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/InterHubMessageSerializerTest.groovy
result[0] instanceof ChannelMessage result[0].channel == channelId result[0].payload == "payload 1" result[1] instanceof ChannelMessage result[1].channel == channelId result[1].payload == "payload 2" serialized.length < message1Serialized.length + message2Serialized.length } def "can serialize messages for multiple channels"() { def channelId1 = new ChannelIdentifier("channel 1")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 4.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/InterHubMessageSerializer.java
int channelNum = decoder.readSmallInt(); ChannelIdentifier channelId = channels.get(channelNum); if (channelId == null) { String channel = decoder.readString(); channelId = new ChannelIdentifier(channel); channels.put(channelNum, channelId); } return channelId; } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go
} } // createChannels returns the standard channel types for a shell connection (STDIN 0, STDOUT 1, STDERR 2) // along with the approximate duplex value. It also creates the error (3) and resize (4) channels. func createChannels(opts Options) []wsstream.ChannelType { // open the requested channels, and always open the error channel channels := make([]wsstream.ChannelType, 5) channels[constants.StreamStdIn] = readChannel(opts.Stdin)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K bytes - Viewed (0) -
src/internal/types/testdata/fixedbugs/issue62157.go
// Unnamed directed channels win over bidirectional channels. b = f(a, b) b = f(b, a) // Defined directed channels win over defined bidirectional channels. A = f(A, a) A = f(a, A) B = f(B, b) B = f(b, B) f(a, b, B) f(a, B, b) f(b, B, a) f(b, a, B) f(B, a, b) f(B, b, a) // Differently named channel types conflict irrespective of channel direction.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 29 23:22:35 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/MultiChannelQueue.java
private final Map<ChannelIdentifier, MultiEndPointQueue> channels = new HashMap<ChannelIdentifier, MultiEndPointQueue>(); private final QueueInitializer initializer = new QueueInitializer(); public MultiChannelQueue(Lock lock) { this.lock = lock; } public MultiEndPointQueue getChannel(ChannelIdentifier channel) { MultiEndPointQueue queue = channels.get(channel); if (queue == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/g3doc/space_to_depth.md
data_format=data_format) # Use the image size without space-to-depth transform as the input of conv0. batch_size, h, w, channel = inputs.get_shape().as_list() conv0.build([ batch_size, h * space_to_depth_block_size, w * space_to_depth_block_size, channel // (space_to_depth_block_size**2) ]) kernel = conv0.weights[0] # [7, 7, 3, 64] --> [8, 8, 3, 64] kernel = tf.pad(
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Oct 24 02:51:43 UTC 2020 - 8.3K bytes - Viewed (0) -
test/chanlinear.go
if fails++; fails >= 5 { panic(fmt.Sprintf("%s: too slow: %d channels: %v; %d channels: %v\n", typ, n, t1, 2*n, t2)) } } } func main() { checkLinear("chanSelect", 1000, func(n int) { const messages = 10 c := make(chan bool) // global channel var a []chan bool // local channels for each goroutine for i := 0; i < n; i++ { d := make(chan bool) a = append(a, d)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 2.1K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/results/AbstractWritableResultsStore.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.8K bytes - Viewed (0)