/foundation/CastEngine/castengine_cast_framework/service/src/session/src/stream/src/ |
H A D | cast_stream_manager_server.cpp | 98 json body; in NotifyPeerSeekDone() local 99 body[KEY_POSITION] = position; in NotifyPeerSeekDone() 100 return SendCallbackAction(ACTION_SEEK_DONE, body); in NotifyPeerSeekDone() 106 json body; in NotifyPeerEndOfStream() local 107 body[KEY_IS_LOOPING] = isLooping; in NotifyPeerEndOfStream() 108 return SendCallbackAction(ACTION_END_OF_STREAM, body); in NotifyPeerEndOfStream() 114 json body; in NotifyPeerPlayerStatusChanged() local 115 body[KEY_PLAY_BACK_STATE] = static_cast<int>(playbackState); in NotifyPeerPlayerStatusChanged() 116 body[KEY_IS_PLAY_WHEN_READY] = isPlayWhenReady; in NotifyPeerPlayerStatusChanged() 117 return SendCallbackAction(ACTION_PLAYER_STATUS_CHANGED, body); in NotifyPeerPlayerStatusChanged() 123 json body; NotifyPeerPositionChanged() local 133 json body; NotifyPeerMediaItemChanged() local 141 json body; NotifyPeerVolumeChanged() local 150 json body; NotifyPeerRepeatModeChanged() local 158 json body; NotifyPeerPlaySpeedChanged() local 166 json body; NotifyPeerPlayerError() local 175 json body; NotifyPeerPlayRequest() local [all...] |
H A D | cast_stream_manager_client.cpp | 125 json body; in NotifyPeerLoad() local 127 body[KEY_CURRENT_INDEX] = 0; in NotifyPeerLoad() 128 body[KEY_PROGRESS_INTERVAL] = 0; in NotifyPeerLoad() 142 body[KEY_LIST] = list; in NotifyPeerLoad() 144 return SendControlAction(ACTION_LOAD, body); in NotifyPeerLoad() 150 json body; in NotifyPeerPlay() local 152 body[KEY_CURRENT_INDEX] = 0; in NotifyPeerPlay() 153 body[KEY_PROGRESS_INTERVAL] = 0; in NotifyPeerPlay() 167 body[KEY_LIST] = list; in NotifyPeerPlay() 169 return SendControlAction(ACTION_PLAY, body); in NotifyPeerPlay() 210 json body; NotifyPeerSeek() local 218 json body; NotifyPeerFastForward() local 226 json body; NotifyPeerFastRewind() local 234 json body; NotifyPeerSetVolume() local 242 json body; NotifyPeerSetMute() local 250 json body; NotifyPeerSetRepeatMode() local 258 json body; NotifyPeerSetSpeed() local [all...] |
/foundation/CastEngine/castengine_cast_plus_stream/src/stream/src/ |
H A D | cast_stream_manager_server.cpp | 98 json body; in NotifyPeerSeekDone() local 99 body[KEY_POSITION] = position; in NotifyPeerSeekDone() 100 return SendCallbackAction(ACTION_SEEK_DONE, body); in NotifyPeerSeekDone() 106 json body; in NotifyPeerEndOfStream() local 107 body[KEY_IS_LOOPING] = isLooping; in NotifyPeerEndOfStream() 108 return SendCallbackAction(ACTION_END_OF_STREAM, body); in NotifyPeerEndOfStream() 114 json body; in NotifyPeerPlayerStatusChanged() local 115 body[KEY_PLAY_BACK_STATE] = static_cast<int>(playbackState); in NotifyPeerPlayerStatusChanged() 116 body[KEY_IS_PLAY_WHEN_READY] = isPlayWhenReady; in NotifyPeerPlayerStatusChanged() 117 return SendCallbackAction(ACTION_PLAYER_STATUS_CHANGED, body); in NotifyPeerPlayerStatusChanged() 123 json body; NotifyPeerPositionChanged() local 133 json body; NotifyPeerMediaItemChanged() local 141 json body; NotifyPeerVolumeChanged() local 150 json body; NotifyPeerRepeatModeChanged() local 158 json body; NotifyPeerPlaySpeedChanged() local 166 json body; NotifyPeerPlayerError() local 175 json body; NotifyPeerPlayRequest() local [all...] |
H A D | cast_stream_manager_client.cpp | 125 json body; in NotifyPeerLoad() local 127 body[KEY_CURRENT_INDEX] = 0; in NotifyPeerLoad() 128 body[KEY_PROGRESS_INTERVAL] = 0; in NotifyPeerLoad() 142 body[KEY_LIST] = list; in NotifyPeerLoad() 144 return SendControlAction(ACTION_LOAD, body); in NotifyPeerLoad() 150 json body; in NotifyPeerPlay() local 152 body[KEY_CURRENT_INDEX] = 0; in NotifyPeerPlay() 153 body[KEY_PROGRESS_INTERVAL] = 0; in NotifyPeerPlay() 167 body[KEY_LIST] = list; in NotifyPeerPlay() 169 return SendControlAction(ACTION_PLAY, body); in NotifyPeerPlay() 210 json body; NotifyPeerSeek() local 218 json body; NotifyPeerFastForward() local 226 json body; NotifyPeerFastRewind() local 234 json body; NotifyPeerSetVolume() local 242 json body; NotifyPeerSetMute() local 250 json body; NotifyPeerSetRepeatMode() local 258 json body; NotifyPeerSetSpeed() local [all...] |
/foundation/CastEngine/castengine_cast_plus_stream/src/rtsp/src/ |
H A D | rtsp_package.cpp | 65 std::string body; in EncapAnnounce() local 66 body.append("encrypt_description: ") in EncapAnnounce() 82 .append(std::to_string(body.length())) in EncapAnnounce() 85 .append(body); in EncapAnnounce() 123 std::string body; in EncapRequestGetParameter() local 124 body.append("his_version") in EncapRequestGetParameter() 133 body.append("his_uibc_capability").append(MSG_SEPARATOR); in EncapRequestGetParameter() 136 body.append("his_feature").append(MSG_SEPARATOR); in EncapRequestGetParameter() 139 body.append("his_vtp").append(MSG_SEPARATOR); in EncapRequestGetParameter() 141 body in EncapRequestGetParameter() 165 EncapFeature(std::string &body, ParamInfo &negParam) EncapFeature() argument 184 EncapResponseGetParamM3Body(ParamInfo &clientParam, const std::string &getParam, std::string &body) EncapResponseGetParamM3Body() argument 240 std::string body; EncapResponseGetParamM3() local 274 EncapSpecialList(std::string &body, const std::vector<std::string> &list, const std::string &type) EncapSpecialList() argument 285 EncapGenericCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapGenericCapList() argument 295 EncapHidcCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapHidcCapList() argument 305 EncapVendorCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapVendorCapList() argument 315 EncapUibc(std::string &body, ParamInfo &negParam) EncapUibc() argument 336 SetAnotherParameter(ParamInfo &negParam, double version, const std::string &ip, std::string &body) SetAnotherParameter() argument 393 std::string body; EncapSetParameterM4Request() local 435 std::string body; SetVideoAndAudioCodecsParameter() local 487 std::string body; SetAudioParameter() local 521 std::string body; EncapActionRequest() local 655 std::string body; EncapEventChangeRequest() local [all...] |
H A D | rtsp_package.h | 55 static void EncapResponseGetParamM3Body(ParamInfo &clientParam, const std::string &getParam, std::string &body); 56 static void EncapUibc(std::string &body, ParamInfo &negParam); 57 static void EncapFeature(std::string &body, ParamInfo &negParam); 60 static void SetAnotherParameter(ParamInfo &negParam, double version, const std::string &ip, std::string &body); 69 static void EncapGenericCapList(std::string &body, const RemoteControlParamInfo ¶mInfo); 70 static void EncapHidcCapList(std::string &body, const RemoteControlParamInfo ¶mInfo); 71 static void EncapVendorCapList(std::string &body, const RemoteControlParamInfo ¶mInfo);
|
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/rtsp/src/ |
H A D | rtsp_package.cpp | 65 std::string body; in EncapAnnounce() local 66 body.append("encrypt_description: ") in EncapAnnounce() 82 .append(std::to_string(body.length())) in EncapAnnounce() 85 .append(body); in EncapAnnounce() 123 std::string body; in EncapRequestGetParameter() local 124 body.append("his_version") in EncapRequestGetParameter() 133 body.append("his_uibc_capability").append(MSG_SEPARATOR); in EncapRequestGetParameter() 136 body.append("his_feature").append(MSG_SEPARATOR); in EncapRequestGetParameter() 139 body.append("his_vtp").append(MSG_SEPARATOR); in EncapRequestGetParameter() 141 body in EncapRequestGetParameter() 165 EncapFeature(std::string &body, ParamInfo &negParam) EncapFeature() argument 184 EncapResponseGetParamM3Body(ParamInfo &clientParam, const std::string &getParam, std::string &body) EncapResponseGetParamM3Body() argument 240 std::string body; EncapResponseGetParamM3() local 274 EncapSpecialList(std::string &body, const std::vector<std::string> &list, const std::string &type) EncapSpecialList() argument 285 EncapGenericCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapGenericCapList() argument 295 EncapHidcCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapHidcCapList() argument 305 EncapVendorCapList(std::string &body, const RemoteControlParamInfo ¶mInfo) EncapVendorCapList() argument 315 EncapUibc(std::string &body, ParamInfo &negParam) EncapUibc() argument 336 SetAnotherParameter(ParamInfo &negParam, double version, const std::string &ip, std::string &body) SetAnotherParameter() argument 393 std::string body; EncapSetParameterM4Request() local 435 std::string body; SetVideoAndAudioCodecsParameter() local 487 std::string body; SetAudioParameter() local 521 std::string body; EncapActionRequest() local 655 std::string body; EncapEventChangeRequest() local [all...] |
H A D | rtsp_package.h | 55 static void EncapResponseGetParamM3Body(ParamInfo &clientParam, const std::string &getParam, std::string &body); 56 static void EncapUibc(std::string &body, ParamInfo &negParam); 57 static void EncapFeature(std::string &body, ParamInfo &negParam); 60 static void SetAnotherParameter(ParamInfo &negParam, double version, const std::string &ip, std::string &body); 69 static void EncapGenericCapList(std::string &body, const RemoteControlParamInfo ¶mInfo); 70 static void EncapHidcCapList(std::string &body, const RemoteControlParamInfo ¶mInfo); 71 static void EncapVendorCapList(std::string &body, const RemoteControlParamInfo ¶mInfo);
|
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
H A D | builder.rs | 29 /// # async fn create_a_downloader(body: Response) { 30 /// let downloader = DownloaderBuilder::new().body(body).console().build(); 37 /// A state indicates that `DownloaderBuilder` wants a body that needs to be downloaded. 54 /// Sets a body part that needs to be downloaded by the downloader. 64 /// # async fn set_body(body: Response) { 65 /// let builder = DownloaderBuilder::new().body(body); 68 pub fn body(self, body functions [all...] |
H A D | mod.rs | 29 /// A downloader that can help you download the response body. 31 /// A `Downloader` provides a template method for downloading the body and 33 /// the body. 38 /// - `download` methods are responsible for reading and copying the body to 102 /// .body(response) 112 body: Response, 134 Self::builder().body(response).console().build() in console() 171 self.info = Some(DownloadInfo::new(self.body.content_length())); 176 // Downloads response body with speed limitation. 183 let data = match self.body [all...] |
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/ |
H A D | request.rs | 34 /// .body("Hello World".as_bytes()); 38 pub(crate) body: T, 161 /// the provided body. 172 /// let request = RequestBuilder::new().body("HelloWorld".as_bytes()).unwrap(); 174 pub fn body<T: Into<reqwest::Body>>(self, body: T) -> Result<Request<T>, HttpClientError> { in body() functions 177 body, in body() 183 /// as the body. 199 pub fn multipart<T>(self, body: T) -> Result<Request<T>, HttpClientError> in multipart() 203 let value = format!("multipart/form-data; boundary={}", body in multipart() [all...] |
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
H A D | multipart.rs | 31 /// .part(Part::new().name("name").body("xiaoming")) 32 /// .part(Part::new().name("password").body("123456789")); 66 /// .part(Part::new().name("name").body("xiaoming")); 96 /// .part(Part::new().name("name").body("xiaoming")); 169 if let Some(body) = part.body.take() { 170 states.push(body); 244 /// let part = Part::new().name("name").body("xiaoming"); 251 body: Option<MultiPartState>, 270 body in new() 349 pub fn body<T: AsRef<[u8]>>(mut self, body: T) -> Self { body() functions [all...] |
/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
H A D | obex_mp_server.cpp | 64 auto body = req.GetItemBody(); in HandlePutRequest() local 65 if (body != nullptr) { in HandlePutRequest() 67 session.GetReceivedObject()->AppendBody(body->GetBytes().get(), body->GetHeaderDataSize()); in HandlePutRequest() 109 auto body = req.GetItemEndBody(); in HandlePutFinalRequest() local 110 if (body != nullptr) { in HandlePutFinalRequest() 112 session.GetReceivedObject()->AppendBody(body->GetBytes().get(), body->GetHeaderDataSize()); in HandlePutFinalRequest() 119 auto body = req.GetItemEndBody(); in HandlePutFinalRequest() local 120 if (body ! in HandlePutFinalRequest() [all...] |
H A D | obex_mp_client.cpp | 42 OBEX_LOG_ERROR("Error: Can't include body/end-of-body header in this method."); in Put() 262 auto body = resp.GetItemBody(); in ProcessGetContinueData() local 263 if (body != nullptr) { in ProcessGetContinueData() 264 recvObj->AppendBody(body->GetBytes().get(), body->GetHeaderDataSize()); in ProcessGetContinueData() 300 auto body = resp.GetItemEndBody(); in ProcessGetSuccessData() local 301 if (body != nullptr) { in ProcessGetSuccessData() 302 recvObj->AppendBody(body->GetBytes().get(), body in ProcessGetSuccessData() [all...] |
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtsp/src/ |
H A D | rtsp_response.cpp | 153 std::stringstream body; in Stringify() local 155 body << item << RTSP_CRLF; in Stringify() 163 ss << RTSP_TOKEN_CONTENT_LENGTH << ":" << RTSP_SP << body.str().length(); in Stringify() 167 return RtspResponse::Stringify() + body.str(); in Stringify() 198 std::stringstream body; in Stringify() local 200 body << item << RTSP_CRLF; in Stringify() 205 ss << RTSP_TOKEN_CONTENT_LENGTH << ":" << RTSP_SP << body.str().length(); in Stringify() 209 if (body.str().empty()) { in Stringify() 213 return RtspResponse::Stringify() + body.str(); in Stringify()
|
H A D | rtsp_request.cpp | 150 std::stringstream body; in Stringify() local 152 body << item << RTSP_CRLF; in Stringify() 155 if (body.str().empty()) { in Stringify() 160 ss << RTSP_TOKEN_CONTENT_LENGTH << ":" << RTSP_SP << body.str().length() << RTSP_CRLF; in Stringify() 163 return RtspRequest::Stringify() + body.str(); in Stringify()
|
/foundation/communication/netstack/frameworks/js/napi/fetch/async_context/src/ |
H A D | fetch_context.cpp | 123 /* if body is empty, return false, or curl will wait for body */ in GetRequestBody() 127 auto body = NapiUtils::GetStringFromValueUtf8(GetEnv(), data); in GetRequestBody() local 128 if (body.empty()) { in GetRequestBody() 129 NETSTACK_LOGE("body napi_string is empty"); in GetRequestBody() 132 request.SetBody(body.c_str(), body.size()); in GetRequestBody() 136 std::string body = NapiUtils::GetStringFromValueUtf8(GetEnv(), NapiUtils::JsonStringify(GetEnv(), data)); in GetRequestBody() local 137 if (body.empty()) { in GetRequestBody() 138 NETSTACK_LOGE("body napi_objec in GetRequestBody() [all...] |
/foundation/communication/netstack/frameworks/js/builtin/fetch/src/ |
H A D | request_data.cpp | 46 body = bodyPara; in SetBody() 71 return body; in GetBody()
|
H A D | fetch_module.cpp | 129 std::unique_ptr<JSIVal, decltype(&JSI::ReleaseValue)> body( in GetRequestBody() 131 if (body == nullptr || JSI::ValueIsUndefined(body.get())) { in GetRequestBody() 132 HTTP_REQUEST_ERROR("get body failed"); in GetRequestBody() 136 if (JSI::ValueIsString(body.get())) { in GetRequestBody() 138 std::unique_ptr<char, decltype(&FreeString)> bodyStr(JSI::ValueToStringWithBufferSize(body.get(), size), in GetRequestBody() 141 HTTP_REQUEST_ERROR("get body str failed"); in GetRequestBody() 146 HTTP_REQUEST_INFO("body is string, size %zu", str.size()); in GetRequestBody() 150 if (JSI::ValueIsObject(body.get())) { in GetRequestBody() 151 std::unique_ptr<char, decltype(&FreeString)> jsonString(JSI::JsonStringify(body in GetRequestBody() [all...] |
/foundation/communication/netmanager_base/test/netsysbpfstats/unittest/bpf_core_test/ |
H A D | BpfRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_core_test/ |
H A D | NetSysRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/vpn_core_test/ |
H A D | VpnRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|
/foundation/communication/netstack/test/unittest/http_test/ |
H A D | HttpClientRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|
/foundation/communication/netmanager_ext/test/networksharemanager/unittest/netshare_core_test/ |
H A D | NetShareRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|
/foundation/communication/netstack/test/unittest/http_client_test/ |
H A D | HttpClientRequestTest.cpp | 114 std::string body = ""; in HWTEST_F() local 117 EXPECT_EQ(bodyTest, body); in HWTEST_F() 123 std::string body = "hello world"; in HWTEST_F() local 125 req.SetBody(body.data(), body.length()); in HWTEST_F() 128 EXPECT_EQ(bodyTest, body); in HWTEST_F()
|