@@ -70,11 +70,11 @@ pub struct Timer {
70
70
struct TimerCallback { tx : Sender < ( ) > }
71
71
72
72
/// Sleep the current task for `msecs` milliseconds.
73
- pub fn sleep ( msecs : u64 ) {
73
+ pub fn sleep_ms ( msecs : u64 ) {
74
74
let timer = Timer :: new ( ) ;
75
75
let mut timer = timer. ok ( ) . expect ( "timer::sleep: could not create a Timer" ) ;
76
76
77
- timer. sleep ( msecs)
77
+ timer. sleep_ms ( msecs)
78
78
}
79
79
80
80
impl Timer {
@@ -91,7 +91,7 @@ impl Timer {
91
91
///
92
92
/// Note that this function will cause any other receivers for this timer to
93
93
/// be invalidated (the other end will be closed).
94
- pub fn sleep ( & mut self , msecs : u64 ) {
94
+ pub fn sleep_ms ( & mut self , msecs : u64 ) {
95
95
self . obj . sleep ( msecs) ;
96
96
}
97
97
@@ -129,7 +129,7 @@ impl Timer {
129
129
/// // The timer object was destroyed, so this will always fail:
130
130
/// // five_ms.recv()
131
131
/// ```
132
- pub fn oneshot ( & mut self , msecs : u64 ) -> Receiver < ( ) > {
132
+ pub fn oneshot_ms ( & mut self , msecs : u64 ) -> Receiver < ( ) > {
133
133
let ( tx, rx) = channel ( ) ;
134
134
self . obj . oneshot ( msecs, box TimerCallback { tx : tx } ) ;
135
135
return rx
@@ -177,7 +177,7 @@ impl Timer {
177
177
/// // The timer object was destroyed, so this will always fail:
178
178
/// // five_ms.recv()
179
179
/// ```
180
- pub fn periodic ( & mut self , msecs : u64 ) -> Receiver < ( ) > {
180
+ pub fn periodic_ms ( & mut self , msecs : u64 ) -> Receiver < ( ) > {
181
181
let ( tx, rx) = channel ( ) ;
182
182
self . obj . period ( msecs, box TimerCallback { tx : tx } ) ;
183
183
return rx
@@ -192,101 +192,101 @@ impl Callback for TimerCallback {
192
192
193
193
#[ cfg( test) ]
194
194
mod test {
195
- iotest ! ( fn test_io_timer_sleep_simple ( ) {
195
+ iotest ! ( fn test_io_timer_sleep_ms_simple ( ) {
196
196
let mut timer = Timer :: new( ) . unwrap( ) ;
197
- timer. sleep ( 1 ) ;
197
+ timer. sleep_ms ( 1 ) ;
198
198
} )
199
199
200
- iotest ! ( fn test_io_timer_sleep_oneshot ( ) {
200
+ iotest ! ( fn test_io_timer_sleep_oneshot_ms ( ) {
201
201
let mut timer = Timer :: new( ) . unwrap( ) ;
202
- timer. oneshot ( 1 ) . recv( ) ;
202
+ timer. oneshot_ms ( 1 ) . recv( ) ;
203
203
} )
204
204
205
- iotest ! ( fn test_io_timer_sleep_oneshot_forget ( ) {
205
+ iotest ! ( fn test_io_timer_sleep_oneshot_ms_forget ( ) {
206
206
let mut timer = Timer :: new( ) . unwrap( ) ;
207
- timer. oneshot ( 100000000000 ) ;
207
+ timer. oneshot_ms ( 100000000000 ) ;
208
208
} )
209
209
210
- iotest ! ( fn oneshot_twice ( ) {
210
+ iotest ! ( fn oneshot_ms_twice ( ) {
211
211
let mut timer = Timer :: new( ) . unwrap( ) ;
212
- let rx1 = timer. oneshot ( 10000 ) ;
213
- let rx = timer. oneshot ( 1 ) ;
212
+ let rx1 = timer. oneshot_ms ( 10000 ) ;
213
+ let rx = timer. oneshot_ms ( 1 ) ;
214
214
rx. recv( ) ;
215
215
assert_eq!( rx1. recv_opt( ) , Err ( ( ) ) ) ;
216
216
} )
217
217
218
- iotest ! ( fn test_io_timer_oneshot_then_sleep ( ) {
218
+ iotest ! ( fn test_io_timer_oneshot_ms_then_sleep ( ) {
219
219
let mut timer = Timer :: new( ) . unwrap( ) ;
220
- let rx = timer. oneshot ( 100000000000 ) ;
221
- timer. sleep ( 1 ) ; // this should invalidate rx
220
+ let rx = timer. oneshot_ms ( 100000000000 ) ;
221
+ timer. sleep_ms ( 1 ) ; // this should invalidate rx
222
222
223
223
assert_eq!( rx. recv_opt( ) , Err ( ( ) ) ) ;
224
224
} )
225
225
226
- iotest ! ( fn test_io_timer_sleep_periodic ( ) {
226
+ iotest ! ( fn test_io_timer_sleep_periodic_ms ( ) {
227
227
let mut timer = Timer :: new( ) . unwrap( ) ;
228
- let rx = timer. periodic ( 1 ) ;
228
+ let rx = timer. periodic_ms ( 1 ) ;
229
229
rx. recv( ) ;
230
230
rx. recv( ) ;
231
231
rx. recv( ) ;
232
232
} )
233
233
234
- iotest ! ( fn test_io_timer_sleep_periodic_forget ( ) {
234
+ iotest ! ( fn test_io_timer_sleep_periodic_ms_forget ( ) {
235
235
let mut timer = Timer :: new( ) . unwrap( ) ;
236
- timer. periodic ( 100000000000 ) ;
236
+ timer. periodic_ms ( 100000000000 ) ;
237
237
} )
238
238
239
- iotest ! ( fn test_io_timer_sleep_standalone ( ) {
240
- sleep ( 1 )
239
+ iotest ! ( fn test_io_timer_sleep_ms_standalone ( ) {
240
+ sleep_ms ( 1 )
241
241
} )
242
242
243
- iotest ! ( fn oneshot ( ) {
243
+ iotest ! ( fn oneshot_ms ( ) {
244
244
let mut timer = Timer :: new( ) . unwrap( ) ;
245
245
246
- let rx = timer. oneshot ( 1 ) ;
246
+ let rx = timer. oneshot_ms ( 1 ) ;
247
247
rx. recv( ) ;
248
248
assert!( rx. recv_opt( ) . is_err( ) ) ;
249
249
250
- let rx = timer. oneshot ( 1 ) ;
250
+ let rx = timer. oneshot_ms ( 1 ) ;
251
251
rx. recv( ) ;
252
252
assert!( rx. recv_opt( ) . is_err( ) ) ;
253
253
} )
254
254
255
255
iotest ! ( fn override( ) {
256
256
let mut timer = Timer :: new( ) . unwrap( ) ;
257
- let orx = timer. oneshot ( 100 ) ;
258
- let prx = timer. periodic ( 100 ) ;
259
- timer. sleep ( 1 ) ;
257
+ let orx = timer. oneshot_ms ( 100 ) ;
258
+ let prx = timer. periodic_ms ( 100 ) ;
259
+ timer. sleep_ms ( 1 ) ;
260
260
assert_eq!( orx. recv_opt( ) , Err ( ( ) ) ) ;
261
261
assert_eq!( prx. recv_opt( ) , Err ( ( ) ) ) ;
262
- timer. oneshot ( 1 ) . recv( ) ;
262
+ timer. oneshot_ms ( 1 ) . recv( ) ;
263
263
} )
264
264
265
- iotest ! ( fn period ( ) {
265
+ iotest ! ( fn period_ms ( ) {
266
266
let mut timer = Timer :: new( ) . unwrap( ) ;
267
- let rx = timer. periodic ( 1 ) ;
267
+ let rx = timer. periodic_ms ( 1 ) ;
268
268
rx. recv( ) ;
269
269
rx. recv( ) ;
270
- let rx2 = timer. periodic ( 1 ) ;
270
+ let rx2 = timer. periodic_ms ( 1 ) ;
271
271
rx2. recv( ) ;
272
272
rx2. recv( ) ;
273
273
} )
274
274
275
- iotest ! ( fn sleep ( ) {
275
+ iotest ! ( fn sleep_ms ( ) {
276
276
let mut timer = Timer :: new( ) . unwrap( ) ;
277
- timer. sleep ( 1 ) ;
278
- timer. sleep ( 1 ) ;
277
+ timer. sleep_ms ( 1 ) ;
278
+ timer. sleep_ms ( 1 ) ;
279
279
} )
280
280
281
- iotest ! ( fn oneshot_fail ( ) {
281
+ iotest ! ( fn oneshot_ms_fail ( ) {
282
282
let mut timer = Timer :: new( ) . unwrap( ) ;
283
- let _rx = timer. oneshot ( 1 ) ;
283
+ let _rx = timer. oneshot_ms ( 1 ) ;
284
284
fail!( ) ;
285
285
} #[ should_fail] )
286
286
287
- iotest ! ( fn period_fail ( ) {
287
+ iotest ! ( fn period_ms_fail ( ) {
288
288
let mut timer = Timer :: new( ) . unwrap( ) ;
289
- let _rx = timer. periodic ( 1 ) ;
289
+ let _rx = timer. periodic_ms ( 1 ) ;
290
290
fail!( ) ;
291
291
} #[ should_fail] )
292
292
@@ -298,7 +298,7 @@ mod test {
298
298
iotest ! ( fn closing_channel_during_drop_doesnt_kill_everything( ) {
299
299
// see issue #10375
300
300
let mut timer = Timer :: new( ) . unwrap( ) ;
301
- let timer_rx = timer. periodic ( 1000 ) ;
301
+ let timer_rx = timer. periodic_ms ( 1000 ) ;
302
302
303
303
spawn( proc( ) {
304
304
let _ = timer_rx. recv_opt( ) ;
@@ -311,58 +311,58 @@ mod test {
311
311
iotest ! ( fn reset_doesnt_switch_tasks( ) {
312
312
// similar test to the one above.
313
313
let mut timer = Timer :: new( ) . unwrap( ) ;
314
- let timer_rx = timer. periodic ( 1000 ) ;
314
+ let timer_rx = timer. periodic_ms ( 1000 ) ;
315
315
316
316
spawn( proc( ) {
317
317
let _ = timer_rx. recv_opt( ) ;
318
318
} ) ;
319
319
320
- timer. oneshot ( 1 ) ;
320
+ timer. oneshot_ms ( 1 ) ;
321
321
} )
322
322
323
323
iotest ! ( fn reset_doesnt_switch_tasks2( ) {
324
324
// similar test to the one above.
325
325
let mut timer = Timer :: new( ) . unwrap( ) ;
326
- let timer_rx = timer. periodic ( 1000 ) ;
326
+ let timer_rx = timer. periodic_ms ( 1000 ) ;
327
327
328
328
spawn( proc( ) {
329
329
let _ = timer_rx. recv_opt( ) ;
330
330
} ) ;
331
331
332
- timer. sleep ( 1 ) ;
332
+ timer. sleep_ms ( 1 ) ;
333
333
} )
334
334
335
335
iotest ! ( fn sender_goes_away_oneshot( ) {
336
336
let rx = {
337
337
let mut timer = Timer :: new( ) . unwrap( ) ;
338
- timer. oneshot ( 1000 )
338
+ timer. oneshot_ms ( 1000 )
339
339
} ;
340
340
assert_eq!( rx. recv_opt( ) , Err ( ( ) ) ) ;
341
341
} )
342
342
343
343
iotest ! ( fn sender_goes_away_period( ) {
344
344
let rx = {
345
345
let mut timer = Timer :: new( ) . unwrap( ) ;
346
- timer. periodic ( 1000 )
346
+ timer. periodic_ms ( 1000 )
347
347
} ;
348
348
assert_eq!( rx. recv_opt( ) , Err ( ( ) ) ) ;
349
349
} )
350
350
351
351
iotest ! ( fn receiver_goes_away_oneshot( ) {
352
352
let mut timer1 = Timer :: new( ) . unwrap( ) ;
353
- timer1. oneshot ( 1 ) ;
353
+ timer1. oneshot_ms ( 1 ) ;
354
354
let mut timer2 = Timer :: new( ) . unwrap( ) ;
355
355
// while sleeping, the previous timer should fire and not have its
356
356
// callback do something terrible.
357
- timer2. sleep ( 2 ) ;
357
+ timer2. sleep_ms ( 2 ) ;
358
358
} )
359
359
360
360
iotest ! ( fn receiver_goes_away_period( ) {
361
361
let mut timer1 = Timer :: new( ) . unwrap( ) ;
362
- timer1. periodic ( 1 ) ;
362
+ timer1. periodic_ms ( 1 ) ;
363
363
let mut timer2 = Timer :: new( ) . unwrap( ) ;
364
364
// while sleeping, the previous timer should fire and not have its
365
365
// callback do something terrible.
366
- timer2. sleep ( 2 ) ;
366
+ timer2. sleep_ms ( 2 ) ;
367
367
} )
368
368
}
0 commit comments