Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 1,514 for close (0.02 seconds)

  1. cmd/bitrot.go

    	}
    	return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum)
    }
    
    // Close all the readers.
    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    	errs := make([]error, len(ws))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 7.7K bytes
    - Click Count (0)
  2. internal/lru/lru.go

    		c.removeOldest()
    	}
    	c.size = size
    	return diff
    }
    
    // Close destroys cleanup goroutine. To clean up the cache, run Purge() before Close().
    // func (c *LRU[K, V]) Close() {
    //	c.mu.Lock()
    //	defer c.mu.Unlock()
    //	select {
    //	case <-c.done:
    //		return
    //	default:
    //	}
    //	close(c.done)
    // }
    
    // removeOldest removes the oldest item from the cache. Has to be called with lock!
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 12.6K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/FaultHidingSink.kt

        if (hasErrors) {
          return
        }
        try {
          super.flush()
        } catch (e: IOException) {
          hasErrors = true
          onException(e)
        }
      }
    
      override fun close() {
        try {
          super.close()
        } catch (e: IOException) {
          hasErrors = true
          onException(e)
        }
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java

                    fos = null; // Successfully wrapped, no need to close explicitly
                } catch (final Exception e) {
                    if (fos != null) {
                        try {
                            fos.close();
                        } catch (final IOException ioe) {
                            // Ignore close exception
                        }
                    }
                    if (newFile != null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 07:09:00 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  5. build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

                    }
                    return delegate.read(cbuf, off, len);
                }
    
                @Override
                public void close() throws IOException {
                    if (delegate != null) {
                        delegate.close();
                    }
                }
            };
            this.lock = this.in;
        }
    
        private Reader transform(Reader in) throws IOException {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Tue Mar 03 01:59:51 GMT 2026
    - 11.3K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/io/TestInputStream.java

        throwIf(closed);
        throwIf(SKIP_THROWS);
        return in.skip(n);
      }
    
      @Override
      public int available() throws IOException {
        throwIf(closed);
        return options.contains(TestOption.AVAILABLE_ALWAYS_ZERO) ? 0 : in.available();
      }
    
      @Override
      public void close() throws IOException {
        closed = true;
        throwIf(CLOSE_THROWS);
        in.close();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 2.6K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectPlan.kt

            throw IOException(npe)
          }
        }
      }
    
      /**
       * Does all the work to build an HTTPS connection over a proxy tunnel. The catch here is that a
       * proxy server can issue an auth challenge and then close the connection.
       *
       * @return the next plan to attempt, or null if no further attempt should be made either because
       *     we've successfully connected or because no further attempts should be made.
       */
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 19.3K bytes
    - Click Count (2)
  8. src/cmd/asm/internal/lex/lex.go

    	// SetBase sets the position base.
    	SetBase(*src.PosBase)
    	// Line reports the source line number of the token.
    	Line() int
    	// Col reports the source column number of the token.
    	Col() int
    	// Close does any teardown required.
    	Close()
    }
    
    // A Token is a scan token plus its string value.
    // A macro is stored as a sequence of Tokens with spaces stripped.
    type Token struct {
    	ScanToken
    	text string
    }
    
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 4.1K bytes
    - Click Count (0)
  9. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/test/ErrorReportingTestListener.java

                EventWriter writer = eventWriters.remove(descriptor);
                if (writer != null) {
                    try {
                        writer.close();
                    } catch (IOException e) {
                        taskLogger.error("Failed to close test suite output stream", e);
                    }
                }
            }
        }
    
        @Override
        public void beforeTest(TestDescriptor testDescriptor) {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 10.7K bytes
    - Click Count (0)
  10. internal/deadlineconn/deadlineconn.go

    	c.infWrites.Store(t.IsZero())
    	c.writeSetAt = time.Time{}
    	return c.Conn.SetWriteDeadline(t)
    }
    
    // Close wraps conn.Close and stops sending deadline updates.
    func (c *DeadlineConn) Close() error {
    	c.abortReads.Store(true)
    	c.abortWrites.Store(true)
    	return c.Conn.Close()
    }
    
    // WithReadDeadline sets a new read side net.Conn deadline.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
Back to Top