- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 108 for choosing (0.52 sec)
-
src/runtime/mfinal.go
// descriptor, and if the last use of p in a function is a call to // syscall.Write(p.d, buf, size), then p may be unreachable as soon as // the program enters [syscall.Write]. The finalizer may run at that moment, // closing p.d, causing syscall.Write to fail because it is writing to // a closed file descriptor (or, worse, to an entirely different // file descriptor opened by a different goroutine). To avoid this problem,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
src/internal/coverage/cfile/testsupport.go
} // Emit text output. if tf != nil { if err := ts.cf.EmitTextual(tf); err != nil { return err } tfClosed = true if err := tf.Close(); err != nil { return fmt.Errorf("closing %s: %v", cfile, err) } } return nil } type tstate struct { calloc.BatchCounterAlloc cm *cmerge.Merger cf *cformat.Formatter cmode coverage.CounterMode }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 8.7K bytes - Viewed (0) -
src/testing/fstest/testfs.go
return } // Check that close does not report an error. if err := d.Close(); err != nil { t.errorf("%s: Close: %w", dir, err) } // Check that closing twice doesn't crash. // The return value doesn't matter. d.Close() // Reopen directory, read a second time, make sure contents match. if d = t.openDir(dir); d == nil { return } defer d.Close()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
src/net/http/h2_bundle.go
type http2ClientConnState struct { // Closed is whether the connection is closed. Closed bool // Closing is whether the connection is in the process of // closing. It may be closing due to shutdown, being a // single-use connection, being marked as DoNotReuse, or // having received a GOAWAY frame. Closing bool // StreamsActive is how many streams are active. StreamsActive int
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
security/pkg/k8s/chiron/utils_test.go
t.Fatalf("error to get the server 2 port: %v", err) } // Server 1 should be reachable, since it is not closed. if !isTCPReachable(host, port1) { t.Fatal("server 1 is unreachable") } // After closing server 2, server 2 should not be reachable server2.httpServer.Close() if isTCPReachable(host, port2) { t.Fatal("server 2 is reachable") } } func TestSubmitCSR(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 03:58:11 UTC 2024 - 13K bytes - Viewed (0) -
src/net/http/transport.go
// // Zero means no limit. MaxConnsPerHost int // IdleConnTimeout is the maximum amount of time an idle // (keep-alive) connection will remain idle before closing // itself. // Zero means no limit. IdleConnTimeout time.Duration // ResponseHeaderTimeout, if non-zero, specifies the amount of // time to wait for a server's response headers after fully
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 91K bytes - Viewed (0) -
src/cmd/cover/cover.go
f.addCounters(clause.Colon+1, clause.Colon+1, clause.End(), clause.Body, false) } return f } } f.addCounters(n.Lbrace, n.Lbrace+1, n.Rbrace+1, n.List, true) // +1 to step past closing brace. case *ast.IfStmt: if n.Init != nil { ast.Walk(f, n.Init) } ast.Walk(f, n.Cond) ast.Walk(f, n.Body) if n.Else == nil { return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 34.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
HealthChecks []healthz.HealthChecker // EncryptionFileContentHash is the hash of the encryption config file. EncryptionFileContentHash string // KMSCloseGracePeriod is the duration we will wait before closing old transformers. // We wait for any in-flight requests to finish by using the duration which is longer than their timeout. KMSCloseGracePeriod time.Duration }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
blockedWatchers []*cacheWatcher // watchersToStop is a list of watchers that were supposed to be stopped // during current dispatching, but stopping was deferred to the end of // dispatching that event to avoid race with closing channels in watchers. watchersToStop []*cacheWatcher // Maintain a timeout queue to send the bookmark event before the watcher times out. // Note that this field when accessed MUST be protected by the Cacher.lock.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/sftp-server-driver.go
switch { case len(w.buffer) > 0: err = errors.New("some file segments were not flushed from the queue") _ = w.w.CloseWithError(err) case w.err != nil: // No need to close here since both pipes were // closing inside TransferError() err = w.err default: err = w.w.Close() } for i := range w.buffer { delete(w.buffer, i) } w.wg.Wait() return err } type writerAt struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 05 07:51:13 UTC 2024 - 11.1K bytes - Viewed (0)