/*
Исходный код среды исполнения ПВТ-ОО.
Этот исходный код является частью проекта ПВТ-ОО.
Copyright © 2021 Малик Разработчик
Это свободная программа: вы можете перераспространять её и/или
изменять её на условиях Меньшей Стандартной общественной лицензии GNU в том виде,
в каком она была опубликована Фондом свободного программного обеспечения;
либо версии 3 лицензии, либо (по вашему выбору) любой более поздней версии.
Эта программа распространяется в надежде, что она может быть полезна,
но БЕЗО ВСЯКИХ ГАРАНТИЙ; даже без неявной гарантии ТОВАРНОГО ВИДА
или ПРИГОДНОСТИ ДЛЯ ОПРЕДЕЛЁННЫХ ЦЕЛЕЙ. Подробнее см. в Меньшей Стандартной
общественной лицензии GNU.
Вы должны были получить копию Меньшей Стандартной общественной лицензии GNU
вместе с этой программой. Если это не так, см.
<http://www.gnu.org/licenses/>.
*/
package avt.io;
import avt.io.extension.*;
public class ByteArrayInputStream(Object, Closeable, Extension, MarkExtension, ByteReader, LimitedSizeExtension, SeekExtension, Extendable)
{
package int fldLength;
package int fldPosition;
package byte[] fldArray;
package final Object fldReserved;
private int fldMarkedPosition;
public () { }
public (byte[] array) {
fldLength = array == null ? 0 : array.length;
fldArray = array;
}
public (byte[] array, int length) {
int alen = array == null ? 0 : array.length;
fldLength = length < 0 ? 0 : length > alen ? alen : length;
fldArray = array;
}
public (byte[] array, int length, int position) {
int alen = array == null ? 0 : array.length;
int slen = fldLength = length < 0 ? 0 : length > alen ? alen : length;
fldPosition = position < 0 ? 0 : position > slen ? slen : position;
fldArray = array;
}
public void close() { }
public void reset() { fldPosition = fldMarkedPosition; }
public void mark(int readLimit) { fldMarkedPosition = fldPosition; }
public int read() {
int pos = fldPosition;
if(pos >= fldLength) return -1;
int result = fldArray[pos++] & 0xffi;
fldPosition = pos;
return result;
}
public int read(byte[] dst) { return read(dst, 0, dst == null ? 0 : dst.length); }
public int read(byte[] dst, int offset, int length) {
if(dst == null)
{
throw new NullPointerException("аргумент dst равен нулевой ссылке");
}
Array.checkBounds(dst, offset, length);
if(length <= 0) return 0;
int pos = fldPosition;
int rem = fldLength - pos;
if(rem <= 0) return -1;
int result = rem > length ? length : rem;
Array.copy(fldArray, pos, dst, offset, result);
fldPosition = pos + result;
return result;
}
public long skip(long bytesQuantity) {
if(bytesQuantity <= 0L) return 0L;
int length = bytesQuantity > (long) Int.MAX_VALUE ? Int.MAX_VALUE : (int) bytesQuantity;
int pos = fldPosition;
int rem = fldLength - pos;
int result = rem > length ? length : rem;
fldPosition = pos + result;
return (long) result;
}
public long available() { return (long) (fldLength - fldPosition); }
public long position() { return (long) fldPosition; }
public long size() { return (long) fldLength; }
public long seek(long offset, int from) {
long pos;
long length = (long) fldLength;
switch(from)
{
case BEGIN:
pos = offset;
break;
case END:
pos = offset + length;
break;
case CURRENT:
pos = offset + (long) fldPosition;
break;
default:
throw new IllegalArgumentException("аргумент from имеет недопустимое значение");
}
if(pos < 0L) pos = 0L;
if(pos > length) pos = length;
return (long) (fldPosition = (int) pos);
}
public Extension[] getExtensions() { return new Extension[] { this }; }
package final void notifyLengthChanged(int length) {
if(fldPosition > length) fldPosition = length;
if(fldMarkedPosition > length) fldMarkedPosition = length;
}
}