Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-10 10:38:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

FileAnalysis: improve HTTP integration.

Browse source 
Seems to be working with various examples I tested, now including
multipart/byteranges.
This commit is contained in:
Jon Siwek 2013-03-14 17:05:05 -05:00
parent e0f3713912
commit 31590fbb9b
3 changed files with 40 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

42
src/HTTP.cc
View file

@ -45,6 +45,9 @@ HTTP_Entity::HTTP_Entity(HTTP_Message *arg_message, MIME_Entity* parent_entity,
deliver_body = (http_entity_data != 0);
encoding = IDENTITY;
zip = 0;
is_partial_content = false;
offset = 0;
content_size = -1; // unspecified
}
void HTTP_Entity::EndOfData()
@ -195,12 +198,6 @@ void HTTP_Entity::DeliverBody(int len, const char* data, int trailing_CRLF)
}
else
DeliverBodyClear(len, data, trailing_CRLF);
file_mgr->DataIn(reinterpret_cast<const u_char*>(data), len,
http_message->MyHTTP_Analyzer()->Conn(),
http_message->IsOrig());
// TODO: set size if we have content_length?
// TODO: handle partial content and multipart/byteranges
}
void HTTP_Entity::DeliverBodyClear(int len, const char* data, int trailing_CRLF)
@ -284,6 +281,28 @@ void HTTP_Entity::SubmitData(int len, const char* buf)
{
if ( deliver_body )
MIME_Entity::SubmitData(len, buf);
if ( is_partial_content )
{
file_mgr->DataIn(reinterpret_cast<const u_char*>(buf), len, offset,
http_message->MyHTTP_Analyzer()->Conn(),
http_message->IsOrig());
offset += len;
if ( content_size >= 0 )
file_mgr->SetSize(content_size,
http_message->MyHTTP_Analyzer()->Conn(),
http_message->IsOrig());
}
else
{
file_mgr->DataIn(reinterpret_cast<const u_char*>(buf), len,
http_message->MyHTTP_Analyzer()->Conn(),
http_message->IsOrig());
if ( content_length >= 0 )
file_mgr->SetSize(content_length,
http_message->MyHTTP_Analyzer()->Conn(),
http_message->IsOrig());
}
}
void HTTP_Entity::SetPlainDelivery(int64_t length)
@ -366,7 +385,14 @@ void HTTP_Entity::SubmitHeader(MIME_Header* h)
DEBUG_MSG("Content-Range length = %"PRId64"\n", len);
if ( len > 0 )
{
if ( instance_length != "*" )
atoi_n(instance_length.size(), instance_length.c_str(), 0, 10,
content_size);
is_partial_content = true;
offset = f;
content_length = len;
}
else
{
http_message->Weird("HTTP_non_positive_content_range");
@ -529,6 +555,7 @@ void HTTP_Message::Done(const int interrupted, const char* detail)
}
MyHTTP_Analyzer()->HTTP_MessageDone(is_orig, this);
file_mgr->EndOfFile(MyHTTP_Analyzer()->Conn(), is_orig);
delete_strings(buffers);
@ -593,7 +620,8 @@ void HTTP_Message::EndEntity(MIME_Entity* entity)
// SubmitAllHeaders (through EndOfData).
if ( entity == top_level )
Done();
else if ( ! ( current_entity->MIMEContentType() == CONTENT_TYPE_MULTIPART &&
MyHTTP_Analyzer()->HTTP_ReplyCode() == 206 ) )
file_mgr->EndOfFile(MyHTTP_Analyzer()->Conn(), is_orig);
}

3
src/HTTP.h
View file

@ -55,6 +55,9 @@ protected:
int deliver_body;
enum { IDENTITY, GZIP, COMPRESS, DEFLATE } encoding;
ZIP_Analyzer* zip;
bool is_partial_content;
uint64_t offset;
int64_t content_size; // total size of content specified by content-range
MIME_Entity* NewChildEntity() { return new HTTP_Entity(http_message, this, 1); }

2
src/MIME.h
View file

@ -131,7 +131,7 @@ protected:
int GetDataBuffer();
void DataOctet(char ch);
void DataOctets(int len, const char* data);
void SubmitData(int len, const char* buf);
virtual void SubmitData(int len, const char* buf);
virtual void SubmitHeader(MIME_Header* h);
// Submit all headers in member "headers".