- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for clone (0.12 sec)
-
cni/pkg/nodeagent/netns_linux.go
n, err := netns.GetNS(nspath) if err != nil { return nil, err } i, err := inodeForFd(n) if err != nil { n.Close() return nil, err } return &NetnsWrapper{innerNetns: n, inode: i}, nil } func NetnsSet(n NetnsFd) error { if err := unix.Setns(int(n.Fd()), unix.CLONE_NEWNET); err != nil { return fmt.Errorf("Error switching to ns fd %v: %v", n.Fd(), err) } return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
p.currentPodCache[uid] = workload } func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
common/Makefile.common.mk
mirror-licenses: mod-download-go @rm -fr licenses @license-lint --mirror TMP := $(shell mktemp -d -u) UPDATE_BRANCH ?= "master" BUILD_TOOLS_ORG ?= "istio" update-common: @mkdir -p $(TMP) @git clone -q --depth 1 --single-branch --branch $(UPDATE_BRANCH) https://github.com/$(BUILD_TOOLS_ORG)/common-files $(TMP)/common-files @cd $(TMP)/common-files ; git rev-parse HEAD >files/common/.commonfiles.sha @rm -fr common
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 02 20:07:36 GMT 2024 - 5.9K bytes - Viewed (0) -
bin/update_crds.sh
fi fi if [ -z "${SHA}" ]; then fail "Unable to retrieve the commit SHA of istio/api from go.mod file. Not updating the CRD file. Please make sure istio/api exists in the Go module."; fi git clone "https://${REPO}" "${API_TMP}" && cd "${API_TMP}" git checkout "${SHA}" if [ ! -f "${API_TMP}/kubernetes/customresourcedefinitions.gen.yaml" ]; then
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 14:28:27 GMT 2024 - 3.4K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
f := filepath.Join(t.TempDir(), "test") l, err := NewListener(f) if err != nil { t.Fatalf("unexpected error %v", err) } defer l.Close() conn, err := connect(f) if err != nil { t.Fatalf("failed to connect %v", err) } conn.Close() } func connect(socket string) (*grpc.ClientConn, error) { var opts []grpc.DialOption
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
bin/update_ztunnel.sh
SCRIPTPATH="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )" ROOTDIR=$(dirname "${SCRIPTPATH}") cd "${ROOTDIR}" # Get the sha of top commit # $1 = repo function getSha() { local dir result dir=$(mktemp -d) git clone --depth=1 "https://github.com/istio/${1}.git" -b "${UPDATE_BRANCH}" "${dir}" result="$(cd "${dir}" && git rev-parse HEAD)" rm -rf "${dir}" echo "${result}" }
Shell Script - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 11 17:50:01 GMT 2023 - 1.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close() // this will retry for a bit, so shouldn't flake mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(0)) } func podAndNetns() (*v1.Pod, *fakeNs) { devNull, err := os.Open(os.DevNull) if err != nil { panic(err) } // we can't close this now, because we need to pass it from the ztunnel server to the client
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w loggingOptions := log.DefaultOptions()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } return data, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
cni/pkg/plugin/sidecar_iptables_linux.go
if err := cfg.FillConfigFromEnvironment(); err != nil { return err } netNs, err := getNs(netns) if err != nil { err = fmt.Errorf("failed to open netns %q: %s", netns, err) return err } defer netNs.Close() return netNs.Do(func(_ ns.NetNS) error { log.Infof("============= Start iptables configuration for %v =============", podName) defer log.Infof("============= End iptables configuration for %v =============", podName)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 17:36:41 GMT 2024 - 2.5K bytes - Viewed (0)