Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 1,164 for dead (0.01 seconds)

  1. internal/http/request-recorder.go

    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    // Read reads from the internal reader and counts/save the body in the memory
    func (r *RequestRecorder) Read(p []byte) (n int, err error) {
    	n, err = r.Reader.Read(p)
    	r.bytesRead += n
    
    	if r.LogBody {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 12 21:37:19 GMT 2023
    - 1.8K bytes
    - Click Count (0)
  2. impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java

                return !(isLocal(url.getHost()) || url.getProtocol().equals("file"));
            } catch (MalformedURLException e) {
                // bad url just skip it here. It should have been validated already, but the wagon lookup will deal with it
                return false;
            }
        }
    
        private static boolean isLocal(String host) {
            return "localhost".equals(host) || "127.0.0.1".equals(host);
        }
    
        /**
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Feb 07 00:45:02 GMT 2025
    - 33.5K bytes
    - Click Count (0)
  3. compat/maven-embedder/src/main/java/org/apache/maven/cli/internal/extension/model/io/xpp3/CoreExtensionsXpp3Reader.java

         * any.
         * @return CoreExtensions
         */
        public CoreExtensions read(Reader reader) throws IOException, XmlPullParserException {
            return read(reader, true);
        } // -- CoreExtensions read( Reader )
    
        /**
         * Method read.
         *
         * @param in a in object.
         * @param strict a strict object.
         * @throws IOException IOException if any.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Mon Oct 27 13:24:03 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  4. samples/guide/src/main/java/okhttp3/recipes/Progress.java

          return new ForwardingSource(source) {
            long totalBytesRead = 0L;
    
            @Override public long read(Buffer sink, long byteCount) throws IOException {
              long bytesRead = super.read(sink, byteCount);
              // read() returns the number of bytes read, or -1 if this source is exhausted.
              totalBytesRead += bytesRead != -1 ? bytesRead : 0;
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Jan 12 03:31:36 GMT 2019
    - 3.9K bytes
    - Click Count (0)
  5. docs/en/docs/tutorial/sql-databases.md

    ### Read Heroes { #read-heroes }
    
    We can **read** `Hero`s from the database using a `select()`. We can include a `limit` and `offset` to paginate the results.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[48:55] hl[51:52,54] *}
    
    ### Read One Hero { #read-one-hero }
    
    We can **read** a single `Hero`.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Tue Dec 02 05:06:56 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  6. cmd/perf-tests.go

    }
    
    type firstByteRecorder struct {
    	t *time.Time
    	r io.Reader
    }
    
    func (f *firstByteRecorder) Read(p []byte) (n int, err error) {
    	if f.t != nil || len(p) == 0 {
    		return f.r.Read(p)
    	}
    	// Read a single byte.
    	n, err = f.r.Read(p[:1])
    	if n > 0 {
    		t := time.Now()
    		f.t = &t
    	}
    	return n, err
    }
    
    // Runs the speedtest on local MinIO process.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  7. internal/s3select/simdj/reader.go

    	err          *error
    	readCloser   io.ReadCloser
    	onReaderExit func()
    
    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    			return nil, errJSONParsingError(*r.err)
    		}
    		return nil, io.EOF
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/io/CharSourceTest.java

        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertEquals(STRING, writer.toString());
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/MultiInputStream.java

      }
    
      @Override
      public int read() throws IOException {
        while (in != null) {
          int result = in.read();
          if (result != -1) {
            return result;
          }
          advance();
        }
        return -1;
      }
    
      @Override
      public int read(byte[] b, int off, int len) throws IOException {
        checkNotNull(b);
        while (in != null) {
          int result = in.read(b, off, len);
          if (result != -1) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  10. impl/maven-core/src/main/java/org/apache/maven/project/MavenProject.java

        }
    
        // TODO let the scope handler deal with this
        private static boolean isCompilePathElement(final String scope) {
            return Artifact.SCOPE_COMPILE.equals(scope)
                    || Artifact.SCOPE_PROVIDED.equals(scope)
                    || Artifact.SCOPE_SYSTEM.equals(scope);
        }
    
        // TODO let the scope handler deal with this
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Aug 29 12:47:20 GMT 2025
    - 67K bytes
    - Click Count (0)
Back to Top