@@ -28,14 +28,14 @@ namespace FirebirdSql.Data.Client.Managed
2828{
2929 sealed class XdrReaderWriter : IXdrReader , IXdrWriter
3030 {
31- readonly IDataProvider _datProvider ;
31+ readonly IDataProvider _dataProvider ;
3232 readonly Charset _charset ;
3333
3434 byte [ ] _smallBuffer ;
3535
3636 public XdrReaderWriter ( IDataProvider dataProvider , Charset charset )
3737 {
38- _datProvider = dataProvider ;
38+ _dataProvider = dataProvider ;
3939 _charset = charset ;
4040
4141 _smallBuffer = new byte [ 8 ] ;
@@ -55,11 +55,11 @@ public async Task<byte[]> ReadBytes(byte[] buffer, int count, AsyncWrappingCommo
5555 var currentlyRead = - 1 ;
5656 while ( toRead > 0 && currentlyRead != 0 )
5757 {
58- toRead -= ( currentlyRead = await _datProvider . Read ( buffer , count - toRead , toRead , async) . ConfigureAwait ( false ) ) ;
58+ toRead -= ( currentlyRead = await _dataProvider . Read ( buffer , count - toRead , toRead , async) . ConfigureAwait ( false ) ) ;
5959 }
6060 if ( currentlyRead == 0 )
6161 {
62- if ( _datProvider is ITracksIOFailure tracksIOFailure )
62+ if ( _dataProvider is ITracksIOFailure tracksIOFailure )
6363 {
6464 tracksIOFailure . IOFailed = true ;
6565 }
@@ -257,16 +257,16 @@ public async Task<int> ReadOperation(AsyncWrappingCommonArgs async)
257257
258258 #region Write
259259
260- public Task Flush( AsyncWrappingCommonArgs async ) => _datProvider . Flush( async ) ;
260+ public Task Flush( AsyncWrappingCommonArgs async ) => _dataProvider . Flush( async ) ;
261261
262- public Task WriteBytes( byte [ ] buffer , int count , AsyncWrappingCommonArgs async ) => _datProvider . Write ( buffer , 0 , count , async ) ;
262+ public Task WriteBytes( byte [ ] buffer , int count , AsyncWrappingCommonArgs async ) => _dataProvider . Write ( buffer , 0 , count , async ) ;
263263
264264 public Task WriteOpaque( byte [ ] buffer , AsyncWrappingCommonArgs async ) => WriteOpaque ( buffer , buffer . Length , async ) ;
265265 public async Task WriteOpaque( byte [ ] buffer , int length , AsyncWrappingCommonArgs async )
266266 {
267267 if ( buffer ! = null && length > 0 )
268268 {
269- await _datProvider . Write ( buffer , 0 , buffer . Length , async ) . ConfigureAwait ( false ) ;
269+ await _dataProvider . Write ( buffer , 0 , buffer . Length , async ) . ConfigureAwait ( false ) ;
270270 await WriteFill( length - buffer . Length , async ) . ConfigureAwait ( false ) ;
271271 await WritePad( ( 4 - length ) & 3 , async ) . ConfigureAwait ( false ) ;
272272 }
@@ -278,7 +278,7 @@ public async Task WriteBuffer(byte[] buffer, int length, AsyncWrappingCommonArgs
278278 await Write ( length , async ) . ConfigureAwait ( false ) ;
279279 if ( buffer ! = null && length > 0 )
280280 {
281- await _datProvider . Write ( buffer , 0 , length , async ) . ConfigureAwait ( false ) ;
281+ await _dataProvider . Write ( buffer , 0 , length , async ) . ConfigureAwait ( false ) ;
282282 await WritePad( ( 4 - length ) & 3 , async ) . ConfigureAwait ( false ) ;
283283 }
284284 }
@@ -290,8 +290,8 @@ public async Task WriteBlobBuffer(byte[] buffer, AsyncWrappingCommonArgs async)
290290 throw new IOException( "Blob buffer too big. ") ;
291291 await Write( length + 2 , async ) . ConfigureAwait ( false ) ;
292292 await Write( length + 2 , async ) . ConfigureAwait ( false ) ; //bizarre but true! three copies of the length
293- await _datProvider . Write ( new [ ] { ( byte ) ( ( length > > 0 ) & 0xff ) , ( byte ) ( ( length > > 8 ) & 0xff ) } , 0 , 2 , async ) . ConfigureAwait ( false ) ;
294- await _datProvider . Write ( buffer , 0 , length , async ) . ConfigureAwait ( false ) ;
293+ await _dataProvider . Write ( new [ ] { ( byte ) ( ( length > > 0 ) & 0xff ) , ( byte ) ( ( length > > 8 ) & 0xff ) } , 0 , 2 , async ) . ConfigureAwait ( false ) ;
294+ await _dataProvider . Write ( buffer , 0 , length , async ) . ConfigureAwait ( false ) ;
295295 await WritePad( ( 4 - length + 2 ) & 3 , async ) . ConfigureAwait ( false ) ;
296296 }
297297
@@ -301,15 +301,15 @@ public async Task WriteTyped(int type, byte[] buffer, AsyncWrappingCommonArgs as
301301 if ( buffer = = null )
302302 {
303303 await Write ( 1 , async ) . ConfigureAwait ( false ) ;
304- await _datProvider . Write ( new [ ] { ( byte ) type } , 0 , 1 , async ) . ConfigureAwait ( false ) ;
304+ await _dataProvider . Write ( new [ ] { ( byte ) type } , 0 , 1 , async ) . ConfigureAwait ( false ) ;
305305 length = 1 ;
306306 }
307307 else
308308 {
309309 length = buffer . Length + 1 ;
310310 await Write ( length , async ) . ConfigureAwait ( false ) ;
311- await _datProvider . Write ( new [ ] { ( byte ) type } , 0 , 1 , async ) . ConfigureAwait ( false ) ;
312- await _datProvider . Write ( buffer , 0 , buffer . Length , async ) . ConfigureAwait ( false ) ;
311+ await _dataProvider . Write ( new [ ] { ( byte ) type } , 0 , 1 , async ) . ConfigureAwait ( false ) ;
312+ await _dataProvider . Write ( buffer , 0 , buffer . Length , async ) . ConfigureAwait ( false ) ;
313313 }
314314 await WritePad( ( 4 - length ) & 3 , async ) . ConfigureAwait ( false ) ;
315315 }
@@ -327,12 +327,12 @@ public Task Write(short value, AsyncWrappingCommonArgs async)
327327
328328 public Task Write( int value , AsyncWrappingCommonArgs async )
329329 {
330- return _datProvider . Write ( TypeEncoder . EncodeInt32 ( value ) , 0 , 4 , async ) ;
330+ return _dataProvider . Write ( TypeEncoder . EncodeInt32 ( value ) , 0 , 4 , async ) ;
331331 }
332332
333333 public Task Write( long value , AsyncWrappingCommonArgs async )
334334 {
335- return _datProvider . Write ( TypeEncoder . EncodeInt64 ( value ) , 0 , 8 , async ) ;
335+ return _dataProvider . Write ( TypeEncoder . EncodeInt64 ( value ) , 0 , 8 , async ) ;
336336 }
337337
338338 public Task Write( float value , AsyncWrappingCommonArgs async )
@@ -417,7 +417,7 @@ public Task WriteTime(TimeSpan value, AsyncWrappingCommonArgs async)
417417 readonly static byte [ ] PadArray = new byte [ ] { 0 , 0 , 0 , 0 } ;
418418 Task WritePad ( int length , AsyncWrappingCommonArgs async )
419419 {
420- return _datProvider . Write ( PadArray , 0 , length , async ) ;
420+ return _dataProvider . Write ( PadArray , 0 , length , async ) ;
421421 }
422422
423423 Task ReadPad( int length , AsyncWrappingCommonArgs async )
@@ -429,7 +429,7 @@ Task ReadPad(int length, AsyncWrappingCommonArgs async)
429429 readonly static byte [ ] FillArray = Enumerable . Repeat ( ( byte ) 32 , 32767 ) . ToArray ( ) ;
430430 Task WriteFill( int length , AsyncWrappingCommonArgs async )
431431 {
432- return _datProvider . Write ( FillArray , 0 , length , async ) ;
432+ return _dataProvider . Write ( FillArray , 0 , length , async ) ;
433433 }
434434
435435 #endregion
0 commit comments