if peer.DeploymentID == globalDeploymentID() {
			continue
		}
		rs, err := loadSiteResyncMetadata(ctx, objAPI, peer.DeploymentID)
		if err != nil {
			return err
		}
		sm.Lock()
		if _, ok := sm.peerResyncMap[peer.DeploymentID]; !ok {
			sm.peerResyncMap[peer.DeploymentID] = resyncState{resyncID: rs.ResyncID, LastSaved: time.Time{}}
			sm.resyncStatus[rs.ResyncID] = rs
		}
		sm.Unlock()
	}

import static org.mockito.Mockito.mock;

import java.util.Date;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;

/**
 * Unit tests for the {@link Info} implementations used by the SMB1
 * protocol handling code.
 */
class InfoTest {

    // A tiny mock to illustrate Mockito interaction patterns.
    @Mock

        deleteByQueryCalled = false;
        deleteIndex = null;
        deleteQuery = null;
        expiresFieldName = "expires";
        documentUpdateIndex = "fess.update";

        // Create mock SearchEngineClient
        searchEngineClient = new SearchEngineClient() {
            @Override
            public long deleteByQuery(String index, QueryBuilder query) {
                deleteByQueryCalled = true;

 * test with reference to the same "lock-like object", and then their interactions with that object
 * are choreographed via the various methods on this class.
 *
 * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
 * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a

    private CIFSContext mockContext;
    private byte[] testFileId;
    private Smb2ChangeNotifyRequest request;

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        mockContext = mock(CIFSContext.class);
        testFileId = new byte[16];
        Arrays.fill(testFileId, (byte) 0xAB);

        // Use lenient stubbing for default configuration values

@ExtendWith(MockitoExtension.class)
class DirFileEntryEnumIterator2Test {

    @Mock
    private SmbTreeHandleImpl tree;

    @Mock
    private SmbResource parent;

    @Mock
    private SmbResourceLocator locator;

    @Mock
    private Configuration config;

    @Mock
    private CIFSContext cifsContext;

    @BeforeEach
    void setup() {

        // Create a mock policy_handle for each test
        mockHandle = mock(policy_handle.class);
    }

    /**
     * Test case for the {@link MsrpcLsarClose#MsrpcLsarClose(policy_handle)} constructor.
     * Verifies that the handle, ptype, and flags are correctly initialized.
     */
    @Test
    void testConstructor() {
        // Create an instance of MsrpcLsarClose with the mock handle

  /** The timestamp of the last taken event, used to measure elapsed time between events. */
  private var lastTimestampNs: Long? = null

  /** Confirm that the thread does not hold a lock on `lock` during the callback. */
  fun forbidLock(lock: Any) {
    forbiddenLocks.add(lock)
  }

  /**
   * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
   * and returns it.
   */

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        crawler = new Crawler();

        // Initialize mock components
        searchEngineClient = new SearchEngineClient() {
            // Mock implementation
        };
        crawler.searchEngineClient = searchEngineClient;

        webFsIndexHelper = new WebFsIndexHelper() {
            @Override

            // Mock implementation that doesn't require client
            entity.setLastUpdated(System.currentTimeMillis());
        }

        @Override
        public void update(JobLog entity) {
            // Mock implementation that doesn't require client
            entity.setLastUpdated(System.currentTimeMillis());
        }
    }

    // Simple mock class without complex interface requirements