Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 271 - 280 of 500 for closer (0.04 seconds)

  1. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/util/KotlinSourceParser.kt

    class KotlinSourceParser {
    
        data class ParsedKotlinFiles(
    
            val ktFiles: List<KtFile>,
    
            private
            val disposable: Disposable
    
        ) : AutoCloseable {
    
            override fun close() {
                Disposer.dispose(disposable)
            }
        }
    
        private
        val messageCollector: MessageCollector
            get() = PrintingMessageCollector(System.out, MessageRenderer.PLAIN_RELATIVE_PATHS, false)
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Sep 16 08:22:33 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  2. misc/go_android_exec/main.go

    	args += "; echo -n " + exitStr + "$?"
    
    	cmd := adbCmd("exec-out", args)
    	cmd.Stdout = filter
    	// If the adb subprocess somehow hangs, go test will kill this wrapper
    	// and wait for our os.Stderr (and os.Stdout) to close as a result.
    	// However, if the os.Stderr (or os.Stdout) file descriptors are
    	// passed on, the hanging adb subprocess will hold them open and
    	// go test will hang forever.
    	//
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Aug 21 17:46:57 GMT 2023
    - 15.3K bytes
    - Click Count (0)
  3. cmd/config-common.go

    	if err != nil {
    		if isErrObjectNotFound(err) {
    			return nil, ObjectInfo{}, errConfigNotFound
    		}
    
    		return nil, ObjectInfo{}, err
    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Click Count (0)
  4. src/archive/tar/reader_test.go

    					t.Fatalf("obscuredtestdata.DecodeToTempFile(%s): %v", path, err)
    				}
    				path = tf
    			}
    
    			f, err := os.Open(path)
    			if err != nil {
    				t.Fatalf("unexpected error: %v", err)
    			}
    			defer f.Close()
    
    			var fr io.Reader = f
    			if strings.HasSuffix(v.file, ".bz2") || strings.HasSuffix(v.file, ".bz2.base64") {
    				fr = bzip2.NewReader(fr)
    			}
    
    			// Capture all headers and checksums.
    			var (
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Dec 15 16:34:13 GMT 2025
    - 47.5K bytes
    - Click Count (0)
  5. internal/s3select/jstream/scanner.go

    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    		var rpos int64 // total bytes read into buffer
    
    		defer func() {
    			atomic.StoreInt64(&sr.end, rpos)
    			close(sr.fillReady)
    		}()
    
    		for range sr.fillReq {
    		scan:
    			n, err := r.Read(sr.nbuf[:])
    
    			if n == 0 {
    				switch err {
    				case io.EOF: // reader is exhausted
    					return
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 23 19:35:41 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  6. src/cmd/addr2line/main.go

    	counter.CountFlags("addr2line/flag:", *flag.CommandLine)
    	if flag.NArg() != 1 {
    		usage()
    	}
    
    	f, err := objfile.Open(flag.Arg(0))
    	if err != nil {
    		log.Fatal(err)
    	}
    	defer f.Close()
    
    	tab, err := f.PCLineTable()
    	if err != nil {
    		log.Fatalf("reading %s: %v", flag.Arg(0), err)
    	}
    
    	stdin := bufio.NewScanner(os.Stdin)
    	stdout := bufio.NewWriter(os.Stdout)
    
    	for stdin.Scan() {
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Jun 21 19:58:04 GMT 2024
    - 2.4K bytes
    - Click Count (0)
  7. cmd/data-scanner_test.go

    	*/
    	lrObjInfos := slices.Clone(objInfos)
    	lrObjInfos[3].UserDefined = objRetentionMeta
    	var lrWants []ObjectInfo
    	lrWants = append(lrWants, lrObjInfos[:4]...)
    
    	/*
    		replObjInfos: objInfos with following modifications
    		version stack for obj-1
    		v1 uuid-1 modTime -4m	"VersionPurgeStatus: replication.VersionPurgePending"
    	*/
    	replObjInfos := slices.Clone(objInfos)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  8. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/ContainerCapsule.java

         */
        @Nonnull
        Optional<ClassLoader> currentThreadClassLoader();
    
        /**
         * Performs a clean shutdown of backing container.
         */
        @Override
        void close() throws Exception;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jan 31 20:56:58 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

            doExecute(session, mojoExecution, dependencyContext);
        }
    
        protected static class NoLock implements NoExceptionCloseable {
            public NoLock() {}
    
            @Override
            public void close() {}
        }
    
        /**
         * Aggregating mojo executions (possibly) modify all MavenProjects, including those that are currently in use
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Jun 12 14:55:55 GMT 2025
    - 21K bytes
    - Click Count (0)
  10. 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()
    	defer direntPool.Put(bufp)
    	buf := *bufp
    
    	boff := 0 // starting read position in buf
    	nbuf := 0 // end valid data in buf
    
    	for {
    		if boff >= nbuf {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.3K bytes
    - Click Count (0)
Back to Top