Skip to content

Commit

Permalink
[Java] Move related classes into status package.
Browse files Browse the repository at this point in the history
  • Loading branch information
mjpt777 committed Mar 20, 2016
1 parent a62e8a8 commit 027a3b3
Show file tree
Hide file tree
Showing 6 changed files with 13 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

import uk.co.real_logic.agrona.ErrorHandler;
import uk.co.real_logic.agrona.Verify;
import uk.co.real_logic.agrona.concurrent.status.AtomicCounter;

import java.nio.channels.ClosedByInterruptException;
import java.util.concurrent.atomic.AtomicReference;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package uk.co.real_logic.agrona.concurrent;
package uk.co.real_logic.agrona.concurrent.status;

import uk.co.real_logic.agrona.concurrent.AtomicBuffer;

/**
* Atomic counter that is backed by an {@link AtomicBuffer} that can be read across threads and processes.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package uk.co.real_logic.agrona.concurrent;
package uk.co.real_logic.agrona.concurrent.status;

import uk.co.real_logic.agrona.MutableDirectBuffer;
import uk.co.real_logic.agrona.concurrent.AtomicBuffer;
import uk.co.real_logic.agrona.concurrent.UnsafeBuffer;

import java.util.Deque;
import java.util.LinkedList;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,11 +13,13 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package uk.co.real_logic.agrona.concurrent;
package uk.co.real_logic.agrona.concurrent.status;

import uk.co.real_logic.agrona.BitUtil;
import uk.co.real_logic.agrona.DirectBuffer;
import uk.co.real_logic.agrona.collections.IntObjConsumer;
import uk.co.real_logic.agrona.concurrent.AtomicBuffer;
import uk.co.real_logic.agrona.concurrent.UnsafeBuffer;

import static uk.co.real_logic.agrona.BitUtil.CACHE_LINE_LENGTH;
import static uk.co.real_logic.agrona.BitUtil.SIZE_OF_INT;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,6 @@
*/
package uk.co.real_logic.agrona.concurrent.status;

import uk.co.real_logic.agrona.concurrent.CountersManager;
import uk.co.real_logic.agrona.concurrent.UnsafeBuffer;

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,18 +21,16 @@
import org.mockito.Mockito;
import uk.co.real_logic.agrona.DirectBuffer;
import uk.co.real_logic.agrona.collections.IntObjConsumer;
import uk.co.real_logic.agrona.concurrent.status.Position;
import uk.co.real_logic.agrona.concurrent.status.ReadablePosition;
import uk.co.real_logic.agrona.concurrent.status.UnsafeBufferPosition;
import uk.co.real_logic.agrona.concurrent.status.*;

import static java.nio.ByteBuffer.allocateDirect;
import static org.hamcrest.Matchers.is;
import static org.junit.Assert.assertThat;
import static org.mockito.Matchers.eq;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static uk.co.real_logic.agrona.concurrent.CountersReader.COUNTER_LENGTH;
import static uk.co.real_logic.agrona.concurrent.CountersReader.METADATA_LENGTH;
import static uk.co.real_logic.agrona.concurrent.status.CountersReader.COUNTER_LENGTH;
import static uk.co.real_logic.agrona.concurrent.status.CountersReader.METADATA_LENGTH;

public class CountersManagerTest
{
Expand Down

0 comments on commit 027a3b3

Please sign in to comment.