TKernel_DataStream

Data streams are the fundamental part of what makes tornado different to any other OS architecture. Data streams essentially are a formal interface for the passing of data between entities which are derived from TKernel_DataStreamableObject. Data is passed between these objects in the form of TKernel_DataStreamData objects.

Data streams can only have one input, but they can have many outputs. This is to facilitate a feature of tornado called "work conglomeration" which essentially means that if the same data needs to be processed twice by two different things then it needs to be done only once and the results sent to two different recipients.

Data streams are inherently multitasking. When you send data into a data stream, the call returns immediately as the data sent is put on a output queue. This flushes asynchronously - essentially at the rate each of the receivers processes that data. As a result, your data stream object must be thread-safe on a per object basis - ie; your DataStreamInterface code will not have more than one thread per object running, but many threads may run as there are instances of that object.

Data stream objects must also be of a finite state - what goes in must always produce the same output. Remember this as tornado optimises data flow through automatically reorganising data flow based on this assumption.

TKernel_DataStreamData

• Attributes:
  • u32 len
  • TKernel_DataStreamableObject *from
  • TKernel_DataStreamType type;
  • u32 cmd
  • void *data

TKernel_DataStream

• Attributes:
  • TKernel_DataStreamType type

• Methods:
  • void SetInput(TKernel_DataStreamableObject *input)
    This sets this input for this data stream to being this object
  • void AddOutput(TKernel_DataStreamableObject *output)
    This adds this output object to this data stream
  • void SendData(const TKernel_DataStreamData data)
    This sends data down this data stream

TKernel_DataStreamableObject

• Attributes:
  • TCore_String ObjectName
    This is the name of this data stream object
• Methods:
  • void LinkInputTo(TKernel_DataStream *input)
    This adds this data stream to the input of this data stream object
  • void LinkOutputTo(TKernel_DataStream *output)
    This adds this data stream to the output of this data stream object
  • void DataStreamInterface(const TKernel_DataStreamData data)