ViewVC Help
View File | Revision Log | View Changeset | Root Listing
root/Oni2/oup/current/DataAccess/Access_OniArchive.pas
(Generate patch)

Comparing oup/current/DataAccess/Access_OniArchive.pas (file contents):
Revision 116 by alloc, Mon Feb 26 22:57:02 2007 UTC vs.
Revision 241 by alloc, Tue Jul 17 22:27:16 2007 UTC

# Line 15 | Line 15 | type
15      FDatOpened:          Boolean;
16      FRawOpened:          Boolean;
17      FSepOpened:          Boolean;
18 +    procedure SetUnloadWhenUnused(doit: Boolean);
19    protected
20    public
21 <    property UnloadWhenUnused: Boolean Read FUnloadWhenUnused Write FUnloadWhenUnused;
21 >    property UnloadWhenUnused: Boolean Read FUnloadWhenUnused Write SetUnloadWhenUnused;
22  
23      constructor Create(DatFilename: String; ConnectionID: Integer; var Msg: TStatusMessages); override;
24      procedure Close; override;
# Line 37 | Line 38 | type
38      function GetDatLink(FileID, DatOffset: Integer): TDatLink; override;
39      function GetRawList(FileID: Integer): TRawDataList; override;
40      function GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo; override;
41 +    function GetRawsForType(RawType: String): TRawDataList; override;
42  
43 <    procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer);
43 >    procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream); overload;
44 >    procedure LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer); overload;
45      procedure LoadRawFile(FileID, DatOffset: Integer; var Target: TStream); overload; override;
46      procedure UpdateRawFile(FileID, DatOffset: Integer; Src: TStream); overload; override;
47      procedure LoadRawFilePart(FileID, DatOffset, Offset, Size: Integer; var Target: TStream); overload; override;
# Line 51 | Line 54 | type
54   implementation
55  
56   uses
57 <  SysUtils, StrUtils, Data, Functions, RawList, DatLinks;
57 >  SysUtils, StrUtils, Data, Functions, RawList, DatLinks, Math;
58  
59  
60   (*
# Line 158 | Line 161 | begin
161    FBackend := DB_ONI;
162    FConnectionID := ConnectionID;
163    FChangeRights := [CR_EditDat, CR_EditRaw, CR_AppendRaw];
164 +
165 +  inherited;
166   end;
167  
168  
169  
170  
171 + procedure TAccess_OniArchive.SetUnloadWhenUnused(doit: Boolean);
172 + begin
173 +  FUnloadWhenUnused := doit;
174 +  if FUnloadWhenUnused then
175 +  begin
176 +    if FDatOpened then
177 +    begin
178 +      FDatOpened := False;
179 +      Fdat_file.Free;
180 +    end;
181 +    if FRawOpened then
182 +    begin
183 +      FRawOpened := False;
184 +      Fraw_file.Free;
185 +    end;
186 +    if FSepOpened then
187 +    begin
188 +      FSepOpened := False;
189 +      Fsep_file.Free;
190 +    end;
191 +  end
192 +  else
193 +  begin
194 +    if not FDatOpened then
195 +    begin
196 +      Fdat_file := TFileStream.Create(FFileName, fmOpenReadWrite);
197 +      FDatOpened := True;
198 +    end;
199 +    if not FRawOpened then
200 +    begin
201 +      Fraw_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.raw'),
202 +        fmOpenReadWrite);
203 +      FRawOpened := True;
204 +    end;
205 +    if (not FSepOpened) and (FDataOS <> DOS_WIN) then
206 +    begin
207 +      Fsep_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.sep'),
208 +        fmOpenReadWrite);
209 +      FSepOpened := True;
210 +    end;
211 +  end;
212 + end;
213 +
214 +
215 +
216 +
217 +
218   procedure TAccess_OniArchive.Close;
219   begin
220    if FDatOpened then
# Line 233 | Line 285 | var
285   begin
286    list := TStringList.Create;
287    list.Sorted := True;
288 +  if ext = '*' then
289 +    ext := '';
290    for i := 0 to GetFileCount - 1 do
291    begin
292      if ((Length(ext) = 0) or (Pos(Fdat_files[i].Extension, ext) > 0)) and
# Line 318 | Line 372 | var
372   begin
373    if fileid < GetFileCount then
374    begin
375 <    if not Assigned(Target) then
322 <      Target := TMemoryStream.Create;
323 <    if not FDatOpened then
324 <      Fdat_file := TFileStream.Create(FFileName, fmOpenReadWrite);
325 <    Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
326 <    streampos := Target.Position;
327 <    Target.CopyFrom(Fdat_file, Fdat_files[fileid].Size);
328 <    Target.Seek(streampos, soFromBeginning);
329 <    if UnloadWhenUnused then
375 >    if GetFileInfo(FileID).Size > 0 then
376      begin
377 <      Fdat_file.Free;
378 <      FDatOpened := False;
379 <    end
380 <    else
381 <      FDatOpened := True;
377 >      if not Assigned(Target) then
378 >        Target := TMemoryStream.Create;
379 >      if not FDatOpened then
380 >        Fdat_file := TFileStream.Create(FFileName, fmOpenReadWrite);
381 >      Fdat_file.Seek(Fdat_files[fileid].DatAddr, soFromBeginning);
382 >      streampos := Target.Position;
383 >      Target.CopyFrom(Fdat_file, Fdat_files[fileid].Size);
384 >      Target.Seek(streampos, soFromBeginning);
385 >      if UnloadWhenUnused then
386 >      begin
387 >        Fdat_file.Free;
388 >        FDatOpened := False;
389 >      end
390 >      else
391 >        FDatOpened := True;
392 >    end;
393    end;
394   end;
395  
# Line 437 | Line 494 | begin
494   end;
495  
496  
497 + function TAccess_OniArchive.GetRawsForType(RawType: String): TRawDataList;
498 + var
499 +  i, j: Integer;
500 +  dats: TStrings;
501 +  list: TRawDataList;
502 + begin
503 +  dats := nil;
504 +  dats := GetFilesList(MidStr(RawType, 1, 4), '', True, ST_IDAsc);
505 +  for i := 0 to dats.Count - 1 do
506 +  begin
507 +    list := GetRawList(StrToInt(MidStr(dats.Strings[i], 1, 5)));
508 +    for j := 0 to Length(list) - 1 do
509 +    begin
510 +      if list[j].RawType = RawType then
511 +      begin
512 +        SetLength(Result, Length(Result)+1);
513 +        Result[High(Result)] := list[j];
514 +      end;
515 +    end;
516 +  end;
517 + end;
518 +
519 +
520   function TAccess_OniArchive.GetRawInfo(FileID, DatOffset: Integer): TRawDataInfo;
521   begin
522    Result := RawLists.GetRawInfo(FConnectionID, FileID, DatOffset);
# Line 444 | Line 524 | end;
524  
525  
526  
527 <
448 < procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer);
527 > procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; var target: TStream);
528   begin
529 +  if not Assigned(Target) then
530 +    Target := TMemoryStream.Create;
531    if not LocSep then
532    begin
533      if not FRawOpened then
# Line 455 | Line 536 | begin
536      if RawAddr <= Fraw_file.Size then
537      begin
538        Fraw_file.Seek(RawAddr, soFromBeginning);
539 <      Fraw_file.Read(target^, size);
539 >      Target.CopyFrom(Fraw_file, size);
540 >      Target.Seek(0, soFromBeginning);
541      end;
542      if UnloadWhenUnused then
543      begin
# Line 473 | Line 555 | begin
555      if RawAddr <= Fsep_file.Size then
556      begin
557        Fsep_file.Seek(RawAddr, soFromBeginning);
558 <      Fsep_file.Read(target^, size);
558 >      Target.CopyFrom(Fsep_file, size);
559 >      Target.Seek(0, soFromBeginning);
560      end;
561      if UnloadWhenUnused then
562      begin
# Line 485 | Line 568 | begin
568    end;
569   end;
570  
571 + procedure TAccess_OniArchive.LoadRawOffset(LocSep: Boolean; RawAddr, Size: Integer; target: Pointer);
572 + var
573 +  data: TStream;
574 + begin
575 +  data := nil;
576 +  LoadRawOffset(LocSep, RawAddr, Size, data);
577 +  data.Read(Target^, Size);
578 +  data.Free;
579 + end;
580 +
581   procedure TAccess_OniArchive.LoadRawFile(FileID, DatOffset: Integer; var Target: TStream);
582   var
583    raw_info: TRawDataInfo;
# Line 545 | Line 638 | begin
638          Fraw_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.raw'),
639            fmOpenReadWrite);
640        Fraw_file.Seek(raw_info.RawAddr, soFromBeginning);
641 <      Fraw_file.CopyFrom(Src, raw_info.RawSize);
641 >      Fraw_file.CopyFrom(Src, Min(raw_info.RawSize, Src.Size));
642        if UnloadWhenUnused then
643        begin
644          FRawOpened := False;
# Line 590 | Line 683 | begin
683    end;
684   end;
685  
686 +
687   procedure TAccess_OniArchive.UpdateRawFilePart(FileID, DatOffset, Offset, Size: Integer; Src: TStream);
688   var
689    raw_info: TRawDataInfo;
# Line 631 | Line 725 | begin
725   end;
726  
727   function TAccess_OniArchive.AppendRawFile(LocSep: Boolean; Src: TStream): Integer;
728 + const
729 +  EmptyBytes: Array[0..31] of Byte = (
730 +      0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0,0 );
731   begin
732    if not LocSep then
733    begin
734      if not FRawOpened then
735        Fraw_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.raw'),
736          fmOpenReadWrite);
737 +    if (Fraw_file.Size mod 32) > 0 then
738 +      Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
739      Result := Fraw_file.Size;
740      Fraw_file.Seek(0, soFromEnd);
741      Fraw_file.CopyFrom(Src, Src.Size);
742 +    if (Fraw_file.Size mod 32) > 0 then
743 +      Fraw_file.Write(EmptyBytes[0], 32 - (Fraw_file.Size mod 32));
744      if UnloadWhenUnused then
745      begin
746        FRawOpened := False;
# Line 653 | Line 754 | begin
754      if not FSepOpened then
755        Fsep_file := TFileStream.Create(AnsiReplaceStr(FFileName, '.dat', '.sep'),
756          fmOpenReadWrite);
757 +    if (Fsep_file.Size mod 32) > 0 then
758 +      Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
759      Result := Fsep_file.Size;
760      Fsep_file.Seek(0, soFromEnd);
761      Fsep_file.CopyFrom(Src, Src.Size);
762 +    if (Fsep_file.Size mod 32) > 0 then
763 +      Fsep_file.Write(EmptyBytes[0], 32 - (Fsep_file.Size mod 32));
764      if UnloadWhenUnused then
765      begin
766        FSepOpened := False;

Diff Legend

Removed lines
+ Added lines
< Changed lines (old)
> Changed lines (new)