language = detectLanguage(DocumentUtil.getValue(doc, f, String.class));
                    if (language != null) {
                        if (logger.isDebugEnabled()) {
                            logger.debug("set {} to lang field", language);
                        }
                        doc.put(fessConfig.getIndexFieldLang(), language);
                        break;
                    }
                }
            }

            // Clean up
            tempFile.delete();
        }
    }

    public void test_createResponseBodyFile_filePermissions() throws Exception {
        // Test that file permissions are set correctly
        ResponseData responseData = new ResponseData() {
            @Override
            public InputStream getResponseBody() {
                return new ByteArrayInputStream("Test permissions".getBytes());

        synchronized (PROTOCOL_HANDLERS) {
            if (Handler.factory != null) {
                throw new IllegalStateException("URLStreamHandlerFactory already set.");
            }
            PROTOCOL_HANDLERS.clear();
            Handler.factory = factory;
        }
    }

    /**
     * Constructs a handler with the specified CIFS context.
     *

            }
        }
    }

    // ===================================================================================
    //                                                                           Query Set
    //                                                                           =========
    public void setId_Equal(String id) {
        setId_Term(id, null);
    }

            response.setReturnCode(message.getReturnCode());
            response.setSequenceNumber(message.getResponseSequenceNumber());

            if (message.isSuccess()) {
                // Set recommended heartbeat interval from server
                response.setRecommendedHeartbeatInterval(message.getHeartbeatInterval());

        byte[] buffer2 = new byte[] { 0x20, 0x00, 0x00, 0x00 }; // 32

        response.readParameterWordsWireFormat(buffer1, 0);
        assertEquals(16L, response.getOffset(), "First read should set offset to 16");

        response.readParameterWordsWireFormat(buffer2, 0);
        assertEquals(32L, response.getOffset(), "Second read should update offset to 32");
    }

    @Test

    private RdmaBufferManager bufferManager;
    private AutoCloseable mocks;

    @BeforeEach
    public void setUp() throws Exception {
        mocks = MockitoAnnotations.openMocks(this);

        // Set up mock provider to return TCP memory regions
        when(mockProvider.registerMemory(any(ByteBuffer.class), any())).thenAnswer(invocation -> {
            ByteBuffer buffer = invocation.getArgument(0);

import java.net.UnknownHostException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jcifs.CIFSContext;
import jcifs.Configuration;
import jcifs.NameServiceClient;
import jcifs.NetbiosAddress;
import jcifs.ResolverType;

        int flags1 = SMBUtil.readInt4(buffer1, 68);
        assertEquals(DirectoryLeaseContext.DIRECTORY_LEASE_FLAG_NOTIFICATIONS, flags1);

        // Test with RECURSIVE_TREE scope (recursive flag set)
        DirectoryLeaseContext context2 = new DirectoryLeaseContext(key, 0, DirectoryCacheScope.RECURSIVE_TREE);
        context2.setNotificationEnabled(true);

        byte[] buffer2 = new byte[context2.size()];

    /**
     * Abbreviates a site string to the maximum allowed length if configured.
     *
     * @param value the site string to abbreviate
     * @return the abbreviated string, or original if no length limit is set
     */
    default String abbreviateSite(final String value) {
        final int maxSiteLength = getMaxSiteLength();
        if (maxSiteLength > -1) {
            return StringUtils.abbreviate(value, maxSiteLength);