9#include <botan/internal/out_buf.h>
10#include <botan/secqueue.h>
19class Null_Filter
final :
public Filter
22 void write(
const uint8_t input[],
size_t length)
override
23 { send(input, length); }
25 std::string
name()
const override {
return "Null"; }
48 for(
auto i = args.begin(); i != args.end(); ++i)
73void Pipe::destruct(
Filter* to_kill)
77 for(
size_t j = 0; j != to_kill->total_ports(); ++j)
78 destruct(to_kill->m_next[j]);
106 write(input, length);
147 throw Invalid_State(
"Pipe::start_msg: Message was already started");
148 if(m_pipe ==
nullptr)
149 m_pipe =
new Null_Filter;
150 find_endpoints(m_pipe);
161 throw Invalid_State(
"Pipe::end_msg: Message was already ended");
162 m_pipe->finish_msg();
163 clear_endpoints(m_pipe);
164 if(
dynamic_cast<Null_Filter*
>(m_pipe))
169 m_inside_msg =
false;
177void Pipe::find_endpoints(
Filter* f)
179 for(
size_t j = 0; j != f->total_ports(); ++j)
180 if(f->m_next[j] && !
dynamic_cast<SecureQueue*
>(f->m_next[j]))
181 find_endpoints(f->m_next[j]);
193void Pipe::clear_endpoints(Filter* f)
196 for(
size_t j = 0; j != f->total_ports(); ++j)
198 if(f->m_next[j] &&
dynamic_cast<SecureQueue*
>(f->m_next[j]))
199 f->m_next[j] =
nullptr;
200 clear_endpoints(f->m_next[j]);
211 if(m_outputs->message_count() != 0)
212 throw Invalid_State(
"Cannot call Pipe::append_filter after start_msg");
224 if(m_outputs->message_count() != 0)
225 throw Invalid_State(
"Cannot call Pipe::prepend_filter after start_msg");
233void Pipe::do_append(
Filter* filter)
243 throw Invalid_State(
"Cannot append to a Pipe while it is processing");
245 filter->m_owned =
true;
247 if(!m_pipe) m_pipe = filter;
248 else m_pipe->attach(filter);
254void Pipe::do_prepend(Filter* filter)
257 throw Invalid_State(
"Cannot prepend to a Pipe while it is processing");
260 if(
dynamic_cast<SecureQueue*
>(filter))
261 throw Invalid_Argument(
"Pipe::prepend: SecureQueue cannot be used");
263 throw Invalid_Argument(
"Filters cannot be shared among multiple Pipes");
265 filter->m_owned =
true;
267 if(m_pipe) filter->attach(m_pipe);
277 throw Invalid_State(
"Cannot pop off a Pipe while it is processing");
282 if(m_pipe->total_ports() > 1)
283 throw Invalid_State(
"Cannot pop off a Filter with multiple ports");
285 size_t to_remove = m_pipe->owns() + 1;
289 std::unique_ptr<Filter> to_destroy(m_pipe);
290 m_pipe = m_pipe->m_next[0];
299 return m_outputs->message_count();
static const message_id LAST_MESSAGE
void process_msg(const uint8_t in[], size_t length)
void process_msg(const std::vector< uint8_t > &in)
void write(const uint8_t in[], size_t length)
static const message_id DEFAULT_MESSAGE
Pipe(Filter *=nullptr, Filter *=nullptr, Filter *=nullptr, Filter *=nullptr)
void prepend_filter(Filter *filt)
void append(Filter *filt)
void append_filter(Filter *filt)
message_id message_count() const
void prepend(Filter *filt)
bool end_of_data() const override
void set_default_msg(message_id msg)
size_t remaining(message_id msg=DEFAULT_MESSAGE) const BOTAN_WARN_UNUSED_RESULT
int(* final)(unsigned char *, CTX *)
std::vector< T, secure_allocator< T > > secure_vector
const uint8_t * cast_char_ptr_to_uint8(const char *s)