Search Options

Results per page
Sort
Preferred Languages
Advance

Results 581 - 590 of 1,639 for dead (0.02 sec)

  2. github.com/minio/minio

    cmd/xl-storage-disk-id-check.go 

    type diskHealthWrapper struct {
	tracker *healthDiskCtxValue
	r       io.Reader
	w       io.Writer
}

func (d *diskHealthWrapper) Read(p []byte) (int, error) {
	if d.r == nil {
		return 0, fmt.Errorf("diskHealthWrapper: Read with no reader")
	}
	n, err := d.r.Read(p)
	if err == nil || err == io.EOF && n > 0 {
		d.tracker.logSuccess()
	}
	return n, err
}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  3. github.com/tiangolo/fastapi

    docs/en/docs/advanced/events.md 

    The same models are shared among requests, so, it's not one model per request, or one per user or something similar.

Let's imagine that loading the model can **take quite some time**, because it has to read a lot of **data from disk**. So you don't want to do it for every request.
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  4. github.com/codelibs/fess

    src/main/webapp/WEB-INF/view/login/newpassword.jsp 

    <%@page pageEncoding="UTF-8" contentType="text/html; charset=UTF-8"%><!DOCTYPE html>
${fe:html(true)}
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<title><la:message key="labels.login.title" /></title>
<link href="${fe:url('/css/admin/bootstrap.min.css')}" rel="stylesheet" type="text/css" />
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 13 05:54:52 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  5. github.com/codelibs/jcifs

    src/main/java/jcifs/smb/SmbTransportImpl.java 

            /*
         * Note the Transport thread isn't running yet so we can
         * read from the socket here.
         */
        try {
            this.socket.setSoTimeout(this.transportContext.getConfig().getConnTimeout());
            if (peekKey() == null) { /* try to read header */
                throw new IOException("transport closed in negotiate");
            }
        } finally {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
  6. github.com/codelibs/jcifs

    src/test/java/jcifs/smb1/smb1/SmbComOpenAndXResponseTest.java 

        }

    @Test
    void testReadParameterWordsWireFormat() {
        byte[] buffer = new byte[1024];
        int result = response.readParameterWordsWireFormat(buffer, 0);

        // The method should read parameter words
        assertTrue(result >= 0, "readParameterWordsWireFormat should return non-negative value");
    }

    @Test
    void testWriteBytesWireFormat() {
        byte[] dst = new byte[1024];
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  7. github.com/apache/maven

    impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/TransformerSupport.java 

        protected static final String SCHEMA_LOCATION_FORMAT = "https://maven.apache.org/xsd/maven-%s.xsd";

    protected Model read(Path src) throws IOException, XMLStreamException {
        try (InputStream is = Files.newInputStream(src)) {
            return new MavenStaxReader().read(is, false, null);
        }
    }

    protected void write(Model model, Path dest) throws IOException, XMLStreamException {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Nov 06 18:32:25 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  8. github.com/codelibs/jcifs

    src/test/java/jcifs/util/transport/TransportTest.java 

                InputStream is = new ByteArrayInputStream("Hi".getBytes());
            byte[] buffer = new byte[10];

            Transport.readn(is, buffer, 0, 2); // Read all
            int bytesRead = Transport.readn(is, buffer, 0, 5); // Try to read more
            assertEquals(0, bytesRead);
        }
    }

    @Nested
    @DisplayName("Resource management tests")
    class ResourceManagementTests {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  9. github.com/apache/maven

    compat/maven-settings-builder/src/main/java/org/apache/maven/settings/building/DefaultSettingsBuilder.java 

                try {
                settings = settingsReader.read(settingsSource.getInputStream(), options);
            } catch (SettingsParseException e) {
                options = Collections.singletonMap(SettingsReader.IS_STRICT, Boolean.FALSE);

                settings = settingsReader.read(settingsSource.getInputStream(), options);

                problems.add(
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jul 23 17:27:08 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  10. github.com/tiangolo/fastapi

    docs/en/docs/reference/apirouter.md 

        options:
        members:
            - websocket
            - include_router
            - get
            - put
            - post
            - delete
            - options
            - head
            - patch
            - trace
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 524 bytes
    - Viewed (0)
  11. github.com/google/guava

    android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java 

      private ExecutionSequencer() {}

  /** Creates a new instance. */
  public static ExecutionSequencer create() {
    return new ExecutionSequencer();
  }

  /** This reference acts as a pointer tracking the head of a linked list of ListenableFutures. */
  private final AtomicReference<ListenableFuture<@Nullable Void>> ref =
      new AtomicReference<>(immediateVoidFuture());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top