fold - Code Search

fess-crawler/src/main/java/org/codelibs/fess/crawler/container/StandardCrawlerContainer.java

         */
        protected Consumer<T> destroyer;

        /**
         * Creates a new ComponentHolder with the specified instance and destroyer.
         * @param instance the component instance to hold
         * @param destroyer the destroyer function for cleanup (can be null)
         */
        protected ComponentHolder(final T instance, final Consumer<T> destroyer) {
            this.instance = instance;

Registered: Sun Sep 21 03:50:09 UTC 2025

- Last Modified: Sun Jul 06 02:13:03 UTC 2025

- 14.3K bytes

- Viewed (0)

github.com/golang/go

src/bufio/bufio.go

// delim.
// For simple uses, a Scanner may be more convenient.
func (b *Reader) ReadBytes(delim byte) ([]byte, error) {
	full, frag, n, err := b.collectFragments(delim)
	// Allocate new buffer to hold the full pieces and the fragment.
	buf := make([]byte, n)
	n = 0
	// Copy full pieces and fragment in.
	for i := range full {
		n += copy(buf[n:], full[i])
	}
	copy(buf[n:], frag)
	return buf, err
}

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Wed Sep 03 14:04:47 UTC 2025

- 22K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

      "FINE: Q10000 finished run in   0 µs: task two",
      "FINE: Q10000 starting              : task one",
      "FINE: Q10000 finished run in   0 µs: task one",
    )
  }

  /**
   * The runner doesn't hold references to its queues! Otherwise we'd need a mechanism to clean them
   * up when they're no longer needed and that's annoying. Instead the task runner only tracks which
   * queues have work scheduled.
   */

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Wed Mar 19 19:25:20 UTC 2025

- 23K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/uk/docs/index.md

<small>* оцінка на основі тестів внутрішньої команди розробників, створення продуктових застосунків.</small>

## Спонсори

<!-- sponsors -->

{% if sponsors %}
{% for sponsor in sponsors.gold -%}
<a href="{{ sponsor.url }}" target="_blank" title="{{ sponsor.title }}"><img src="{{ sponsor.img }}" style="border-radius:15px"></a>
{% endfor -%}
{%- for sponsor in sponsors.silver -%}

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Sun Aug 31 10:49:48 UTC 2025

- 24.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-metadata-sys.go

		if err != nil {
			internalLogOnceIf(ctx, fmt.Errorf("Unable to load bucket metadata, will be retried: %w", err),
				"load-bucket-metadata-"+buckets[index], logger.WarningKind)
		}
	}

	// Hold lock here to update in-memory map at once,
	// instead of serializing the Go routines.
	sys.Lock()
	for i, meta := range bucketMetas {
		if errs[i] != nil {
			continue
		}
		sys.metadataMap[buckets[i]] = meta

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 20.4K bytes

- Viewed (0)

github.com/minio/minio

cmd/erasure-server-pool.go

	// Remove entries that are above.
	for i, z := range p {
		if z.Available > 0 && z.MaxUsedPct < maxUsed {
			continue
		}
		p[i].Available = 0
	}
}

// getAvailablePoolIdx will return an index that can hold size bytes.
// -1 is returned if no serverPools have available space for the size given.
func (z *erasureServerPools) getAvailablePoolIdx(ctx context.Context, bucket, object string, size int64) int {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Fri Aug 29 02:39:48 UTC 2025

- 89.1K bytes

- Viewed (0)

github.com/golang/go

src/bufio/scan.go

// the [Scanner] returns it to the user. If the token is nil, the
// Scanner reads more data and continues scanning; if there is no more
// data--if atEOF was true--the [Scanner] returns. If the data does not
// yet hold a complete token, for instance if it has no newline while
// scanning lines, a [SplitFunc] can return (0, nil, nil) to signal the
// [Scanner] to read more data into the slice and try again with a

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Wed May 21 18:05:26 UTC 2025

- 14.2K bytes

- Viewed (0)

github.com/golang/go

misc/go_android_exec/main.go

	// and wait for our os.Stderr (and os.Stdout) to close as a result.
	// However, if the os.Stderr (or os.Stdout) file descriptors are
	// passed on, the hanging adb subprocess will hold them open and
	// go test will hang forever.
	//
	// Avoid that by wrapping stderr, breaking the short circuit and
	// forcing cmd.Run to use another pipe and goroutine to pass
	// along stderr from adb.

Registered: Tue Sep 09 11:13:09 UTC 2025

- Last Modified: Mon Aug 21 17:46:57 UTC 2023

- 15.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/view/admin/searchlist/admin_searchlist_edit.jsp

    <title><la:message key="labels.admin_brand_title"/> | <la:message key="labels.search_list_configuration"/></title>
    <jsp:include page="/WEB-INF/view/common/admin/head.jsp"></jsp:include>
</head>
<body class="hold-transition sidebar-mini">
<div class="wrapper">
    <jsp:include page="/WEB-INF/view/common/admin/header.jsp"></jsp:include>
    <jsp:include page="/WEB-INF/view/common/admin/sidebar.jsp">

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Thu Feb 13 07:47:04 UTC 2020

- 24.9K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

LICENSE

      License. However, in accepting such obligations, You may act only
      on Your own behalf and on Your sole responsibility, not on behalf
      of any other Contributor, and only if You agree to indemnify,
      defend, and hold each Contributor harmless for any liability
      incurred by, or claims asserted against, such Contributor by reason
      of your accepting any such warranty or additional liability.

   END OF TERMS AND CONDITIONS

Registered: Tue Sep 09 12:39:10 UTC 2025

- Last Modified: Mon Nov 29 17:31:56 UTC 2021

- 13.3K bytes

- Viewed (0)

Search Options