/* * CDDL HEADER START * * The contents of this file are subject to the terms of the * Common Development and Distribution License, Version 1.0 only * (the "License"). You may not use this file except in compliance * with the License. * * You can obtain a copy of the license at legal-notices/CDDLv1_0.txt * or http://forgerock.org/license/CDDLv1.0.html. * See the License for the specific language governing permissions * and limitations under the License. * * When distributing Covered Code, include this CDDL HEADER in each * file and include the License file at legal-notices/CDDLv1_0.txt. * If applicable, add the following below this CDDL HEADER, with the * fields enclosed by brackets "[]" replaced with your own identifying * information: * Portions Copyright [yyyy] [name of copyright owner] * * CDDL HEADER END * * * Copyright 2006-2008 Sun Microsystems, Inc. * Portions copyright 2013 ForgeRock AS */ package org.opends.server.core; import java.util.ArrayList; import org.opends.messages.Message; import org.opends.server.plugins.InvocationCounterPlugin; import org.opends.server.protocols.internal.InternalClientConnection; import org.opends.server.types.CancelRequest; import org.opends.server.types.Control; import org.opends.server.types.Operation; import org.opends.server.types.ResultCode; import org.testng.annotations.Test; import static org.opends.server.protocols.internal.InternalClientConnection.*; import static org.testng.Assert.*; /** * A set of test cases for unbind operations */ public class UnbindOperationTestCase extends OperationTestCase { /** {@inheritDoc} */ @Override() protected Operation[] createTestOperations() throws Exception { final InternalClientConnection conn = getRootConnection(); return new Operation[] { new UnbindOperationBasis(conn, nextOperationID(), nextMessageID(), null), new UnbindOperationBasis(conn, nextOperationID(), nextMessageID(), new ArrayList()) }; } /** * Invokes a number of operation methods on the provided unbind operation for * which all processing has been completed. * * @param unbindOperation The operation to be tested. */ private void examineCompletedOperation(UnbindOperation unbindOperation) { assertTrue(unbindOperation.getProcessingStartTime() > 0); assertTrue(unbindOperation.getProcessingStopTime() > 0); assertTrue(unbindOperation.getProcessingTime() >= 0); } /** * Attempts an internal unbind operation. This won't actually do anything, * since there's nothing to disconnect with an internal connection, but it * will at least exercise the code path. */ @Test() public void testUnbindInternal() { InvocationCounterPlugin.resetAllCounters(); final InternalClientConnection conn = getRootConnection(); UnbindOperationBasis unbindOperation = new UnbindOperationBasis( conn, nextOperationID(), nextMessageID(), new ArrayList()); unbindOperation.run(); examineCompletedOperation(unbindOperation); // assertTrue(InvocationCounterPlugin.getPreParseCount() > 0); // assertTrue(InvocationCounterPlugin.getPostOperationCount() > 0); } /** * Tests the cancel method to ensure that it indicates that the * operation cannot be cancelled. */ @Test() public void testCancel() { final InternalClientConnection conn = getRootConnection(); CancelRequest cancelRequest = new CancelRequest(false, Message.raw("Test Unbind Cancel")); UnbindOperationBasis unbindOperation = new UnbindOperationBasis( conn, nextOperationID(), nextMessageID(), new ArrayList()); assertEquals(unbindOperation.cancel(cancelRequest).getResultCode(), ResultCode.CANNOT_CANCEL); } /** * Tests the getCancelRequest method to ensure that it always * returns null. */ @Test public void testGetCancelRequest() { final InternalClientConnection conn = getRootConnection(); CancelRequest cancelRequest = new CancelRequest(false, Message.raw("Test Unbind Cancel")); UnbindOperationBasis unbindOperation = new UnbindOperationBasis( conn, nextOperationID(), nextMessageID(), new ArrayList()); assertNull(unbindOperation.getCancelRequest()); assertEquals(unbindOperation.cancel(cancelRequest).getResultCode(), ResultCode.CANNOT_CANCEL); assertNull(unbindOperation.getCancelRequest()); } }