- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 136 for npipe (0.14 sec)
-
cmd/kubeadm/app/constants/constants_windows.go
const ( // CRISocketContainerd is the containerd CRI endpoint CRISocketContainerd = "npipe:////./pipe/containerd-containerd" // CRISocketCRIO is the cri-o CRI endpoint // NOTE: this is a placeholder as CRI-O does not support Windows CRISocketCRIO = "npipe:////./pipe/cri-o" // CRISocketDocker is the cri-dockerd CRI endpoint CRISocketDocker = "npipe:////./pipe/cri-dockerd" // DefaultCRISocket defines the default CRI socket
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1.1K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta4/defaults_windows.go
DefaultCACertPath = "C:/etc/kubernetes/pki/ca.crt" // DefaultContainerRuntimeURLScheme defines default socket url prefix DefaultContainerRuntimeURLScheme = "npipe"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 11:33:30 UTC 2023 - 879 bytes - Viewed (0) -
cmd/kubeadm/app/util/runtime/runtime_windows.go
func isExistingSocket(path string) bool { u, err := url.Parse(path) if err != nil { // should not happen, since we are trying to access known / hardcoded sockets return false } // the dial path must be without "npipe://" _, err = winio.DialPipe(u.Path, nil) if err != nil { return false } return true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 12 15:15:45 UTC 2022 - 1K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/util_windows_test.go
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 cmd
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 09:45:16 UTC 2023 - 687 bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/v1beta3/defaults_windows.go
DefaultCACertPath = "C:/etc/kubernetes/pki/ca.crt" // DefaultContainerRuntimeURLScheme defines default socket url prefix DefaultContainerRuntimeURLScheme = "npipe"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 03 19:15:03 UTC 2022 - 879 bytes - Viewed (0) -
pkg/kubelet/util/util_windows.go
limitations under the License. */ package util import ( "fmt" "path/filepath" "strings" "syscall" "time" ) const npipeProtocol = "npipe" // LocalEndpoint returns the full path to a named pipe at the given endpoint - unlike on unix, we can't use sockets. func LocalEndpoint(path, file string) (string, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/util/util_windows_test.go
}{ { path: "/var/lib/kubelet/pod-resources", file: "kube.sock", // this is not the default, but it's not relevant here expectError: false, expectedFullPath: `npipe://\\.\pipe\kubelet-pod-resources`, }, } for _, test := range tests { fullPath, err := LocalEndpoint(test.path, test.file) if test.expectError { assert.NotNil(t, err, "expected error") continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 3.1K bytes - Viewed (0) -
src/io/pipe.go
a.Lock() defer a.Unlock() return a.err } // ErrClosedPipe is the error used for read or write operations on a closed pipe. var ErrClosedPipe = errors.New("io: read/write on closed pipe") // A pipe is the shared pipe structure underlying PipeReader and PipeWriter. type pipe struct { wrMu sync.Mutex // Serializes Write operations wrCh chan []byte rdCh chan int once sync.Once // Protects closing done
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 18 19:34:35 UTC 2023 - 5.1K bytes - Viewed (0) -
src/net/pipe.go
} return p1, p2 } func (*pipe) LocalAddr() Addr { return pipeAddr{} } func (*pipe) RemoteAddr() Addr { return pipeAddr{} } func (p *pipe) Read(b []byte) (int, error) { n, err := p.read(b) if err != nil && err != io.EOF && err != io.ErrClosedPipe { err = &OpError{Op: "read", Net: "pipe", Err: err} } return n, err } func (p *pipe) read(b []byte) (n int, err error) { switch {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 5.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/wait-on-pipe.go
import ( "log" "os" "runtime/trace" "syscall" "time" ) func main() { // Create a pipe to block on. var p [2]int if err := syscall.Pipe(p[:]); err != nil { log.Fatalf("failed to create pipe: %v", err) } rfd, wfd := p[0], p[1] // Create a goroutine that blocks on the pipe. done := make(chan struct{}) go func() { var data [1]byte _, err := syscall.Read(rfd, data[:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.6K bytes - Viewed (0)