- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,295 for info2 (0.19 sec)
-
src/os/dir_unix.go
dirents = append(dirents, de) } else { info, err := lstat(f.name + "/" + string(name)) if IsNotExist(err) { // File disappeared between readdir + stat. // Treat as if it didn't exist. continue } if err != nil { return nil, nil, infos, err } infos = append(infos, info) } } if n > 0 && len(names)+len(dirents)+len(infos) == 0 { return nil, nil, nil, io.EOF }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 20:11:45 UTC 2024 - 4.8K bytes - Viewed (0) -
src/os/dir_plan9.go
dirents = append(dirents, dirEntry{f}) } else { infos = append(infos, f) } } d.bufp += m n-- } if n > 0 && len(names)+len(dirents)+len(infos) == 0 { return nil, nil, nil, io.EOF } return names, dirents, infos, nil } type dirEntry struct { fs *fileStat } func (de dirEntry) Name() string { return de.fs.Name() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 20:52:06 UTC 2024 - 2.1K bytes - Viewed (0) -
src/io/ioutil/ioutil.go
// If you must continue obtaining a list of [fs.FileInfo], you still can: // // entries, err := os.ReadDir(dirname) // if err != nil { ... } // infos := make([]fs.FileInfo, 0, len(entries)) // for _, entry := range entries { // info, err := entry.Info() // if err != nil { ... } // infos = append(infos, info) // } func ReadDir(dirname string) ([]fs.FileInfo, error) { f, err := os.Open(dirname) if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
dir := mounter.GetPath() mounter.MetricsProvider = NewMetricsCsi(volumeHandle, dir, csiDriverName(driverName)) klog.V(4).Info(log("mounter created successfully")) return mounter, nil } func (p *csiPlugin) NewUnmounter(specName string, podUID types.UID) (volume.Unmounter, error) { klog.V(4).Infof(log("setting up unmounter for [name=%v, podUID=%v]", specName, podUID)) kvh, ok := p.host.(volume.KubeletVolumeHost) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 29.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
if plState == nil { klog.V(7).Infof("plName=%s, plState==nil", plName) return } useless := plState.quiescing && plState.numPending == 0 && plState.queues.IsIdle() klog.V(7).Infof("plState.quiescing=%v, plState.numPending=%d, useless=%v", plState.quiescing, plState.numPending, useless) if !useless { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
security/pkg/nodeagent/test/mock/caserver.go
*pb.IstioCertificateResponse, error, ) { caServerLog.Infof("received CSR request") if s.shouldReject() { caServerLog.Info("force rejecting CSR request") return nil, status.Error(codes.Unavailable, "CA server is not available") } if s.sendEmpty() { caServerLog.Info("force sending empty cert chain in CSR response") response := &pb.IstioCertificateResponse{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/kubeletfinalize.go
} info, ok := kubeconfig.AuthInfos[userName] if !ok { return errors.Errorf("the file %q does not contain authentication for user %q", kubeconfigPath, cfg.NodeRegistration.Name) } // Update the client certificate and key of the node authorizer to point to the PEM symbolic link. info.ClientKeyData = []byte{} info.ClientCertificateData = []byte{} info.ClientKey = pemPath
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 10:54:51 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/kubelet/cm/dra/manager.go
// Add the prepared CDI devices to the claim info err := m.cache.withLock(func() error { info, exists := m.cache.get(claim.Name, claim.Namespace) if !exists { return fmt.Errorf("unable to get claim info for claim %s in namespace %s", claim.Name, claim.Namespace) } if err := info.setCDIDevices(pluginName, result.GetCDIDevices()); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:23:29 UTC 2024 - 19.4K bytes - Viewed (0) -
cmd/kubeadm/app/phases/etcd/local.go
klog.V(5).Infof("[etcd] member was already removed, because no member id exists for peer %s", etcdPeerAddress) return nil } return err } klog.V(1).Infof("[etcd] removing etcd member: %s, id: %d", etcdPeerAddress, id) members, err = etcdClient.RemoveMember(id) if err != nil { return err } klog.V(1).Infof("[etcd] Updated etcd member list: %v", members)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 14:07:27 UTC 2024 - 13.8K bytes - Viewed (1) -
pilot/cmd/pilot-agent/app/cmd.go
if err != nil { return fmt.Errorf("failed to get proxy config: %v", err) } if out, err := protomarshal.ToYAML(proxyConfig); err != nil { log.Infof("Failed to serialize to YAML: %v", err) } else { log.Infof("Effective config: %s", out) } secOpts, err := options.NewSecurityOptions(proxyConfig, proxyArgs.StsPort, proxyArgs.TokenManagerPlugin) if err != nil { return err
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0)