summaryrefslogtreecommitdiffhomepage
path: root/pkg/tcpip
diff options
context:
space:
mode:
authorZach Koopmans <zkoopmans@google.com>2021-11-04 12:08:45 -0700
committergVisor bot <gvisor-bot@google.com>2021-11-04 12:11:41 -0700
commit23a115dae84e7e63c8785c49dfff3e551a0bf97e (patch)
tree3c39ad2b1ab9f90971cdce9664ab58a35c0696ab /pkg/tcpip
parent80cba65bd84d6415719b07daeca7188871000242 (diff)
[syserr] Reverse dependency for tcpip.Error
PiperOrigin-RevId: 407638912
Diffstat (limited to 'pkg/tcpip')
-rw-r--r--pkg/tcpip/BUILD15
-rw-r--r--pkg/tcpip/syserr.go146
2 files changed, 161 insertions, 0 deletions
diff --git a/pkg/tcpip/BUILD b/pkg/tcpip/BUILD
index b98de54c5..7a159d5c8 100644
--- a/pkg/tcpip/BUILD
+++ b/pkg/tcpip/BUILD
@@ -24,14 +24,17 @@ go_library(
"socketops.go",
"stdclock.go",
"stdclock_state.go",
+ "syserr.go",
"tcpip.go",
"tcpip_state.go",
"timer.go",
],
visibility = ["//visibility:public"],
deps = [
+ "//pkg/abi/linux/errno",
"//pkg/atomicbitops",
"//pkg/sync",
+ "//pkg/syserr",
"//pkg/tcpip/buffer",
"//pkg/waiter",
],
@@ -55,6 +58,18 @@ deps_test(
"//pkg/state/wire",
"//pkg/sync",
"//pkg/waiter",
+ "//pkg/syserr",
+ "//pkg/abi/linux/errno",
+ "//pkg/errors",
+ "//pkg/errors/linuxerr",
+ "//pkg/safecopy",
+ "//pkg/sighandling",
+ "//pkg/abi/linux",
+ "//pkg/abi:abi",
+ "//pkg/bits",
+ "//pkg/hostarch",
+ "//pkg/marshal",
+ "//pkg/marshal/primitive",
# Other deps.
"@com_github_google_btree//:go_default_library",
diff --git a/pkg/tcpip/syserr.go b/pkg/tcpip/syserr.go
new file mode 100644
index 000000000..c73a0fb79
--- /dev/null
+++ b/pkg/tcpip/syserr.go
@@ -0,0 +1,146 @@
+// Copyright 2018 The gVisor Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package tcpip
+
+import (
+ "fmt"
+
+ "gvisor.dev/gvisor/pkg/abi/linux/errno"
+ "gvisor.dev/gvisor/pkg/syserr"
+)
+
+// LINT.IfChange
+
+// Mapping for tcpip.Error types.
+var (
+ SyserrUnknownProtocol = syserr.New((&ErrUnknownProtocol{}).String(), errno.EINVAL)
+ SyserrUnknownNICID = syserr.New((&ErrUnknownNICID{}).String(), errno.ENODEV)
+ SyserrUnknownDevice = syserr.New((&ErrUnknownDevice{}).String(), errno.ENODEV)
+ SyserrUnknownProtocolOption = syserr.New((&ErrUnknownProtocolOption{}).String(), errno.ENOPROTOOPT)
+ SyserrDuplicateNICID = syserr.New((&ErrDuplicateNICID{}).String(), errno.EEXIST)
+ SyserrDuplicateAddress = syserr.New((&ErrDuplicateAddress{}).String(), errno.EEXIST)
+ SyserrAlreadyBound = syserr.New((&ErrAlreadyBound{}).String(), errno.EINVAL)
+ SyserrInvalidEndpointState = syserr.New((&ErrInvalidEndpointState{}).String(), errno.EINVAL)
+ SyserrAlreadyConnecting = syserr.New((&ErrAlreadyConnecting{}).String(), errno.EALREADY)
+ SyserrNoPortAvailable = syserr.New((&ErrNoPortAvailable{}).String(), errno.EAGAIN)
+ SyserrPortInUse = syserr.New((&ErrPortInUse{}).String(), errno.EADDRINUSE)
+ SyserrBadLocalAddress = syserr.New((&ErrBadLocalAddress{}).String(), errno.EADDRNOTAVAIL)
+ SyserrClosedForSend = syserr.New((&ErrClosedForSend{}).String(), errno.EPIPE)
+ SyserrClosedForReceive = syserr.New((&ErrClosedForReceive{}).String(), errno.NOERRNO)
+ SyserrTimeout = syserr.New((&ErrTimeout{}).String(), errno.ETIMEDOUT)
+ SyserrAborted = syserr.New((&ErrAborted{}).String(), errno.EPIPE)
+ SyserrConnectStarted = syserr.New((&ErrConnectStarted{}).String(), errno.EINPROGRESS)
+ SyserrDestinationRequired = syserr.New((&ErrDestinationRequired{}).String(), errno.EDESTADDRREQ)
+ SyserrNotSupported = syserr.New((&ErrNotSupported{}).String(), errno.EOPNOTSUPP)
+ SyserrQueueSizeNotSupported = syserr.New((&ErrQueueSizeNotSupported{}).String(), errno.ENOTTY)
+ SyserrNoSuchFile = syserr.New((&ErrNoSuchFile{}).String(), errno.ENOENT)
+ SyserrInvalidOptionValue = syserr.New((&ErrInvalidOptionValue{}).String(), errno.EINVAL)
+ SyserrBroadcastDisabled = syserr.New((&ErrBroadcastDisabled{}).String(), errno.EACCES)
+ SyserrNotPermittedNet = syserr.New((&ErrNotPermitted{}).String(), errno.EPERM)
+ SyserrBadBuffer = syserr.New((&ErrBadBuffer{}).String(), errno.EFAULT)
+ SyserrMalformedHeader = syserr.New((&ErrMalformedHeader{}).String(), errno.EINVAL)
+ SyserrInvalidPortRange = syserr.New((&ErrInvalidPortRange{}).String(), errno.EINVAL)
+)
+
+// TranslateNetstackError converts an error from the tcpip package to a sentry
+// internal error.
+func TranslateNetstackError(err Error) *syserr.Error {
+ switch err.(type) {
+ case nil:
+ return nil
+ case *ErrUnknownProtocol:
+ return SyserrUnknownProtocol
+ case *ErrUnknownNICID:
+ return SyserrUnknownNICID
+ case *ErrUnknownDevice:
+ return SyserrUnknownDevice
+ case *ErrUnknownProtocolOption:
+ return SyserrUnknownProtocolOption
+ case *ErrDuplicateNICID:
+ return SyserrDuplicateNICID
+ case *ErrDuplicateAddress:
+ return SyserrDuplicateAddress
+ case *ErrNoRoute:
+ return syserr.ErrNoRoute
+ case *ErrAlreadyBound:
+ return SyserrAlreadyBound
+ case *ErrInvalidEndpointState:
+ return SyserrInvalidEndpointState
+ case *ErrAlreadyConnecting:
+ return SyserrAlreadyConnecting
+ case *ErrAlreadyConnected:
+ return syserr.ErrAlreadyConnected
+ case *ErrNoPortAvailable:
+ return SyserrNoPortAvailable
+ case *ErrPortInUse:
+ return SyserrPortInUse
+ case *ErrBadLocalAddress:
+ return SyserrBadLocalAddress
+ case *ErrClosedForSend:
+ return SyserrClosedForSend
+ case *ErrClosedForReceive:
+ return SyserrClosedForReceive
+ case *ErrWouldBlock:
+ return syserr.ErrWouldBlock
+ case *ErrConnectionRefused:
+ return syserr.ErrConnectionRefused
+ case *ErrTimeout:
+ return SyserrTimeout
+ case *ErrAborted:
+ return SyserrAborted
+ case *ErrConnectStarted:
+ return SyserrConnectStarted
+ case *ErrDestinationRequired:
+ return SyserrDestinationRequired
+ case *ErrNotSupported:
+ return SyserrNotSupported
+ case *ErrQueueSizeNotSupported:
+ return SyserrQueueSizeNotSupported
+ case *ErrNotConnected:
+ return syserr.ErrNotConnected
+ case *ErrConnectionReset:
+ return syserr.ErrConnectionReset
+ case *ErrConnectionAborted:
+ return syserr.ErrConnectionAborted
+ case *ErrNoSuchFile:
+ return SyserrNoSuchFile
+ case *ErrInvalidOptionValue:
+ return SyserrInvalidOptionValue
+ case *ErrBadAddress:
+ return syserr.ErrBadAddress
+ case *ErrNetworkUnreachable:
+ return syserr.ErrNetworkUnreachable
+ case *ErrMessageTooLong:
+ return syserr.ErrMessageTooLong
+ case *ErrNoBufferSpace:
+ return syserr.ErrNoBufferSpace
+ case *ErrBroadcastDisabled:
+ return SyserrBroadcastDisabled
+ case *ErrNotPermitted:
+ return SyserrNotPermittedNet
+ case *ErrAddressFamilyNotSupported:
+ return syserr.ErrAddressFamilyNotSupported
+ case *ErrBadBuffer:
+ return SyserrBadBuffer
+ case *ErrMalformedHeader:
+ return SyserrMalformedHeader
+ case *ErrInvalidPortRange:
+ return SyserrInvalidPortRange
+ default:
+ panic(fmt.Sprintf("unknown error %T", err))
+ }
+}
+
+// LINT.ThenChange(../tcpip/errors.go)