LoggableActions.java
| Index Score | ||
|---|---|---|
![]() |
![]() |
org.apache.derby.impl.store.raw.data |
![]() |
![]() |
Apache Derby |
View: Reasons, Metrics, Source Code
These are the metrics that contribute to the Enerjy Score for this file, ranked by impact. So the metrics listed at the top influence the score to a greater extent that the metrics listed at the bottom.
/*
Derby - Class org.apache.derby.impl.store.raw.data.LoggableActions
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.derby.impl.store.raw.data;
import org.apache.derby.impl.store.raw.data.PageActions;
import org.apache.derby.impl.store.raw.data.BasePage;
import org.apache.derby.iapi.services.io.FormatIdUtil;
import org.apache.derby.iapi.store.access.conglomerate.LogicalUndo;
import org.apache.derby.iapi.store.raw.xact.RawTransaction;
import org.apache.derby.iapi.store.raw.RecordHandle;
import org.apache.derby.iapi.store.raw.Loggable;
import org.apache.derby.iapi.store.raw.log.LogInstant;
import org.apache.derby.iapi.error.StandardException;
import org.apache.derby.iapi.types.DataValueDescriptor;
import org.apache.derby.iapi.services.sanity.SanityManager;
import org.apache.derby.iapi.services.io.FormatableBitSet;
import org.apache.derby.iapi.services.io.DynamicByteArrayOutputStream;
import org.apache.derby.iapi.services.io.DynamicByteArrayOutputStream;
import java.io.IOException;
public class LoggableActions implements PageActions {
public void actionDelete(
RawTransaction t,
BasePage page,
int slot,
int recordId,
boolean delete,
LogicalUndo undo)
throws StandardException
{
DeleteOperation lop =
new DeleteOperation(t, page, slot, recordId, delete, undo);
doAction(t, page, lop);
}
public int actionUpdate(
RawTransaction t,
BasePage page,
int slot,
int recordId,
Object[] row,
FormatableBitSet validColumns,
int realStartColumn,
DynamicByteArrayOutputStream logBuffer,
int realSpaceOnPage,
RecordHandle headRowHandle)
throws StandardException
{
UpdateOperation lop =
new UpdateOperation(t, page, slot, recordId, row, validColumns,
realStartColumn, logBuffer,
realSpaceOnPage, headRowHandle);
doAction(t, page, lop);
return lop.getNextStartColumn();
}
public void actionPurge(
RawTransaction t,
BasePage page,
int slot,
int num_rows,
int[] recordIds,
boolean logData)
throws StandardException
{
PurgeOperation lop =
new PurgeOperation(t, page, slot, num_rows, recordIds, logData);
doAction(t, page, lop);
}
public void actionUpdateField(
RawTransaction t,
BasePage page,
int slot,
int recordId,
int fieldId,
Object newValue,
LogicalUndo undo)
throws StandardException
{
UpdateFieldOperation lop =
new UpdateFieldOperation(
t, page, slot, recordId, fieldId, newValue, undo);
doAction(t, page, lop);
}
public int actionInsert(
RawTransaction t,
BasePage page,
int slot,
int recordId,
Object[] row,
FormatableBitSet validColumns,
LogicalUndo undo,
byte insertFlag,
int startColumn,
boolean isLongColumn,
int realStartColumn,
DynamicByteArrayOutputStream logBuffer,
int realSpaceOnPage,
int overflowThreshold)
throws StandardException
{
InsertOperation lop = new InsertOperation(t, page, slot, recordId,
row, validColumns, undo, insertFlag, startColumn, isLongColumn,
realStartColumn, logBuffer, realSpaceOnPage, overflowThreshold);
doAction(t, page, lop);
return (lop.getNextStartColumn());
}
public void actionCopyRows(
RawTransaction t,
BasePage destPage,
BasePage srcPage,
int srcSlot,
int numRows,
int destSlot,
int[] recordIds)
throws StandardException
{
CopyRowsOperation lop =
new CopyRowsOperation(
t, destPage, srcPage,srcSlot, numRows, destSlot, recordIds);
doAction(t, destPage, lop);
}
public void actionInvalidatePage(RawTransaction t, BasePage page)
throws StandardException
{
InvalidatePageOperation lop = new InvalidatePageOperation(page);
doAction(t, page, lop);
}
public void actionInitPage(
RawTransaction t,
BasePage page,
int initFlag,
int pageFormatId,
long pageOffset)
throws StandardException
{
InitPageOperation lop =
new InitPageOperation(page, initFlag, pageFormatId, pageOffset);
doAction(t, page, lop);
}
public void actionShrinkReservedSpace(
RawTransaction t,
BasePage page,
int slot,
int recordId,
int newValue,
int oldValue)
throws StandardException
{
SetReservedSpaceOperation lop =
new SetReservedSpaceOperation(
page, slot, recordId, newValue, oldValue);
doAction(t, page, lop);
}
private void doAction(RawTransaction t, BasePage page, Loggable lop)
throws StandardException
{
long oldversion = 0; // sanity check
LogInstant oldLogInstant = null; // sanity check
if (SanityManager.DEBUG)
{
oldLogInstant = page.getLastLogInstant();
oldversion = page.getPageVersion();
}
// mark the page as pre-dirtied so that if a checkpoint happens after
// the log record is sent to the log stream, the cache cleaning will
// wait for this change.
page.preDirty();
t.logAndDo(lop);
if (SanityManager.DEBUG) {
// log instant may not supported by underlying log factory, in that
// case, it is expected to stay null
if (oldLogInstant != null && page.getLastLogInstant() != null &&
! oldLogInstant.lessThan(page.getLastLogInstant()))
SanityManager.THROWASSERT(
"old log instant = " + oldLogInstant +
" lastlog = " + page.getLastLogInstant() );
SanityManager.ASSERT(
oldversion == ((PageBasicOperation)lop).getPageVersion());
SanityManager.ASSERT(page.getPageVersion() > oldversion);
}
}
}
The table below shows all metrics for LoggableActions.java.




