- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 170 for strerror (0.16 sec)
-
pkg/controller/namespace/deletion/namespaced_resources_deleter_test.go
} scenarios := map[string]struct { testNamespace *v1.Namespace kubeClientActionSet sets.String metadataClientActionSet sets.String gvrError error expectErrorOnDelete error expectStatus *v1.NamespaceStatus }{ "pending-finalize": { testNamespace: testNamespacePendingFinalize, kubeClientActionSet: sets.NewString(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 07:34:23 UTC 2023 - 15.8K 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) -
cmd/object-lambda-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } // Check for auth type to return S3 compatible error. cred, _, s3Error := checkRequestAuthTypeCredential(ctx, r, policy.GetObjectAction) if s3Error != ErrNone { writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL) return } target, err := globalLambdaTargetList.Lookup(r.Form.Get("lambdaArn")) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10.2K bytes - Viewed (0) -
src/vendor/golang.org/x/crypto/cryptobyte/builder.go
func NewFixedBuilder(buffer []byte) *Builder { return &Builder{ result: buffer, fixedSize: true, } } // SetError sets the value to be returned as the error from Bytes. Writes // performed after calling SetError are ignored. func (b *Builder) SetError(err error) { b.err = err } // Bytes returns the bytes written by the builder or an error if one has // occurred during building.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 10 16:32:44 UTC 2023 - 9.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) -
src/main/assemblies/files/service.bat
set SERVICE_CMD=%1 shift if "x%1x" == "xx" goto checkServiceCmd set SERVICE_ID=%1 :checkServiceCmd if "%LOG_OPTS%" == "" set LOG_OPTS=--LogPath "%LOG_DIR%" --LogPrefix "%SERVICE_ID%" --StdError auto --StdOutput auto if /i %SERVICE_CMD% == install goto doInstall if /i %SERVICE_CMD% == remove goto doRemove if /i %SERVICE_CMD% == start goto doStart if /i %SERVICE_CMD% == stop goto doStop
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/ztypes_darwin_arm64.go
So_linger int16 So_state int16 So_pcb uint32 Xso_protocol int32 Xso_family int32 So_qlen int16 So_incqlen int16 So_qlimit int16 So_timeo int16 So_error uint16 So_pgid int32 So_oobmark uint32 So_rcv XSockbuf So_snd XSockbuf So_uid uint32 } type XSocket64 struct { Xso_len uint32 _ [8]byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 12.4K bytes - Viewed (0)