zymon/PortAudio.jl
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

no runtime error capturing

Browse source
This commit is contained in:
Brandon Taylor 2022-01-06 13:58:10 -05:00
parent 44d4ca38f8
commit aa8e9fc7cd
1 changed files with 6 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
src/PortAudio.jl
View file

@ -446,17 +446,7 @@ function send(messenger)
scribe = messenger.scribe scribe = messenger.scribe
input_channel = messenger.input_channel input_channel = messenger.input_channel
output_channel = messenger.output_channel output_channel = messenger.output_channel
while true for input in input_channel
input = try
take!(input_channel)
catch an_error
# if the input channel is closed, the scribe knows its done
if an_error isa InvalidStateException && an_error.state === :closed
break
else
rethrow(an_error)
end
end
put!(output_channel, scribe(buffer, input)) put!(output_channel, scribe(buffer, input))
end end
end end
@ -488,15 +478,11 @@ function messenger_task(
# if there's channels at all # if there's channels at all
# we can't make the task a field of the buffer, because the task uses the buffer # we can't make the task a field of the buffer, because the task uses the buffer
task = Task(let messenger = messenger task = Task(let messenger = messenger
() -> begin # xruns will return an error code and send a duplicate warning to stderr
# xruns will return an error code and send a duplicate warning to stderr # since we handle the error codes, we don't need the duplicate warnings
# since we handle the error codes, we don't need the duplicate warnings # so we could send them to a debug log
# so we send them to a debug log # but that causes problems when done from multiple threads
log = @capture_err send(messenger) () -> send(messenger)
if !isempty(log)
@debug log
end
end
end) end)
# makes it able to run on a separate thread # makes it able to run on a separate thread
task.sticky = false task.sticky = false