Searched refs:Position (Results 1 – 11 of 11) sorted by relevance
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Client/ |
| D | TMemoryBufferTransport.cs | 48 public int Position { get; set; } property in Thrift.Transport.Client.TMemoryBufferTransport
80 Position = Math.Min(Position, value); in SetLength()
105 newPos = Position + delta; in Seek()
116 Position = newPos; in Seek()
119 CountConsumedMessageBytes(Position); in Seek()
124 var count = Math.Min(Length - Position, length); in ReadAsync()
125 Buffer.BlockCopy(Bytes, Position, buffer, offset, count); in ReadAsync()
126 Position += count; in ReadAsync()
138 var free = Length - Position; in WriteAsync()
140 Buffer.BlockCopy(buffer, offset, Bytes, Position, count); in WriteAsync()
[all …]
|
| /thrift-3.4.0/lib/delphi/src/ |
| D | Thrift.Stream.pas | 51 function Position : Int64; in Position() function
70 function Position : Int64; virtual; in Position() function
87 function Position : Int64; override; in Position() function
106 function Position : Int64; override; in Position() function
145 Position := 0;
189 function TThriftStreamAdapterCOM.Position : Int64; in TThriftStreamAdapterCOM.Position() function
299 function TThriftStreamImpl.Position : Int64; in Position() function
340 function TThriftStreamAdapterDelphi.Position : Int64; in TThriftStreamAdapterDelphi.Position() function
342 result := FStream.Position;
384 OrgPos := FStream.Position;
[all …]
|
| D | Thrift.Serializer.pas | 224 before := FStream.Position;
226 FStream.Position := before;
|
| D | Thrift.Transport.pas | 344 function Position : Int64; override; in Position() function
1071 FWriteBuffer.Position := 0;
1104 if FReadBuffer.Position >= FReadBuffer.Size then begin
1111 FReadBuffer.Position := 0;
1114 if FReadBuffer.Position < FReadBuffer.Size then begin
1115 nRead := Min( FReadBuffer.Size - FReadBuffer.Position, count);
1137 FReadBuffer.Position := 0;
1165 function TBufferedStreamImpl.Position : Int64; in Position() function
1167 result := FReadBuffer.Position;
1304 buffered := FInputBuffer.Size - FInputBuffer.Position;
[all …]
|
| D | Thrift.Transport.MsxmlHTTP.pas | 255 ms.Position := 0;
|
| /thrift-3.4.0/contrib/zeromq/csharp/ |
| D | TZmqClient.cs | 55 _rbuf.Position = 0; //For reading in Read()
58 if (_rbuf.Length == _rbuf.Position) //Finished reading in Read()
60 …g (string.Format ("Client_Read return {0}b, remaining {1}b", ret, _rbuf.Length - _rbuf.Position)); in Read()
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Layered/ |
| D | TBufferedTransport.cs | 98 var count = ReadBuffer.Length - ReadBuffer.Position; in ReadAsync()
115 ReadBuffer.Position = 0; in ReadAsync()
174 var buffered = ReadBuffer.Length - ReadBuffer.Position; in CheckReadBytesAvailable()
|
| D | TFramedTransport.cs | 79 if (ReadBuffer.Position >= ReadBuffer.Length) in ReadAsync()
159 var buffered = ReadBuffer.Length - ReadBuffer.Position; in CheckReadBytesAvailable()
|
| /thrift-3.4.0/lib/delphi/test/ |
| D | TestClient.pas | 1157 Expect( stm.Position = stm.Size, 'Stream position/length after write');
1158 stm.Position := 0;
1193 Expect( stm.Position = stm.Size, 'Stream position after read');
1197 stm.Position := 0;
1200 stm.Position := 0;
1210 stm.Position := 0;
1216 stm.Position := 0;
1223 stm.Position := 0;
1226 stm.Position := 0;
|
| /thrift-3.4.0/lib/delphi/test/serializer/ |
| D | TestSerializer.Tests.pas | 194 stream.Position := 0;
253 stream.Position := 0;
428 input.Position := 0;
|
| /thrift-3.4.0/lib/delphi/test/Performance/ |
| D | PerfTests.pas | 130 FMemBuffer.Position := 0;
|
