- Sort Score
- Result 10 results
- Languages All
Results 611 - 620 of 977 for close1 (0.12 sec)
-
cmd/os_unix.go
fd, err = openFileWithFD(dirPath, os.O_RDONLY, 0o666) if err != nil { if osErrToFileErr(err) == errFileNotFound { return nil } return osErrToFileErr(err) } } defer syscall.Close(fd) bufp := direntPool.Get().(*[]byte) defer direntPool.Put(bufp) buf := *bufp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf for { if boff >= nbuf {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.3K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/superpom/SuperPomProvider.java
/** * Gets the super POM for the specified model version. The returned model is supposed to be read-only, i.e. if the * caller intends to make updates to the model the return value must be cloned before updating to ensure the * modifications don't affect future retrievals of the super POM. * * @param version The model version to retrieve the super POM for (e.g. "4.0.0"), must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.6K bytes - Viewed (0) -
src/test/java/org/codelibs/curl/io/IOIntegrationTest.java
req.execute(res -> { logger.info("Processing request. Number of temp files: " + countTmpFiles()); }, e -> {}); long after = countTmpFiles(); logger.info("After close response. Number of temp files: " + after); // ## Assert ## assertEquals(before, after); } private long countTmpFiles() {
Registered: Thu Oct 31 02:32:13 UTC 2024 - Last Modified: Mon Nov 14 21:05:19 UTC 2022 - 3.4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/create/Smb2CloseResponse.java
bufferIndex += 8; this.fileAttributes = SMBUtil.readInt4(buffer, bufferIndex); bufferIndex += 4; if ( log.isDebugEnabled() ) { log.debug(String.format("Closed %s (%s)", Hexdump.toHexString(this.fileId), this.fileName)); } return bufferIndex - start; }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5.5K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
/kind api-change /kind deprecation /kind failing-test /kind flake /kind regression --> #### What this PR does / why we need it: #### Which issue(s) this PR fixes: <!-- *Automatically closes linked issue when PR is merged. Usage: `Fixes #<issue number>`, or `Fixes (paste link of issue)`. _If PR is about `failing-tests or flakes`, please post the related issues/tests in a comment and do not use `Fixes`_* --> Fixes #
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Sun Aug 01 08:59:21 UTC 2021 - 2.8K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
f, err := os.OpenFile(filePath, os.O_WRONLY|os.O_SYNC, 0) if err != nil { t.Fatalf("Failed to open %s: %s\n", filePath, err) } f.WriteString("oops") // Will cause bitrot error f.Close() break } } rQuorum := len(errs) - z.serverPools[0].sets[0].defaultParityCount onlineDisks, modTime, _ := listOnlineDisks(erasureDisks, partsMetadata, test.errs, rQuorum)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0) -
doc/go_mem.html
the <code>print</code>. </p> <p class="rule"> The closing of a channel is synchronized before a receive that returns a zero value because the channel is closed. </p> <p> In the previous example, replacing <code>c <- 0</code> with <code>close(c)</code> yields a program with the same guaranteed behavior. </p> <p class="rule"> A receive from an unbuffered channel is synchronized before the completion of
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
cmd/post-policy_test.go
} // Set the File formData writer, err := w.CreateFormFile("file", "upload.txt") if err != nil { // return nil, err return nil, err } writer.Write([]byte("hello world")) // Close before creating the new request. w.Close() // Set the body equal to the created policy. reader := bytes.NewReader(buf.Bytes()) req, err := http.NewRequest(http.MethodPost, makeTestTargetURL(endPoint, bucketName, "", nil), reader)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
docs/debugging/healing-bin/main.go
if strings.HasSuffix(file, ".zip") { var sz int64 f, err := os.Open(file) if err != nil { return err } if st, err := f.Stat(); err == nil { sz = st.Size() } defer f.Close() zr, err := zip.NewReader(f, sz) if err != nil { return err } for _, file := range zr.File { if !file.FileInfo().IsDir() && strings.HasSuffix(file.Name, ".healing.bin") { r, err := file.Open()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.2K bytes - Viewed (0) -
tensorflow/c/eager/abstract_operation.h
// it will be compatible with it: the name will be updated by device placement // logic to refer to the specific device chosen. // // Example: If one calls `op->SetDeviceName("/device:GPU")`, the value // returned by DeviceName should be "/device:GPU:*" until a particular GPU is // chosen for the operation by the device placement logic in the // executor. After that, the value returned by DeviceName will be a full
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 7.3K bytes - Viewed (0)