Skip to content

Commit f9169d2

Browse files
committed
skip recording inputs & outputs in fake script plugin when CNI_COMMAND=VERSION
Signed-off-by: Bruce Ma <[email protected]>
1 parent 6cb788c commit f9169d2

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

pkg/kubelet/dockershim/network/cni/cni_test.go

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ package cni
2020

2121
import (
2222
"bytes"
23-
"context"
2423
"encoding/json"
2524
"fmt"
2625
"io/ioutil"
@@ -76,14 +75,18 @@ func installPluginUnderTest(t *testing.T, testBinDir, testConfDir, testDataDir,
7675
f, err = os.Create(pluginExec)
7776
require.NoError(t, err)
7877

78+
// TODO: use mock instead of fake shell script plugin
7979
const execScriptTempl = `#!/usr/bin/env bash
80+
echo -n "{ \"cniVersion\": \"{{.CNIVersion}}\", \"ip4\": { \"ip\": \"{{.PodIP}}/24\" } }"
81+
if [ "$CNI_COMMAND" = "VERSION" ]; then
82+
exit
83+
fi
8084
cat > {{.InputFile}}
8185
env > {{.OutputEnv}}
8286
echo "%@" >> {{.OutputEnv}}
8387
export $(echo ${CNI_ARGS} | sed 's/;/ /g') &> /dev/null
8488
mkdir -p {{.OutputDir}} &> /dev/null
85-
echo -n "$CNI_COMMAND $CNI_NETNS $K8S_POD_NAMESPACE $K8S_POD_NAME $K8S_POD_INFRA_CONTAINER_ID" >& {{.OutputFile}}
86-
echo -n "{ \"cniVersion\": \"{{.CNIVersion}}\", \"ip4\": { \"ip\": \"{{.PodIP}}/24\" } }"`
89+
echo -n "$CNI_COMMAND $CNI_NETNS $K8S_POD_NAMESPACE $K8S_POD_NAME $K8S_POD_INFRA_CONTAINER_ID" >& {{.OutputFile}}`
8790

8891
inputFile := path.Join(testDataDir, binName+".in")
8992
outputFile := path.Join(testDataDir, binName+".out")
@@ -225,8 +228,8 @@ func TestCNIPlugin(t *testing.T) {
225228
cniPlugin.execer = fexec
226229
cniPlugin.loNetwork.CNIConfig = mockLoCNI
227230

228-
mockLoCNI.On("AddNetworkList", context.TODO(), cniPlugin.loNetwork.NetworkConfig, mock.AnythingOfType("*libcni.RuntimeConf")).Return(&types020.Result{IP4: &types020.IPConfig{IP: net.IPNet{IP: []byte{127, 0, 0, 1}}}}, nil)
229-
mockLoCNI.On("DelNetworkList", context.TODO(), cniPlugin.loNetwork.NetworkConfig, mock.AnythingOfType("*libcni.RuntimeConf")).Return(nil)
231+
mockLoCNI.On("AddNetworkList", mock.AnythingOfType("*context.emptyCtx"), cniPlugin.loNetwork.NetworkConfig, mock.AnythingOfType("*libcni.RuntimeConf")).Return(&types020.Result{IP4: &types020.IPConfig{IP: net.IPNet{IP: []byte{127, 0, 0, 1}}}}, nil)
232+
mockLoCNI.On("DelNetworkList", mock.AnythingOfType("*context.emptyCtx"), cniPlugin.loNetwork.NetworkConfig, mock.AnythingOfType("*libcni.RuntimeConf")).Return(nil)
230233

231234
// Check that status returns an error
232235
if err := cniPlugin.Status(); err == nil {

0 commit comments

Comments
 (0)