* Correct reader signatures

This commit is contained in:
Michaël Van Canneyt 2021-08-11 22:03:36 +02:00
parent 2f81580e04
commit 25e937b0c9

View File

@ -540,8 +540,6 @@ type
function GetFieldSize(FieldDef : TFieldDef) : longint; function GetFieldSize(FieldDef : TFieldDef) : longint;
procedure CalcRecordSize; procedure CalcRecordSize;
function IntAllocRecordBuffer: TRecordBuffer; function IntAllocRecordBuffer: TRecordBuffer;
procedure IntLoadFieldDefsFromPacket(aReader : TDataPacketReader);
procedure IntLoadRecordsFromPacket(aReader : TDataPacketReader);
function GetCurrentBuffer: TRecordBuffer; function GetCurrentBuffer: TRecordBuffer;
procedure CurrentRecordToBuffer(Buffer: TRecordBuffer); procedure CurrentRecordToBuffer(Buffer: TRecordBuffer);
function LoadBuffer(Buffer : TRecordBuffer): TGetResult; function LoadBuffer(Buffer : TRecordBuffer): TGetResult;
@ -551,7 +549,9 @@ type
function GetActiveRecordUpdateBuffer : boolean; function GetActiveRecordUpdateBuffer : boolean;
procedure CancelRecordUpdateBuffer(AUpdateBufferIndex: integer; var ABookmark: TBufBookmark); procedure CancelRecordUpdateBuffer(AUpdateBufferIndex: integer; var ABookmark: TBufBookmark);
procedure ParseFilter(const AFilter: string); procedure ParseFilter(const AFilter: string);
// Packet handling
procedure IntLoadFieldDefsFromPacket(aReader : TDataPacketHandler); virtual;
procedure IntLoadRecordsFromPacket(aReader : TDataPacketHandler); virtual;
function GetBufUniDirectional: boolean; function GetBufUniDirectional: boolean;
// indexes handling // indexes handling
function GetIndexDefs : TIndexDefs; function GetIndexDefs : TIndexDefs;
@ -661,8 +661,8 @@ type
const ACaseInsFields: string = ''); virtual; const ACaseInsFields: string = ''); virtual;
procedure ClearIndexes; procedure ClearIndexes;
procedure SetDatasetPacket(AReader : TDataPacketReader); procedure SetDatasetPacket(AReader : TDataPacketHandler);
procedure GetDatasetPacket(AWriter : TDataPacketReader); procedure GetDatasetPacket(AWriter : TDataPacketHandler);
procedure LoadFromStream(AStream : TStream; Format: TDataPacketFormat = dfDefault); procedure LoadFromStream(AStream : TStream; Format: TDataPacketFormat = dfDefault);
procedure SaveToStream(AStream : TStream; Format: TDataPacketFormat = dfBinary); procedure SaveToStream(AStream : TStream; Format: TDataPacketFormat = dfBinary);
procedure LoadFromFile(AFileName: string = ''; Format: TDataPacketFormat = dfDefault); procedure LoadFromFile(AFileName: string = ''; Format: TDataPacketFormat = dfDefault);
@ -3468,7 +3468,7 @@ begin
Result := TBufBlobStream.Create(Field as TBlobField, Mode); Result := TBufBlobStream.Create(Field as TBlobField, Mode);
end; end;
procedure TCustomBufDataset.SetDatasetPacket(AReader: TDataPacketReader); procedure TCustomBufDataset.SetDatasetPacket(AReader: TDataPacketHandler);
begin begin
FPacketHandler := AReader; FPacketHandler := AReader;
try try
@ -3478,7 +3478,7 @@ begin
end; end;
end; end;
procedure TCustomBufDataset.GetDatasetPacket(AWriter: TDataPacketReader); procedure TCustomBufDataset.GetDatasetPacket(AWriter: TDataPacketHandler);
procedure StoreUpdateBuffer(AUpdBuffer : TRecUpdateBuffer; var ARowState: TRowState); procedure StoreUpdateBuffer(AUpdBuffer : TRecUpdateBuffer; var ARowState: TRowState);
var AThisRowState : TRowState; var AThisRowState : TRowState;
@ -3699,7 +3699,7 @@ begin
Result := -1; Result := -1;
end; end;
procedure TCustomBufDataset.IntLoadFieldDefsFromPacket(aReader : TDataPacketReader); procedure TCustomBufDataset.IntLoadFieldDefsFromPacket(aReader : TDataPacketHandler);
begin begin
FReadFromFile := True; FReadFromFile := True;
@ -3711,7 +3711,7 @@ begin
BindFields(true); BindFields(true);
end; end;
procedure TCustomBufDataset.IntLoadRecordsFromPacket(aReader : TDataPacketReader); procedure TCustomBufDataset.IntLoadRecordsFromPacket(aReader : TDataPacketHandler);
var var
SavedState : TDataSetState; SavedState : TDataSetState;