testing/internal-testing/                   @gradle/bt-developer-productivity
testing/precondition-tester                 @gradle/bt-developer-productivity

# Release coordination
packaging/core-platform/                @gradle/bt-product-operations
packaging/distributions-dependencies/   @gradle/bt-product-operations
packaging/distributions-full/           @gradle/bt-product-operations

    /**
     * Creates a new instance of DataIndexHelper.
     * This constructor initializes the helper for managing data crawling operations,
     * including thread pool management and session-based crawling coordination.
     */
    public DataIndexHelper() {
        // Default constructor with explicit documentation
    }

    /**
     * Initiates crawling for all configured data stores.

- [ ] Implement client registration
- [ ] Add notification callback mechanism
- [ ] Create resource monitoring
- [ ] Implement automatic re-registration
- [ ] Add cluster node tracking
- [ ] Create failover coordination

#### 6.3 Integration Points
- Integrate with `CIFSContext` for witness support
- Modify `SmbTransport` for failover handling
- Update `DfsResolver` for witness-aware resolution

---

 * This class serves as the entry point for crawling web content, file systems, and data stores.
 * It manages the crawling lifecycle, including initialization, execution coordination,
 * monitoring, and cleanup operations.
 *
 * <p>The crawler can operate in different modes based on command-line options:
 * <ul>
 * <li>Web crawling - crawls web sites and web content</li>

a struct with a <code>_size</code> field), <code>#include
"go_asm.h"</code> will fail with a "redefinition of macro" error.
</p>

<h3 id="runtime">Runtime Coordination</h3>

<p>
For garbage collection to run correctly, the runtime must know the
location of pointers in all global data and in most stack frames.
The Go compiler emits this information when compiling Go source files,

          return readyTask
        }

        // Notify the coordinator of a task that's coming up soon.
        coordinatorWaiting -> {
          if (minDelayNanos < coordinatorWakeUpAt - now) {
            backend.coordinatorNotify(this@TaskRunner)
          }
          return null
        }

        // No other thread is coordinating. Become the coordinator!
        else -> {
          coordinatorWaiting = true

    require(currentTask == TestThreadSerialTask)

    // Queue a task to interrupt the waiting coordinator.
    serialTaskQueue +=
      object : SerialTask {
        override fun start() {
          taskRunner.assertLockHeld()
          waitingCoordinatorInterrupted = true
          val coordinatorTask = waitingCoordinatorTask ?: error("no coordinator waiting")
          currentTask = coordinatorTask
          taskRunner.notifyAll()

  @Test fun onlyOneCoordinatorWaitingToStartFutureTasks() {
    // Enqueueing the red task starts a coordinator thread.
    redQueue.execute("red task", 100.µs) {
      log += "red:run@${taskFaker.nanoTime}"
    }
    assertThat(taskFaker.executeCallCount).isEqualTo(1)

    // Enqueueing the blue task doesn't need a 2nd coordinator yet.
    blueQueue.execute("blue task", 200.µs) {
      log += "blue:run@${taskFaker.nanoTime}"
    }

import org.codelibs.fess.util.ComponentUtil;

/**
 * Helper class for web and file system crawling and indexing operations.
 * Manages the crawling process for both web configurations and file configurations,
 * coordinating multiple crawler threads and handling indexing operations.
 */
public class WebFsIndexHelper {

    /**
     * Default constructor.
     */
    public WebFsIndexHelper() {
        // Default constructor