1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127
|
/*
* Filter
* (C) 1999-2007 Jack Lloyd
*
* Distributed under the terms of the Botan license
*/
#include <botan/filter.h>
#include <botan/secqueue.h>
#include <botan/exceptn.h>
namespace Botan {
/*
* Filter Constructor
*/
Filter::Filter()
{
next.resize(1);
port_num = 0;
filter_owns = 0;
owned = false;
}
/*
* Send data to all ports
*/
void Filter::send(const byte input[], size_t length)
{
bool nothing_attached = true;
for(size_t j = 0; j != total_ports(); ++j)
if(next[j])
{
if(write_queue.size())
next[j]->write(&write_queue[0], write_queue.size());
next[j]->write(input, length);
nothing_attached = false;
}
if(nothing_attached)
write_queue += std::make_pair(input, length);
else
write_queue.clear();
}
/*
* Start a new message
*/
void Filter::new_msg()
{
start_msg();
for(size_t j = 0; j != total_ports(); ++j)
if(next[j])
next[j]->new_msg();
}
/*
* End the current message
*/
void Filter::finish_msg()
{
end_msg();
for(size_t j = 0; j != total_ports(); ++j)
if(next[j])
next[j]->finish_msg();
}
/*
* Attach a filter to the current port
*/
void Filter::attach(Filter* new_filter)
{
if(new_filter)
{
Filter* last = this;
while(last->get_next())
last = last->get_next();
last->next[last->current_port()] = new_filter;
}
}
/*
* Set the active port on a filter
*/
void Filter::set_port(size_t new_port)
{
if(new_port >= total_ports())
throw Invalid_Argument("Filter: Invalid port number");
port_num = new_port;
}
/*
* Return the next Filter in the logical chain
*/
Filter* Filter::get_next() const
{
if(port_num < next.size())
return next[port_num];
return 0;
}
/*
* Set the next Filters
*/
void Filter::set_next(Filter* filters[], size_t size)
{
next.clear();
port_num = 0;
filter_owns = 0;
while(size && filters && filters[size-1] == 0)
--size;
if(filters && size)
next.assign(filters, filters + size);
}
/*
* Return the total number of ports
*/
size_t Filter::total_ports() const
{
return next.size();
}
}
|