Home
last modified time | relevance | path

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

1234

/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
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 …]
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
Dquic_stream_peer.h2 // Use of this source code is governed by a BSD-style license that can be
20 namespace test {
43 static QuicStreamSequencer* sequencer(QuicStream* stream);
51 } // namespace test
Dquic_stream_peer.cc2 // Use of this source code is governed by a BSD-style license that can be
15 namespace test { namespace
19 stream->write_side_closed_ = value; in SetWriteSideClosed()
25 stream->send_buffer_.stream_bytes_written_ = stream_bytes_written; in SetStreamBytesWritten()
26 stream->send_buffer_.stream_bytes_outstanding_ = stream_bytes_written; in SetStreamBytesWritten()
27 QuicStreamSendBufferPeer::SetStreamOffset(&stream->send_buffer_, in SetStreamBytesWritten()
34 QuicFlowControllerPeer::SetSendWindowOffset(&*stream->flow_controller_, in SetSendWindowOffset()
40 return stream->flow_controller_->bytes_consumed(); in bytes_consumed()
46 QuicFlowControllerPeer::SetReceiveWindowOffset(&*stream->flow_controller_, in SetReceiveWindowOffset()
53 QuicFlowControllerPeer::SetMaxReceiveWindow(&*stream->flow_controller_, size); in SetMaxReceiveWindow()
[all …]
/external/libwebsockets/minimal-examples/api-tests/api-test-lws_sequencer/
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 …]
/external/libwebsockets/lib/abstract/
Dtest-sequencer.c2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <andy@warmcat.com>
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 …]
DCMakeLists.txt2 # libwebsockets - small server side websockets and web server implementation
4 # Copyright (C) 2010 - 2020 Andy Green <andy@warmcat.com>
26 # - changes to LIB_LIST
27 # - changes to SOURCES
28 # - includes via include_directories
39 abstract/test-sequencer.c)
43 abstract/transports/unit-test.c)
48 # abstract/protocols/smtp/smtp-sequencer.c
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 …]
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
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 …]
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
128 // Connection-level flow controller. Owned by the session.
130 // Stream-level flow controller.
161 // Called by the subclass or the sequencer to reset the stream from this
174 // Called by the subclass or the sequencer to close the entire connection from
[all …]
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 …]
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 …]
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 …]
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 …]
/external/libwebsockets/minimal-examples/secure-streams/minimal-secure-streams-seq/
Dminimal-secure-streams.c2 * lws-minimal-secure-streams-seq
4 * Written in 2010-2020 by Andy Green <andy@warmcat.com>
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 …]
/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_stream.h2 // Use of this source code is governed by a BSD-style license that can be
46 namespace test {
49 } // namespace test
108 // Called by the sequencer when new data is available. Decodes the data and
158 // OnStreamHeaderList(). Trailer data will be consumed from the sequencer only
165 // This block of functions wraps the sequencer's functions of the same
167 // been fully processed. Then they simply delegate to the sequencer.
172 // Returns true if header contains a valid 3-digit status and parse the status
177 // 3-digit status and parse the status code to |status_code|.
183 // For IETF QUIC, bytes-to-read/readable-bytes only concern body (not headers
[all …]
Dquic_spdy_stream.cc2 // Use of this source code is governed by a BSD-style license that can be
60 stream_->OnUnrecoverableError(decoder->error(), decoder->error_detail()); in OnError()
85 return stream_->OnDataFrameStart(header_length, payload_length); in OnDataFrameStart()
90 return stream_->OnDataFramePayload(payload); in OnDataFramePayload()
93 bool OnDataFrameEnd() override { return stream_->OnDataFrameEnd(); } in OnDataFrameEnd()
97 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFrameStart()
101 return stream_->OnHeadersFrameStart(header_length, payload_length); in OnHeadersFrameStart()
106 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFramePayload()
110 return stream_->OnHeadersFramePayload(payload); in OnHeadersFramePayload()
114 if (!VersionUsesHttp3(stream_->transport_version())) { in OnHeadersFrameEnd()
[all …]
/external/libwebsockets/lib/abstract/protocols/smtp/
Dsmtp-sequencer.c2 * Abstract SMTP support for libwebsockets - SMTP sequencer
4 * Copyright (C) 2016-2019 Andy Green <andy@warmcat.com>
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 …]
/external/libwebsockets/lib/abstract/transports/
Dunit-test.c2 * libwebsockets - small server side websockets and web server implementation
4 * Copyright (C) 2010 - 2019 Andy Green <andy@warmcat.com>
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 …]
/external/libbrillo/brillo/dbus/
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});
/external/libwebsockets/minimal-examples/api-tests/api-test-smtp_client/
Dmain.c2 * lws-unit-tests-smtp-client
4 * Written in 2010-2019 by Andy Green <andy@warmcat.com>
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 = "noreply@warmcat.com"; in smtp_test_instance_init()
46 email->email_to = "andy@warmcat.com"; 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 …]
/external/tensorflow/tensorflow/compiler/jit/
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 …]
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 __anon652166350b02()
308 c->set_output(0, c->Vector(2)); in __anon652166350c02()
317 TF_RETURN_IF_ERROR(c->Merge(c->UnknownShape(), c->input(0), &o)); in __anon652166350d02()
[all …]
/external/libwebsockets/minimal-examples/abstract/protocols/smtp-client/
Dmain.c2 * lws-api-test-smtp_client
4 * Written in 2010-2019 by Andy Green <andy@warmcat.com>
26 /* you could examine email->data here */ in done_cb()
36 free((char *)email->payload); in done_cb()
60 if ((p = lws_cmdline_option(argc, argv, "-d"))) in main()
63 p = lws_cmdline_option(argc, argv, "-r"); in main()
65 lwsl_err("-r <recipient email> is required\n"); in main()
90 ss_args.helo = "lws-abs-smtp-test"; in main()
95 lwsl_err("%s: smtp sequencer create failed\n", __func__); in main()
104 "Subject: Test email for lws smtp-client\n" in main()
[all …]
/external/grpc-grpc/include/grpc/
Dstatus.h9 * http://www.apache.org/licenses/LICENSE-2.0
37 an error-space that is not known in this address space. Also
74 /** Some resource has been exhausted, perhaps a per-user quota, or
80 to be deleted may be non-empty, an rmdir operation is applied to
81 a non-directory, etc.
83 A litmus test that may help a service implementor in deciding
86 (b) Use ABORTED if the client should retry at a higher-level
87 (e.g., restarting a read-modify-write sequence).
90 fails because the directory is non-empty, FAILED_PRECONDITION
96 read-modify-write on the same resource. */
[all …]

1234