Home
last modified time | relevance | path

Searched +full:test +full:- +full:sequencer (Results 1 – 25 of 450) sorted by relevance

12345678910>>...18

/aosp_15_r20/packages/modules/Permission/PermissionController/tests/mocking/src/com/android/permissioncontroller/tests/mocking/safetycenter/ui/
DSafetyStatusAnimationSequencerTest.kt8 * http://www.apache.org/licenses/LICENSE-2.0
22 import androidx.test.ext.junit.runners.AndroidJUnit4
23 import androidx.test.filters.SdkSuppress
26 import org.junit.Test
33 private val sequencer: SafetyStatusAnimationSequencer = SafetyStatusAnimationSequencer() constant in com.android.permissioncontroller.tests.mocking.safetycenter.ui.SafetyStatusAnimationSequencerTest
35 @Test
37 assertThat(sequencer.getCurrentlyVisibleSeverityLevel()) in getCurrentlyVisibleSeverityLevel_returnsUnknown()
41 @Test
43 sequencer.onUpdateReceived(REFRESHING, OVERALL_SEVERITY_LEVEL_CRITICAL_WARNING) in getCurrentlyVisibleSeverityLevel_refreshingWithCriticalSeverity_returnsCritical()
44 sequencer.onStartScanningAnimationStart() in getCurrentlyVisibleSeverityLevel_refreshingWithCriticalSeverity_returnsCritical()
[all …]
/aosp_15_r20/external/libwebsockets/minimal-examples/api-tests/api-test-lws_sequencer/
H A Dmain.c2 * lws-api-test-lws_sequencer
9 * This api test uses the lws_sequencer api to make five http client requests
32 * sequencer when that is created.
34 * You'd put everything your sequencer needs to do its job in here.
41 int state; /* which test we're on */
45 /* sequencer messages specific to this sequencer */
70 * This is the sequencer-aware http protocol handler. It monitors the client
71 * http action and queues messages for the sequencer when something definitive
93 s->http_resp = (int)lws_http_client_http_response(wsi); in callback_http()
94 lwsl_info("Connected with server response: %d\n", s->http_resp); in callback_http()
[all …]
/aosp_15_r20/external/libwebsockets/lib/abstract/
H A Dtest-sequencer.c2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <[email protected]>
28 * for each test using te
31 #include <private-lib-core.h>
42 /* holds the per-test token for the unit-test transport to consume */
50 /* sequencer messages specific to this sequencer */
59 * We get called back when the unit test transport has decided if the test
60 * passed or failed. We get the priv, and report to the sequencer message queue
90 return -1; in unit_test_result_cb()
93 lws_seq_queue_event(s->unit_test_seq, r, NULL, NULL); in unit_test_result_cb()
[all …]
H A DREADME.md6 to the network-related apis inside lws.
12 ![lws_abstract overview](/doc-assets/abstract-overview.svg)
32 up the protocol implementation to a test jig sending canned
33 test vectors and confirming the response at buffer level, without
39 protocol and the transport are passed in at instantiation-time,
43 and lws provides a raw socket transport built-in.
50 …- [abstract.h](https://libwebsockets.org/git/libwebsockets/tree/include/libwebsockets/abstract/abs…
51 …- [protocols.h](https://libwebsockets.org/git/libwebsockets/tree/include/libwebsockets/abstract/pr…
52 …- [transports.h](https://libwebsockets.org/git/libwebsockets/tree/include/libwebsockets/abstract/t…
76 At the moment only "`raw-skt`" is defined as an lws built-in, athough
[all …]
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
H A Dquic_stream_sequencer_peer.cc2 // Use of this source code is governed by a BSD-style license that can be
11 namespace test { namespace
15 QuicStreamSequencer* sequencer) { in GetNumBufferedBytes() argument
16 return sequencer->buffered_frames_.BytesBuffered(); in GetNumBufferedBytes()
21 QuicStreamSequencer* sequencer) { in GetCloseOffset() argument
22 return sequencer->close_offset_; in GetCloseOffset()
27 QuicStreamSequencer* sequencer) { in IsUnderlyingBufferAllocated() argument
28 QuicStreamSequencerBufferPeer buffer_peer(&(sequencer->buffered_frames_)); in IsUnderlyingBufferAllocated()
34 QuicStreamSequencer* sequencer, QuicStreamOffset total_bytes_read) { in SetFrameBufferTotalBytesRead() argument
35 QuicStreamSequencerBufferPeer buffer_peer(&(sequencer->buffered_frames_)); in SetFrameBufferTotalBytesRead()
[all …]
H A Dquic_stream_sequencer_peer.h2 // Use of this source code is governed by a BSD-style license that can be
14 namespace test {
20 static size_t GetNumBufferedBytes(QuicStreamSequencer* sequencer);
22 static QuicStreamOffset GetCloseOffset(QuicStreamSequencer* sequencer);
24 static bool IsUnderlyingBufferAllocated(QuicStreamSequencer* sequencer);
26 static void SetFrameBufferTotalBytesRead(QuicStreamSequencer* sequencer,
30 } // namespace test
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
H A Dquic_spdy_stream.h2 // Use of this source code is governed by a BSD-style license that can be
47 namespace test {
50 } // namespace test
146 // Called by the sequencer when new data is available. Decodes the data and
196 // OnStreamHeaderList(). Trailer data will be consumed from the sequencer only
203 // This block of functions wraps the sequencer's functions of the same
205 // been fully processed. Then they simply delegate to the sequencer.
210 // Returns true if header contains a valid 3-digit status and parse the status
215 // 3-digit status and parse the status code to |status_code|.
221 // For IETF QUIC, bytes-to-read/readable-bytes only concern body (not headers
[all …]
H A Dquic_spdy_stream.cc2 // Use of this source code is governed by a BSD-style license that can be
61 stream_->OnUnrecoverableError(decoder->error(), decoder->error_detail()); in OnError()
86 return stream_->OnDataFrameStart(header_length, payload_length); in OnDataFrameStart()
91 return stream_->OnDataFramePayload(payload); in OnDataFramePayload()
94 bool OnDataFrameEnd() override { return stream_->OnDataFrameEnd(); } in OnDataFrameEnd()
98 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFrameStart()
102 return stream_->OnHeadersFrameStart(header_length, payload_length); in OnHeadersFrameStart()
107 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFramePayload()
111 return stream_->OnHeadersFramePayload(payload); in OnHeadersFramePayload()
115 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFrameEnd()
[all …]
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/
H A Dquic_stream_sequencer.h2 // Use of this source code is governed by a BSD-style license that can be
19 namespace test {
21 } // namespace test
27 // Interface that thie Sequencer uses to communicate with the Stream.
32 // Called when new data is available to be read from the sequencer.
36 // Called when bytes have been consumed from the sequencer.
64 // If the frame is the next one we need in order to process in-order data,
71 // If the frame is the next one we need in order to process in-order data,
82 // number of iovs used. Non-destructive of the underlying data.
101 // to do zero-copy reads.
[all …]
H A Dquic_stream.h2 // Use of this source code is governed by a BSD-style license that can be
45 namespace test {
47 } // namespace test
74 // Buffers the contents of |frame|. Frame must have a non-zero offset.
96 const QuicStreamSequencer* sequencer() const { return &sequencer_; } in sequencer() function
100 // Tells the sequencer to ignore all incoming data itself and not call
130 // Connection-level flow controller. Owned by the session.
132 // Stream-level flow controller.
165 // Called by the subclass or the sequencer to reset the stream from this
178 // Called by the subclass or the sequencer to close the entire connection from
[all …]
H A Dquic_stream_sequencer_test.cc2 // Use of this source code is governed by a BSD-style license that can be
30 namespace test { namespace
64 ASSERT_EQ(num_bytes, sequencer_->Readv(&iov, 1)); in ConsumeData()
87 bool VerifyReadableRegion(const QuicStreamSequencer& sequencer, in VerifyReadableRegion() argument
90 if (sequencer.GetReadableRegions(iovecs, 1)) { in VerifyReadableRegion()
91 return (VerifyIovecs(sequencer, iovecs, 1, in VerifyReadableRegion()
99 bool VerifyReadableRegions(const QuicStreamSequencer& sequencer, in VerifyReadableRegions() argument
103 sequencer.GetReadableRegions(iovecs, ABSL_ARRAYSIZE(iovecs)); in VerifyReadableRegions()
104 return VerifyReadableRegion(sequencer, expected) && in VerifyReadableRegions()
105 VerifyIovecs(sequencer, iovecs, num_iovecs, expected); in VerifyReadableRegions()
[all …]
H A Dquic_crypto_stream.cc2 // Use of this source code is governed by a BSD-style license that can be
26 (session()->perspective() == Perspective::IS_SERVER ? "Server: " \
32 QuicVersionUsesCryptoFrames(session->transport_version()) in QuicCryptoStream()
33 ? QuicUtils::GetInvalidStreamId(session->transport_version()) in QuicCryptoStream()
34 : QuicUtils::GetCryptoStreamId(session->transport_version()), in QuicCryptoStream()
37 QuicVersionUsesCryptoFrames(session->transport_version()) in QuicCryptoStream()
69 !QuicVersionUsesCryptoFrames(session()->transport_version())) in OnCryptoFrame()
71 EncryptionLevel level = session()->connection()->last_decrypted_level(); in OnCryptoFrame()
80 substream.sequencer.OnCryptoFrame(frame); in OnCryptoFrame()
82 if (substream.sequencer.NumBytesBuffered() > in OnCryptoFrame()
[all …]
H A Dquic_crypto_stream.h2 // Use of this source code is governed by a BSD-style license that can be
31 // normal 1-RTT handshake, the client will send a client hello, CHLO, message.
37 // https://docs.google.com/document/d/1g5nIXAIkN_Y-7XJW5K45IblHd_L2f5LTaDUDwvZ5L6g/edit?usp=sharing
46 // Returns the per-packet framing overhead associated with sending a
77 // Returns the ssl_early_data_reason_t describing why 0-RTT was accepted or
125 // TODO(wub): This function is test only, move it to a test only library.
132 // Called to provide the server-side application state that must be checked
133 // when performing a 0-RTT TLS resumption.
135 // On a client, this may be called at any time; 0-RTT tickets will not be
136 // cached until this function is called. When a 0-RTT resumption is attempted,
[all …]
H A Dquic_crypto_client_stream_test.cc2 // Use of this source code is governed by a BSD-style license that can be
31 namespace test { namespace
34 const char kServerHostname[] = "test.example.com";
37 // This test tests the client-side of the QUIC crypto handshake. It does not
38 // test the TLS handshake - that is in tls_client_handshaker_test.cc.
45 std::make_unique<test::SimpleSessionCache>()), in QuicCryptoClientStreamTest()
57 {AlpnForVersion(connection_->version())}))); in CreateSession()
65 connection_->AdvanceTime(QuicTime::Delta::FromSeconds(1)); in CreateConnection()
71 if (stream()->handshake_protocol() != PROTOCOL_TLS1_3) { in CompleteCryptoHandshake()
78 stream()->CryptoConnect(); in CompleteCryptoHandshake()
[all …]
/aosp_15_r20/external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-seq/
H A Dminimal-secure-streams.c2 * lws-minimal-secure-streams-seq
4 * Written in 2010-2020 by Andy Green <[email protected]>
14 * This is the "secure streams" api equivalent of minimal-http-client...
15 * it shows how to use a sequencer to make it easy to build more complex
22 * ------ app ------ process
23 * ---- sequencer ---- process
24 * --- secure stream --- process
25 * ------- wsi ------- connection
27 * see minimal-secure-streams for a similar example without the sequencer.
39 "\"schema-version\":" "1,"
[all …]
/aosp_15_r20/external/libwebsockets/lib/abstract/transports/
H A Dunit-test.c2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <[email protected]>
26 * to provided canned packets from an array of test vectors.
29 #include "private-lib-core.h"
30 #include "private-lib-abstract.h"
32 /* this is the transport priv instantiated at abs->ati */
66 * A definitive result has appeared for the current test
74 assert(priv->disposition == LPE_CONTINUE); in lws_unit_test_packet_dispose()
79 lws_strncpy(priv->note, note, sizeof(priv->note)); in lws_unit_test_packet_dispose()
81 priv->disposition = disp; in lws_unit_test_packet_dispose()
[all …]
/aosp_15_r20/external/libwebsockets/lib/abstract/protocols/smtp/
H A Dsmtp-sequencer.c2 * Abstract SMTP support for libwebsockets - SMTP sequencer
4 * Copyright (C) 2016-2019 Andy Green <[email protected]>
24 * This sequencer sits above the abstract protocol, and manages queueing,
27 * Having the sequencer means that, eg, we can manage retries after complete
33 #include "private-lib-core.h"
34 #include "private-lib-abstract-protocols-smtp.h"
58 /* sequencer messages specific to this sequencer */
66 * We're going to bind to the raw-skt transport, so tell that what we want it
90 pd2 = lws_dll2_get_head(&s->emails_owner); in lws_smtpc_kick_internal()
100 if (s->connstate == LSMTPSS_DISCONNECTED) { in lws_smtpc_kick_internal()
[all …]
/aosp_15_r20/external/tensorflow/tensorflow/compiler/jit/
H A Dencapsulate_subgraphs_pass_test.cc7 http://www.apache.org/licenses/LICENSE-2.0
37 #include "tensorflow/core/platform/test.h"
58 FunctionDef* fdef = library->add_function(); in AddGraphDefToFunctionLibrary()
84 if (!compare(elt_a.first, elt_a.second, iter->second)) { in EqualProtoMap()
89 value_to_string(iter->second), "'"); in EqualProtoMap()
275 if (!EqualFunctionDef(expected_function, *it->second, diff)) return false; in EqualFunctionDefLibrary()
283 actual_index.begin()->second->signature().name(), "'"); in EqualFunctionDefLibrary()
301 c->set_output(0, c->UnknownShape()); in __anon4e24c0570b02()
308 c->set_output(0, c->Vector(2)); in __anon4e24c0570c02()
317 TF_RETURN_IF_ERROR(c->Merge(c->UnknownShape(), c->input(0), &o)); in __anon4e24c0570d02()
[all …]
H A Dextract_outside_compilation_pass_test.cc7 http://www.apache.org/licenses/LICENSE-2.0
25 #include "tensorflow/compiler/xla/test.h"
34 #include "tensorflow/core/platform/test.h"
40 TEST(RewriteOutsideCompilationSubgraphFnTest, Basic) { in TEST() function
54 auto node_name_image = g->BuildNodeNameIndex(); in TEST()
57 add_node->AddAttr(kXlaConnectedToXlaComputationAttrName, "cluster"); in TEST()
58 add_node->AddAttr(kXlaConnectedFromXlaComputationAttrName, "cluster"); in TEST()
66 node_name_image = g->BuildNodeNameIndex(); in TEST()
72 for (Node *n : g->nodes()) { in TEST()
73 EXPECT_NE(n->type_string(), "_Arg"); in TEST()
[all …]
/aosp_15_r20/external/pytorch/test/cpp/api/
H A Ddataloader.cpp5 #include <test/cpp/api/support.h>
33 // NOLINTNEXTLINE(cppcoreguidelines-narrowing-conversions,bugprone-narrowing-conversions) in get()
43 TEST(DataTest, DatasetCallsGetCorrectly) { in TEST() function
50 TEST(DataTest, TransformCallsGetApplyCorrectly) { in TEST() function
76 // NOLINTNEXTLINE(bugprone-fold-init-type) in read_chunk()
93 …// NOLINTNEXTLINE(modernize-avoid-c-arrays,cppcoreguidelines-avoid-magic-numbers,cppcoreguidelines…
97 TEST(DataTest, ChunkDataSetWithInvalidInitParameter) { in TEST() function
161 TEST(DataTest, InfiniteStreamDataset) { in TEST() function
184 TEST(DataTest, NoSequencerIsIdentity) { in TEST() function
191 TEST(DataTest, OrderedSequencerIsSetUpWell) { in TEST() function
[all …]
/aosp_15_r20/tools/test/connectivity/acts/framework/acts/controllers/rohdeschwarz_lib/
Dcontest.py3 # Copyright 2019 - The Android Open Source Project
9 # http://www.apache.org/licenses/LICENSE-2.0
30 """ Controller interface for Rohde Schwarz CONTEST sequencer software. """
122 """ Executes a test plan with Contest's Remote Server sequencer.
125 the class logger and pulls the json report from the server if the test
129 testplan: the test plan's name in the Contest system
132 a dictionary with test results if the test finished successfully,
168 # test equipment will be stored in the remote computer
178 match = re.search('(?<=Exit code: )-?\d+', output)
183 # Reset the not-responding counter
[all …]
/aosp_15_r20/prebuilts/jdk/jdk8/linux-x86/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/
DScanManager.java8 * - Redistributions of source code must retain the above copyright
11 * - Redistributions in binary form must reproduce the above copyright
15 * - Neither the name of Oracle nor the names of its
35 * required for a production-quality application, such as security checks,
101 * @author Sun Microsystems, 2006 - All rights reserved.
164 * action. The logic we have implemented is to fail - rather
167 private final Semaphore sequencer = new Semaphore(1); field in ScanManager
354 if (!sequencer.tryAcquire()) { in applyConfiguration()
366 sequencer.release(); in applyConfiguration()
463 // ---------------------------------------------------------------
[all …]
/aosp_15_r20/prebuilts/jdk/jdk8/darwin-x86/sample/jmx/jmx-scandir/src/com/sun/jmx/examples/scandir/
DScanManager.java8 * - Redistributions of source code must retain the above copyright
11 * - Redistributions in binary form must reproduce the above copyright
15 * - Neither the name of Oracle nor the names of its
35 * required for a production-quality application, such as security checks,
101 * @author Sun Microsystems, 2006 - All rights reserved.
164 * action. The logic we have implemented is to fail - rather
167 private final Semaphore sequencer = new Semaphore(1); field in ScanManager
354 if (!sequencer.tryAcquire()) { in applyConfiguration()
366 sequencer.release(); in applyConfiguration()
463 // ---------------------------------------------------------------
[all …]
/aosp_15_r20/external/libbrillo/brillo/dbus/
H A Dasync_event_sequencer.h2 // Use of this source code is governed by a BSD-style license that can be
29 // scoped_refptr<AsyncEventSequencer> sequencer(
31 // one_delegate_needing_init_.Init(sequencer->GetHandler(
33 // dbus_init_delegate_.Init(sequencer->GetExportHandler(
34 // "org.test.Interface", "ExposedMethodName",
36 // sequencer->OnAllTasksCompletedCall({cb});
/aosp_15_r20/external/libwebsockets/minimal-examples/api-tests/api-test-smtp_client/
H A Dmain.c2 * lws-unit-tests-smtp-client
4 * Written in 2010-2019 by Andy Green <[email protected]>
27 * The test helper calls this on the instance it created to prepare it for
28 * the test. In our case, we need to queue up a test email to send on the
44 email->data = NULL /* email specific user data */; in smtp_test_instance_init()
45 email->email_from = "[email protected]"; in smtp_test_instance_init()
46 email->email_to = "[email protected]"; in smtp_test_instance_init()
47 email->payload = (void *)&email[1]; in smtp_test_instance_init()
49 lws_snprintf((char *)email->payload, 2048, in smtp_test_instance_init()
52 "Subject: Test email for lws smtp-client\n" in smtp_test_instance_init()
[all …]

12345678910>>...18