Deveel.Data.Store.ObjectStream Class Reference

Inheritance diagram for Deveel.Data.Store.ObjectStream:

Public Member Functions
	ObjectStream (ILargeObject largeObject)
override void	Flush ()
override long	Seek (long offset, SeekOrigin origin)
override void	SetLength (long value)
override int	Read (byte[] buffer, int offset, int count)
override void	Write (byte[] buffer, int offset, int count)

Protected Member Functions
override void	Dispose (bool disposing)

Properties
override bool	CanRead [get]
override bool	CanSeek [get]
override bool	CanWrite [get]
override long	Length [get]
override long	Position [get, set]

Private Member Functions
void	ReadPageContent (byte[] buffer, long pos, int length)
void	FillBuffer (long pos)

Private Attributes
readonly ILargeObject	largeObject
long	position
Stream	outTempStream
long	readBufferPos
readonly byte[]	readBuf
const int	BufferSize = 64*1024

Detailed Description

Definition at line 21 of file ObjectStream.cs.

Constructor & Destructor Documentation

Deveel.Data.Store.ObjectStream.ObjectStream ( ILargeObject  largeObject )

inline

Definition at line 31 of file ObjectStream.cs.

                                                      {
            if (largeObject == null)
                throw new ArgumentNullException("largeObject");

            this.largeObject = largeObject;
            outTempStream = new MemoryStream(64*1024);

            readBuf = new byte[BufferSize];
            readBufferPos = -1;
        }

Member Function Documentation

override void Deveel.Data.Store.ObjectStream.Dispose ( bool  disposing )

inlineprotected

Definition at line 55 of file ObjectStream.cs.

                                                        {
            if (disposing) {
                if (outTempStream != null)
                    outTempStream.Dispose();
            }

            outTempStream = null;
            base.Dispose(disposing);
        }

void Deveel.Data.Store.ObjectStream.FillBuffer ( long  pos )

inlineprivate

Definition at line 46 of file ObjectStream.cs.

                                          {
            long readPos = (pos/BufferSize)*BufferSize;
            int toRead = (int) System.Math.Min(BufferSize, (largeObject.RawSize - readPos));
            if (toRead > 0) {
                ReadPageContent(readBuf, readPos, toRead);
                readBufferPos = readPos;
            }
        }

override void Deveel.Data.Store.ObjectStream.Flush ( )

inline

Definition at line 65 of file ObjectStream.cs.

                                     {
            if (outTempStream == null ||
                outTempStream.Length == 0)
                return;

            try {
                long offset = 0;
                var buffer = new byte[BufferSize];
                var totalLength = outTempStream.Length;

                outTempStream.Seek(0, SeekOrigin.Begin);

                while (offset < totalLength) {
                    // Fill the buffer
                    int index = 0;
                    int blockRead = (int) System.Math.Min((long) BufferSize, (totalLength - offset));
                    int toRead = blockRead;
                    while (toRead > 0) {
                        int count = outTempStream.Read(buffer, index, toRead);
                        if (count == 0)
                            break;

                        index += count;
                        toRead -= count;
                    }

                    // Send the part of the streamable object to the database.
                    largeObject.Write(offset, buffer, blockRead);
                    // Increment the offset and upload the next part of the object.
                    offset += blockRead;
                }
            } finally {
                outTempStream.SetLength(0);
            }
        }

override int Deveel.Data.Store.ObjectStream.Read ( byte[]  buffer, int  offset, int  count  )

inline

Definition at line 109 of file ObjectStream.cs.

                                                                       {
            if (!largeObject.IsComplete)
                throw new IOException("The underlying object is not complete.");

            if (count <= 0) {
                return 0;
            }

            if (readBufferPos == -1) {
                FillBuffer(position);
            }

            int p = (int) (position - readBufferPos);
            long bufferEnd = System.Math.Min(readBufferPos + BufferSize, largeObject.RawSize);
            int toRead = (int) System.Math.Min((long) count, bufferEnd - position);
            if (toRead <= 0) {
                return 0;
            }
            int hasRead = 0;
            while (toRead > 0) {
                Array.Copy(readBuf, p, buffer, offset, toRead);
                hasRead += toRead;
                p += toRead;
                offset += toRead;
                count -= toRead;
                position += toRead;
                if (p >= BufferSize) {
                    FillBuffer(readBufferPos + BufferSize);
                    p -= BufferSize;
                }
                bufferEnd = System.Math.Min(readBufferPos + BufferSize, largeObject.RawSize);
                toRead = (int) System.Math.Min((long)count, bufferEnd - position);
            }

            return hasRead;
        }

void Deveel.Data.Store.ObjectStream.ReadPageContent ( byte[]  buffer, long  pos, int  length  )

inlineprivate

Definition at line 42 of file ObjectStream.cs.

                                                                          {
            largeObject.Read(pos, buffer, length);
        }

override long Deveel.Data.Store.ObjectStream.Seek ( long  offset, SeekOrigin  origin  )

inline

Definition at line 101 of file ObjectStream.cs.

                                                                  {
            throw new NotImplementedException();
        }

override void Deveel.Data.Store.ObjectStream.SetLength ( long  value )

inline

Definition at line 105 of file ObjectStream.cs.

                                                   {
            throw new NotSupportedException("The lenght of the underlying object cannot be changed.");
        }

override void Deveel.Data.Store.ObjectStream.Write ( byte[]  buffer, int  offset, int  count  )

inline

Definition at line 146 of file ObjectStream.cs.

                                                                         {
            if (largeObject.IsComplete)
                throw new IOException("The underlying object is complete.");

            outTempStream.Write(buffer, offset, count);
            position += count;
        }

Member Data Documentation

const int Deveel.Data.Store.ObjectStream.BufferSize = 64*1024

private

Definition at line 29 of file ObjectStream.cs.

readonly ILargeObject Deveel.Data.Store.ObjectStream.largeObject

private

Definition at line 22 of file ObjectStream.cs.

Stream Deveel.Data.Store.ObjectStream.outTempStream

private

Definition at line 24 of file ObjectStream.cs.

long Deveel.Data.Store.ObjectStream.position

private

Definition at line 23 of file ObjectStream.cs.

readonly byte [] Deveel.Data.Store.ObjectStream.readBuf

private

Definition at line 27 of file ObjectStream.cs.

long Deveel.Data.Store.ObjectStream.readBufferPos

private

Definition at line 26 of file ObjectStream.cs.

Property Documentation

override bool Deveel.Data.Store.ObjectStream.CanRead

get

Definition at line 154 of file ObjectStream.cs.

override bool Deveel.Data.Store.ObjectStream.CanSeek

get

Definition at line 158 of file ObjectStream.cs.

override bool Deveel.Data.Store.ObjectStream.CanWrite

get

Definition at line 162 of file ObjectStream.cs.

override long Deveel.Data.Store.ObjectStream.Length

get

Definition at line 166 of file ObjectStream.cs.

override long Deveel.Data.Store.ObjectStream.Position

getset

Definition at line 170 of file ObjectStream.cs.

---

The documentation for this class was generated from the following file:

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Store/ObjectStream.cs