Fix PortsForwarder.Expose() proxy check#441
Fix PortsForwarder.Expose() proxy check#441openshift-merge-bot[bot] merged 3 commits intocontainers:mainfrom
PortsForwarder.Expose() proxy check#441Conversation
97b8f50 to
0a63f4e
Compare
cfergeau
left a comment
There was a problem hiding this comment.
Ouch, good catch.
I'd add this on top of this commit to let the compiler catch such bugs in the future:
diff --git a/pkg/services/forwarder/ports.go b/pkg/services/forwarder/ports.go
index 6b92a005..a1de5401 100644
--- a/pkg/services/forwarder/ports.go
+++ b/pkg/services/forwarder/ports.go
@@ -25,11 +25,13 @@ import (
"gvisor.dev/gvisor/pkg/tcpip/stack"
)
+type ProxyKey string
+
type PortsForwarder struct {
stack *stack.Stack
proxiesLock sync.Mutex
- proxies map[string]proxy
+ proxies map[ProxyKey]proxy
}
type proxy struct {
@@ -61,7 +63,7 @@ func (w CloseWrapper) Close() error {
func NewPortsForwarder(s *stack.Stack) *PortsForwarder {
return &PortsForwarder{
stack: s,
- proxies: make(map[string]proxy),
+ proxies: make(map[ProxyKey]proxy),
}
}
@@ -256,8 +258,8 @@ func (f *PortsForwarder) Expose(protocol types.TransportProtocol, local, remote
return nil
}
-func key(protocol types.TransportProtocol, local string) string {
- return fmt.Sprintf("%s/%s", protocol, local)
+func key(protocol types.TransportProtocol, local string) ProxyKey {
+ return ProxyKey(fmt.Sprintf("%s/%s", protocol, local))
}
func (f *PortsForwarder) Unexpose(protocol types.TransportProtocol, local string) error {
0a63f4e to
8992370
Compare
|
I've added the suggested change as a new commit, rebased to get a fix for CI failures, and force-pushed this to your branch. |
|
This break the port forwarding test: it's reproducible locally with only your commit on top of git main, so this is not related to the github environment. The main branch is green: https://github.com/containers/gvisor-tap-vsock/actions/runs/12671768387/job/35314238072 |
|
The test is failing because |
Ah tests are not independent from each other :-/ |
|
@cfergeau I don't have the permission to do so :/ |
The check for existing `proxies` entries used `local` as a key, but they're actually inserted using keys of: `key(protocol, local)`. This meant that, previously, the check was ineffective and wouldn't reject duplicate forwards. Signed-off-by: Chris Pick <chris@chrispick.com>
This allows the go compiler to catch the bug fixed in the previous commit: ``` GOARCH=amd64 GOOS=freebsd go build -ldflags "-s -w -X github.com/containers/gvisor-tap-vsock/pkg/types.gitVersion=v0.8.1-5-g9df1d587" -o bin/gvproxy-freebsd-amd64 ./cmd/gvproxy # github.com/containers/gvisor-tap-vsock/pkg/services/forwarder pkg/services/forwarder/ports.go:73:24: cannot use local (variable of type string) as ProxyKey value in map index make: *** [Makefile:57: cross] Error 1 ``` Signed-off-by: Christophe Fergeau <cfergeau@redhat.com>
…gain This also fixes a pre-existing issue with this test file, an exposed port was not unexposed before attempting to expose it again, which caused a test failure after the PortsForwarder.Expose() fix. Signed-off-by: Gunjan Vyas <vyasgun20@gmail.com>
434e487 to
233ecd8
Compare
|
CI is green now. I'll merge this next week if you don't have objections to these follow-ups commits @cpick |
|
/lgtm |
|
[APPROVALNOTIFIER] This PR is APPROVED This pull-request has been approved by: cfergeau, cpick The full list of commands accepted by this bot can be found here. The pull request process is described here DetailsNeeds approval from an approver in each of these files:
Approvers can indicate their approval by writing |
The check for existing
proxiesentries usedlocalas a key, but they're actually inserted using keys of:key(protocol, local).This meant that, previously, the check was ineffective and wouldn't reject duplicate forwards.