- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 3,379 for FClose (0.14 sec)
-
src/net/nss.go
if len(srcs) > 0 && srcs[0] == '[' { bclose := bytealg.IndexByteString(srcs, ']') if bclose == -1 { conf.err = errors.New("unclosed criterion bracket") return conf } var err error criteria, err = parseCriteria(srcs[1:bclose]) if err != nil { conf.err = errors.New("invalid criteria: " + srcs[1:bclose]) return conf } srcs = srcs[bclose+1:] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 15 20:15:51 UTC 2022 - 5.5K bytes - Viewed (0) -
pkg/kubelet/logs/container_log_manager.go
sort.Strings(inuse) return append(inuse, log), nil } // compressReadCloser wraps gzip.Reader with a function to close file handler. type compressReadCloser struct { f *os.File *gzip.Reader } func (rc *compressReadCloser) Close() error { ferr := rc.f.Close() rerr := rc.Reader.Close() if ferr != nil { return ferr } if rerr != nil { return rerr } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 15K bytes - Viewed (0) -
src/runtime/crash_unix_test.go
cmd.Stderr = &outbuf rp, wp, err := os.Pipe() if err != nil { t.Fatal(err) } defer rp.Close() cmd.ExtraFiles = []*os.File{wp} if err := cmd.Start(); err != nil { wp.Close() t.Fatalf("starting program: %v", err) } if err := wp.Close(); err != nil { t.Logf("closing write pipe: %v", err) } if _, err := rp.Read(make([]byte, 1)); err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 12 20:11:47 UTC 2023 - 9.2K bytes - Viewed (0) -
src/net/http/serve_test.go
go func() { server.Serve(cl) sdone <- true }() time.Sleep(10 * time.Millisecond) server.Shutdown(context.Background()) ln.Close() <-sdone nclose := atomic.LoadInt32(&cl.closes) if nclose != 1 { t.Errorf("Close calls = %v; want 1", nclose) } } // Issue 20239: don't block in Serve if Shutdown is called first. func TestServerShutdownThenServe(t *testing.T) { var srv Server
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/runtime/select.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 13 21:36:04 UTC 2024 - 15K bytes - Viewed (0) -
src/cmd/compile/internal/typecheck/universe.go
okforlen [types.NTYPE]bool okforarith [types.NTYPE]bool ) var builtinFuncs = [...]struct { name string op ir.Op }{ {"append", ir.OAPPEND}, {"cap", ir.OCAP}, {"clear", ir.OCLEAR}, {"close", ir.OCLOSE}, {"complex", ir.OCOMPLEX}, {"copy", ir.OCOPY}, {"delete", ir.ODELETE}, {"imag", ir.OIMAG}, {"len", ir.OLEN}, {"make", ir.OMAKE}, {"max", ir.OMAX}, {"min", ir.OMIN}, {"new", ir.ONEW},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 05 15:20:28 UTC 2023 - 4.7K bytes - Viewed (0) -
src/cmd/compile/internal/types2/universe.go
name string nargs int variadic bool kind exprKind }{ _Append: {"append", 1, true, expression}, _Cap: {"cap", 1, false, expression}, _Clear: {"clear", 1, false, statement}, _Close: {"close", 1, false, statement}, _Complex: {"complex", 2, false, expression}, _Copy: {"copy", 2, false, statement}, _Delete: {"delete", 2, false, statement}, _Imag: {"imag", 1, false, expression},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 9.1K bytes - Viewed (0) -
src/go/types/universe.go
name string nargs int variadic bool kind exprKind }{ _Append: {"append", 1, true, expression}, _Cap: {"cap", 1, false, expression}, _Clear: {"clear", 1, false, statement}, _Close: {"close", 1, false, statement}, _Complex: {"complex", 2, false, expression}, _Copy: {"copy", 2, false, statement}, _Delete: {"delete", 2, false, statement}, _Imag: {"imag", 1, false, expression},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 07 20:08:23 UTC 2024 - 9.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
type kubeController struct { MeshServiceController *aggregate.Controller *Controller workloadEntryController *serviceentry.Controller stop chan struct{} } func (k *kubeController) Close() { close(k.stop) clusterID := k.Controller.clusterID k.MeshServiceController.UnRegisterHandlersForCluster(clusterID) k.MeshServiceController.DeleteRegistry(clusterID, provider.Kubernetes) if k.workloadEntryController != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
src/time/tick_test.go
// With the fix, the code runs in under a second. done := make(chan bool) AfterFunc(60*Second, func() { close(done) }) // Set up a queuing goroutine to ping pong through the scheduler. inQ := make(chan func()) outQ := make(chan func()) defer close(inQ) wg.Add(1) go func() { defer wg.Done() defer close(outQ) var q []func() for { var sendTo chan func() var send func()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0)