mirror of
https://github.com/kovidgoyal/kitty
synced 2026-06-08 14:18:26 +02:00
DRYer
This commit is contained in:
@@ -52,20 +52,13 @@ func read_input(input_file *os.File, input_file_name string, input_channel chan<
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
read_with_retry := func(b []byte) (n int, err error) {
|
|
||||||
for {
|
|
||||||
n, err = input_file.Read(b)
|
|
||||||
if err != unix.EAGAIN && err != unix.EINTR {
|
|
||||||
break
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
for err != nil {
|
for err != nil {
|
||||||
n, err = read_with_retry(buf_array[:])
|
n, err = input_file.Read(buf_array[:])
|
||||||
if n > 0 {
|
if n > 0 {
|
||||||
process_chunk(buf_array[:n])
|
process_chunk(buf_array[:n])
|
||||||
}
|
}
|
||||||
|
if err == unix.EAGAIN || err == unix.EINTR {
|
||||||
|
err = nil
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user