- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 183 for choosing (5 sec)
-
ReadMe.md
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Thu Apr 11 14:28:46 UTC 2024 - 8.7K bytes - Viewed (0) -
docs/distributed/DESIGN.md
> http://host2/export7 > http://host1/export8 > http://host2/export8 ``` *A noticeable trait of this expansion is that it chooses unique hosts such the setup provides maximum protection and availability.* - Choosing an erasure set for the object is decided during `PutObject()`, object names are used to find the right erasure set using the following pseudo code. ```go // hashes the key returning an integer.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 8K bytes - Viewed (0) -
src/internal/trace/testdata/fuzz/FuzzReader/closing-unknown-region
Carlos Amedee <******@****.***> 1715265901 -0400
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 240 bytes - Viewed (0) -
pkg/queue/instance.go
// the processing go routine should stop. func (q *queueImpl) get() (task *queueTask, shutdown bool) { q.cond.L.Lock() defer q.cond.L.Unlock() // wait for closing to be set, or a task to be pushed for !q.closing && len(q.tasks) == 0 { q.cond.Wait() } if q.closing && len(q.tasks) == 0 { // We must be shutting down. return nil, true } task = q.tasks[0]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0) -
src/net/file.go
func (f fileAddr) String() string { return string(f) } // FileConn returns a copy of the network connection corresponding to // the open file f. // It is the caller's responsibility to close f when finished. // Closing c does not affect f, and closing f does not affect c. func FileConn(f *os.File) (c Conn, err error) { c, err = fileConn(f) if err != nil { err = &OpError{Op: "file", Net: "file+net", Source: nil, Addr: fileAddr(f.Name()), Err: err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 09 06:14:44 UTC 2019 - 1.7K bytes - Viewed (0) -
src/internal/poll/fd_poll_js.go
"time" ) type pollDesc struct { fd *FD closing bool } func (pd *pollDesc) init(fd *FD) error { pd.fd = fd; return nil } func (pd *pollDesc) close() {} func (pd *pollDesc) evict() { pd.closing = true if pd.fd != nil { syscall.StopIO(pd.fd.Sysfd) } } func (pd *pollDesc) prepare(mode int, isFile bool) error { if pd.closing { return errClosing(isFile) } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:40 UTC 2023 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closeables.java
logger.log(Level.WARNING, "IOException thrown while closing Closeable.", e); } else { throw e; } } } /** * Closes the given {@link InputStream}, logging any {@code IOException} that's thrown rather than * propagating it. * * <p>While it's not safe in the general case to ignore exceptions that are thrown when closing an
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
src/net/rpc/client.go
client.mutex.Lock() client.shutdown = true closing := client.closing if err == io.EOF { if closing { err = ErrShutdown } else { err = io.ErrUnexpectedEOF } } for _, call := range client.pending { call.Error = err call.done() } client.mutex.Unlock() client.reqMutex.Unlock() if debugLog && err != io.EOF && !closing { log.Println("rpc: client protocol error:", err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
guava/src/com/google/common/io/Closeables.java
logger.log(Level.WARNING, "IOException thrown while closing Closeable.", e); } else { throw e; } } } /** * Closes the given {@link InputStream}, logging any {@code IOException} that's thrown rather than * propagating it. * * <p>While it's not safe in the general case to ignore exceptions that are thrown when closing an
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/service/DefaultServiceRegistryConcurrencyTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 4K bytes - Viewed (0)