commit 5a781c2e71c2d5da052fac6cd6386267ab68694e
author Jens Geyer <jensg@apache.org> Tue Feb 04 23:35:55 2025 +0100
committer Jens Geyer <jensg@apache.org> Wed Feb 05 01:47:07 2025 +0100
tree 5c2bfedbc23281875eac71b25d1e8c96b206453a
parent c854f648dfbe64f08f9e4d97f9ace64dbcf394f3

THRIFT-5851 Promote known total stream sizes for seekable stream transports properly
Client: Delphi
Patch: Jens Geyer

lib/delphi/src/Thrift.Transport.Pipes.pas

diff --git a/lib/delphi/src/Thrift.Transport.Pipes.pas b/lib/delphi/src/Thrift.Transport.Pipes.pas
index 10f4dec..d3980d7 100644
--- a/lib/delphi/src/Thrift.Transport.Pipes.pas
+++ b/lib/delphi/src/Thrift.Transport.Pipes.pas
@@ -679,22 +679,22 @@
 
 function TPipeTransportBase.GetIsOpen: Boolean;
 begin
-  result := (FInputStream <> nil)  and (FInputStream.IsOpen)
-        and (FOutputStream <> nil) and (FOutputStream.IsOpen);
+  result := (InputStream <> nil)  and (InputStream.IsOpen)
+        and (OutputStream <> nil) and (OutputStream.IsOpen);
 end;
 
 
 procedure TPipeTransportBase.Open;
 begin
-  FInputStream.Open;
-  FOutputStream.Open;
+  InputStream.Open;
+  OutputStream.Open;
 end;
 
 
 procedure TPipeTransportBase.Close;
 begin
-  FInputStream.Close;
-  FOutputStream.Close;
+  InputStream.Close;
+  OutputStream.Close;
 end;
 
 
@@ -709,8 +709,8 @@
 // Named pipe constructor
 begin
   inherited Create( nil, nil, aConfig);
-  FInputStream  := TNamedPipeStreamImpl.Create( aPipeName, TRUE, aShareMode, aSecurityAttributes, aTimeOut, aOpenTimeOut);
-  FOutputStream := FInputStream;  // true for named pipes
+  SetInputStream( TNamedPipeStreamImpl.Create( aPipeName, TRUE, aShareMode, aSecurityAttributes, aTimeOut, aOpenTimeOut));
+  SetOutputStream( InputStream);  // true for named pipes
 end;
 
 
@@ -721,8 +721,8 @@
 // Named pipe constructor
 begin
   inherited Create( nil, nil, aConfig);
-  FInputStream  := THandlePipeStreamImpl.Create( aPipe, aOwnsHandle, TRUE, aTimeOut);
-  FOutputStream := FInputStream;  // true for named pipes
+  SetInputStream(  THandlePipeStreamImpl.Create( aPipe, aOwnsHandle, TRUE, aTimeOut));
+  SetOutputStream( InputStream);  // true for named pipes
 end;
 
 
@@ -761,8 +761,8 @@
 begin
   inherited Create( nil, nil, aConfig);
   // overlapped is not supported with AnonPipes, see MSDN
-  FInputStream  := THandlePipeStreamImpl.Create( aPipeRead, aOwnsHandles, FALSE, aTimeout);
-  FOutputStream := THandlePipeStreamImpl.Create( aPipeWrite, aOwnsHandles, FALSE, aTimeout);
+  SetInputStream(  THandlePipeStreamImpl.Create( aPipeRead, aOwnsHandles, FALSE, aTimeout));
+  SetOutputStream( THandlePipeStreamImpl.Create( aPipeWrite, aOwnsHandles, FALSE, aTimeout));
 end;