Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 1,261 for closer (0.05 seconds)

  1. internal/lock/lock_test.go

    	}
    
    	// Decrease reference count by 1.
    	if err = rlk.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	isClosed = rlk.IsClosed()
    	if isClosed {
    		t.Fatal("File ref count shouldn't be zero")
    	}
    
    	// Decrease reference count by 1.
    	if err = rlk.Close(); err != nil {
    		t.Fatal(err)
    	}
    
    	// Now file should be closed.
    	isClosed = rlk.IsClosed()
    	if !isClosed {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

        return writer
      }
    
      /**
       * Shortens the last frame from its original length to `length`. This will cause the peer to
       * close the socket as soon as this frame has been written; otherwise the peer stays open until
       * explicitly closed.
       */
      fun truncateLastFrame(length: Int): Http2Writer {
        val lastFrame = outFrames.removeAt(outFrames.size - 1)
        require(length < bytesOut.size - lastFrame.start)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 8.7K bytes
    - Click Count (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc4ConnectionMonitorTarget.java

                logger.warn("clientConnectionManager is null.");
                return;
            }
    
            try {
                // Close expired connections
                clientConnectionManager.closeExpiredConnections();
                // Close idle connections
                clientConnectionManager.closeIdleConnections(idleConnectionTimeout, TimeUnit.MILLISECONDS);
            } catch (final Exception e) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jan 04 13:09:59 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/io/CharSourceTest.java

      }
    
      public void testCopyToAppendable_doesNotCloseIfWriter() throws IOException {
        TestWriter writer = new TestWriter();
        assertFalse(writer.closed());
        source.copyTo(writer);
        assertFalse(writer.closed());
      }
    
      public void testClosesOnErrors_copyingToCharSinkThatThrows() {
        for (TestOption option : EnumSet.of(OPEN_THROWS, WRITE_THROWS, CLOSE_THROWS)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 11.6K bytes
    - Click Count (0)
  5. tests/prepared_stmt_test.go

    	}
    	pdb.Mux.Unlock()
    
    	pdb.Close()
    	pdb.Mux.Lock()
    	defer pdb.Mux.Unlock()
    	if len(pdb.Stmts.Keys()) != 0 {
    		t.Fatalf("prepared stmt should be empty")
    	}
    }
    
    func isUsingClosedConnError(err error) bool {
    	// https://github.com/golang/go/blob/e705a2d16e4ece77e08e80c168382cdb02890f5b/src/database/sql/sql.go#L2717
    	return err.Error() == "sql: statement is closed"
    }
    
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/core/sql/ResultSetUtil.java

         */
        protected ResultSetUtil() {
        }
    
        /**
         * Closes the result set.
         * <p>
         * If {@link ResultSet#close()} throws an exception, an error message is logged. The exception is not rethrown.
         * </p>
         *
         * @param resultSet
         *            The result set
         */
        public static void close(final ResultSet resultSet) {
            if (resultSet == null) {
                return;
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  7. docs/metrics/prometheus/grafana/replication/minio-replication-cluster.json

          "5m",
          "15m",
          "1h",
          "6h",
          "12h",
          "24h",
          "2d",
          "7d",
          "30d"
        ]
      },
      "timezone": "",
      "title": "MinIO Cluster Replication Dashboard",
      "uid": "TgmJnnqnk3",
      "version": 1,
      "weekStart": ""
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Aug 04 01:46:49 GMT 2025
    - 71.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/io/ByteSourceTest.java

      }
    
      public void testCopyToStream_doesNotCloseThatStream() throws IOException {
        TestOutputStream out = new TestOutputStream(ByteStreams.nullOutputStream());
        assertFalse(out.closed());
        source.copyTo(out);
        assertFalse(out.closed());
      }
    
      public void testClosesOnErrors_copyingToByteSinkThatThrows() {
        for (TestOption option : EnumSet.of(OPEN_THROWS, WRITE_THROWS, CLOSE_THROWS)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  9. internal/s3select/json/preader.go

    	dstRec.SelectFormat = sql.SelectFmtJSON
    	return dstRec, nil
    }
    
    // Close - closes underlying reader.
    func (r *PReader) Close() error {
    	if r.close != nil {
    		close(r.close)
    		r.readerWg.Wait()
    		r.close = nil
    	}
    	r.recordsRead = len(r.current)
    	if r.err == nil {
    		r.err = io.EOF
    	}
    	return r.readCloser.Close()
    }
    
    // nextSplit will attempt to skip a number of bytes and
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/http/Hc5ConnectionMonitorTarget.java

            if (clientConnectionManager == null) {
                logger.warn("clientConnectionManager is null.");
                return;
            }
    
            try {
                // Close expired connections
                clientConnectionManager.closeExpired();
                // Close idle connections
                clientConnectionManager.closeIdle(TimeValue.ofMilliseconds(idleConnectionTimeout));
            } catch (final Exception e) {
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Sun Jan 04 13:09:59 GMT 2026
    - 3.3K bytes
    - Click Count (0)
Back to Top