async fn create_topology(queue: Arc<JobQueue>) {
    let r1 = create_target("ms1").await;
    // let r2 = create_target("ms2").await;
    let endpoint = create_nexus("ms3", vec![r1]).await;

    // the nexus is running on ms3 we will use a 4th instance of mayastor to
    // create a nvmf bdev and push IO to it.

    let ms = MAYASTOR.get().unwrap();
    let bdev = ms
        .spawn(async move {
            let bdev = bdev_create(&endpoint).await.unwrap();
            bdev
        })
        .await;

    // start the workload by running a job on each core, this simulates the way
    // the targets use multiple cores
    ms.spawn(async move {
        for c in Cores::count() {
            let bdev = Bdev::lookup_by_name(&bdev).unwrap();
            let job = io_driver::Builder::new()
                .core(c)
                .bdev(bdev)
                .qd(8)
                .io_size(512)
                .build()
                .await;

            queue.start(job);
        }
    })
    .await;
}
/// create the work -- which means the nexus, replica's and the jobs. on return
/// IO flows through mayastorTest to all 3 containers
create the work -- which means the nexus, replica's and the jobs. on return
IO flows through mayastorTest to all 3 containers
create the work -- which means the nexus replica ' s and the jobs . on return IO flows through mayastorTest to all 3 containers
async fn create_topology(queue: Arc<JobQueue>) {
    let r1 = create_target("ms1").await;
    // let r2 = create_target("ms2").await;
    let endpoint = create_nexus("ms3", vec![r1]).await;
    // the nexus is running on ms3 we will use a 4th instance of mayastor to
    // create a nvmf bdev and push IO to it.
    let ms = MAYASTOR.get().unwrap();
    let bdev = ms
        .spawn(async move {
            let bdev = bdev_create(&endpoint).await.unwrap();
            bdev
        })
        .await;
    // start the workload by running a job on each core, this simulates the way
    // the targets use multiple cores
    ms.spawn(async move {
        for c in Cores::count() {
            let bdev = Bdev::lookup_by_name(&bdev).unwrap();
            let job = io_driver::Builder::new()
                .core(c)
                .bdev(bdev)
                .qd(8)
                .io_size(512)
                .build()
                .await;
            queue.start(job);
        }
    })
    .await;
}
async fn create_topology ( queue : Arc < JobQueue > ) { let r1 = create_target ( " " ) . await ; // let r2 = create_target("ms2").await; let endpoint = create_nexus ( " " , vec ! [ r1 ] ) . await ; // the nexus is running on ms3 we will use a 4th instance of mayastor to // create a nvmf bdev and push IO to it. let ms = MAYASTOR . get ( ) . unwrap ( ) ; let bdev = ms . spawn ( async move { let bdev = bdev_create ( & endpoint ) . await . unwrap ( ) ; bdev } ) . await ; // start the workload by running a job on each core, this simulates the way // the targets use multiple cores ms . spawn ( async move { for c in Cores :: count ( ) { let bdev = Bdev :: lookup_by_name ( & bdev ) . unwrap ( ) ; let job = io_driver :: Builder :: new ( ) . core ( c ) . bdev ( bdev ) . qd ( 8 ) . io_size ( 512 ) . build ( ) . await ; queue . start ( job ) ; } } ) . await ; }
create the work -- which means the nexus, replica's and the jobs.
create the work -- which means the nexus replica ' s and the jobs .
queue
Arc<JobQueue>