Skip to content

Commit 39e26c6

Browse files
committed
correct timer start position
1 parent 0003841 commit 39e26c6

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/cq_event_listener.rs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -369,6 +369,10 @@ impl ManualTrigger {
369369
/// .await
370370
/// .unwrap();
371371
///
372+
/// let mut lmr = rdma.alloc_local_mr(Layout::new::<[u8; 8]>())?;
373+
/// let _num = lmr.as_mut_slice().write(&[1_u8; 8])?;
374+
/// let instant = Instant::now();
375+
///
372376
/// let trigger = rdma.get_manual_trigger().unwrap();
373377
/// // polling task
374378
/// let _trigger_handle = tokio::spawn(async move {
@@ -378,9 +382,6 @@ impl ManualTrigger {
378382
/// }
379383
/// });
380384
///
381-
/// let mut lmr = rdma.alloc_local_mr(Layout::new::<[u8; 8]>())?;
382-
/// let _num = lmr.as_mut_slice().write(&[1_u8; 8])?;
383-
/// let instant = Instant::now();
384385
/// rdma.send(&lmr).await?;
385386
/// assert!(instant.elapsed() >= POLLING_INTERVAL);
386387
/// Ok(())

0 commit comments

Comments
 (0)