mirrors/bun.sh
1
0
Fork 0
mirror of https://github.com/oven-sh/bun synced 2026-02-09 10:28:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Automatically retry on would block

Browse Source
This commit is contained in:
Jarred SUmner
2022-01-24 23:42:16 -08:00
parent 0e138bcc8f
commit ff7785e023
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/io/io_linux.zig
View File

@@ -798,7 +798,7 @@ pub const Completion = struct {
},
.connect => {
const result = if (completion.result < 0) switch (-completion.result) {
os.EINTR => {
os.EAGAIN, os.EINPROGRESS, os.EINTR => {
completion.io.enqueue(completion);
return;
},
@@ -806,7 +806,6 @@ pub const Completion = struct {
os.EADDRINUSE => error.AddressInUse,
os.EADDRNOTAVAIL => error.AddressNotAvailable,
os.EAFNOSUPPORT => error.AddressFamilyNotSupported,
os.EAGAIN, os.EINPROGRESS => error.WouldBlock,
os.EALREADY => error.OpenAlreadyInProgress,
os.EBADF => error.FileDescriptorInvalid,
os.ECONNREFUSED => error.ConnectionRefused,
@@ -840,11 +839,10 @@ pub const Completion = struct {
},
.read => {
const result = if (completion.result < 0) switch (-completion.result) {
os.EINTR => {
os.EAGAIN, os.EINTR => {
completion.io.enqueue(completion);
return;
},
os.EAGAIN => error.WouldBlock,
os.EBADF => error.NotOpenForReading,
os.ECONNRESET => error.ConnectionResetByPeer,
os.EINVAL => error.Alignment,
@@ -861,11 +859,10 @@ pub const Completion = struct {
},
.readev, .recv => {
const result = if (completion.result < 0) switch (-completion.result) {
os.EINTR => {
os.EAGAIN, os.EINTR => {
completion.io.enqueue(completion);
return;
},
os.EAGAIN => error.WouldBlock,
os.EBADF => error.FileDescriptorInvalid,
os.ECONNREFUSED => error.ConnectionRefused,
os.ENOMEM => error.SystemResources,
@@ -878,12 +875,11 @@ pub const Completion = struct {
},
.writev, .send => {
const result = if (completion.result < 0) switch (-completion.result) {
os.EINTR => {
os.EAGAIN, os.EINTR => {
completion.io.enqueue(completion);
return;
},
os.EACCES => error.AccessDenied,
os.EAGAIN => error.WouldBlock,
os.EALREADY => error.FastOpenAlreadyInProgress,
os.EAFNOSUPPORT => error.AddressFamilyNotSupported,
os.EBADF => error.FileDescriptorInvalid,