blob: 01e89eb23612c74d07f38eb874633bd352102e59 [file]
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software 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.apache.datasketches.common.positional;
/**
* This implements the positional API.
* This is different from and simpler than Java BufferImpl positional approach.
* <ul><li>All based on longs instead of ints.</li>
* <li>Eliminated "mark". Rarely used and confusing with its silent side effects.</li>
* <li>The invariants are {@code 0 <= start <= position <= end <= capacity}.</li>
* <li>It always starts up as (0, 0, capacity, capacity).</li>
* <li>You set (start, position, end) in one call with <i>setStartPositionEnd(long, long, long)</i></li>
* <li>Position can be set directly or indirectly when using the positional get/put methods.
* <li>Added incrementPosition(long), which is much easier when you know the increment.</li>
* <li>This approach eliminated a number of methods and checks, and has no unseen side effects,
* e.g., mark being invalidated.</li>
* <li>Clearer method naming (IMHO).</li>
* </ul>
*
* @author Lee Rhodes
*/
class PositionalImpl implements Positional {
private final long capacity;
private long start = 0;
private long pos = 0;
private long end;
/**
* Construct with total capacity.
* @param capacity the upper limit of positional range.
*/
PositionalImpl(
final long capacity) {
this.capacity = end = capacity;
}
@Override
public final PositionalImpl incrementPosition(final long increment) {
pos += increment;
return this;
}
@Override
public final long getEnd() {
return end;
}
@Override
public final long getPosition() {
return pos;
}
@Override
public final long getStart() {
return start;
}
@Override
public final long getRemaining() {
return end - pos;
}
@Override
public final boolean hasRemaining() {
return (end - pos) > 0;
}
@Override
public final PositionalImpl resetPosition() {
pos = start;
return this;
}
@Override
public final PositionalImpl setPosition(final long position) {
checkInvariants(start, position, end, capacity);
pos = position;
return this;
}
@Override
public final PositionalImpl setStartPositionEnd(final long start, final long position, final long end) {
checkInvariants(start, position, end, capacity);
this.start = start;
this.end = end;
pos = position;
return this;
}
//RESTRICTED
/**
* The invariants equation is: {@code 0 <= start <= position <= end <= capacity}.
* If this equation is violated an <i>PositionInvariantsException</i> will be thrown.
* @param start the lowest start position
* @param pos the current position
* @param end the highest position
* @param cap the capacity of the backing resource.
*/
private static final void checkInvariants(final long start, final long pos, final long end,
final long cap) {
if ((start | pos | end | cap | (pos - start) | (end - pos) | (cap - end) ) < 0L) {
throw new PositionInvariantsException(
"Violation of Invariants: "
+ "start: " + start
+ " <= pos: " + pos
+ " <= end: " + end
+ " <= cap: " + cap
+ "; (pos - start): " + (pos - start)
+ ", (end - pos): " + (end - pos)
+ ", (cap - end): " + (cap - end)
);
}
}
}