Home
last modified time | relevance | path

Searched refs:message (Results 1 - 15 of 15) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Ddecoder.rs189 let mut message = match self.streams.remove(&stream_id) { variables
191 Some(mut message) => {
192 if let Some(vec) = message.remaining.take() {
194 self.decode_buffered_repr(vec.as_slice(), &mut message, stream_id)?;
196 message
200 self.decode_buffered_repr(buf, &mut message, stream_id)
202 self.streams.insert(stream_id, message);
210 message: &mut ReprMessage, in decode_buffered_repr()
218 Searcher::new(self.max_field_section_size, &self.table, &mut message.lines); in decode_buffered_repr()
221 match decoder.decode(&buf[cnt..], &mut message in decode_buffered_repr()
[all...]
/commonlibrary/ets_utils/js_sys_module/console/test/
H A Dtest_console.cpp125 std::string message = "console test %d"; in HWTEST_F() local
127 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage0); in HWTEST_F()
180 std::string message = "console test %d"; in HWTEST_F() local
182 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage0); in HWTEST_F()
204 std::string message = "console test %s"; in HWTEST_F() local
206 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage0); in HWTEST_F()
228 std::string message in HWTEST_F() local
252 std::string message = "console test %O"; HWTEST_F() local
275 std::string message = "console test %o"; HWTEST_F() local
299 std::string message = "console test %i"; HWTEST_F() local
323 std::string message = "console test %f"; HWTEST_F() local
347 std::string message = "console test %c"; HWTEST_F() local
371 std::string message = "console test %%"; HWTEST_F() local
395 std::string message = "console test %r"; HWTEST_F() local
426 std::string message = "abc"; // random value HWTEST_F() local
662 std::string message = "abc"; // Random value HWTEST_F() local
715 std::string message = "log"; // Message to print HWTEST_F() local
836 std::string message = "abc"; // Random value HWTEST_F() local
883 std::string message = ""; HWTEST_F() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp173 static void PostMessage(Worker *worker, void *message) in PostMessage() argument
175 worker->PostMessageInner(message); in PostMessage()
250 std::string messageStr = "message"; in RemoveGlobalCallObject()
1044 std::string message = "host"; in HWTEST_F() local
1045 napi_create_string_utf8(env, message.c_str(), message.length(), &argv[0]); in HWTEST_F()
1070 std::string message = "host"; in HWTEST_F() local
1071 napi_create_string_utf8(env, message.c_str(), message.length(), &argv[0]); in HWTEST_F()
1100 std::string message in HWTEST_F() local
1130 std::string message = "host"; HWTEST_F() local
1161 std::string message = "host"; HWTEST_F() local
1211 std::string message = ""; HWTEST_F() local
1238 std::string message = "host"; HWTEST_F() local
1289 std::string message = "host"; HWTEST_F() local
1325 std::string message = "host"; HWTEST_F() local
1371 std::string message = "host"; HWTEST_F() local
1414 std::string message = "host"; HWTEST_F() local
1489 std::string message = "host"; HWTEST_F() local
1771 std::string message = "host"; HWTEST_F() local
1823 std::string message = "host"; HWTEST_F() local
1849 std::string message = "host"; HWTEST_F() local
1880 std::string message = "host"; HWTEST_F() local
1930 std::string message = "host"; HWTEST_F() local
2461 std::string message = "host"; HWTEST_F() local
2491 std::string message = "host"; HWTEST_F() local
2515 std::string message = "host"; HWTEST_F() local
2544 std::string message = "host"; HWTEST_F() local
2734 std::string message = "host"; HWTEST_F() local
2762 std::string message = "host"; HWTEST_F() local
2789 std::string message = "host"; HWTEST_F() local
2817 std::string message = "host"; HWTEST_F() local
2851 std::string message = "host"; HWTEST_F() local
2885 std::string message = "host"; HWTEST_F() local
3086 std::string message = "host"; HWTEST_F() local
3108 std::string message = "host"; HWTEST_F() local
3131 std::string message = "host"; HWTEST_F() local
3154 std::string message = "host"; HWTEST_F() local
3179 std::string message = "host"; HWTEST_F() local
3204 std::string message = "host"; HWTEST_F() local
3507 std::string message = "host"; HWTEST_F() local
3529 std::string message = "host"; HWTEST_F() local
3552 std::string message = "host"; HWTEST_F() local
3575 std::string message = "host"; HWTEST_F() local
3625 std::string message = "host"; HWTEST_F() local
3657 std::string message = "host"; HWTEST_F() local
3692 std::string message = "host"; HWTEST_F() local
3727 std::string message = "host"; HWTEST_F() local
3764 std::string message = "host"; HWTEST_F() local
3796 std::string message = "host"; HWTEST_F() local
4043 std::string message = "host"; HWTEST_F() local
4078 std::string message = "host"; HWTEST_F() local
4114 std::string message = "host"; HWTEST_F() local
4144 std::string message = "host"; HWTEST_F() local
4177 std::string message = "host"; HWTEST_F() local
4212 std::string message = "host"; HWTEST_F() local
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Dencoder.rs65 message: EncodeMessage,
86 /// let message = encoder.encode(0, &mut res, &mut ins).unwrap();
177 /// let message = encoder.encode(0, &mut res, &mut ins).unwrap();
277 pub(crate) fn new(message: EncodeMessage) -> Self {
279 message,
284 pub(crate) fn message(&self) -> &EncodeMessage {
285 &self.message
305 self.message.fields().len() - self.repr_offset
309 self.message.inst().len() - self.inst_offset
403 if let Some(ref message) in encode_headers_repr_and_inst()
[all...]
H A Ddecoder.rs44 /// let message = decoder.decode(0, data_frame_bytes).unwrap();
144 /// let message = decoder.decode(0, data_frame_bytes).unwrap();
172 let message = stream.return_by_type(frames)?; in decode()
174 return Ok(message); in decode()
179 let message = stream.return_by_type(frames)?; in decode()
181 return Ok(message); in decode()
186 let message = stream.return_by_type(frames)?; in decode()
188 return Ok(message); in decode()
195 let message = stream.return_by_type(frames)?; in decode()
197 return Ok(message); in decode()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Doutput.rs171 let message = if let Err(e) = self.update_settings(&frame) { in poll_iterator_frames()
177 match self.transmit_message(cx, message) { in poll_iterator_frames()
211 message: OutputMessage, in transmit_message()
215 let ft = async move { sender.send(message).await }; in transmit_message()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp1.rs39 mut message: Message,
44 message
47 message
49 .intercept_request(message.request.ref_mut())?;
53 message.request.ref_mut(),
54 &message.interceptor,
59 encode_various_body(message.request.ref_mut(), &mut conn, &mut buf).await?;
77 message.interceptor.intercept_output(&buf[..size])?;
89 decode_response(message, part, conn, pre)
170 mut message in decode_response()
[all...]
H A Dmod.rs39 pub(crate) async fn request<S>(conn: Conn<S>, message: Message) -> Result<Response, HttpClientError>
45 Conn::Http1(http1) => http1::request(http1, message).await,
48 Conn::Http2(http2) => http2::request(http2, message).await,
51 Conn::Http3(http3) => http3::request(http3, message).await,
H A Dhttp3.rs41 mut message: Message,
46 message
48 .intercept_request(message.request.ref_mut())?;
49 let part = message.request.ref_mut().part().clone();
54 let data = BodyDataRef::new(message.request.clone());
61 frame_2_response(conn, frame, message)
105 mut message: Message, in frame_2_response()
139 let length = match BodyLengthParser::new(message.request.ref_mut().method(), &part).parse() { in frame_2_response()
145 let body = HttpBody::new(message.interceptor, length, Box::new(data_io), &[0u8; 0])?; in frame_2_response()
H A Dhttp2.rs43 mut message: Message,
48 message
50 .intercept_request(message.request.ref_mut())?;
51 let part = message.request.ref_mut().part().clone();
56 let data = BodyDataRef::new(message.request.clone());
64 frame_2_response(conn, frame, message)
70 mut message: Message, in frame_2_response()
120 let length = match BodyLengthParser::new(message.request.ref_mut().method(), &part).parse() { in frame_2_response()
126 let body = HttpBody::new(message.interceptor, length, Box::new(text_io), &[0u8; 0])?; in frame_2_response()
/commonlibrary/ets_utils/js_sys_module/timer/test/
H A Dtest_timer.cpp169 std::string message = "50"; in HWTEST_F() local
171 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage1); // timeout is string in HWTEST_F()
205 std::string message = "50"; // Random number in HWTEST_F() local
206 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage); in HWTEST_F()
268 std::string message = "50"; // Random number in HWTEST_F() local
270 napi_create_string_utf8(env, message.c_str(), message.length(), &nativeMessage4); in HWTEST_F()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs478 message: RespMessage,
484 let ft = async move { sender.send(message).await };
563 Some(message) => match message {
572 Ok(message) => match message {
596 Poll::Ready(Some(message)) => match message {
608 Poll::Ready(Ok(message)) => match message {
[all...]
/commonlibrary/ets_utils/js_concurrent_module/common/helper/
H A Derror_helper.h193 // add message in TranslateErrorEvent()
196 napi_set_named_property(env, obj, "message", msgValue); in TranslateErrorEvent()
241 napi_value message = NapiHelper::GetNameProperty(env, error, "message"); in ObjectToError() local
244 napi_create_error(env, nullptr, message, &businessError); in ObjectToError()
246 napi_set_named_property(env, businessError, "name", message); in ObjectToError()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dclient.rs212 let message = Message {
217 TimeoutFuture::new(conn::request(conn, message), timeout).await
219 conn::request(conn, message).await
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp247 const char* message = "test taskpool"; in TestFunction() local
248 size_t length = strlen(message); in TestFunction()
249 napi_create_string_utf8(env, message, length, &result); in TestFunction()

Completed in 28 milliseconds