| 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. | 
|---|