Deveel.Data.Client.StreamDatabaseInterface Class Reference

An stream implementation of an interface to a database. More...

Inheritance diagram for Deveel.Data.Client.StreamDatabaseInterface:

Protected Member Functions
override void	SendCommand (byte[] command, int offset, int size)
override byte[]	ReceiveCommand (int timeout)
override void	CloseConnection ()

Protected Attributes
BinaryWriter	output
	The data output stream for the db protocol. More...
BinaryReader	input
	The data input stream for the db protocol. More...

Package Functions
	StreamDatabaseInterface (string initial_database)
void	Setup (Stream rawin, Stream rawout)
	Sets up the stream connection with the given input/output stream. More...

Private Attributes
bool	closed = false

Detailed Description

An stream implementation of an interface to a database.

This is a stream based communication protocol.

Definition at line 26 of file StreamDatabaseInterface.cs.

Constructor & Destructor Documentation

Deveel.Data.Client.StreamDatabaseInterface.StreamDatabaseInterface ( string  initial_database )

inlinepackage

Definition at line 27 of file StreamDatabaseInterface.cs.

            : base(initial_database) {
        }

Member Function Documentation

override void Deveel.Data.Client.StreamDatabaseInterface.CloseConnection ( )

inlineprotected

Definition at line 80 of file StreamDatabaseInterface.cs.

                                                  {
            try {
                if (output != null)
                    output.Close();
            } finally {
                if (input != null)
                    input.Close();

                closed = true;
            }
        }

override byte [] Deveel.Data.Client.StreamDatabaseInterface.ReceiveCommand ( int  timeout )

inlineprotected

Definition at line 64 of file StreamDatabaseInterface.cs.

                                                              {
            if (closed) {
                throw new IOException("IDatabaseInterface is closed!");
            }
            try {
                int commandLength = input.ReadInt32();
                byte[] buf = new byte[commandLength];
                input.Read(buf, 0, commandLength);
                return buf;
            } catch (NullReferenceException) {
                Console.Out.WriteLine("Throwable generated at: " + this);
                throw;
            }
        }

override void Deveel.Data.Client.StreamDatabaseInterface.SendCommand ( byte[]  command, int  offset, int  size  )

inlineprotected

Definition at line 57 of file StreamDatabaseInterface.cs.

                                                                                  {
            output.Write(size);
            output.Write(command, 0, size);
            output.Flush();
        }

void Deveel.Data.Client.StreamDatabaseInterface.Setup ( Stream  rawin, Stream  rawout  )

inlinepackage

Sets up the stream connection with the given input/output stream.

Parameters

rawin
rawout

Definition at line 47 of file StreamDatabaseInterface.cs.

                                                         {
            if (rawin == null || rawout == null) {
                throw new IOException("rawin or rawin is null");
            }
            // Get the input and output and wrap around Data streams.
            input = new BinaryReader(new BufferedStream(rawin, 32768));
            output = new BinaryWriter(new BufferedStream(rawout, 32768));
        }

Member Data Documentation

bool Deveel.Data.Client.StreamDatabaseInterface.closed = false

private

Definition at line 40 of file StreamDatabaseInterface.cs.

BinaryReader Deveel.Data.Client.StreamDatabaseInterface.input

protected

The data input stream for the db protocol.

Definition at line 38 of file StreamDatabaseInterface.cs.

BinaryWriter Deveel.Data.Client.StreamDatabaseInterface.output

protected

The data output stream for the db protocol.

Definition at line 34 of file StreamDatabaseInterface.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/StreamDatabaseInterface.cs