Lines Matching refs:Command
5 use crate::generators::component_async::wasmtime_fuzz::fuzz::async_test::{self, Command};
110 commands: Vec<(Scope, Command)>,
112 guest_caller_stream: Option<StreamReader<Command>>,
113 guest_callee_stream: Option<StreamReader<Command>>,
192 ) -> StreamReader<Command> { in get_commands() argument
295 async fn host_caller_cmd(test: &Guest, store: &Accessor<Data>, cmd: Command) { in host_caller_cmd() argument
297 Command::Ack => {} in host_caller_cmd()
298 Command::SyncReadyCall => test.call_sync_ready(store).await.unwrap(), in host_caller_cmd()
299 Command::AsyncReadyCall => test.call_async_ready(store).await.unwrap(), in host_caller_cmd()
300 Command::AsyncPendingExportComplete(_i) => todo!(), in host_caller_cmd()
301 Command::AsyncPendingExportAssertCancelled(_i) => todo!(), in host_caller_cmd()
302 Command::AsyncPendingImportCall(i) => { in host_caller_cmd()
323 Command::AsyncPendingImportCancel(_i) => todo!(), in host_caller_cmd()
324 Command::AsyncPendingImportAssertReady(i) => { in host_caller_cmd()
331 Command::FutureTake(i) => { in host_caller_cmd()
338 Command::FutureGive(i) => { in host_caller_cmd()
342 Command::StreamTake(i) => { in host_caller_cmd()
349 Command::StreamGive(i) => { in host_caller_cmd()
358 async fn host_callee_cmd(store: &Accessor<Data>, cmd: Command) { in host_callee_cmd() argument
360 Command::Ack => {} in host_callee_cmd()
361 Command::SyncReadyCall => todo!(), in host_callee_cmd()
362 Command::AsyncReadyCall => todo!(), in host_callee_cmd()
363 Command::AsyncPendingExportComplete(i) => store.with(|mut s| { in host_callee_cmd()
371 Command::AsyncPendingExportAssertCancelled(i) => { in host_callee_cmd()
377 Command::AsyncPendingImportCall(_i) => todo!(), in host_callee_cmd()
378 Command::AsyncPendingImportCancel(_i) => todo!(), in host_callee_cmd()
379 Command::AsyncPendingImportAssertReady(_i) => todo!(), in host_callee_cmd()
385 async fn future_or_stream_cmd(store: &Accessor<Data>, cmd: Command) { in future_or_stream_cmd() argument
388 Command::Ack in future_or_stream_cmd()
389 | Command::SyncReadyCall in future_or_stream_cmd()
390 | Command::AsyncReadyCall in future_or_stream_cmd()
391 | Command::AsyncPendingExportComplete(_) in future_or_stream_cmd()
392 | Command::AsyncPendingExportAssertCancelled(_) in future_or_stream_cmd()
393 | Command::AsyncPendingImportCall(_) in future_or_stream_cmd()
394 | Command::AsyncPendingImportCancel(_) in future_or_stream_cmd()
395 | Command::FutureTake(_) in future_or_stream_cmd()
396 | Command::FutureGive(_) in future_or_stream_cmd()
397 | Command::StreamTake(_) in future_or_stream_cmd()
398 | Command::StreamGive(_) in future_or_stream_cmd()
399 | Command::AsyncPendingImportAssertReady(_) => unreachable!(), in future_or_stream_cmd()
401 Command::FutureNew(id) => { in future_or_stream_cmd()
415 Command::FutureDropReadable(id) => { in future_or_stream_cmd()
424 Command::FutureWriteReady(payload) => { in future_or_stream_cmd()
447 Command::FutureWritePending(payload) => store.with(|mut s| { in future_or_stream_cmd()
460 Command::FutureWriteDropped(id) => store.with(|mut s| { in future_or_stream_cmd()
465 Command::FutureReadReady(payload) => { in future_or_stream_cmd()
495 Command::FutureReadPending(id) => { in future_or_stream_cmd()
507 Command::FutureCancelWrite(id) => store.with(|mut s| { in future_or_stream_cmd()
512 Command::FutureCancelRead(id) => store.with(|mut s| { in future_or_stream_cmd()
517 Command::FutureReadAssertComplete(payload) => { in future_or_stream_cmd()
537 Command::FutureWriteAssertComplete(id) => store.with(|mut s| { in future_or_stream_cmd()
542 Command::FutureWriteAssertDropped(id) => store.with(|mut s| { in future_or_stream_cmd()
548 Command::StreamNew(id) => { in future_or_stream_cmd()
562 Command::StreamDropReadable(id) => { in future_or_stream_cmd()
571 Command::StreamDropWritable(id) => store.with(|mut s| { in future_or_stream_cmd()
575 Command::StreamWriteReady(payload) => { in future_or_stream_cmd()
608 Command::StreamReadReady(payload) => { in future_or_stream_cmd()
638 Command::StreamWritePending(payload) => store.with(|mut s| { in future_or_stream_cmd()
655 Command::StreamReadPending(payload) => { in future_or_stream_cmd()
668 Command::StreamWriteDropped(payload) => store.with(|mut s| { in future_or_stream_cmd()
677 Command::StreamReadDropped(payload) => { in future_or_stream_cmd()
694 Command::StreamCancelWrite(id) => store.with(|mut s| { in future_or_stream_cmd()
703 Command::StreamCancelRead(id) => store.with(|mut s| { in future_or_stream_cmd()
711 Command::StreamReadAssertComplete(payload) => store.with(|mut s| { in future_or_stream_cmd()
725 Command::StreamWriteAssertComplete(payload) => store.with(|mut s| { in future_or_stream_cmd()
739 Command::StreamWriteAssertDropped(payload) => { in future_or_stream_cmd()
758 Command::StreamReadAssertDropped(id) => { in future_or_stream_cmd()
1146 async fn next(&mut self, accessor: &Accessor<Data>) -> Option<Command> { in next() argument
1165 ) -> Poll<(Option<Command>, StreamResult)> { in poll() argument
1191 if matches!(command, Command::Ack) { in poll()
1194 *command = Command::Ack; in poll()
1218 type Item = Command;
1219 type Buffer = Option<Command>;
1262 (GuestCaller, Command::AsyncPendingImportCall(0)), in simple()
1263 (GuestCallee, Command::AsyncPendingImportCall(1)), in simple()
1264 (GuestCallee, Command::AsyncPendingExportComplete(0)), in simple()
1265 (GuestCaller, Command::AsyncPendingImportAssertReady(0)), in simple()
1266 (GuestCaller, Command::AsyncPendingImportCall(2)), in simple()
1273 static COMMANDS: &[(Scope, Command)] = &[ in somewhat_larger()
1274 (GuestCallee, Command::FutureNew(0)), in somewhat_larger()
1275 (HostCaller, Command::FutureNew(1)), in somewhat_larger()
1276 (GuestCallee, Command::FutureReadPending(0)), in somewhat_larger()
1277 (GuestCaller, Command::AsyncPendingImportCall(2)), in somewhat_larger()
1278 (GuestCaller, Command::AsyncPendingImportCall(3)), in somewhat_larger()
1279 (GuestCaller, Command::AsyncPendingImportCall(4)), in somewhat_larger()
1280 (GuestCaller, Command::AsyncPendingImportCall(5)), in somewhat_larger()
1281 (GuestCallee, Command::AsyncPendingExportComplete(5)), in somewhat_larger()
1282 (GuestCallee, Command::AsyncPendingExportComplete(3)), in somewhat_larger()
1283 (GuestCallee, Command::AsyncPendingExportComplete(4)), in somewhat_larger()
1284 (GuestCallee, Command::AsyncPendingExportComplete(2)), in somewhat_larger()
1285 (GuestCaller, Command::AsyncPendingImportCall(6)), in somewhat_larger()
1286 (GuestCallee, Command::AsyncPendingExportComplete(6)), in somewhat_larger()
1287 (GuestCaller, Command::AsyncPendingImportCall(7)), in somewhat_larger()
1288 (GuestCallee, Command::AsyncPendingExportComplete(7)), in somewhat_larger()
1289 (GuestCaller, Command::AsyncPendingImportCall(8)), in somewhat_larger()
1290 (GuestCallee, Command::AsyncPendingExportComplete(8)), in somewhat_larger()
1291 (GuestCaller, Command::AsyncPendingImportCall(9)), in somewhat_larger()
1292 (GuestCallee, Command::AsyncPendingExportComplete(9)), in somewhat_larger()
1293 (GuestCaller, Command::AsyncPendingImportCall(10)), in somewhat_larger()
1294 (GuestCallee, Command::AsyncPendingExportComplete(10)), in somewhat_larger()
1295 (GuestCaller, Command::AsyncPendingImportCall(11)), in somewhat_larger()
1296 (GuestCallee, Command::AsyncPendingExportComplete(11)), in somewhat_larger()
1297 (GuestCaller, Command::AsyncPendingImportCall(12)), in somewhat_larger()
1298 (GuestCallee, Command::AsyncPendingExportComplete(12)), in somewhat_larger()
1299 (GuestCaller, Command::AsyncPendingImportCall(13)), in somewhat_larger()
1300 (GuestCallee, Command::AsyncPendingExportComplete(13)), in somewhat_larger()
1301 (GuestCaller, Command::AsyncPendingImportCall(14)), in somewhat_larger()
1302 (GuestCallee, Command::AsyncPendingExportComplete(14)), in somewhat_larger()
1303 (GuestCaller, Command::AsyncPendingImportCall(15)), in somewhat_larger()
1304 (GuestCallee, Command::AsyncPendingExportComplete(15)), in somewhat_larger()
1305 (GuestCaller, Command::AsyncPendingImportCall(16)), in somewhat_larger()
1306 (GuestCallee, Command::AsyncPendingExportComplete(16)), in somewhat_larger()
1307 (GuestCaller, Command::AsyncPendingImportCall(17)), in somewhat_larger()
1308 (GuestCallee, Command::AsyncPendingExportComplete(17)), in somewhat_larger()
1309 (GuestCaller, Command::AsyncPendingImportCall(18)), in somewhat_larger()
1310 (GuestCallee, Command::AsyncPendingExportComplete(18)), in somewhat_larger()
1311 (GuestCaller, Command::AsyncPendingImportCall(19)), in somewhat_larger()
1312 (GuestCallee, Command::AsyncPendingExportComplete(19)), in somewhat_larger()
1313 (GuestCaller, Command::AsyncPendingImportCall(20)), in somewhat_larger()
1314 (GuestCallee, Command::AsyncPendingExportComplete(20)), in somewhat_larger()
1315 (GuestCaller, Command::AsyncPendingImportCall(21)), in somewhat_larger()
1316 (GuestCallee, Command::AsyncPendingExportComplete(21)), in somewhat_larger()
1317 (GuestCaller, Command::AsyncPendingImportCall(22)), in somewhat_larger()
1318 (GuestCallee, Command::AsyncPendingExportComplete(22)), in somewhat_larger()
1319 (GuestCaller, Command::AsyncPendingImportCall(23)), in somewhat_larger()
1320 (GuestCallee, Command::AsyncPendingExportComplete(23)), in somewhat_larger()
1321 (GuestCaller, Command::AsyncPendingImportCall(24)), in somewhat_larger()
1322 (GuestCallee, Command::AsyncPendingExportComplete(24)), in somewhat_larger()
1323 (GuestCaller, Command::AsyncPendingImportCall(25)), in somewhat_larger()
1324 (GuestCallee, Command::AsyncPendingExportComplete(25)), in somewhat_larger()
1325 (GuestCaller, Command::AsyncPendingImportCall(26)), in somewhat_larger()
1326 (GuestCallee, Command::AsyncPendingExportComplete(26)), in somewhat_larger()
1327 (GuestCaller, Command::AsyncPendingImportCall(27)), in somewhat_larger()
1328 (GuestCallee, Command::AsyncPendingExportComplete(27)), in somewhat_larger()
1329 (GuestCaller, Command::AsyncPendingImportCall(28)), in somewhat_larger()
1330 (GuestCallee, Command::AsyncPendingExportComplete(28)), in somewhat_larger()
1331 (GuestCaller, Command::AsyncPendingImportCall(29)), in somewhat_larger()
1332 (GuestCallee, Command::AsyncPendingExportComplete(29)), in somewhat_larger()
1333 (GuestCaller, Command::AsyncPendingImportCall(30)), in somewhat_larger()
1334 (GuestCallee, Command::AsyncPendingExportComplete(30)), in somewhat_larger()
1335 (GuestCaller, Command::AsyncPendingImportCall(31)), in somewhat_larger()
1336 (GuestCallee, Command::AsyncPendingExportComplete(31)), in somewhat_larger()
1337 (GuestCaller, Command::AsyncPendingImportCall(32)), in somewhat_larger()
1338 (GuestCallee, Command::AsyncPendingExportComplete(32)), in somewhat_larger()
1339 (GuestCaller, Command::AsyncPendingImportCall(33)), in somewhat_larger()
1340 (GuestCallee, Command::AsyncPendingExportComplete(33)), in somewhat_larger()
1341 (GuestCaller, Command::AsyncPendingImportCall(34)), in somewhat_larger()
1342 (GuestCallee, Command::AsyncPendingExportComplete(34)), in somewhat_larger()
1343 (GuestCaller, Command::AsyncPendingImportCall(35)), in somewhat_larger()
1344 (GuestCallee, Command::AsyncPendingExportComplete(35)), in somewhat_larger()
1345 (GuestCaller, Command::AsyncPendingImportCall(36)), in somewhat_larger()
1346 (GuestCallee, Command::AsyncPendingExportComplete(36)), in somewhat_larger()
1347 (GuestCaller, Command::AsyncPendingImportCall(37)), in somewhat_larger()
1348 (GuestCallee, Command::AsyncPendingExportComplete(37)), in somewhat_larger()
1349 (GuestCaller, Command::AsyncPendingImportAssertReady(36)), in somewhat_larger()
1364 (HostCallee, Command::StreamNew(1)), in simple_stream1()
1367 Command::StreamReadPending(StreamReadPayload { in simple_stream1()
1372 (HostCallee, Command::StreamCancelRead(1)), in simple_stream1()
1373 (GuestCaller, Command::SyncReadyCall), in simple_stream1()
1376 Command::StreamWritePending(StreamWritePayload { in simple_stream1()
1382 (HostCallee, Command::StreamCancelWrite(1)), in simple_stream1()
1383 (HostCallee, Command::StreamDropWritable(1)), in simple_stream1()
1386 Command::StreamReadDropped(StreamReadPayload { in simple_stream1()
1401 (GuestCaller, Command::StreamNew(26)), in simple_stream3()
1404 Command::StreamReadPending(StreamReadPayload { in simple_stream3()
1409 (GuestCaller, Command::StreamDropWritable(26)), in simple_stream3()
1410 (GuestCaller, Command::StreamReadAssertDropped(26)), in simple_stream3()
1421 (GuestCaller, Command::StreamNew(23)), in simple_stream4()
1424 Command::StreamWritePending(StreamWritePayload { in simple_stream4()
1430 (GuestCaller, Command::StreamGive(23)), in simple_stream4()
1431 (GuestCallee, Command::StreamDropReadable(23)), in simple_stream4()
1434 Command::StreamWriteAssertDropped(StreamReadPayload { in simple_stream4()
1449 (GuestCaller, Command::StreamNew(10)), in zero_length_behavior()
1450 (HostCaller, Command::StreamTake(10)), in zero_length_behavior()
1453 Command::StreamWritePending(StreamWritePayload { in zero_length_behavior()
1461 Command::StreamReadReady(StreamReadyPayload { in zero_length_behavior()
1470 Command::StreamReadReady(StreamReadyPayload { in zero_length_behavior()