| 1 | unit uRpcLogEntry;
 | 
|---|
| 2 | 
 | 
|---|
| 3 | interface
 | 
|---|
| 4 | 
 | 
|---|
| 5 | uses
 | 
|---|
| 6 |       Windows, Messages, SysUtils, Classes, Graphics, Controls, Forms, Dialogs,
 | 
|---|
| 7 |   StdCtrls, TRpcb;
 | 
|---|
| 8 | 
 | 
|---|
| 9 | type
 | 
|---|
| 10 |   TDisplayFormat = (dfFormatFullWithoutClientName,dfFormatFullWithClientName,
 | 
|---|
| 11 |                         dfFormatForList);
 | 
|---|
| 12 | 
 | 
|---|
| 13 |   TMyString = class(TObject)
 | 
|---|
| 14 |   private
 | 
|---|
| 15 |     FString: String;
 | 
|---|
| 16 |   public
 | 
|---|
| 17 |     Constructor Create(Str: String);
 | 
|---|
| 18 |     procedure Append(Str: String);
 | 
|---|
| 19 |     function ToString: String;
 | 
|---|
| 20 |   end;
 | 
|---|
| 21 | 
 | 
|---|
| 22 |   TRpcLogEntry = class(TObject)
 | 
|---|
| 23 |   private
 | 
|---|
| 24 |     mUniqueClientId: Integer;
 | 
|---|
| 25 |     mClientName: String;
 | 
|---|
| 26 |     mConnectionIndex: Integer;
 | 
|---|
| 27 |     mContext: String;
 | 
|---|
| 28 |     mUniqueId: Integer;      // unique rpc id
 | 
|---|
| 29 |     mRpcName: String;
 | 
|---|
| 30 |     mRpcParamsString: String;
 | 
|---|
| 31 |     mRpcResults: String;
 | 
|---|
| 32 |     mRpcEndDateTime: Double;
 | 
|---|
| 33 |     mRpcDuration: Integer;
 | 
|---|
| 34 |     mRpcParams: TParams;
 | 
|---|
| 35 |   protected
 | 
|---|
| 36 |     procedure SetParamsString(Value: String);
 | 
|---|
| 37 |   public
 | 
|---|
| 38 |     Constructor Create; overload;
 | 
|---|
| 39 |     Constructor Create(uniqueClientId: Integer; clientName: String;
 | 
|---|
| 40 |                connectionIndex: Integer; rpcUniqueId: Integer; rpcEndDateTime: Double;
 | 
|---|
| 41 |                rpcDuration: Integer; context, rpcName, rpcParams, rpcResults: String); overload;
 | 
|---|
| 42 |     property StrResults: String read mRpcResults write mRpcResults;
 | 
|---|
| 43 |     property EndDateTime: double read mRpcEndDateTime write mRpcEndDateTime;
 | 
|---|
| 44 |     property Duration: Integer read mRpcDuration write mRpcDuration;
 | 
|---|
| 45 |     property Params: TParams read mRpcParams;
 | 
|---|
| 46 |     property UniqueClientId: Integer read mUniqueClientId write mUniqueClientId;
 | 
|---|
| 47 |     property ClientName: String read mClientName write mClientName;
 | 
|---|
| 48 |     property ConnectionIndex: Integer read mConnectionIndex write mConnectionIndex;
 | 
|---|
| 49 |     property UniqueId: Integer read mUniqueId write mUniqueId;
 | 
|---|
| 50 |     property Context: String read mContext write mContext;
 | 
|---|
| 51 |     property Name: String read mRpcName write mRpcName;
 | 
|---|
| 52 |     property ParamsString: String read mRpcParamsString write SetParamsString;
 | 
|---|
| 53 |     function CreateDisplayString(format: TDisplayFormat): String;
 | 
|---|
| 54 |     function ToString: String;
 | 
|---|
| 55 |     function CreateClipboardString: String;
 | 
|---|
| 56 |     function CreateParamsDisplayString: String;
 | 
|---|
| 57 |     function CreateResultsDisplayString: String;
 | 
|---|
| 58 |   end;
 | 
|---|
| 59 | 
 | 
