SecureQueue

A queue that knows how to zeroise itself

Constructors

this
this()

SecureQueue default constructor (creates empty queue)

this
this(SecureQueue input)

SecureQueue copy constructor

Destructor

~this
~this()
Undocumented in source.

Members

Functions

attachable
bool attachable()
Undocumented in source. Be warned that the author may not have intended to support it.
endMsg
void endMsg()
Undocumented in source. Be warned that the author may not have intended to support it.
endOfData
bool endOfData()
Undocumented in source. Be warned that the author may not have intended to support it.
getBytesRead
size_t getBytesRead()

Return how many bytes have been read so far.

id
string id()
Undocumented in source. Be warned that the author may not have intended to support it.
peek
size_t peek(ubyte* output, size_t length, size_t offset)
Undocumented in source. Be warned that the author may not have intended to support it.
read
size_t read(ubyte* output, size_t length)
Undocumented in source. Be warned that the author may not have intended to support it.
setNext
void setNext(Filter* filters, size_t sz)
Undocumented in source. Be warned that the author may not have intended to support it.
size
size_t size()
startMsg
void startMsg()
Undocumented in source. Be warned that the author may not have intended to support it.
write
void write(const(ubyte)* input, size_t length)
Undocumented in source. Be warned that the author may not have intended to support it.

Properties

empty
bool empty [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
length
size_t length [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.
name
string name [@property getter]
Undocumented in source. Be warned that the author may not have intended to support it.

Inherited Members

From FanoutFilter

incrOwns
void incrOwns()

Increment the number of filters past us that we own

setNext
void setNext(Filter f, size_t n)
Undocumented in source. Be warned that the author may not have intended to support it.
setPort
void setPort(size_t n)
Undocumented in source. Be warned that the author may not have intended to support it.
setNext
void setNext(Filter* f, size_t n)
Undocumented in source. Be warned that the author may not have intended to support it.
attach
void attach(Filter f)
Undocumented in source. Be warned that the author may not have intended to support it.

From DataSourceImpl

read
size_t read(ubyte* output, size_t length)

Read from the source. Moves the internal offset so that every call to read will return a new portion of the source.

peek
size_t peek(ubyte* output, size_t length, size_t peek_offset)

Read from the source but do not modify the internal offset. Consecutive calls to peek() will return portions of the source starting at the same position.

endOfData
bool endOfData()

Test whether the source still has data that can be read.

id
string id()

return the id of this data source

readByte
size_t readByte(ubyte output)

Read one ubyte.

peekByte
size_t peekByte(ubyte output)

Peek at one ubyte.

discardNext
size_t discardNext(size_t n)

Discard the next N bytes of the data

getBytesRead
size_t getBytesRead()

From Filterable

name
string name [@property getter]
write
void write(const(ubyte)* input, size_t length)

Write a portion of a message to this filter.

startMsg
void startMsg()

Start a new message. Must be closed by endMsg() before another message can be started.

endMsg
void endMsg()

Notify that the current message is finished; flush buffers and do end-of-message processing (if any).

attachable
bool attachable()

Check whether this filter is an attachable filter.

setNext
void setNext(Filter* filters, size_t size)

Meta