ThreadedFork

This class is a threaded version of the Fork filter. While this uses threads, the class itself is NOT thread-safe. This is meant as a drop- in replacement for Fork where performance gains are possible.

class ThreadedFork : Fork , Filterable {

string name [@property getter];

this(Filter f1, Filter f2, Filter f3, Filter f4);

this(Filter* filter_arr, size_t length);

void write(const(ubyte)* input, size_t len);

void setNext(Filter* f, size_t n);

void send(const(ubyte)* input, size_t length);

}

Constructors

this this(Filter f1, Filter f2, Filter f3, Filter f4): Construct a Threaded_Fork filter with up to four forks.
this this(Filter* filter_arr, size_t length): Construct a Threaded_Fork from range of filters

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.
send void send(const(ubyte)* input, size_t length): 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.
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 len): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

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

Inherited Members

From Fork

write void write(const(ubyte)* input, size_t length): 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.
name string name [@property getter]: 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.
setNext void setNext(Filter* filters, size_t sz): Undocumented in source. Be warned that the author may not have intended to support it.

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)