|---|
| 60 | 
 | 
|---|
| 61 | const
 | 
|---|
| 62 |   kHeaderStartTag: String    = '________________________RPC START____________________';
 | 
|---|
| 63 |   kRpcTag: String = 'RPC>'#09#09#09;
 | 
|---|
| 64 |   kRpcDebugIdTag: String = 'RPC DEBUG ID>'#09;
 | 
|---|
| 65 |   kClientNameTag: String = 'CLIENT NAME>'#09#09;
 | 
|---|
| 66 |   kClientDebugIdTag: String = 'CLIENT DEBUG ID>'#09;
 | 
|---|
| 67 |   kContextTag: String = 'CONTEXT>'#09#09;
 | 
|---|
| 68 |   kDurationTag: String = 'DURATION>'#09#09;
 | 
|---|
| 69 |     // kTimeDateTag: String = 'END TIME>'#09#09;
 | 
|---|
| 70 |   kParamsTag: String = '________________________PARAMS_______________________';
 | 
|---|
| 71 |   kResultsTag: String = '________________________RESULTS______________________';
 | 
|---|
| 72 |   kHeaderEndTag: String = '________________________RPC END______________________';
 | 
|---|
| 73 | 
 | 
|---|
| 74 | function PosNext(SubString: String; CurStart: Integer; S: String): Integer;
 | 
|---|
| 75 | 
 | 
|---|
| 76 | implementation
 | 
|---|
| 77 | 
 | 
|---|
| 78 | function PosNext(SubString: string; CurStart: Integer; S: String): Integer;
 | 
|---|
| 79 | var
 | 
|---|
| 80 |   Str1: String;
 | 
|---|
| 81 | begin
 | 
|---|
| 82 |   Str1 := Copy(S,CurStart,Length(S));
 | 
|---|
| 83 |   Result := CurStart + Pos(SubString,Str1)-1;
 | 
|---|
| 84 | end;
 | 
|---|
| 85 | 
 | 
|---|
| 86 | function TMyString.ToString: string;
 | 
|---|
| 87 | begin
 | 
|---|
| 88 |   Result := FString;
 | 
|---|
| 89 | end;
 | 
|---|
| 90 | 
 | 
|---|
| 91 | procedure TMyString.Append(Str: string);
 | 
|---|
| 92 | begin
 | 
|---|
| 93 |   FString := FString + Str;
 | 
|---|
| 94 | end;
 | 
|---|
| 95 | 
 | 
|---|
| 96 | constructor TMyString.Create(Str: string);
 | 
|---|
| 97 | begin
 | 
|---|
| 98 |   FString := Str;
 | 
|---|
| 99 | end;
 | 
|---|
| 100 | 
 | 
|---|
| 101 | 
 | 
|---|
| 102 | procedure TRpcLogEntry.SetParamsString(Value: string);
 | 
|---|
| 103 | begin
 | 
|---|
| 104 |   mRpcParamsString := value;
 | 
|---|
| 105 |         // TODO:
 | 
|---|
| 106 |         // now break the string into a string array and
 | 
|---|
| 107 |         // shove it into the Params
 | 
|---|
| 108 |         // Just rebuild the mParams
 | 
|---|
| 109 |   if (mRpcParams <> nil) then
 | 
|---|
| 110 |   begin
 | 
|---|
| 111 |     mRpcParams.Free;
 | 
|---|
| 112 |     mRpcParams := nil;
 | 
|---|
| 113 |   end;
 | 
|---|
| 114 | 
 | 
|---|
| 115 |   mRpcParams := TParams.Create(Application);
 | 
|---|
| 116 | //  mRpcParams.
 | 
|---|
| 117 | end;
 | 
|---|
| 118 | 
 | 
|---|
| 119 |   /// <summary>
 | 
|---|
| 120 |   /// Summary description for RpcLogEntry.
 | 
|---|
| 121 |    /// </summary>
 | 
|---|
| 122 | Constructor TRpcLogEntry.Create;
 | 
|---|
| 123 | begin
 | 
|---|
| 124 |   inherited;
 | 
|---|
| 125 | end;
 | 
|---|
| 126 | 
 | 
