- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 48 for strerror (0.14 sec)
-
cmd/kubeadm/app/phases/addons/proxy/proxy_test.go
name string simError SimulatedError expErrString string expBindAddr string expClusterCIDR string }{ { name: "Successful proxy addon", simError: NoError, expErrString: "", expBindAddr: "0.0.0.0", expClusterCIDR: "5.6.7.8/24", }, { name: "Simulated service account error", simError: ServiceAccountError,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 8.7K bytes - Viewed (0) -
src/encoding/gob/encoder.go
func (enc *Encoder) pushWriter(w io.Writer) { enc.w = append(enc.w, w) } // popWriter pops the innermost writer. func (enc *Encoder) popWriter() { enc.w = enc.w[0 : len(enc.w)-1] } func (enc *Encoder) setError(err error) { if enc.err == nil { // remember the first. enc.err = err } } // writeMessage sends the data item preceded by an unsigned count of its length.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 7.8K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_send_device_context.cc
return; } status = stream_->RecordEvent(done_event_.get().get()); if (!status.ok()) { done(status); return; } if (auto st = stream_->BlockHostUntilDone(); !st.ok()) { done_event_.SetError(absl::InternalError(absl::StrFormat( "failed to synchronize send operation with a stream: %s", st.ToString()))); return; } done_event_.SetStateConcrete(); done(absl::OkStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 1.6K bytes - Viewed (0) -
src/syscall/net_fake.go
) const ( IPPROTO_IP = 0 IPPROTO_IPV4 = 4 IPPROTO_IPV6 = 0x29 IPPROTO_TCP = 6 IPPROTO_UDP = 0x11 ) const ( SOMAXCONN = 0x80 ) const ( _ = iota IPV6_V6ONLY SO_ERROR ) // Misc constants expected by package net but not supported. const ( _ = iota F_DUPFD_CLOEXEC SYS_FCNTL = 500 // unsupported ) type Sockaddr any type SockaddrInet4 struct { Port int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 883 bytes - Viewed (0) -
security/pkg/server/ca/fuzz_test.go
) func FuzzCreateCertificate(f *testing.F) { fuzz.Fuzz(f, func(fg fuzz.Helper) { csr := fuzz.Struct[pb.IstioCertificateRequest](fg) ca := fuzz.Struct[mockca.FakeCA](fg) ca.SignErr = caerror.NewError(caerror.CSRError, fmt.Errorf("cannot sign")) server := &Server{ ca: &ca, Authenticators: []security.Authenticator{&mockAuthenticator{}}, monitoring: newMonitoringMetrics(), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Sep 15 21:32:54 UTC 2022 - 1.3K bytes - Viewed (0) -
src/net/fd_unix.go
// non-blocking socket under Unix variants does not // necessarily result in earlier errors being // returned. Instead, once runtime-integrated network // poller tells us that the socket is ready, get the // SO_ERROR socket option to see if the connection // succeeded or failed. See issue 7474 for further // details. if err := fd.pfd.WaitWrite(); err != nil { select { case <-ctxDone:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_host_recv_device_context.cc
return; } status = stream_->RecordEvent(done_event_.get().get()); if (!status.ok()) { done(status); return; } if (auto st = stream_->BlockHostUntilDone(); !st.ok()) { done_event_.SetError(absl::InternalError(absl::StrFormat( "failed to synchronize send operation with a stream: %s", st.ToString()))); return; } done_event_.SetStateConcrete(); done(absl::OkStatus()); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 17 22:46:36 UTC 2024 - 1.9K bytes - Viewed (0) -
security/pkg/pki/ra/k8s_ra.go
} if possibleRootCert == nil { return nil, raerror.NewError(raerror.CSRError, fmt.Errorf("failed to find root cert from either signed cert-chain or mesh config")) } if verifyErr := util.VerifyCertificate(nil, cert, possibleRootCert, nil); verifyErr != nil { return nil, raerror.NewError(raerror.CSRError, fmt.Errorf("root cert from signed cert-chain is invalid (%v)", verifyErr)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 02 14:34:38 UTC 2023 - 7.2K bytes - Viewed (0) -
pkg/registry/registrytest/node.go
Items: make([]api.Node, len(nodes)), } for i := range nodes { list.Items[i].Name = nodes[i] list.Items[i].Status.Capacity = nodeResources } return &list } func (r *NodeRegistry) SetError(err error) { r.Lock() defer r.Unlock() r.Err = err } func (r *NodeRegistry) ListNodes(ctx context.Context, options *metainternalversion.ListOptions) (*api.NodeList, error) { r.Lock() defer r.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 23:13:50 UTC 2024 - 2.8K bytes - Viewed (0) -
pkg/registry/registrytest/service.go
mu sync.Mutex List api.ServiceList Service *api.Service Updates []api.Service Err error DeletedID string GottenID string UpdatedID string } func (r *ServiceRegistry) SetError(err error) { r.mu.Lock() defer r.mu.Unlock() r.Err = err } func (r *ServiceRegistry) ListServices(ctx context.Context, options *metainternalversion.ListOptions) (*api.ServiceList, error) { r.mu.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.9K bytes - Viewed (0)