drainCancelQueue(eventSource)
  }

  override fun onEvent(
    eventSource: EventSource,
    id: String?,
    type: String?,
    data: String,
  ) {
    get().log("[ES] onEvent", Platform.INFO, null)
    events.add(Event(id, type, data))
    drainCancelQueue(eventSource)
  }

  override fun onClosed(eventSource: EventSource) {
    get().log("[ES] onClosed", Platform.INFO, null)

            try {
                final StatsObject data = statsCache.getIfPresent(key);
                if (data != null && data.decrement() <= 0) {
                    statsCache.invalidate(key);
                    final Long begin = data.remove(BEGIN_KEY);
                    if (begin != null) {
                        printStats(keyObj, data, begin, true);
                    }
                }

 */
package jcifs.internal.smb2.ioctl;

/**
 * Request data for FSCTL_QUERY_NETWORK_INTERFACE_INFO
 *
 * This IOCTL has no input data - the request is empty
 */
public class QueryNetworkInterfaceInfoRequest {

    /**
     * Create query network interface info request
     */
    public QueryNetworkInterfaceInfoRequest() {
        // No input data required for this IOCTL
    }

    /**

            searchPaging(data, form);
        });
    }

    /**
     * Handles search pagination and data preparation for rendering.
     *
     * @param data render data to populate with search results
     * @param form search form containing current search state
     */
    protected void searchPaging(final RenderData data, final SearchForm form) {

        while (trace != null) {
            Object data = trace.getData();
            if (data instanceof CollectStepData collectStepData) {
                collectStepTrace = collectStepData;
            } else if (data instanceof ArtifactDescriptorRequest artifactDescriptorRequestData) {
                artifactDescriptorRequest = artifactDescriptorRequestData;
            } else if (data instanceof ArtifactRequest artifactRequestData) {

     */
    void setInitParameterMap(Map<String, Object> params);

    /**
     * Executes a request and returns the response data.
     *
     * @param data the request data to be executed
     * @return the response data from the executed request
     */
    ResponseData execute(RequestData data);

    /**
     * Closes the crawler client and releases any resources associated with it.

            writeLittleEndianLong(baos, 104); // offset (aligned)

            // Add buffer data
            while (baos.size() < 72) {
                baos.write(0);
            }
            // LOGON_INFO data (minimal)
            baos.write(new byte[8]);

            // SERVER_CHECKSUM data
            writeLittleEndianInt(baos, PacSignature.KERB_CHECKSUM_HMAC_MD5);
            baos.write(mockChecksum);

    /**
     * Parse network interface info from encoded bytes
     *
     * @param data encoded data
     * @param offset offset in data
     * @return parsed NetworkInterfaceInfo
     */
    public static NetworkInterfaceInfo decode(byte[] data, int offset) {
        // Ensure we have enough data for the full structure
        if (data.length < offset + Smb2ChannelCapabilities.NETWORK_INTERFACE_INFO_SIZE) {
            return null;

 * Callback interface for handling index update operations during data store processing.
 * This interface provides methods for storing documents, tracking processing metrics,
 * and committing changes to the search index.
 */
public interface IndexUpdateCallback {

    /**
     * Stores a document in the search index with the specified parameters and data.
     *
     * @param paramMap the data store parameters containing configuration and metadata

// early instead of silently corrupting data.
func erasureSelfTest() {
	// Approx runtime ~1ms
	var testConfigs [][2]uint8
	for total := uint8(4); total < 16; total++ {
		for data := total / 2; data < total; data++ {
			parity := total - data
			testConfigs = append(testConfigs, [2]uint8{data, parity})
		}
	}
	got := make(map[[2]uint8]map[ErasureAlgo]uint64, len(testConfigs))