|---|
| 127 | Constructor TRpcLogEntry.Create(uniqueClientId: Integer; clientName: String;
 | 
|---|
| 128 |                connectionIndex: Integer; rpcUniqueId: Integer; rpcEndDateTime: Double;
 | 
|---|
| 129 |                rpcDuration: Integer; context, rpcName, rpcParams, rpcResults: String);
 | 
|---|
| 130 | begin
 | 
|---|
| 131 |   mUniqueClientId  := uniqueClientId;
 | 
|---|
| 132 |   mClientName    := clientName;
 | 
|---|
| 133 |   if (context = '') then
 | 
|---|
| 134 |     mContext := ''
 | 
|---|
| 135 |   else
 | 
|---|
| 136 |     mContext  := context;
 | 
|---|
| 137 | 
 | 
|---|
| 138 |   mConnectionIndex := connectionIndex;
 | 
|---|
| 139 | 
 | 
|---|
| 140 |   mUniqueId := rpcUniqueId;
 | 
|---|
| 141 |   if (rpcName = '') then
 | 
|---|
| 142 |     mrpcName := ''
 | 
|---|
| 143 |   else
 | 
|---|
| 144 |     mrpcName := rpcName;
 | 
|---|
| 145 | 
 | 
|---|
| 146 |   if(rpcParams = '') then
 | 
|---|
| 147 |     mrpcParamsString := ''
 | 
|---|
| 148 |   else
 | 
|---|
| 149 |     mrpcParamsString := rpcParams;
 | 
|---|
| 150 | 
 | 
|---|
| 151 |   if(rpcResults = '') then
 | 
|---|
| 152 |     mrpcResults := ''
 | 
|---|
| 153 |   else
 | 
|---|
| 154 |     mrpcResults   := rpcResults;
 | 
|---|
| 155 | 
 | 
|---|
| 156 |   mRpcEndDateTime   := rpcEndDateTime;
 | 
|---|
| 157 |   mRpcDuration   := rpcDuration;
 | 
|---|
| 158 | end;
 | 
|---|
| 159 | 
 | 
|---|
| 160 | 
 | 
|---|
| 161 | function TRpcLogEntry.ToString: String;
 | 
|---|
| 162 | begin
 | 
|---|
| 163 |   Result := CreateDisplayString(dfFormatForList);
 | 
|---|
| 164 | end;
 | 
|---|
| 165 | 
 | 
|---|
| 166 |     /// <summary>
 | 
|---|
| 167 |     /// CreateDisplayString returns a string with the rpc params
 | 
|---|
| 168 |     /// formated based on the DisplayFormat format 
 | 
|---|
| 169 |     /// </summary>
 | 
|---|
| 170 |     /// <param name:='format'></param>
 | 
|---|
| 171 |     /// <returns></returns>
 | 
|---|
| 172 |     ///
 | 
|---|
| 173 | const
 | 
|---|
| 174 |   kInitialStringBuilderSize: Integer = 1000;
 | 
|---|
| 175 |   kNamePad: Integer = 31;
 | 
|---|
| 176 |   krpcIdPad: Integer = 5;
 | 
|---|
| 177 |   kcIdpad: Integer = 7;
 | 
|---|
| 178 |   kDurationPad: Integer = 3;
 | 
|---|
| 179 |   kLiteral: String = 'literal';
 | 
|---|
| 180 |   kReference: String = 'reference';
 | 
|---|
| 181 |   kList: String = 'list';
 | 
|---|
| 182 |   kUndefined: String = 'undefined';
 | 
|---|
| 183 | 
 | 
|---|
| 184 | 
 | 
|---|
| 185 | function TRpcLogEntry.CreateDisplayString(format: TDisplayFormat): String;
 | 
|---|
| 186 | var
 | 
|---|
| 187 |   ResultVal: TMyString;
 | 
|---|
| 188 | begin
 | 
|---|
| 189 | 
 | 
|---|
| 190 |   ResultVal := TMyString.Create('');
 | 
|---|
| 191 | 
 | 
|---|
| 192 |   case (format) of
 | 
|---|
| 193 |     dfFormatFullWithClientName:
 | 
