6364
6365
6366
6367
6368
6369
6370
6371
6372
6373
6374
6375
6376
6377
|
6364
6365
6366
6367
6368
6369
6370
6371
6372
6373
6374
6375
6376
6377
6378
6379
6380
6381
6382
6383
6384
6385
6386
6387
6388
6389
6390
6391
6392
6393
6394
6395
6396
6397
6398
6399
6400
6401
6402
6403
6404
6405
6406
6407
6408
6409
6410
6411
6412
6413
6414
6415
6416
6417
6418
6419
6420
6421
6422
6423
6424
6425
6426
6427
6428
6429
6430
6431
6432
6433
6434
6435
6436
6437
6438
6439
6440
6441
6442
6443
6444
6445
6446
6447
6448
6449
6450
6451
6452
6453
6454
6455
6456
6457
6458
6459
6460
6461
6462
6463
6464
6465
6466
6467
6468
6469
6470
6471
6472
6473
6474
6475
6476
6477
6478
6479
6480
6481
6482
6483
6484
6485
|
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
|
close $chan
set ::io-44.7-result success
} [namespace current]]
vwait ::io-44.7-result
set ::io-44.7-result
} -result success
test io-44.8 {write-only refchan should not hang} -setup {
catch {namespace delete rc}
namespace eval rc {
namespace export *
namespace ensemble create
proc buffer chan {
namespace upvar chan_$chan buffer buffer
return $buffer
}
proc initialize {chan mode} {
namespace eval chan_$chan {
variable buffer {}
variable watch {}
variable writetask {}
}
return {initialize finalize watch write}
}
proc finalize chan {
namespace upvar chan_$chan writetask writetask
after cancel $writetask
set writetask {}
namespace delete chan_$chan
}
proc watch {chan spec} {
set channs [namespace current]::chan_$chan
namespace upvar $channs watch watch writetask writetask
set watch $spec
after cancel $writetask
if {{write} in $spec} {
set writetask [after 0 [list after idle [
list ::apply {{channs chan} {
if {[namespace exists $channs]} {
chan postevent $chan write
}
}} $channs $chan]]]
} else {
set writetask {}
}
return
}
proc write {chan data} {
set channs [namespace current]::chan_$chan
namespace upvar $channs buffer buffer watch watch \
writetask writetask
append buffer $data
after cancel writetask
if {{write} in $watch} {
set writetask [after 0 [list after idle [
list ::apply {{channs chan} {
if {[namespace exists $channs]} {
chan postevent $chan write
}
}} $channs $chan]]]
} else {
set writetask {}
}
return [string length $data]
}
proc post {chan side} {
set ns chan_$chan
if [namespace exists $ns] {
chan postevent $chan $side
}
return
}
}
} -cleanup {
namespace delete rc
} -body {
variable done
set chan [chan create write [namespace which rc]]
try {
chan configure $chan -blocking 0
coroutine c1 apply [list chan {
variable done
after 0 [list [info coroutine]]
set written 0
yield
chan event $chan writable [list [info coroutine]]
# Perform enough to exercise more than one buffer.
while {[incr i] < 500000} {
yield
puts $chan $i
set written [expr {$written + [string length $i] + 1}]
}
chan configure $chan -blocking 1
flush $chan
set buffersize [string length [rc buffer $chan]]
set done [list $written $buffersize]
} [namespace current]] $chan
vwait [namespace current]::done
} finally {
close $chan
}
return $done
} -result {3388888 3388888}
makeFile "foo bar" foo
test io-45.1 {DeleteFileEvent, cleanup on close} {fileevent} {
set f [open $path(foo) r]
fileevent $f readable [namespace code {
lappend x "binding triggered: \"[gets $f]\""
fileevent $f readable {}
|