File tree Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Expand file tree Collapse file tree 2 files changed +2
-5
lines changed Original file line number Diff line number Diff line change 1
1
---
2
- refs/heads/master: 6969f0f2fcd4441f694344bdd8d6f10aa9fc56ef
2
+ refs/heads/master: bc507c4ef5a5e4da95e95c080239dbe10ffcd376
3
3
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
4
4
refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
5
5
refs/heads/try: 2898dcc5d97da9427ac367542382b6239d9c0bbf
Original file line number Diff line number Diff line change @@ -25,8 +25,6 @@ for *at least* that period of time.
25
25
" ]
26
26
fn delayed_send < T : copy send> ( iotask : iotask ,
27
27
msecs : uint , ch : comm:: chan < T > , val : T ) {
28
- // FIME: Looks like we don't need to spawn here
29
- task:: spawn ( ) { ||
30
28
unsafe {
31
29
let timer_done_po = comm:: port :: < ( ) > ( ) ;
32
30
let timer_done_ch = comm:: chan ( timer_done_po) ;
@@ -59,7 +57,6 @@ fn delayed_send<T: copy send>(iotask: iotask,
59
57
comm:: send ( ch, copy ( val) ) ;
60
58
// uv_close for this timer has been processed
61
59
comm:: recv ( timer_done_po) ;
62
- }
63
60
} ;
64
61
}
65
62
@@ -106,7 +103,7 @@ fn recv_timeout<T: copy send>(iotask: iotask,
106
103
let timeout_po = comm:: port :: < ( ) > ( ) ;
107
104
let timeout_ch = comm:: chan ( timeout_po) ;
108
105
delayed_send ( iotask, msecs, timeout_ch, ( ) ) ;
109
- // FIXME: This could be written clearer
106
+ // FIXME: This could be written clearer (#2618)
110
107
either:: either (
111
108
{ |left_val|
112
109
log ( debug, #fmt ( "recv_time .. left_val %?" ,
You can’t perform that action at this time.
0 commit comments