Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 2,175 for close1 (0.29 sec)

  1. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/IoActions.java

            return result;
        }
    
        /**
         * Closes the given resource rethrowing any {@link IOException} as a {@link UncheckedIOException}.
         *
         * @param resource The resource to be closed
         */
        public static void uncheckedClose(@Nullable Closeable resource) {
            try {
                if (resource != null) {
                    resource.close();
                }
            } catch (IOException e) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  2. internal/s3select/simdj/reader.go

    	if !ok {
    		dstRec = &Record{}
    	}
    	dstRec.object = v
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *Reader) Close() error {
    	// Close the input.
    	// Potentially racy if the stream decoder is still reading.
    	if r.readCloser != nil {
    		r.readCloser.Close()
    	}
    	if r.exitReader != nil {
    		close(r.exitReader)
    		r.readerWg.Wait()
    		r.exitReader = nil
    		r.input = nil
    	}
    	return nil
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 30 17:02:22 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  3. platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LineBufferingOutputStream.java

        }
    
        /**
         * Closes this output stream and releases any system resources associated with this stream. The general contract of
         * <code>close</code> is that it closes the output stream. A closed stream cannot perform output operations and
         * cannot be reopened.
         */
        @Override
        public void close() throws IOException {
            hasBeenClosed = true;
            flush();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 12 08:51:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  4. src/cmd/internal/bio/must.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package bio
    
    import (
    	"io"
    	"log"
    )
    
    // MustClose closes Closer c and calls log.Fatal if it returns a non-nil error.
    func MustClose(c io.Closer) {
    	if err := c.Close(); err != nil {
    		log.Fatal(err)
    	}
    }
    
    // MustWriter returns a Writer that wraps the provided Writer,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 14 17:58:33 UTC 2016
    - 883 bytes
    - Viewed (0)
  5. platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/MultiProcessSafeIndexedCacheTest.groovy

            1 * backingCache.close()
            0 * _._
        }
    
        def "closes cache when closed"() {
            given:
            cacheOpened()
    
            when:
            cache.finishWork()
    
            then:
            1 * fileAccess.writeFile(!null) >> { Runnable action -> action.run() }
            1 * backingCache.close()
            0 * _._
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:50 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  6. src/io/pipe_test.go

    		want := tt.err
    		if want == nil {
    			want = EOF
    		}
    		if err != want {
    			t.Errorf("read from closed pipe: %v want %v", err, want)
    		}
    		if n != 0 {
    			t.Errorf("read on closed pipe returned %d", n)
    		}
    		if err = r.Close(); err != nil {
    			t.Errorf("r.Close: %v", err)
    		}
    	}
    }
    
    // Test close on Read side during Read.
    func TestPipeReadClose2(t *testing.T) {
    	c := make(chan int, 1)
    	r, _ := Pipe()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. subprojects/core/src/main/java/org/gradle/util/internal/DisconnectableInputStream.java

            }
        }
    
        /**
         * Closes this {@code InputStream} for reading. Any threads blocked in read() will receive an end-of-stream. Also requests that the
         * reader thread stop reading, if possible, but does not block waiting for this to happen.
         *
         * <p>NOTE: this method does not close the source input stream.</p>
         */
        @Override
        public void close() throws IOException {
            lock.lock();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed Apr 07 08:18:46 UTC 2021
    - 6.5K bytes
    - Viewed (0)
  8. src/internal/xcoff/ar.go

    	}
    	arch, err := NewArchive(f)
    	if err != nil {
    		f.Close()
    		return nil, err
    	}
    	arch.closer = f
    	return arch, nil
    }
    
    // Close closes the Archive.
    // If the Archive was created using NewArchive directly instead of OpenArchive,
    // Close has no effect.
    func (a *Archive) Close() error {
    	var err error
    	if a.closer != nil {
    		err = a.closer.Close()
    		a.closer = nil
    	}
    	return err
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 04 17:32:51 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. src/unique/clone.go

    	"unsafe"
    )
    
    // clone makes a copy of value, and may update string values found in value
    // with a cloned version of those strings. The purpose of explicitly cloning
    // strings is to avoid accidentally giving a large string a long lifetime.
    //
    // Note that this will clone strings in structs and arrays found in value,
    // and will clone value if it itself is a string. It will not, however, clone
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun May 05 00:24:21 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  10. src/cmd/go/internal/lockedfile/lockedfile.go

    	return OpenFile(name, os.O_RDWR|os.O_CREATE, 0666)
    }
    
    // Close unlocks and closes the underlying file.
    //
    // Close may be called multiple times; all calls after the first will return a
    // non-nil error.
    func (f *File) Close() error {
    	if f.closed {
    		return &fs.PathError{
    			Op:   "close",
    			Path: f.Name(),
    			Err:  fs.ErrClosed,
    		}
    	}
    	f.closed = true
    
    	err := closeFile(f.osFile.File)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 20 18:41:18 UTC 2020
    - 5.1K bytes
    - Viewed (0)
Back to top