|---|
| 194 |     begin
 | 
|---|
| 195 |       ResultVal.Append(kHeaderStartTag);
 | 
|---|
| 196 |       ResultVal.Append(#13#10 + kRpcTag      + Name);
 | 
|---|
| 197 |       ResultVal.Append(#13#10 + kRpcDebugIdTag    + IntToStr(UniqueId));
 | 
|---|
| 198 |       ResultVal.Append(#13#10 + kClientNameTag    + ClientName);
 | 
|---|
| 199 |       ResultVal.Append(#13#10 + kClientDebugIdTag  + IntToStr(UniqueClientId));
 | 
|---|
| 200 |       ResultVal.Append(#13#10 + kContextTag    + Context);
 | 
|---|
| 201 |       ResultVal.Append(#13#10 + kDurationTag    + IntToStr(Duration) + 'ms');
 | 
|---|
| 202 |       //ResultVal.Append(#13#10 + kTimeDateTag    + EndDateTime);
 | 
|---|
| 203 |       ResultVal.Append(#13#10 + kParamsTag      + CreateParamsDisplayString);
 | 
|---|
| 204 |       ResultVal.Append(#13#10 + kResultsTag    + CreateResultsDisplayString);
 | 
|---|
| 205 |       ResultVal.Append(#13#10 + kHeaderEndTag);
 | 
|---|
| 206 |     end;
 | 
|---|
| 207 |     dfFormatForList:
 | 
|---|
| 208 |     begin
 | 
|---|
| 209 | //          ResultVal.Append(Name+#09rpcId:='+UniqueId+#09cId:='+UniqueClientId+'  time:='+Duration+'ms  '+ClientName);
 | 
|---|
| 210 | {      if(Duration < 1)
 | 
|---|
| 211 |         durationStr := '<1'
 | 
|---|
| 212 |       else
 | 
|---|
| 213 |        durationStr := Duration.ToString();
 | 
|---|
| 214 | 
 | 
|---|
| 215 |       ResultVal.Append(  Name.PadRight(kNamePad)+
 | 
|---|
| 216 |                   ' cId:='+UniqueClientId.ToString().PadRight(kcIdpad)+
 | 
|---|
| 217 |                   ' time:='+duration.PadLeft(kDurationPad)+'ms'+
 | 
|---|
| 218 |                   ' rpcId:='+UniqueId.ToString().PadRight(krpcIdPad)+
 | 
|---|
| 219 |                   ClientName);
 | 
|---|
| 220 | }
 | 
|---|
| 221 |       end;
 | 
|---|
| 222 |     else
 | 
|---|
| 223 |       begin
 | 
|---|
| 224 |           ResultVal.Append(kHeaderStartTag);
 | 
|---|
| 225 |           ResultVal.Append(#13#10 + kRpcTag      + Name);
 | 
|---|
| 226 |           ResultVal.Append(#13#10 + kRpcDebugIdTag    + IntToStr(UniqueId));
 | 
|---|
| 227 |           //ResultVal.Append(#13#10 + kClientNameTag    + ClientName);
 | 
|---|
| 228 |           //ResultVal.Append(#13#10 + kClientDebugIdTag  + UniqueClientId);
 | 
|---|
| 229 |           ResultVal.Append(#13#10 + kContextTag    + Context);
 | 
|---|
| 230 |           ResultVal.Append(#13#10 + kDurationTag    + IntToStr(Duration) + 'ms');
 | 
|---|
| 231 |           //ResultVal.Append(#13#10 + kTimeDateTag    + EndDateTime);
 | 
|---|
| 232 |           ResultVal.Append(#13#10 + kParamsTag      + CreateParamsDisplayString());
 | 
|---|
| 233 |           ResultVal.Append(#13#10 + kResultsTag    + CreateResultsDisplayString());
 | 
|---|
| 234 |           ResultVal.Append(#13#10 + kHeaderEndTag);
 | 
|---|
| 235 |           // Default case is FormatFullWithoutClientName
 | 
|---|
| 236 |       end;
 | 
|---|
| 237 |     end;
 | 
|---|
| 238 |     Result := ResultVal.ToString();
 | 
|---|
| 239 | end;
 | 
|---|
| 240 |     
 | 
|---|
| 241 | function TRpcLogEntry.CreateClipboardString: String;
 | 
|---|
| 242 | var
 | 
|---|
| 243 |   ResultVal: TMyString;
 | 
|---|
| 244 | begin
 | 
|---|
| 245 |   ResultVal := TMyString.Create('');
 | 
|---|
| 246 |       ResultVal.Append(kHeaderStartTag);
 | 
|---|
| 247 |       ResultVal.Append(#13#10#13#10+kRpcTag+Name);
 | 
|---|
| 248 |       ResultVal.Append(#13#10+kRpcDebugIdTag+ IntToStr(UniqueId));
 | 
|---|
| 249 |       ResultVal.Append(#13#10+kClientNameTag+ClientName);
 | 
|---|
| 250 |       ResultVal.Append(#13#10+kClientDebugIdTag+ IntToStr(UniqueClientId));
 | 
|---|
| 251 |       ResultVal.Append(#13#10+kContextTag+Context);
 | 
|---|
| 252 |       ResultVal.Append(#13#10+kDurationTag+ IntToStr(Duration));
 | 
|---|
| 253 |       ResultVal.Append(#13#10#13#10+kParamsTag+#13#10);
 | 
|---|
| 254 |       ResultVal.Append(CreateParamsDisplayString);
 | 
|---|
| 255 |       ResultVal.Append(#13#10#13#10+kResultsTag+#13#10);
 | 
|---|
| 256 |       ResultVal.Append(CreateResultsDisplayString);
 | 
|---|
| 257 |       ResultVal.Append(#13#10#13#10+kHeaderEndTag+#13#10#13#10);
 | 
|---|
| 258 |   Result := ResultVal.ToString();
 | 
|---|
| 259 | end;
 | 
|---|
| 260 | 
 | 
|---|
| 261 | // const char kSEP_FS = (char)28;
 | 
|---|
| 262 | const kSEP_GS: String = #29;
 | 
|---|
| 263 | const kSEP_US: String = #30;
 | 
|---|
| 264 | const kSEP_RS: String = #31;
 | 
|---|
| 265 | 
 | 
|---|
| 266 | function TRpcLogEntry.CreateParamsDisplayString: String;
 | 
|---|
| 267 | var
 | 
|---|
| 268 |   Str: String;
 | 
|---|
| 269 |   Chr: Char;
 | 
|---|
| 270 |   Chr1: String;
 | 
|---|
| 271 |   TypeStr{, x, y}: String;
 | 
|---|
| 272 |   ResultVal: TMyString;
 | 
|---|
| 273 |   i, {j,} CurrStart: Integer;
 | 
|---|
| 274 |   LengthOfRpcParams: Integer;
 | 
|---|
| 275 |   EndOfSegment: Integer;
 | 
|---|
| 276 |   ARef, AVal: String;
 | 
|---|
| 277 |   Str2: String;
 | 
|---|
| 278 | begin
 | 
|---|
| 279 |   ResultVal := TMyString.Create('');
 | 
|---|
| 280 |   LengthOfRpcParams := Length(mRpcParamsString);
 | 
|---|
| 281 |   if LengthOfRpcParams > 0 then
 | 
|---|
| 282 |   begin
 | 
|---|
| 283 |     Str := mRpcParamsString;
 | 
|---|
| 284 |     CurrStart := 1;
 | 
|---|
| 285 |     i := 1;
 | 
|---|
| 286 | //      for i:=0 to Pred(Params.Count) do
 | 
|---|
| 287 |     while CurrStart < LengthOfRpcParams do
 | 
|---|
| 288 |     begin
 | 
|---|
| 289 |       Chr1 := Copy(Str,CurrStart,1);
 | 
|---|
| 290 |       Chr := PChar(Chr1)^;
 | 
|---|
| 291 |       case Chr of    //
 | 
|---|
| 292 |         'L': typeStr := kLiteral;
 | 
|---|
| 293 |         'R': typeStr := kReference;
 | 
|---|
| 294 |         'M': typeStr := kList;
 | 
|---|
| 295 |         else typeStr := kUndefined ;
 | 
|---|
| 296 |       end;    // case
 | 
|---|
| 297 |       if i <> 1 then
 | 
|---|
| 298 |         ResultVal.Append(#13#10);
 | 
|---|
| 299 |       ResultVal.Append(TypeStr+#9);
 | 
|---|
| 300 |       CurrStart := CurrStart + 2;
 | 
|---|
| 301 |       if TypeStr = kList then
 | 
|---|
| 302 |       begin
 | 
|---|
| 303 |         EndOfSegment := 0;
 | 
|---|
| 304 |         while Copy(Str,CurrStart,1) <> kSep_GS do
 | 
|---|
| 305 |         begin
 | 
|---|
| 306 |           EndOfSegment := PosNext(kSep_US,CurrStart,Str);
 | 
|---|
| 307 |           ARef := Copy(Str,CurrStart,EndOfSegment-CurrStart);
 | 
|---|
| 308 |           CurrStart := EndOfSegment + 1;
 | 
|---|
| 309 |           EndOfSegment := PosNext(kSep_RS,CurrStart,Str);
 | 
|---|
| 310 |           AVal := Copy(Str,CurrStart,EndOfSegment-CurrStart);
 | 
|---|
| 311 |           CurrStart := EndOfSegment + 1;
 | 
|---|
| 312 |           ResultVal.Append(#13#10#9+ARef+#9+AVal);
 | 
|---|
| 313 |           Str2 := #13#10#9+Aref+#9+Aval;
 | 
|---|
| 314 |           Aval := Str2;
 | 
|---|
| 315 |         end;    // while
 | 
|---|
| 316 |         if EndOfSegment = 0 then
 | 
|---|
| 317 |           EndOfSegment := PosNext(kSep_GS,CurrStart,Str);
 | 
|---|
| 318 |         CurrStart := EndOfSegment + 1;
 | 
|---|
| 319 |       end
 | 
|---|
| 320 |       else
 | 
|---|
| 321 |       begin
 | 
|---|
| 322 |         EndOfSegment := PosNext(kSEP_GS,CurrStart,Str);
 | 
|---|
| 323 |         ResultVal.Append(Copy(Str,CurrStart,EndOfSegment-CurrStart));
 | 
|---|
| 324 |         CurrStart := EndOfSegment + 1;
 | 
|---|
| 325 |       end;
 | 
|---|
| 326 |       Inc(i);
 | 
|---|
| 327 |     end;  // while
 | 
|---|
| 328 |   end;
 | 
|---|
| 329 | {
 | 
|---|
| 330 |   else
 | 
|---|
| 331 |       Assert(False);
 | 
|---|
| 332 | }
 | 
|---|
| 333 | {
 | 
|---|
| 334 |     if (i<>0) then
 | 
|---|
| 335 |       ResultVal.Append(#13#10);
 | 
|---|
| 336 |     ResultVal.Append(typeStr+#09+Params[i].Value);
 | 
|---|
| 337 |         if (Params[i].PType = List) then
 | 
|---|
| 338 |         begin
 | 
|---|
| 339 |           for j:=0 to Pred(Params[i].Mult.Count) do
 | 
|---|
| 340 |           begin
 | 
|---|
| 341 |             x := Params[i].Mult.Subscript(j);
 | 
|---|
| 342 |             y := Params[i].Mult[x];
 | 
|---|
| 343 |             ResultVal.Append(#13#10#09+'('+x+'):='+y);
 | 
|---|
| 344 |           end
 | 
|---|
| 345 |         end
 | 
|---|
| 346 |       end;
 | 
|---|
| 347 | }
 | 
|---|
| 348 |   Result := ResultVal.ToString;
 | 
|---|
| 349 | end;
 | 
|---|
| 350 | 
 | 
|---|
| 351 | function TRpcLogEntry.CreateResultsDisplayString: String;
 | 
|---|
| 352 | begin
 | 
|---|
| 353 |   Result := StrResults;
 | 
|---|
| 354 | end;
 | 
|---|
| 355 | 
 | 
|---|
| 356 | end.
 | 
|---|