* distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.bsentity.dbmeta;

import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;

        assertEquals(0x0010, SmbConstants.FLAGS_VERIFY_ALL_WRITES);
        assertEquals(0x0020, SmbConstants.FLAGS_TREE_COPY);
    }

    @Test
    @DisplayName("Should define protocol specific constants")
    void testProtocolConstants() {
        assertEquals(0x0000, SmbConstants.OPEN_FUNCTION_FAIL_IF_EXISTS);
        assertEquals(0x0020, SmbConstants.OPEN_FUNCTION_OVERWRITE_IF_EXISTS);

 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.app.pager;

import java.io.Serializable;
import java.util.List;

import org.codelibs.fess.util.ComponentUtil;

 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.app.service;

import java.io.IOException;
import java.io.Reader;
import java.io.Writer;

 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.entity;

import org.codelibs.fess.crawler.Constants;
import org.codelibs.fess.crawler.entity.RequestData.Method;

 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.extractor.impl;

import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;

import jcifs.dcerpc.ndr.NdrBuffer;
import jcifs.dcerpc.ndr.NdrException;

/**
 * WitnessRegister RPC message implementation for MS-SWN specification.
 * This message is used to register for witness notifications on a specific resource.
 */
public class WitnessRegisterMessage extends WitnessRpcMessage {

    // Input parameters for WitnessRegister
    private WitnessVersion version;
    private String netName;
    private String shareName;

    @MethodSource("wrapExceptions")
    void connectWrapException_wrapsToSmbException(SmbResourceLocatorImpl loc, Exception thrown) throws Exception {
        // Arrange: spy on instance to force connect() failure with specific exception
        CIFSContext ctx = mock(CIFSContext.class);
        SmbTreeConnectionTrace trace = Mockito.spy(new SmbTreeConnectionTrace(ctx));
        doThrow(thrown).when(trace).connect(loc);

            smbTransportMockedStatic.close();
        if (configMockedStatic != null)
            configMockedStatic.close();
    }

    @Test
    void testCacheEntry() {
        // Test with a specific TTL
        long ttl = 600; // 10 minutes
        Dfs.CacheEntry cacheEntry = new Dfs.CacheEntry(ttl);
        long expectedExpiration = System.currentTimeMillis() + ttl * 1000L;

 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package okhttp3.internal.http

import app.cash.burst.Burst
import assertk.assertThat
import assertk.assertions.contains