Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel Class Reference

Inheritance diagram for Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel:

Public Member Functions
	DirectStreamableObjectChannel (ServerConnector connector, IRef obj)
void	Dispose ()
void	PushData (long offset, byte[] buffer, int length)
byte[]	ReadData (long offset, int length)

Private Attributes
readonly IRef	obj
readonly ServerConnector	connector

Detailed Description

Definition at line 651 of file ServerConnector.old.cs.

Constructor & Destructor Documentation

Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.DirectStreamableObjectChannel ( ServerConnector  connector, IRef  obj  )

inline

Definition at line 655 of file ServerConnector.old.cs.

                                                                                      {
                this.obj = obj;
                this.connector = connector;
            }

Member Function Documentation

void Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.Dispose ( )

inline

Definition at line 660 of file ServerConnector.old.cs.

                                  {
                connector.DisposeChannel(obj.Id);
            }

void Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.PushData ( long  offset, byte[]  buffer, int  length  )

inline

Definition at line 664 of file ServerConnector.old.cs.

                                                                         {
                obj.Write(offset, buffer, length);
            }

byte [] Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.ReadData ( long  offset, int  length  )

inline

Definition at line 668 of file ServerConnector.old.cs.

                                                            {
                if (length > 512 * 1024)
                    throw new DatabaseException("Request length exceeds 512 KB");

                try {
                    // Read the blob part into the byte array.
                    var blobPart = new byte[length];
                    obj.Read(offset, blobPart, length);

                    // And return as a StreamableObjectPart object.
                    return blobPart;
                } catch (IOException e) {
                    throw new DatabaseException("Exception while reading blob: " + e.Message, e);
                }
            }

Member Data Documentation

readonly ServerConnector Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.connector

private

Definition at line 653 of file ServerConnector.old.cs.

readonly IRef Deveel.Data.Protocol.ServerConnector.DirectStreamableObjectChannel.obj

private

Definition at line 652 of file ServerConnector.old.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Protocol/ServerConnector.old.cs