1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
unit lesethreadunit;
{$mode objfpc}{$H+}
interface
uses
Classes, SysUtils, Process, Math;
type
tLeseProzess = class
private
prozess: tProcess;
puffer: string;
_anzahl,sollVorrat: longint;
function rAnzahl: longint;
procedure fuelleVorrat;
public
property anzahl: longint read rAnzahl;
constructor create(dateiName: string; vorratsZeilen: longint);
destructor destroy; override;
function gibZeile(out s: string): boolean;
end;
implementation
// tLeseThread *****************************************************************
constructor tLeseProzess.create(dateiName: string; vorratsZeilen: longint);
begin
inherited create;
puffer:='';
_anzahl:=0;
sollVorrat:=vorratsZeilen;
prozess:=tProcess.create(nil);
prozess.executable:='/usr/bin/tail';
prozess.parameters.add('-f');
prozess.parameters.add(dateiName);
prozess.options:=prozess.options + [poUsePipes];
prozess.execute;
sleep(100);
end;
destructor tLeseProzess.destroy;
begin
prozess.free;
puffer:='';
inherited destroy;
end;
function tLeseProzess.rAnzahl: longint;
begin
fuelleVorrat;
result:=_anzahl;
end;
procedure tLeseProzess.fuelleVorrat;
var
s: string;
len,i: longint;
const
maxLen = 1024*1024;
begin
while (_anzahl<sollVorrat) and (prozess.output.numBytesAvailable>0) do begin
setlength(s,min(maxLen,prozess.output.numBytesAvailable));
len:=prozess.output.read(s[1],length(s));
for i:=1 to len do
_anzahl:=_anzahl+byte(s[i]=#10);
puffer:=puffer+copy(s,1,len);
end;
end;
function tLeseProzess.gibZeile(out s: string): boolean;
begin
result:=anzahl>0;
if not result then exit;
s:=copy(puffer,1,pos(#10,puffer)-1);
delete(puffer,1,pos(#10,puffer));
dec(_anzahl);
end;
end.
|
