Search Options

Results per page
Sort
Preferred Languages
Advance

Results 611 - 620 of 977 for close1 (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. .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)
  6. 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)
  7. 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 &lt;- 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)
  8. 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)
  9. 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)
  10. 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)
Back to top