udr/client/FBActivityMonitor.pas

(*
 *  Firebird Interface (fbintf). The fbintf components provide a set of
 *  Pascal language bindings for the Firebird API.
 *
 *  The contents of this file are subject to the Initial Developer's
 *  Public License Version 1.0 (the "License"); you may not use this
 *  file except in compliance with the License. You may obtain a copy
 *  of the License here:
 *
 *    http://www.firebirdsql.org/index.php?op=doc&id=idpl
 *
 *  Software distributed under the License is distributed on an "AS
 *  IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
 *  implied. See the License for the specific language governing rights
 *  and limitations under the License.
 *
 *  The Initial Developer of the Original Code is Tony Whyman.
 *
 *  The Original Code is (C) 2016 Tony Whyman, MWA Software
 *  (http://www.mwasoftware.co.uk).
 *
 *  All Rights Reserved.
 *
 *  Contributor(s): ______________________________________.
 *
*)
unit FBActivityMonitor;

{$IFDEF FPC}
{$mode objfpc}{$H+}
{$interfaces COM}
{$ENDIF}

interface

uses
  Classes, SysUtils, IBExternals;

  { $DEFINE DEBUGINTERFACES}   {Define this to check that all interfaces are
                                being destroyed.}

type
  { TMonitoredObject is an optional class used to journal all interface creatino
   and deletion as well as keeping a count of how many monitored interfaces
   exist at any one time. It is used at development to look for memory leaks
   due to interfaces not being discarded when no longer used.}

  {$IFDEF DEBUGINTERFACES}
  TMonitoredObject = class(TInterfacedObject)
  private
    FObjectCount: integer; static;
  public
    constructor Create;
    destructor Destroy; override;
  end;

  {TFBInterfacedObject is used as the base class for interfaces objects and can
   be either a synonym for TInterfacedObject (default) or TMonitored object}

    TFBInterfacedObject = TMonitoredObject;
  {$ELSE}
    TFBInterfacedObject = TInterfacedObject;
  {$ENDIF}

  { TInterfaceOwner }

  TInterfaceOwner = class(TFBInterfacedObject)
  private
    FInterfaces: array of TInterfacedObject;
    FInterfaceRefs: array of IUnknown;
    FRetainInterfaces: boolean;
    FMinInterfaces: integer;
    function GetCount: integer;
    procedure SetRetainInterfaces(AValue: boolean);
  protected
    procedure AddInterface(index: integer; obj: TInterfacedObject);
    function HasInterface(index: integer): boolean;
    procedure ReleaseInterfaces;
  public
    constructor Create(aInterfaces: integer=0);
    destructor Destroy; override;
    procedure AddObject(obj: TInterfacedObject);
    function GetInterface(index: integer): TInterfacedObject;
    procedure Remove(intf: TInterfacedObject);
    property InterfaceCount: integer read GetCount;
    property RetainInterfaces: boolean read FRetainInterfaces write SetRetainInterfaces;
  end;

  {The IActivityMonitor interface is provided by classes that receive activity
   reports.}

  IActivityMonitor = interface
    procedure AddObject(obj: TInterfacedObject);
    procedure Remove(intf: TInterfacedObject);
    procedure SignalActivity;
  end;

  { TActivityReporter is a base class for objects that need to report their activity
    to an activity monitor, where activity is defined as use of a Firebird API call.
    Objects descending from this class always used the "Call" method as a wrapper
    for calls to the Firebird API. Each such call is then classed as activity
    and reported to one or more activity monitors.

    In practice, a transaction monitors statements, blobs and arrays. A Database
    monitors transactions and events. Transaction monitors use the ITransactionMonitor
    interface, implemented through the helper object TTransactionMonitor.
  }

  TActivityReporter = class(TInterfaceOwner)
  private
    FHasActivity: boolean;
    FMonitors: array of IActivityMonitor;
    function FindMonitor(aMonitor: IActivityMonitor): integer;
  protected
    function Call(ErrCode: ISC_STATUS; RaiseError: Boolean = true): ISC_STATUS;
    procedure AddMonitor(aMonitor: IActivityMonitor);
    procedure RemoveMonitor(aMonitor: IActivityMonitor);
  public
    constructor Create(aMonitor: IActivityMonitor;aInterfaces: integer=0);
    destructor Destroy; override;
    function HasActivity: boolean;
    procedure SignalActivity;
  end;

  { TActivityHandler is a base class for classes that receive activity reports.}

  TActivityHandler = class(TInterfaceOwner,IActivityMonitor)
  private
    FHasActivity: boolean;
  public
    function HasActivity: boolean;
    procedure SignalActivity;
  end;

implementation

uses FB25ClientAPI;

{ TActivityHandler }

function TActivityHandler.HasActivity: boolean;
begin
  Result := FHasActivity;
  FHasActivity := false;
end;

procedure TActivityHandler.SignalActivity;
begin
  FHasActivity := true;
end;

{ TMonitoredObject }

{$IFDEF DEBUGINTERFACES}
constructor TMonitoredObject.Create;
begin
  inherited Create;
  Inc(FObjectCount);
  writeln('Creating ' + ClassName,', Obj Count = ',FObjectCount);
end;

destructor TMonitoredObject.Destroy;
begin
  Dec(FObjectCount);
  writeln('Destroying ' + ClassName,' Obj Count = ',FObjectCount);
  inherited Destroy;
end;
{$ENDIF}

{ TActivityReporter}

function TActivityReporter.FindMonitor(aMonitor: IActivityMonitor): integer;
var i: integer;
begin
  Result := -1;
  for i := 0 to Length(FMonitors) - 1 do
    if FMonitors[i] = aMonitor then
    begin
      Result := i;
      Exit;
    end;
end;

function TActivityReporter.Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS;
begin
  result := ErrCode;
  SignalActivity;
  if RaiseError and (ErrCode > 0) then
    Firebird25ClientAPI.IBDataBaseError;
end;

procedure TActivityReporter.AddMonitor(aMonitor: IActivityMonitor);
var i: integer;
begin
  if FindMonitor(aMonitor) = -1 then
  begin
    i := Length(FMonitors);
    Setlength(FMonitors,i+1);
    FMonitors[i] := aMonitor;
    aMonitor.AddObject(self);
  end;
end;

procedure TActivityReporter.RemoveMonitor(aMonitor: IActivityMonitor);
var i,j: integer;
begin
  i := FindMonitor(aMonitor);
  if i <> -1 then
  begin
    aMonitor.Remove(self);
    if Length(FMonitors) = 1 then
      SetLength(FMonitors,0)
    else
    begin
      for j := i + 1 to Length(FMonitors) - 1 do
        FMonitors[j-1] := FMonitors[j];
      SetLength(FMonitors,Length(FMonitors)-1);
    end;
  end;
end;

procedure TActivityReporter.SignalActivity;
var i: integer;
begin
  FHasActivity := true;
  for i := 0 to Length(FMonitors) - 1 do
      FMonitors[i].SignalActivity;
end;

constructor TActivityReporter.Create(aMonitor: IActivityMonitor;
  aInterfaces: integer);
begin
  inherited Create(aInterfaces);
  if aMonitor <> nil then
  begin
    SetLength(FMonitors,1);
    FMonitors[0] := aMonitor;
  end;
end;

destructor TActivityReporter.Destroy;
var i: integer;
begin
  for i := 0 to Length(FMonitors) - 1 do
    FMonitors[i].Remove(self);
  inherited Destroy;
end;

function TActivityReporter.HasActivity: boolean;
begin
  Result := FHasActivity;
  FHasActivity := false;
end;

{ TInterfaceOwner }

constructor TInterfaceOwner.Create(aInterfaces: integer);
begin
  inherited Create;
  FMinInterfaces := aInterfaces;
  SetLength(FInterfaces,aInterfaces);
  SetLength(FInterfaceRefs,aInterfaces);
end;

destructor TInterfaceOwner.Destroy;
begin
  ReleaseInterfaces;
  inherited Destroy;
end;

procedure TInterfaceOwner.AddObject(obj: TInterfacedObject);
var index: integer;
begin
  index := Length(FInterfaces);
  SetLength(FInterfaces,index+1);
  SetLength(FInterfaceRefs,index+1);
  AddInterface(index,obj);
end;

function TInterfaceOwner.GetInterface(index: integer): TInterfacedObject;
begin
  Result := FInterfaces[index];
end;

procedure TInterfaceOwner.SetRetainInterfaces(AValue: boolean);
begin
  if FRetainInterfaces = AValue then Exit;
  FRetainInterfaces := AValue;
  if not FRetainInterfaces then
    ReleaseInterfaces;
end;

function TInterfaceOwner.GetCount: integer;
begin
  Result := Length(FInterfaces);
end;

procedure TInterfaceOwner.AddInterface(index: integer; obj: TInterfacedObject);
begin
  FInterfaces[index] := obj;
  if RetainInterfaces then
    FInterfaceRefs[index] := obj;
end;

function TInterfaceOwner.HasInterface(index: integer): boolean;
begin
  Result := FInterfaces[index] <> nil;
end;

procedure TInterfaceOwner.Remove(intf: TInterfacedObject);
var i, j: integer;
begin
  for i := 0 to Length(FInterfaces) - 1 do
    if FInterfaces[i] = intf then
    begin
      if i < FMinInterfaces then
      begin
        FInterfaceRefs[i] := nil;
        FInterfaces[i] := nil;
      end
      else
      begin
        for j := i to Length(FInterfaces) - 2 do
        begin
          FInterfaceRefs[j] := FInterfaceRefs[j+1];
          FInterfaces[j] := FInterfaces[j+1];
        end;
        SetLength(FInterfaces,Length(FInterfaces)-1);
        SetLength(FInterfaceRefs,Length(FInterfaceRefs)-1);
      end;
      Exit;
    end;
end;

procedure TInterfaceOwner.ReleaseInterfaces;
var i: integer;
begin
  for i := 0 to Length(FInterfaces) - 1 do
    FInterfaceRefs[i] := nil;
end;

end.

Revision:	45
Committed:	Tue Dec 6 10:33:46 2016 UTC (7 years, 11 months ago) by tony
Content type:	text/x-pascal
Original Path:	*ibx/trunk/fbintf/client/FBActivityMonitor.pas*
File size:	9068 byte(s)
Log Message:	Committing updates for Release R2-0-0
#	Content
1	(*
2	* Firebird Interface (fbintf). The fbintf components provide a set of
3	* Pascal language bindings for the Firebird API.
4	*
5	* The contents of this file are subject to the Initial Developer's
6	* Public License Version 1.0 (the "License"); you may not use this
7	* file except in compliance with the License. You may obtain a copy
8	* of the License here:
9	*
10	* http://www.firebirdsql.org/index.php?op=doc&id=idpl
11	*
12	* Software distributed under the License is distributed on an "AS
13	* IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
14	* implied. See the License for the specific language governing rights
15	* and limitations under the License.
16	*
17	* The Initial Developer of the Original Code is Tony Whyman.
18	*
19	* The Original Code is (C) 2016 Tony Whyman, MWA Software
20	* (http://www.mwasoftware.co.uk).
21	*
22	* All Rights Reserved.
23	*
24	* Contributor(s): ______________________________________.
25	*
26	*)
27	unit FBActivityMonitor;
28
29	{$IFDEF FPC}
30	{$mode objfpc}{$H+}
31	{$interfaces COM}
32	{$ENDIF}
33
34	interface
35
36	uses
37	Classes, SysUtils, IBExternals;
38
39	{ $DEFINE DEBUGINTERFACES} {Define this to check that all interfaces are
40	being destroyed.}
41
42	type
43	{ TMonitoredObject is an optional class used to journal all interface creatino
44	and deletion as well as keeping a count of how many monitored interfaces
45	exist at any one time. It is used at development to look for memory leaks
46	due to interfaces not being discarded when no longer used.}
47
48	{$IFDEF DEBUGINTERFACES}
49	TMonitoredObject = class(TInterfacedObject)
50	private
51	FObjectCount: integer; static;
52	public
53	constructor Create;
54	destructor Destroy; override;
55	end;
56
57	{TFBInterfacedObject is used as the base class for interfaces objects and can
58	be either a synonym for TInterfacedObject (default) or TMonitored object}
59
60	TFBInterfacedObject = TMonitoredObject;
61	{$ELSE}
62	TFBInterfacedObject = TInterfacedObject;
63	{$ENDIF}
64
65	{ TInterfaceOwner }
66
67	TInterfaceOwner = class(TFBInterfacedObject)
68	private
69	FInterfaces: array of TInterfacedObject;
70	FInterfaceRefs: array of IUnknown;
71	FRetainInterfaces: boolean;
72	FMinInterfaces: integer;
73	function GetCount: integer;
74	procedure SetRetainInterfaces(AValue: boolean);
75	protected
76	procedure AddInterface(index: integer; obj: TInterfacedObject);
77	function HasInterface(index: integer): boolean;
78	procedure ReleaseInterfaces;
79	public
80	constructor Create(aInterfaces: integer=0);
81	destructor Destroy; override;
82	procedure AddObject(obj: TInterfacedObject);
83	function GetInterface(index: integer): TInterfacedObject;
84	procedure Remove(intf: TInterfacedObject);
85	property InterfaceCount: integer read GetCount;
86	property RetainInterfaces: boolean read FRetainInterfaces write SetRetainInterfaces;
87	end;
88
89	{The IActivityMonitor interface is provided by classes that receive activity
90	reports.}
91
92	IActivityMonitor = interface
93	procedure AddObject(obj: TInterfacedObject);
94	procedure Remove(intf: TInterfacedObject);
95	procedure SignalActivity;
96	end;
97
98	{ TActivityReporter is a base class for objects that need to report their activity
99	to an activity monitor, where activity is defined as use of a Firebird API call.
100	Objects descending from this class always used the "Call" method as a wrapper
101	for calls to the Firebird API. Each such call is then classed as activity
102	and reported to one or more activity monitors.
103
104	In practice, a transaction monitors statements, blobs and arrays. A Database
105	monitors transactions and events. Transaction monitors use the ITransactionMonitor
106	interface, implemented through the helper object TTransactionMonitor.
107	}
108
109	TActivityReporter = class(TInterfaceOwner)
110	private
111	FHasActivity: boolean;
112	FMonitors: array of IActivityMonitor;
113	function FindMonitor(aMonitor: IActivityMonitor): integer;
114	protected
115	function Call(ErrCode: ISC_STATUS; RaiseError: Boolean = true): ISC_STATUS;
116	procedure AddMonitor(aMonitor: IActivityMonitor);
117	procedure RemoveMonitor(aMonitor: IActivityMonitor);
118	public
119	constructor Create(aMonitor: IActivityMonitor;aInterfaces: integer=0);
120	destructor Destroy; override;
121	function HasActivity: boolean;
122	procedure SignalActivity;
123	end;
124
125	{ TActivityHandler is a base class for classes that receive activity reports.}
126
127	TActivityHandler = class(TInterfaceOwner,IActivityMonitor)
128	private
129	FHasActivity: boolean;
130	public
131	function HasActivity: boolean;
132	procedure SignalActivity;
133	end;
134
135	implementation
136
137	uses FB25ClientAPI;
138
139	{ TActivityHandler }
140
141	function TActivityHandler.HasActivity: boolean;
142	begin
143	Result := FHasActivity;
144	FHasActivity := false;
145	end;
146
147	procedure TActivityHandler.SignalActivity;
148	begin
149	FHasActivity := true;
150	end;
151
152	{ TMonitoredObject }
153
154	{$IFDEF DEBUGINTERFACES}
155	constructor TMonitoredObject.Create;
156	begin
157	inherited Create;
158	Inc(FObjectCount);
159	writeln('Creating ' + ClassName,', Obj Count = ',FObjectCount);
160	end;
161
162	destructor TMonitoredObject.Destroy;
163	begin
164	Dec(FObjectCount);
165	writeln('Destroying ' + ClassName,' Obj Count = ',FObjectCount);
166	inherited Destroy;
167	end;
168	{$ENDIF}
169
170	{ TActivityReporter}
171
172	function TActivityReporter.FindMonitor(aMonitor: IActivityMonitor): integer;
173	var i: integer;
174	begin
175	Result := -1;
176	for i := 0 to Length(FMonitors) - 1 do
177	if FMonitors[i] = aMonitor then
178	begin
179	Result := i;
180	Exit;
181	end;
182	end;
183
184	function TActivityReporter.Call(ErrCode: ISC_STATUS; RaiseError: Boolean): ISC_STATUS;
185	begin
186	result := ErrCode;
187	SignalActivity;
188	if RaiseError and (ErrCode > 0) then
189	Firebird25ClientAPI.IBDataBaseError;
190	end;
191
192	procedure TActivityReporter.AddMonitor(aMonitor: IActivityMonitor);
193	var i: integer;
194	begin
195	if FindMonitor(aMonitor) = -1 then
196	begin
197	i := Length(FMonitors);
198	Setlength(FMonitors,i+1);
199	FMonitors[i] := aMonitor;
200	aMonitor.AddObject(self);
201	end;
202	end;
203
204	procedure TActivityReporter.RemoveMonitor(aMonitor: IActivityMonitor);
205	var i,j: integer;
206	begin
207	i := FindMonitor(aMonitor);
208	if i <> -1 then
209	begin
210	aMonitor.Remove(self);
211	if Length(FMonitors) = 1 then
212	SetLength(FMonitors,0)
213	else
214	begin
215	for j := i + 1 to Length(FMonitors) - 1 do
216	FMonitors[j-1] := FMonitors[j];
217	SetLength(FMonitors,Length(FMonitors)-1);
218	end;
219	end;
220	end;
221
222	procedure TActivityReporter.SignalActivity;
223	var i: integer;
224	begin
225	FHasActivity := true;
226	for i := 0 to Length(FMonitors) - 1 do
227	FMonitors[i].SignalActivity;
228	end;
229
230	constructor TActivityReporter.Create(aMonitor: IActivityMonitor;
231	aInterfaces: integer);
232	begin
233	inherited Create(aInterfaces);
234	if aMonitor <> nil then
235	begin
236	SetLength(FMonitors,1);
237	FMonitors[0] := aMonitor;
238	end;
239	end;
240
241	destructor TActivityReporter.Destroy;
242	var i: integer;
243	begin
244	for i := 0 to Length(FMonitors) - 1 do
245	FMonitors[i].Remove(self);
246	inherited Destroy;
247	end;
248
249	function TActivityReporter.HasActivity: boolean;
250	begin
251	Result := FHasActivity;
252	FHasActivity := false;
253	end;
254
255	{ TInterfaceOwner }
256
257	constructor TInterfaceOwner.Create(aInterfaces: integer);
258	begin
259	inherited Create;
260	FMinInterfaces := aInterfaces;
261	SetLength(FInterfaces,aInterfaces);
262	SetLength(FInterfaceRefs,aInterfaces);
263	end;
264
265	destructor TInterfaceOwner.Destroy;
266	begin
267	ReleaseInterfaces;
268	inherited Destroy;
269	end;
270
271	procedure TInterfaceOwner.AddObject(obj: TInterfacedObject);
272	var index: integer;
273	begin
274	index := Length(FInterfaces);
275	SetLength(FInterfaces,index+1);
276	SetLength(FInterfaceRefs,index+1);
277	AddInterface(index,obj);
278	end;
279
280	function TInterfaceOwner.GetInterface(index: integer): TInterfacedObject;
281	begin
282	Result := FInterfaces[index];
283	end;
284
285	procedure TInterfaceOwner.SetRetainInterfaces(AValue: boolean);
286	begin
287	if FRetainInterfaces = AValue then Exit;
288	FRetainInterfaces := AValue;
289	if not FRetainInterfaces then
290	ReleaseInterfaces;
291	end;
292
293	function TInterfaceOwner.GetCount: integer;
294	begin
295	Result := Length(FInterfaces);
296	end;
297
298	procedure TInterfaceOwner.AddInterface(index: integer; obj: TInterfacedObject);
299	begin
300	FInterfaces[index] := obj;
301	if RetainInterfaces then
302	FInterfaceRefs[index] := obj;
303	end;
304
305	function TInterfaceOwner.HasInterface(index: integer): boolean;
306	begin
307	Result := FInterfaces[index] <> nil;
308	end;
309
310	procedure TInterfaceOwner.Remove(intf: TInterfacedObject);
311	var i, j: integer;
312	begin
313	for i := 0 to Length(FInterfaces) - 1 do
314	if FInterfaces[i] = intf then
315	begin
316	if i < FMinInterfaces then
317	begin
318	FInterfaceRefs[i] := nil;
319	FInterfaces[i] := nil;
320	end
321	else
322	begin
323	for j := i to Length(FInterfaces) - 2 do
324	begin
325	FInterfaceRefs[j] := FInterfaceRefs[j+1];
326	FInterfaces[j] := FInterfaces[j+1];
327	end;
328	SetLength(FInterfaces,Length(FInterfaces)-1);
329	SetLength(FInterfaceRefs,Length(FInterfaceRefs)-1);
330	end;
331	Exit;
332	end;
333	end;
334
335	procedure TInterfaceOwner.ReleaseInterfaces;
336	var i: integer;
337	begin
338	for i := 0 to Length(FInterfaces) - 1 do
339	FInterfaceRefs[i] := nil;
340	end;
341
342	end.
343