79 lines
		
	
	
		
			1.9 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			79 lines
		
	
	
		
			1.9 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
// +build windows
 | 
						|
 | 
						|
/*
 | 
						|
   Copyright The containerd 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 netns
 | 
						|
 | 
						|
import "github.com/Microsoft/hcsshim/hcn"
 | 
						|
 | 
						|
// NetNS holds network namespace for sandbox
 | 
						|
type NetNS struct {
 | 
						|
	path string
 | 
						|
}
 | 
						|
 | 
						|
// NewNetNS creates a network namespace for the sandbox
 | 
						|
func NewNetNS(baseDir string) (*NetNS, error) {
 | 
						|
	temp := hcn.HostComputeNamespace{}
 | 
						|
	hcnNamespace, err := temp.Create()
 | 
						|
	if err != nil {
 | 
						|
		return nil, err
 | 
						|
	}
 | 
						|
 | 
						|
	return &NetNS{path: hcnNamespace.Id}, nil
 | 
						|
}
 | 
						|
 | 
						|
// LoadNetNS loads existing network namespace.
 | 
						|
func LoadNetNS(path string) *NetNS {
 | 
						|
	return &NetNS{path: path}
 | 
						|
}
 | 
						|
 | 
						|
// Remove removes network namespace if it exists and not closed. Remove is idempotent,
 | 
						|
// meaning it might be invoked multiple times and provides consistent result.
 | 
						|
func (n *NetNS) Remove() error {
 | 
						|
	hcnNamespace, err := hcn.GetNamespaceByID(n.path)
 | 
						|
	if err != nil {
 | 
						|
		if hcn.IsNotFoundError(err) {
 | 
						|
			return nil
 | 
						|
		}
 | 
						|
		return err
 | 
						|
	}
 | 
						|
	err = hcnNamespace.Delete()
 | 
						|
	if err == nil || hcn.IsNotFoundError(err) {
 | 
						|
		return nil
 | 
						|
	}
 | 
						|
	return err
 | 
						|
}
 | 
						|
 | 
						|
// Closed checks whether the network namespace has been closed.
 | 
						|
func (n *NetNS) Closed() (bool, error) {
 | 
						|
	_, err := hcn.GetNamespaceByID(n.path)
 | 
						|
	if err == nil {
 | 
						|
		return false, nil
 | 
						|
	}
 | 
						|
	if hcn.IsNotFoundError(err) {
 | 
						|
		return true, nil
 | 
						|
	}
 | 
						|
	return false, err
 | 
						|
}
 | 
						|
 | 
						|
// GetPath returns network namespace path for sandbox container
 | 
						|
func (n *NetNS) GetPath() string {
 | 
						|
	return n.path
 | 
						|
}
 | 
						|
 | 
						|
// NOTE: Do function is not supported.
 |