current_flow->session_data_mutex.lock();
if (current_flow->get_tcp_flow())
current_flow->get_tcp_flow()->last_data_seen = packet_time();
-
+ sess->co_tracker_mutex.lock();
if (parent_tree->get_cotracker())
{
- sess->co_tracker_mutex.lock();
DCE2_CoProcess(current_flow->get_dce2_session_data(), parent_tree->get_cotracker(),
file_data, data_size);
- sess->co_tracker_mutex.unlock();
}
+ sess->co_tracker_mutex.unlock();
current_flow->session_data_mutex.unlock();
return true;
}
if (share_type != SMB2_SHARE_TYPE_DISK)
{
+ parent_session->co_tracker_mutex.lock();
DCE2_CoCleanTracker(co_tracker);
+ parent_session->co_tracker_mutex.unlock();
+
}
}
{
data_size = UINT16_MAX;
}
+ parent_session->co_tracker_mutex.lock();
if (co_tracker)
{
- parent_session->co_tracker_mutex.lock();
DCE2_CoProcess(get_dce2_session_data(p->flow), co_tracker, file_data, data_size);
- parent_session->co_tracker_mutex.unlock();
}
+ parent_session->co_tracker_mutex.unlock();
}
void Dce2Smb2TreeTracker::process(uint16_t command, uint8_t command_type,