/tools/metalava/metalava-model/src/testFixtures/java/com/android/tools/metalava/model/ |
D | Assertions.kt | 159 body: (VariableTypeItem.() -> Unit)? = null in assertReferencesTypeParameter() 163 if (body != null) this.body() in assertReferencesTypeParameter() 171 fun <T : TypeItem> T?.assertNotNullTypeItem(body: (T.() -> Unit)? = null) { in assertNotNullTypeItem() 173 if (body != null) this?.body() in assertNotNullTypeItem() 180 fun TypeItem?.assertArrayTypeItem(body: (ArrayTypeItem.() -> Unit)? = null) { in assertArrayTypeItem() 181 assertIsInstanceOf(body ?: {}) in assertArrayTypeItem() 188 fun TypeItem?.assertClassTypeItem(body: (ClassTypeItem.() -> Unit)? = null) { in assertClassTypeItem() 189 assertIsInstanceOf(body ?: {}) in assertClassTypeItem() 196 fun TypeItem?.assertPrimitiveTypeItem(body: (PrimitiveTypeItem.() -> Unit)? = null) { in assertPrimitiveTypeItem() 197 assertIsInstanceOf(body ?: {}) in assertPrimitiveTypeItem() [all …]
|
/tools/test/connectivity/acts/framework/acts/controllers/amarisoft_lib/ |
D | ims.py | 63 head, body = self.remote.send_message(const.PortNumber.URI_IMS, dump_msg) 64 self.remote.verify_response('mt_call', head, body) 84 head, body = self.remote.send_message(const.PortNumber.URI_IMS, dump_msg) 85 self.remote.verify_response('sms', head, body) 103 head, body = self.remote.send_message(const.PortNumber.URI_IMS, dump_msg) 104 self.remote.verify_response('mms', head, body) 120 head, body = self.remote.send_message(const.PortNumber.URI_IMS, dump_msg) 121 _, loaded_body = self.remote.verify_response('users_get', head, body) 134 body = self.users_get(True) 135 for index in range(len(body['users'])): [all …]
|
D | mme.py | 48 head, body = self.remote.send_message(const.PortNumber.URI_MME, dump_msg) 49 self.remote.verify_response('pws_write', head, body) 65 head, body = self.remote.send_message(const.PortNumber.URI_MME, dump_msg) 66 self.remote.verify_response('pws_kill', head, body) 79 head, body = self.remote.send_message(const.PortNumber.URI_MME, dump_msg) 80 self.remote.verify_response('ue_del', head, body)
|
D | amarisoft_client.py | 62 body = await websocket.recv() 63 return head, body 79 body: str) -> Tuple[Mapping[str, Any], Mapping[str, Any]]: 105 loaded_body = json.loads(body)
|
/tools/netsim/rust/daemon/src/http_server/ |
D | server_response.rs | 40 fn put_ok(&mut self, mime_type: &str, body: &str, headers: StrHeaders); in put_ok() 42 fn put_ok_with_vec(&mut self, mime_type: &str, body: Vec<u8>, headers: StrHeaders); in put_ok_with_vec() 70 buffer.extend_from_slice(response.body()); in put_response() 86 let body = error_message.as_bytes().to_vec(); in put_error() localVariable 93 HeaderValue::from_str(body.len().to_string().as_str()).unwrap(), in put_error() 95 .body(body) in put_error() 110 .body(Vec::new()) in put_ok_with_length() 115 fn put_ok(&mut self, mime_type: &str, body: &str, headers: StrHeaders) { in put_ok() 116 let mut response = new_ok(mime_type, body.into()); in put_ok() 120 fn put_ok_with_vec(&mut self, mime_type: &str, body: Vec<u8>, headers: StrHeaders) { in put_ok_with_vec() [all …]
|
D | http_router.rs | 56 let body = format!("404 Not found (netsim): HttpRouter unknown uri {:?}", request.uri()); in handle_request() localVariable 57 writer.put_error(404, body.as_str()); in handle_request() 108 let body = format!("Hello, {user_id}!"); in handle_user() localVariable 109 writer.put_ok("application/json", body.as_str(), vec![]); in handle_user() 113 let body = format!("The query is '{}'!", request.uri().query().unwrap()); in handle_query() localVariable 114 writer.put_ok("text/plain", body.as_str(), vec![]); in handle_query() 141 .body(Vec::<u8>::new()) in test_handle_request() 155 .body(Vec::<u8>::new()) in test_handle_request() 174 .body(Vec::<u8>::new()) in test_mismatch_uri() 193 .body(Vec::<u8>::new()) in test_handle_query()
|
D | http_request.rs | 80 let mut body = Vec::new(); in parse_http_request() localVariable 82 body.resize(len, 0); in parse_http_request() 83 reader.read_exact(&mut body).map_err(|e| format!("Failed to read body: {e}"))?; in parse_http_request() 85 match builder.body(body) { in parse_http_request() 111 assert_eq!(http_request.body().to_owned(), b"Hello World\r\n".to_vec()); in test_parse() 125 assert_eq!(http_request.body().to_owned(), Vec::<u8>::new()); in test_parse_without_body() 140 assert_eq!(http_request.body().to_owned(), Vec::<u8>::new()); in test_parse_without_content_length()
|
D | http_handlers.rs | 112 if let Ok(body) = fs::read(&filepath) { in handle_file() 113 writer.put_ok_with_vec(to_content_type(&filepath), body, vec![]); in handle_file() 117 let body = format!("404 not found (netsim): handle_file with unknown path {path}"); in handle_file() localVariable 118 writer.put_error(404, body.as_str()); in handle_file() 132 let body = format!("{{\"version\": \"{}\"}}", VERSION); in handle_version() localVariable 133 writer.put_ok("text/plain", body.as_str(), vec![]); in handle_version() 165 let body = format!("404 not found (netsim): Invalid path {path}"); in handle_connection() localVariable 166 writer.put_error(404, body.as_str()); in handle_connection() 191 let body = "404 not found (netsim): parse header failed"; in handle_connection() localVariable 192 response_writer.put_error(404, body); in handle_connection()
|
/tools/netsim/src/frontend/ |
D | frontend_server.cc | 40 : grpc_writer_(nullptr), err(""), is_ok(false), body(""), length(0) {}; in CxxServerResponseWritable() 43 : grpc_writer_(grpc_writer), err(""), is_ok(false), body(""), length(0) { in CxxServerResponseWritable() 65 const std::string &body) const override { in put_ok() 66 this->body = body; in put_ok() 74 mutable std::string body; member in netsim::__anonde92192e0111::CxxServerResponseWritable 93 google::protobuf::util::JsonStringToMessage(writer.body, reply); in ListDevice() 107 google::protobuf::util::JsonStringToMessage(writer.body, response); in CreateDevice() 121 google::protobuf::util::JsonStringToMessage(writer.body, response); in DeleteChip() 165 google::protobuf::util::JsonStringToMessage(writer.body, reply); in ListCapture()
|
/tools/test/mobly_extensions/tools/results_uploader/src/ |
D | resultstore_client.py | 132 body=invocation, 154 body=configuration, 192 body=target, 217 body=configured_target, 258 body=action, 286 body=merge_request, 305 body=finalize_request, 326 body=merge_request, 343 body=finalize_request, 358 request = self._service.invocations().merge(body=merge_request, [all …]
|
/tools/asuite/atest/logstorage/ |
D | logstorage_utils.py | 165 body = { 172 return self.client.build().insert(buildType='local', body=body).execute() 189 body=build_attempt, 228 return self.client.invocation().insert(body=invocation).execute() 265 .update(resourceId=invocation['invocationId'], body=invocation) 279 return self.client.workunit().insert(body=workunit).execute()
|
/tools/acloud/internal/lib/ |
D | gcompute_client.py | 335 body = { 345 body=body) 455 body = { 464 body = { 469 body["labels"] = labels 470 api = self.service.images().insert(project=self._project, body=body) 505 body = { 510 project=self._project, resource=image_name, body=body) 658 body = { 667 project=self._project, zone=zone, instance=instance, body=body) [all …]
|
D | gcompute_client_test.py | 226 project=PROJECT, body=expected_body) 251 project=PROJECT, body=expected_body) 277 project=PROJECT, body=expected_body) 303 body={ 351 project=PROJECT, body=expected_body) 618 project=PROJECT, zone=self.ZONE, body=expected_body) 697 project=PROJECT, zone=self.ZONE, body=expected_body) 771 project=PROJECT, zone=self.ZONE, body=expected_body) 836 body={ 863 body={ [all …]
|
/tools/tradefederation/core/common_util/com/android/tradefed/util/ |
D | IEmail.java | 69 public Message(String to, String subject, String body) { in Message() argument 72 setBody(body); in Message() 105 public void setBody(String body) { in setBody() argument 106 mBody = body; in setBody()
|
/tools/tradefederation/core/javatests/com/android/tradefed/util/ |
D | EmailTest.java | 155 final String body = extractBody(mEmail.getMailerData(), headers); in testSend_simple() local 157 assertEquals("body", body); in testSend_simple() 174 final String body = extractBody(mEmail.getMailerData(), headers); in testSend_htmlEmail() local 176 assertEquals(expectedBody, body); in testSend_htmlEmail() 214 final String body = "<html><body><h1>What do we want?!</h1><h2>Time travel!</h2>" + in _manual_testFuncSend() local 221 msg.setBody(body); in _manual_testFuncSend()
|
/tools/netsim/rust/daemon/src/ |
D | ffi.rs | 330 body: String, in handle_capture_cxx() 338 body: String, in handle_device_cxx() 355 fn put_ok(self: &CxxServerResponseWriter, mime_type: &CxxString, body: &CxxString); in put_ok() 438 fn put_ok(&mut self, mime_type: &str, body: &str, _headers: StrHeaders) { in put_ok() 440 let_cxx_string!(body = body); in put_ok() 441 self.writer.put_ok(&mime_type, &body); in put_ok()
|
/tools/netsim/rust/daemon/src/captures/ |
D | captures_handler.rs | 197 let body = request.body(); in handle_capture_internal() localVariable 198 let state = String::from_utf8(body.to_vec()).unwrap(); in handle_capture_internal() 215 body: String, in handle_capture_cxx() 224 let request = match builder.body(body.as_bytes().to_vec()) { in handle_capture_cxx()
|
/tools/tradefederation/core/src/com/android/tradefed/build/ |
D | OtaZipfileBuildProvider.java | 79 StringBuilder body = new StringBuilder(); in getBuildPropContents() local 84 body.append(line).append("\n"); in getBuildPropContents() 88 return body.toString(); in getBuildPropContents()
|
/tools/metalava/metalava/src/test/java/com/android/tools/metalava/ |
D | SignatureWriterTest.kt | 30 body: (SignatureWriter) -> Unit, in runTest() 46 body(writer) in runTest()
|
D | JDiffXmlTest.kt | 27 private fun jdiffTest(body: JDiffTestConfig.() -> Unit) { in jdiffTest() 31 body() in jdiffTest()
|
/tools/metalava/metalava-model/src/main/java/com/android/tools/metalava/model/ |
D | Codebase.kt | 139 fun iterateAllClasses(body: (ClassItem) -> Unit) { in iterateAllClasses() 148 body(classItem) in iterateAllClasses()
|
/tools/netsim/ui/dist/js/ |
D | device-observer.js | 1 …body:t}),this.notifyObservers()}patchDevice(i){const t=JSON.stringify(i);fetch(e,{method:"PATCH",h… property
|
/tools/netsim/ui/ts/ |
D | device-observer.ts | 223 body: state, 236 body: jsonBody, 291 body: jsonBody,
|
/tools/netsim/rust/daemon/src/devices/ |
D | devices_handler.rs | 711 let body = request.body(); in handle_device() localVariable 712 let subscribe_json = String::from_utf8(body.to_vec()).unwrap(); in handle_device() 716 let body = request.body(); in handle_device() localVariable 717 let patch_json = String::from_utf8(body.to_vec()).unwrap(); in handle_device() 721 let body = &request.body(); in handle_device() localVariable 722 let create_json = String::from_utf8(body.to_vec()).unwrap(); in handle_device() 726 let body = &request.body(); in handle_device() localVariable 727 let delete_json = String::from_utf8(body.to_vec()).unwrap(); in handle_device() 743 let body = request.body(); in handle_device() localVariable 744 let patch_json = String::from_utf8(body.to_vec()).unwrap(); in handle_device() [all …]
|
/tools/metalava/metalava/src/test/java/com/android/tools/metalava/cli/common/ |
D | BaseCommandTest.kt | 190 fun check(body: () -> Unit) { in check() 192 body() in check()
|