/**
     * Default constructor.
     */
    public AdminCrawlinginfoAction() {
        super();
    }

    /** The role for this action. */
    public static final String ROLE = "admin-crawlinginfo";

    private static final Logger logger = LogManager.getLogger(AdminCrawlinginfoAction.class);

    // ===================================================================================

 * limitations under the License.
 */

package com.google.common.base;

import static com.google.common.base.ReflectionFreeAssertThrows.assertThrows;
import static com.google.common.collect.ImmutableList.toImmutableList;
import static com.google.common.truth.Truth.assertThat;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;

 * query is malformed, contains invalid syntax, or violates query constraints.
 */
public class InvalidQueryException extends FessSystemException {

    /** Serial version UID for serialization */
    private static final long serialVersionUID = 1L;

    /** Message code for localized error messages */
    private final transient VaMessenger<FessMessages> messageCode;

    /**

 * that are validated against the admin role configuration.</p>
 */
public abstract class FessApiAdminAction extends FessApiAction {

    /** Logger instance for this class. */
    private static final Logger logger = LogManager.getLogger(FessApiAdminAction.class);

    /**
     * Default constructor.
     */
    public FessApiAdminAction() {
        super();
    }

    /**

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.collect.testing.google;

import static java.util.Collections.sort;

import com.google.common.annotations.GwtCompatible;
import com.google.common.collect.Multiset;
import com.google.common.collect.testing.AnEnum;

 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */

package com.google.common.eventbus;

import static com.google.common.base.Preconditions.checkNotNull;

import java.lang.reflect.Method;

/**
 * Context for an exception thrown by a subscriber.
 *
 * @since 16.0
 */
public class SubscriberExceptionContext {

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.graph;

import static com.google.common.base.Preconditions.checkNotNull;

import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Iterators;
import com.google.common.collect.UnmodifiableIterator;

 *
 * For TCP fallback, memory regions are just wrappers around
 * ByteBuffers since no real RDMA registration is needed.
 */
public class TcpMemoryRegion extends RdmaMemoryRegion {

    private static final AtomicInteger keyGenerator = new AtomicInteger(1000);

    /**
     * Create new TCP memory region
     *
     * @param buffer memory buffer
     * @param access access permissions (ignored for TCP)
     */

                    request.getArtifact(),
                    request.getRemoteRepositories());
        }
    }

    private static <T> List<T> toList(Collection<T> items) {
        return (items != null) ? new ArrayList<>(items) : null;
    }

        }
    }

    static class MockSystemHelper extends SystemHelper {
        @Override
        public long getCurrentTimeAsLong() {
            return System.currentTimeMillis();
        }

        @Override
        public String getSearchRoleByRole(String role) {
            return "search_" + role;
        }
    }

    static class MockPermissionHelper extends PermissionHelper {