Skip to content

Commit 6d7c113

Browse files
committed
Update
1 parent ce7a573 commit 6d7c113

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

examples/singleapp/unix/socket/03.nonblocking/client/client.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,6 +86,8 @@ func run() error {
8686
log.Println("[CLIENT][SEND] --> unix.EAGAIN")
8787
case errors.Is(err, unix.EWOULDBLOCK):
8888
log.Println("[CLIENT][SEND] --> unix.EWOULDBLOCK")
89+
case errors.Is(err, unix.EINTR):
90+
log.Println("[CLIENT][SEND] --> unix.EINTR")
8991
default:
9092
return err
9193
}
@@ -121,6 +123,8 @@ func run() error {
121123
log.Println("[CLIENT][RECV] --> unix.EAGAIN")
122124
case errors.Is(err, unix.EWOULDBLOCK):
123125
log.Println("[CLIENT][RECV] --> unix.EWOULDBLOCK")
126+
case errors.Is(err, unix.EINTR):
127+
log.Println("[CLIENT][RECV] --> unix.EINTR")
124128
default:
125129
return err
126130
}

examples/singleapp/unix/socket/03.nonblocking/server/server.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ func run() error {
9393
for {
9494
cfd, cAddr, err = unix.Accept(sfd)
9595
if err != nil {
96-
if errors.Is(err, unix.EAGAIN) || errors.Is(err, unix.EWOULDBLOCK) {
96+
if errors.Is(err, unix.EAGAIN) || errors.Is(err, unix.EWOULDBLOCK) || errors.Is(err, unix.EINTR) {
9797
log.Println("[SERVER][ACCEPT] --> unix.EAGAIN")
9898

9999
time.Sleep(100 * time.Millisecond)

0 commit comments

Comments
 (0)