// Then
        Field notifyFlagsField = Smb2ChangeNotifyRequest.class.getDeclaredField("notifyFlags");
        notifyFlagsField.setAccessible(true);
        assertEquals(flags, notifyFlagsField.getInt(request));
    }

    @Test
    @DisplayName("Should set completion filter correctly")
    void testSetCompletionFilter() throws Exception {
        // Given

package jcifs.smb1.smb1;

import jcifs.smb1.Config;

class SmbComWriteAndX extends AndXServerMessageBlock {

    private static final int READ_ANDX_BATCH_LIMIT = Config.getInt("jcifs.smb1.smb.client.WriteAndX.ReadAndX", 1);
    private static final int CLOSE_BATCH_LIMIT = Config.getInt("jcifs.smb1.smb.client.WriteAndX.Close", 1);

    private int fid, remaining, dataLength, dataOffset, off;
    private byte[] b;
    private long offset;

            final Response response = checkMethodBase(requestBody).put("/api/admin/scheduler/" + schedulerId + "/start");
            if (response.getBody().jsonPath().getInt("response.status") == 0) {
                logger.info("Start scheduler \"{}\"", schedulerId);
                return;
            }
            ThreadUtil.sleep(1000L);
        }
        fail("could not start job.");

        Set<Integer> values = new HashSet<>();

        for (Field field : fields) {
            if (field.getType() == int.class) {
                int value = field.getInt(null);
                assertTrue(values.add(value), "Duplicate value found for field: " + field.getName());
            }
        }
    }

    @Test
    @DisplayName("Test constant values follow bit flag pattern")

        crc0 = computeForWord(crc0);
        crc1 = computeForWord(crc1);
        crc2 = computeForWord(crc2);
        crc3 = computeForWord(crc3);
        crc0 ^= bb.getInt();
        crc1 ^= bb.getInt();
        crc2 ^= bb.getInt();
        crc3 ^= bb.getInt();
      }
    }

    @Override
    protected void processRemaining(ByteBuffer bb) {
      if (finished) {
        return;
      }

                in.close();
            }
        } catch (final IOException ioe) {
            if (LogStream.level > 0) {
                ioe.printStackTrace(log);
            }
        }

        level = Config.getInt("jcifs.smb1.util.loglevel", -1);
        if (level != -1) {
            LogStream.setLevel(level);
        }

        try {
            "".getBytes(DEFAULT_OEM_ENCODING);

pkg syscall (windows-amd64), type SysProcAttr struct, ParentProcess Handle
pkg testing, method (*B) Setenv(string, string)
pkg testing, method (*T) Setenv(string, string)
pkg testing, type TB interface, Setenv(string, string)
pkg text/template/parse, const SkipFuncCheck = 2
pkg text/template/parse, const SkipFuncCheck Mode
pkg time, const Layout = "01/02 03:04:05PM '06 -0700"

    fi
fi

if [ "$REMOVE_USER_AND_GROUP" = "true" ]; then
    if id "$FESS_USER" > /dev/null 2>&1 ; then
        userdel "$FESS_USER"
    fi

    if getent group "$FESS_GROUP" > /dev/null 2>&1 ; then
        groupdel "$FESS_GROUP"
    fi
fi

    private int getStatus(NetShareEnumResponse response) throws Exception {
        Field field = getSuperclassField(response.getClass(), "status");
        field.setAccessible(true);
        return field.getInt(response);
    }

    private void setStatus(NetShareEnumResponse response, int value) throws Exception {
        Method method = getSuperclassMethod(response.getClass(), "setStatus", int.class);

    private int getSearchAttributes(SmbComDelete smbComDelete) {
        try {
            Field field = smbComDelete.getClass().getDeclaredField("searchAttributes");
            field.setAccessible(true);
            return field.getInt(smbComDelete);
        } catch (Exception e) {
            throw new RuntimeException("Failed to get searchAttributes field", e);
        }
    }