Ковальчук Владислав M33371 HW5 #285
Conversation
(cherry picked from commit 5ac9637)
|
|
||
| @Override | ||
| public E next() { | ||
| E entry = extractor.readEntry(storageSegment, start); |
There was a problem hiding this comment.
Согласно спецификации у тебя должно бросаться NoSuchElementException, если следующего элемента нет. На каком этапе ты его бросаешь?
There was a problem hiding this comment.
Добавил
if (!hasNext()) {
throw new NoSuchElementException();
}
в начало метода.
В принципе этот класс разработан для внутреннего использования, merge iterator для внешнего (там кидается NoSuchElementException)
|
|
||
| /** | ||
| * Вставляет значение и возвращает размер стораджа, по которому можно судить нужно ли планировать flush. | ||
| * Бросает MemoryOverflowException если достигнут порог по размеру, а предыдущий flush() еще выполняется или упал. |
There was a problem hiding this comment.
То есть, если у тебя на шаге n не был достигнут порог, а на шаге n+1 уже стал, то ты кинешь ошибку?
There was a problem hiding this comment.
Да, но если предыдущий flush() еще не выполнился.
То есть если после n+1 шага порог достигнут, начинаем флашить и очищаем мапу. Если уже до этого что то флашили и не закончили, то не успеваем.
Сделано под это условие:
В случаях, когда flush не поспевает за вставкой данных (одна полная таблица всё ещё пишется на диск, в то время как заполнилась следующая таблица), параллельные
upsert()ы должны бросать исключение -- тем самым мы сигнализируем клиенту о перегрузке и избегаем падения поOutOfMemory
Если тут есть проблема, не понял в чем она
| } | ||
| } | ||
|
|
||
| @SuppressWarnings("unused") |
There was a problem hiding this comment.
Может добавить в него состояние, что она не запущенна? (когда не нужно делать flush). Тогда
- Ты сможешь создать её в конструкторе
- Не нужно будет вешать
volatile, который может замедлить производительность - Пропадут свистопляски с созданием и переводом в
null
There was a problem hiding this comment.
И думаю тогда компилятор перестанет ругаться
There was a problem hiding this comment.
volatile вешать все равно нужно, так как это record и он immutable. По остальным пунктам согласен, сделал красивее.
There was a problem hiding this comment.
Компилятор не перестал ругаться :(
| } | ||
| @Override | ||
| public void upsert(E entry) { | ||
| long size = inMemoryStorage.upsertAndGetSize(entry); |
There was a problem hiding this comment.
Получается, что если хранилище переполненно и кто-то в другом потоке сделал flush, то у тебя полетит ошибка? И ты никак это не отлавливаешь?
There was a problem hiding this comment.
Не полетят если flush поспевает за вставкой данных.
Допустим, сейчас на диск ничего не флашится и хранилище переполнено.
Вызвали одновременно flush() и upsert().
Внутри flush() под writeLock'ом меняется state на RUNNING, очищается мапа и размер становится 0.
Внутри upsert() кидаются MemoryOverflowException, если размер превышет лимит и state RUNNING или FAILED. Размер и state читается под readLock'ом.
Благодаря локам все будет корректно.
Ошибку кидать разумно, так как в случае RUNNING flush() уже выполняется, и пока он выполняется мы успели опять накопить полную таблицу, не успеваем. В случае FAILED, произошла ошибка при flush(), из памяти мы не ничего удаляли чтобы не потерять. Тоже кидаем MemoryOverflowException, так как есть полная таблица и таблица на flush, что превывает лимит.
| stateLock.writeLock().lock(); | ||
| try { | ||
| if (flushingDaoState != null && flushingDaoState.isRunning()) { | ||
| return null; |
There was a problem hiding this comment.
А как мне понять, что у мне уже можно делать upsert? У меня же flush просто вернётся и я не смогу понять до каких моментов нельзя вставлять
There was a problem hiding this comment.
Можно добавить возвращаемое значение для flush(), но сейчас он void() и я не могу поменять код Dao.java, так как сломает код других студентов.
С точки зрения приложения-клиента разве что попытаться попозже. Ну или когда во 2 семестре будем делать уже полноценную бд на нодах можно задуматься. Если вся бд падает то в случае продовой ситуации там уже должно быть куча ошибок в логах и надо разбираться что не так :)
| FileChannel offsets = FileChannel.open(offsetsPath, WRITE_OPTIONS); | ||
| Arena arena = Arena.ofConfined()) { | ||
|
|
||
| long offsetsSize = info.recordsCount() * Long.BYTES; |
There was a problem hiding this comment.
Long.BYTES лучше вынести в константу, иначе люди, которые не смотрели лекций от одноклассников, могут просто не понять что это и зачем
There was a problem hiding this comment.
Вынес в OFFSET_SIZE
dr