Mirror/zeek
1
0
Fork 0
mirror of https://github.com/zeek/zeek.git synced 2025-10-02 14:48:21 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

logging: Fix typos from review

Browse source
This commit is contained in:
Arne Welzel 2023-11-30 11:46:06 +01:00
parent ee65623600
commit 9956d96824
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/logging/Manager.cc
View file

@ -129,7 +129,7 @@ public:
void AppendPostDelayCallback(FuncPtr f) { post_delay_callbacks.emplace_back(std::move(f)); } void AppendPostDelayCallback(FuncPtr f) { post_delay_callbacks.emplace_back(std::move(f)); }
private: private:
// ActiveWrite information // Active log write information
WriteContext ctx; WriteContext ctx;
// References - number of Log::delay() calls. // References - number of Log::delay() calls.
@ -1217,7 +1217,7 @@ ValPtr Manager::Delay(const EnumValPtr& id, const RecordValPtr record, FuncPtr p
} }
else { else {
// This is the first time this Log::write() is delayed, allocate a // This is the first time this Log::write() is delayed, allocate a
// new token an return it to script land. // new token and return it to script land.
detail::DelayTokenType token = ++last_delay_token; detail::DelayTokenType token = ++last_delay_token;
token_val = zeek::make_intrusive<detail::LogDelayTokenVal>(token); token_val = zeek::make_intrusive<detail::LogDelayTokenVal>(token);
double expire_time = run_state::network_time + stream->max_delay_interval; double expire_time = run_state::network_time + stream->max_delay_interval;
@ -1304,7 +1304,7 @@ bool Manager::DelayCompleted(Stream* stream, detail::DelayInfo& delay_info) {
{ {
// Push a new active write when running the post delay callbacks. This // Push a new active write when running the post delay callbacks. This
// allows re-delay the record and putting it at the end of the queue. // allows re-delaying the record and putting it at the end of the queue.
uint64_t idx = ++stream->write_idx; uint64_t idx = ++stream->write_idx;
detail::WriteContext write_context{delay_info.StreamId(), delay_info.Record(), idx}; detail::WriteContext write_context{delay_info.StreamId(), delay_info.Record(), idx};
detail::ActiveWriteScope active_write_scope{active_writes, write_context}; detail::ActiveWriteScope active_write_scope{active_writes, write_context};