Home
last modified time | relevance | path

Searched full:channel (Results 1 – 25 of 9037) sorted by relevance

12345678910>>...362

/external/google-cloud-java/java-channel/
Dsynth.metadata6 "remote": "https://github.com/googleapis/java-channel.git",
30 "apiName": "channel",
105 "google-cloud-channel/src/main/java/com/google/cloud/channel/v1/CloudChannelServiceClient.java",
106 … "google-cloud-channel/src/main/java/com/google/cloud/channel/v1/CloudChannelServiceSettings.java",
107 "google-cloud-channel/src/main/java/com/google/cloud/channel/v1/gapic_metadata.json",
108 "google-cloud-channel/src/main/java/com/google/cloud/channel/v1/package-info.java",
109 …"google-cloud-channel/src/main/java/com/google/cloud/channel/v1/stub/CloudChannelServiceStub.java",
110 …"google-cloud-channel/src/main/java/com/google/cloud/channel/v1/stub/CloudChannelServiceStubSettin…
111 …"google-cloud-channel/src/main/java/com/google/cloud/channel/v1/stub/GrpcCloudChannelServiceCallab…
112 …"google-cloud-channel/src/main/java/com/google/cloud/channel/v1/stub/GrpcCloudChannelServiceStub.j…
[all …]
DCHANGELOG.md3 …om/googleapis/google-cloud-java/compare/google-cloud-channel-v3.8.1-SNAPSHOT...google-cloud-channe…
25 …hub.com/googleapis/google-cloud-java/compare/google-cloud-channel-v3.7.6...google-cloud-channel-v3…
46 ## [3.7.6](https://github.com/googleapis/java-channel/compare/v3.7.5...v3.7.6) (2022-10-04)
51 * update protobuf to v3.21.7 ([556b83d](https://github.com/googleapis/java-channel/commit/556b83d24…
53 ## [3.7.5](https://github.com/googleapis/java-channel/compare/v3.7.4...v3.7.5) (2022-10-03)
58 …51](https://github.com/googleapis/java-channel/issues/351)) ([d4cf483](https://github.com/googleap…
60 ## [3.7.4](https://github.com/googleapis/java-channel/compare/v3.7.3...v3.7.4) (2022-09-15)
65 …44](https://github.com/googleapis/java-channel/issues/344)) ([7af76d8](https://github.com/googleap…
67 ## [3.7.3](https://github.com/googleapis/java-channel/compare/v3.7.2...v3.7.3) (2022-09-09)
72 …40](https://github.com/googleapis/java-channel/issues/340)) ([102e7d3](https://github.com/googleap…
[all …]
/external/perfetto/src/base/threading/
Dchannel_unittest.cc17 #include "perfetto/ext/base/threading/channel.h"
39 using ReadResult = Channel<int>::ReadResult;
40 using WriteResult = Channel<int>::WriteResult;
64 Channel<int> channel(1); in TEST() local
65 ASSERT_TRUE(IsReady(channel.write_fd())); in TEST()
66 ASSERT_FALSE(IsReady(channel.read_fd())); in TEST()
68 ASSERT_EQ(channel.WriteNonBlocking(100), WriteResult(true, false)); in TEST()
69 ASSERT_EQ(channel.WriteNonBlocking(101), WriteResult(false, false)); in TEST()
71 ASSERT_FALSE(IsReady(channel.write_fd())); in TEST()
72 ASSERT_TRUE(IsReady(channel.read_fd())); in TEST()
[all …]
/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/
DJimfsFileChannelTest.java66 * interactions with the file and channel positions.
73 private static FileChannel channel(RegularFile file, OpenOption... options) throws IOException { in channel() method in JimfsFileChannelTest
82 FileChannel channel = channel(regularFile(10), READ); in testPosition() local
83 assertEquals(0, channel.position()); in testPosition()
84 assertSame(channel, channel.position(100)); in testPosition()
85 assertEquals(100, channel.position()); in testPosition()
91 FileChannel channel = channel(file, READ); in testSize() local
93 assertEquals(10, channel.size()); in testSize()
96 assertEquals(100, channel.size()); in testSize()
102 FileChannel channel = channel(file, READ); in testRead() local
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/selects/
DSelectRendezvousChannelTest.kt17 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
20 assertEquals("OK", channel.receive()) in <lambda>()
26 channel.onSend("OK") { in <lambda>()
36 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
39 assertEquals("OK", channel.receive()) in <lambda>()
45 channel.onSend("OK") { in <lambda>()
58 val channel = Channel<String>(Channel.RENDEZVOUS) in <lambda>() constant
60 channel.onSend("OK") { in <lambda>()
71 assertEquals("CHK", channel.receive()) in <lambda>()
77 channel.send("CHK") in <lambda>()
[all …]
DSelectBufferedChannelTest.kt16 val channel = Channel<String>(1) in <lambda>() constant
19 assertEquals("OK", channel.receive()) in <lambda>()
25 channel.onSend("OK") { in <lambda>()
35 val channel = Channel<String>(1) in <lambda>() constant
38 assertEquals("OK", channel.receive()) in <lambda>()
44 channel.onSend("OK") { in <lambda>()
57 val channel = Channel<String>(1) in <lambda>() constant
59 channel.onSend("OK") { in <lambda>()
65 channel.onReceive { v -> in <lambda>()
76 val channel = Channel<String>(1) in <lambda>() constant
[all …]
/external/openthread/tests/toranj/cli/
Dtest-602-channel-manager-channel-select.py37 # Verifies `ChannelManager` channel selection procedure
55 node.form('chan-sel', channel=24)
62 channel = 24 variable
66 verify(int(node.get_channel()) == channel)
69 delay = int(node.cli('channel manager delay')[0])
70 # add kRequestStartJitterInterval=10000ms to expected channel manager delay
79 # Set supported channel mask to be all channels
80 node.cli('channel manager supported', all_channels_mask)
88 result = cli.Node.parse_list(node.cli('channel monitor')[:5])
92 # Issue a channel-select with quality check enabled, and verify that no
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/http2/
DMultiplexedChannelRecordTest.java21 import io.netty.channel.Channel;
22 import io.netty.channel.ChannelHandlerContext;
23 import io.netty.channel.ChannelInboundHandlerAdapter;
24 import io.netty.channel.ChannelInitializer;
25 import io.netty.channel.EventLoopGroup;
26 import io.netty.channel.embedded.EmbeddedChannel;
27 import io.netty.channel.nio.NioEventLoopGroup;
45 private MockChannel channel; field in MultiplexedChannelRecordTest
50 channel = new MockChannel(); in setup()
56 channel.close(); in teardown()
[all …]
DHttp2PingHandlerTest.java21 import io.netty.channel.ChannelHandler;
22 import io.netty.channel.ChannelHandlerContext;
23 import io.netty.channel.ChannelInboundHandlerAdapter;
24 import io.netty.channel.ChannelOutboundHandlerAdapter;
25 import io.netty.channel.ChannelPromise;
26 import io.netty.channel.SimpleChannelInboundHandler;
27 import io.netty.channel.embedded.EmbeddedChannel;
57 EmbeddedChannel channel = new EmbeddedChannel(slowChecker); in register_withoutProtocol_Fails() local
58 assertThat(channel.pipeline().get(Http2PingHandler.class)).isNull(); in register_withoutProtocol_Fails()
63 EmbeddedChannel channel = createChannelWithoutProtocol(fastChecker); in register_withIncompleteProtocol_doesNotPing() local
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/
DNettyClientLogger.java18 import io.netty.channel.Channel;
26 …* Logger facade similar to {@link software.amazon.awssdk.utils.Logger}, that also includes channel…
27 …* when provided. When the logger has at least DEBUG level enabled, the logger uses {@link Channel#…
28 …* complete information about the channel. If only less verbose levels are available, then only the…
30 …* Having the channel information associated with the log message whenever available makes correlat…
31 …* logged within the context of that channel possible; this is impossible to do otherwise because t…
34 …* <b>NOTE:</b> The absence of overrides that don't take a {@code Channel} parameter is deliberate.…
35 * chances that a {code Channel} is omitted from the log by accident.
52 * Log a DEBUG level message including the channel information.
54 * @param channel The channel for this message is being logged
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/
DIdleConnectionCountingChannelPool.java20 import io.netty.channel.Channel;
21 import io.netty.channel.pool.ChannelPool;
35 …* A channel pool implementation that tracks the number of "idle" channels in an underlying channel…
37 …ol counts the number of channels acquired and then released from/to the underlying channel pool. It
45 …* The idle channel state for a specific channel. This should only be accessed from the {@link #exe…
61 …* The number of idle connections in the underlying channel pool. This value is only valid if acces…
72 public Future<Channel> acquire() { in acquire()
77 public Future<Channel> acquire(Promise<Channel> promise) { in acquire()
78 Future<Channel> acquirePromise = delegatePool.acquire(executor.newPromise()); in acquire()
84 Channel channel = acquirePromise.getNow(); in acquire()
[all …]
DHealthCheckedChannelPool.java20 import io.netty.channel.Channel;
21 import io.netty.channel.EventLoopGroup;
22 import io.netty.channel.pool.ChannelPool;
37 * <li>All connections acquired from the underlying channel pool are in the active state.</li>
41 … Acquisitions that fail due to an unhealthy underlying channel are retried until a healthy channel…
59 public Future<Channel> acquire() { in acquire()
64 public Future<Channel> acquire(Promise<Channel> resultFuture) { in acquire()
65 … // Schedule a task to time out this acquisition, in case we can't acquire a channel fast enough. in acquire()
76 private void timeoutAcquire(Promise<Channel> resultFuture) { in timeoutAcquire()
82 …* Try to acquire a channel from the underlying pool. This will keep retrying the acquisition until…
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DChannelUndeliveredElementFailureTest.kt13 * Tests for failures inside `onUndeliveredElement` handler in [Channel].
25 val channel = Channel(onUndeliveredElement = onCancelFail) in isElementCancelException() constant
27 channel.send(item) in isElementCancelException()
35 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
38 channel.onSend(item) { in <lambda>()
48 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
50 channel.receive() in <lambda>()
53 channel.send(item) in <lambda>()
59 val channel = Channel(onUndeliveredElement = onCancelFail) in <lambda>() constant
62 channel.onReceive { in <lambda>()
[all …]
DChannelUndeliveredElementTest.kt15 val channel = kind.create<Resource> { it.cancel() } in <lambda>() constant
18 channel.send(res) in <lambda>()
20 val ok = channel.receive() in <lambda>()
23 channel.close() in <lambda>()
30 val channel = Channel<Resource> { it.cancel() } in <lambda>() constant
34 channel.send(res) // suspends & get cancelled in <lambda>()
43 val channel = Channel<Resource>(1) { it.cancel() } in <lambda>() constant
47 channel.send(resA) // goes to buffer in <lambda>()
49 channel.send(resB) // suspends & get cancelled in <lambda>()
55 channel.cancel() // now cancel the channel in <lambda>()
[all …]
DChannelReceiveCatchingTest.kt13 val channel = Channel<Throwable>() in <lambda>() constant
15 channel.send(TestException1()) in <lambda>()
16 channel.close(TestException2()) in <lambda>()
19 val element = channel.receiveCatching() in <lambda>()
23 val closed = channel.receiveCatching() in <lambda>()
32 val channel = Channel<Int?>() in <lambda>() constant
35 channel.send(1) in <lambda>()
37 channel.send(null) in <lambda>()
40 channel.close() in <lambda>()
44 val element = channel.receiveCatching() in <lambda>()
[all …]
/external/google-cloud-java/java-channel/grpc-google-cloud-channel-v1/src/main/java/com/google/cloud/channel/v1/
DCloudChannelServiceGrpc.java16 package com.google.cloud.channel.v1;
25 * their customers, channel partners, entitlements, and reports.
28 * 2. Distributors can register an authorized reseller in their channel and
32 * - [Customer][google.cloud.channel.v1.Customer]s: An entity-usually an
34 * - [Entitlement][google.cloud.channel.v1.Entitlement]s: An entity that
37 * - [ChannelPartnerLink][google.cloud.channel.v1.ChannelPartnerLink]s: An
39 * resellers in a channel.
44 comments = "Source: google/cloud/channel/v1/service.proto")
50 public static final String SERVICE_NAME = "google.cloud.channel.v1.CloudChannelService";
54 com.google.cloud.channel.v1.ListCustomersRequest,
[all …]
DCloudChannelReportsServiceGrpc.java16 package com.google.cloud.channel.v1;
25 * distributors retrieve and combine a variety of data in Cloud Channel for
32 comments = "Source: google/cloud/channel/v1/reports_service.proto")
38 public static final String SERVICE_NAME = "google.cloud.channel.v1.CloudChannelReportsService";
42 com.google.cloud.channel.v1.RunReportJobRequest, com.google.longrunning.Operation>
47 requestType = com.google.cloud.channel.v1.RunReportJobRequest.class,
51 com.google.cloud.channel.v1.RunReportJobRequest, com.google.longrunning.Operation>
54 com.google.cloud.channel.v1.RunReportJobRequest, com.google.longrunning.Operation> in getRunReportJobMethod()
63 .<com.google.cloud.channel.v1.RunReportJobRequest, in getRunReportJobMethod()
71 com.google.cloud.channel.v1.RunReportJobRequest.getDefaultInstance())) in getRunReportJobMethod()
[all …]
/external/curl/tests/data/
Dtest57153 rtp: part 2 channel 1 size 10
54 rtp: part 2 channel 0 size 500
55 rtp: part 2 channel 0 size 196
56 rtp: part 2 channel 0 size 124
57 rtp: part 2 channel 0 size 824
58 rtp: part 2 channel 0 size 18 size_err -6
59 rtp: part 3 channel 1 size 10
60 rtp: part 3 channel 0 size 50
61 rtp: part 4 channel 0 size 798
62 rtp: part 4 channel 0 size 42
[all …]
/external/rust/crates/grpcio-sys/grpc/third_party/cares/cares/src/lib/
Dares_init.c65 static int init_by_options(ares_channel channel,
68 static int init_by_environment(ares_channel channel);
69 static int init_by_resolv_conf(ares_channel channel);
70 static int init_by_defaults(ares_channel channel);
76 static int set_search(ares_channel channel, const char *str);
77 static int set_options(ares_channel channel, const char *str);
88 static int config_domain(ares_channel channel, char *str);
89 static int config_lookup(ares_channel channel, const char *str,
109 ares_channel channel; in ares_init_options() local
117 channel = ares_malloc(sizeof(struct ares_channeldata)); in ares_init_options()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/
DStackTraceRecoveryChannelsTest.kt20 val channel = Channel<Int>() in <lambda>() constant
23 channel.close(RecoverableTestException()) in <lambda>()
27 channelReceive(channel) in <lambda>()
35 val channel = Channel<Int>() in <lambda>() constant
36 channel.close(RecoverableTestException()) in <lambda>()
37 channelReceive(channel) in <lambda>()
42 val channel = Channel<Int>() in <lambda>() constant
43 channel.close(RecoverableTestException()) in <lambda>()
44 channelSend(channel) in <lambda>()
49 val channel = Channel<Int>() in <lambda>() constant
[all …]
/external/grpc-grpc/src/core/lib/surface/
Dchannel.cc19 #include "src/core/lib/surface/channel.h"
27 #include "src/core/lib/channel/channel_args.h"
28 #include "src/core/lib/channel/channel_trace.h"
29 #include "src/core/lib/channel/channelz.h"
40 // Channel::RegisteredCall
43 Channel::RegisteredCall::RegisteredCall(const char* method_arg, in RegisteredCall()
51 Channel::RegisteredCall::RegisteredCall(const RegisteredCall& other) in RegisteredCall()
58 Channel::RegisteredCall::~RegisteredCall() {} in ~RegisteredCall()
61 // Channel
64 Channel::Channel(std::string target, const ChannelArgs& channel_args) in Channel() function in grpc_core::Channel
[all …]
/external/grpc-grpc/src/php/ext/grpc/
Dchannel.c20 * class Channel
21 * @see https://github.com/grpc/grpc/tree/master/src/php/ext/grpc/channel.c
24 #include "channel.h"
48 void free_grpc_channel_wrapper(grpc_channel_wrapper* channel, bool free_channel) { in free_grpc_channel_wrapper() argument
49 if (free_channel && channel->wrapped) { in free_grpc_channel_wrapper()
50 grpc_channel_destroy(channel->wrapped); in free_grpc_channel_wrapper()
51 channel->wrapped = NULL; in free_grpc_channel_wrapper()
53 free(channel->target); in free_grpc_channel_wrapper()
54 free(channel->args_hashstr); in free_grpc_channel_wrapper()
55 free(channel->creds_hashstr); in free_grpc_channel_wrapper()
[all …]
/external/openthread/include/openthread/
Dchannel_manager.h32 * This file includes the OpenThread API for Channel Manager module.
45 * @addtogroup api-channel-manager
48 * This module includes functions for Channel Manager.
50 * The functions in this module are available when Channel Manager features
52 …* OPENTHREAD_CONFIG_CHANNEL_MANAGER_CSL_CHANNEL_SELECT_ENABLE` are enabled. Channel Manager behavi…
53 …* device role. It manages the network-wide PAN channel on a Full Thread Device in rx-on-when-idle …
55 * selects CSL channel in synchronized rx-off-when-idle mode. On a Minimal Thread Device
57 * the CSL channel.
64 * Requests a Thread network channel change.
66 …* The network switches to the given channel after a specified delay (see #otChannelManagerSetDelay…
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannel.kt10 import kotlinx.coroutines.channels.Channel.Factory.BUFFERED
11 import kotlinx.coroutines.channels.Channel.Factory.CHANNEL_DEFAULT_CAPACITY
12 import kotlinx.coroutines.channels.Channel.Factory.CONFLATED
13 import kotlinx.coroutines.channels.Channel.Factory.RENDEZVOUS
14 import kotlinx.coroutines.channels.Channel.Factory.UNLIMITED
22 * Sender's interface to [Channel].
26 …* Returns `true` if this channel was closed by an invocation of [close] or its receiving side was …
30 …* channel can be concurrently closed right after the check. For such scenarios, it is recommended …
40 …* Sends the specified [element] to this channel, suspending the caller while the buffer of this ch…
41 …* or if it does not exist, or throws an exception if the channel [is closed for `send`][isClosedFo…
[all …]
/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
DHealthCheckedChannelPoolTest.java28 import io.netty.channel.Channel;
29 import io.netty.channel.EventLoop;
30 import io.netty.channel.EventLoopGroup;
56 private List<Channel> channels = new ArrayList<>();
84 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeJustOneCall()
100 Future<Channel> acquire = channelPool.acquire(); in acquireCanMakeManyCalls()
116 Future<Channel> acquire = channelPool.acquire(); in acquireActiveAndKeepAliveTrue_shouldAcquireOnce()
133 Future<Channel> acquire = channelPool.acquire(); in acquire_firstChannelKeepAliveFalse_shouldAcquireAnother()
149 Future<Channel> acquire = channelPool.acquire(); in badDownstreamAcquiresCausesException()
171 Future<Channel> acquire = channelPool.acquire(); in slowAcquireTimesOut()
[all …]

12345678910>>...362