- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 79 for reopened (0.2 sec)
-
internal/http/server.go
// Double and clamp for next time. pollIntervalBase *= 2 if pollIntervalBase > shutdownPollIntervalMax { pollIntervalBase = shutdownPollIntervalMax } return interval } // Wait for opened connection to be closed up to Shutdown timeout. shutdownTimeout := srv.ShutdownTimeout shutdownTimer := time.NewTimer(shutdownTimeout) defer shutdownTimer.Stop() timer := time.NewTimer(nextPollInterval())
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// // This code is similar in spirit to io.Copy but it is only to be // used with DIRECT I/O based file descriptor and it is expected that // input writer *os.File not a generic io.Writer. Make sure to have // the file opened for writes with syscall.O_DIRECT flag. func CopyAligned(w io.Writer, r io.Reader, alignedBuf []byte, totalSize int64, file *os.File) (int64, error) { if totalSize == 0 { return 0, nil } var written int64
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
src/main/java/jcifs/SmbResource.java
* * The file locator provides details about * * @return the fileLocator */ SmbResourceLocator getLocator (); /** * The context this file was opened with * * @return the context associated with this file */ CIFSContext getContext (); /** * Returns the last component of the target URL. This will
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Dec 20 14:09:34 GMT 2020 - 26K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
* - Both request discover no existing connection. They both make a connection. * - The first request "wins the race". * - The second request discovers it "lost the race" and closes the connection it just opened. * - The second request uses the coalesced connection from request1. * - The coalesced connection is violently closed after servicing the first request.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
return "Files.asByteSource(" + file + ")"; } } /** * Returns a new {@link ByteSink} for writing bytes to the given file. The given {@code modes} * control how the file is opened for writing. When no mode is provided, the file will be * truncated before writing. When the {@link FileWriteMode#APPEND APPEND} mode is provided, writes * will append to the end of the file without truncating it. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 15 16:12:13 GMT 2024 - 33.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt
curtain she had not noticed before, and behind it was a little door about fifteen inches high: she tried the little golden key in the lock, and to her great delight it fitted! Alice opened the door and found that it led into a small passage, not much larger than a rat-hole: she knelt down and looked along the passage into the loveliest garden you ever saw.
Plain Text - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Oct 29 21:35:03 GMT 2012 - 145.2K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
if err != nil { return nil, err } desiredUIDs := sets.New(maps.Keys(pods)...) for _, entry := range entries { // we can't break here because we need to close all the netns we opened // plus we want to return whatever we can to the user. res, err := p.processEntry(p.proc, netnsObserved, desiredUIDs, entry) if err != nil { log.Debugf("error processing entry: %s %v", entry.Name(), err) continue
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
.github/workflows/build.yml
name: build on: push: branches: - master pull_request: types: [opened, labeled, unlabeled, synchronize] permissions: contents: read env: GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false" jobs: publish: runs-on: ubuntu-latest if: github.repository == 'square/okhttp' && github.ref == 'refs/heads/master' steps: - name: Checkout
Others - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 01:51:50 GMT 2024 - 17.2K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSource.java
* typically implemented by opening a reader using one of the methods in the first category, * doing something and finally closing the reader that was opened. * </ul> * * <p>Several methods in this class, such as {@link #readLines()}, break the contents of the source * into lines. Like {@link BufferedReader}, these methods break lines on any of {@code \n}, {@code
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 22.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* compacted by dropping redundant lines. A temporary file named "journal.tmp" will be used during * compaction; that file should be deleted if it exists when the cache is opened. */ private val journalFile: Path private val journalFileTmp: Path private val journalFileBackup: Path private var size: Long = 0L private var journalWriter: BufferedSink? = null
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0)