Bugfixes.

This commit is contained in:
Gunnar Beutner 2012-06-21 15:01:54 +02:00
parent abd34bdaa0
commit 77ce61d548
2 changed files with 4 additions and 1 deletions

View File

@ -151,7 +151,9 @@ void TlsClient::WritableEventHandler(void)
m_BlockRead = false; m_BlockRead = false;
m_BlockWrite = false; m_BlockWrite = false;
rc = SSL_write(m_SSL.get(), (const char *)GetSendQueue()->GetReadBuffer(), GetSendQueue()->GetSize()); size_t write_size = std::min(GetSendQueue()->GetSize(), (size_t)(16 * 1024));
rc = SSL_write(m_SSL.get(), (const char *)GetSendQueue()->GetReadBuffer(), write_size);
if (rc <= 0) { if (rc <= 0) {
int error = SSL_get_error(m_SSL.get(), rc); int error = SSL_get_error(m_SSL.get(), rc);

View File

@ -210,6 +210,7 @@ void DelegationComponent::DelegationTimerHandler(void)
if (delegated > 0) { if (delegated > 0) {
// TODO: send clear message when session is established // TODO: send clear message when session is established
// TODO: clear local assignments when session is lost // TODO: clear local assignments when session is lost
need_clear = true; /* remove this once clear messages are properly sent */
if (need_clear) { if (need_clear) {
map<Endpoint::Ptr, int>::iterator hit; map<Endpoint::Ptr, int>::iterator hit;
for (hit = histogram.begin(); hit != histogram.end(); hit++) { for (hit = histogram.begin(); hit != histogram.end(); hit++) {