FanoutFilter

This is the abstract FanoutFilter base class.

Members

Functions

attach
void attach(Filter f)
Undocumented in source. Be warned that the author may not have intended to support it.
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.
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.

Inherited Members

From Filter

write
void write(const(ubyte)[] input)

Write a portion of a message to this filter.

write
void write(const(ubyte)* input, size_t length)
Undocumented in source.
send
void send(const(ubyte)* input, size_t length)
send
void send(ubyte input)
send
void send(Vector!(ubyte, ALLOC) input)
send
void send(RefCounted!(Vector!(ubyte, ALLOC), ALLOC) input)
send
void send(Vector!(ubyte, ALLOC) input, size_t length)
send
void send(RefCounted!(Vector!(ubyte, ALLOC), ALLOC) input, size_t length)
newMsg
void newMsg()

Start a new message in this and all following filters. Only for internal use, not intended for use in client applications.

finishMsg
void finishMsg()

End a new message in this and all following filters. Only for internal use, not intended for use in client applications.

totalPorts
size_t totalPorts()
Undocumented in source. Be warned that the author may not have intended to support it.
currentPort
size_t currentPort()
Undocumented in source. Be warned that the author may not have intended to support it.
setPort
void setPort(size_t new_port)

Set the active port

owns
size_t owns()
Undocumented in source. Be warned that the author may not have intended to support it.
attach
void attach(Filter new_filter)

Attach another filter to this one

setNext
void setNext(Filter* filters, size_t size)
getNext
Filter getNext()
Undocumented in source. Be warned that the author may not have intended to support it.
attachable
bool attachable()
Undocumented in source. Be warned that the author may not have intended to support it.
startMsg
void startMsg()
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.
name
string name [@property getter]
Undocumented in source.
m_write_queue
SecureVector!ubyte m_write_queue;
Undocumented in source.
m_next
Vector!Filter m_next;
Undocumented in source.
m_port_num
size_t m_port_num;
m_filter_owns
size_t m_filter_owns;
Undocumented in source.
m_owned
bool m_owned;
Undocumented in source.

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