mirror of
https://github.com/zeek/zeek.git
synced 2025-10-04 15:48:19 +00:00
Merge remote-tracking branch 'origin/topic/timw/nullptr'
* origin/topic/timw/nullptr: The remaining nulls plugin/probabilistic/zeekygen: Replace nulls with nullptr file_analysis: Replace nulls with nullptr analyzer: Replace nulls with nullptr iosource/threading/input/logging: Replace nulls with nullptr
This commit is contained in:
commit
a3a38f0849
187 changed files with 1119 additions and 1117 deletions
|
@ -147,7 +147,7 @@ WriterBackend* Manager::CreateBackend(WriterFrontend* frontend, EnumVal* tag)
|
|||
if ( ! c )
|
||||
{
|
||||
reporter->Error("unknown writer type requested");
|
||||
return 0;
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
WriterBackend* backend = (*c->Factory())(frontend);
|
||||
|
@ -161,7 +161,7 @@ Manager::Stream* Manager::FindStream(EnumVal* id)
|
|||
unsigned int idx = id->AsEnum();
|
||||
|
||||
if ( idx >= streams.size() || ! streams[idx] )
|
||||
return 0;
|
||||
return nullptr;
|
||||
|
||||
return streams[idx];
|
||||
}
|
||||
|
@ -182,7 +182,7 @@ Manager::WriterInfo* Manager::FindWriter(WriterFrontend* writer)
|
|||
}
|
||||
}
|
||||
|
||||
return 0;
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
bool Manager::CompareFields(const Filter* filter, const WriterFrontend* writer)
|
||||
|
@ -264,7 +264,7 @@ bool Manager::CreateStream(EnumVal* id, RecordVal* sval)
|
|||
}
|
||||
|
||||
auto event_val = sval->Lookup("ev");
|
||||
Func* event = event_val ? event_val->AsFunc() : 0;
|
||||
Func* event = event_val ? event_val->AsFunc() : nullptr;
|
||||
|
||||
if ( event )
|
||||
{
|
||||
|
@ -298,7 +298,7 @@ bool Manager::CreateStream(EnumVal* id, RecordVal* sval)
|
|||
unsigned int idx = id->AsEnum();
|
||||
|
||||
while ( idx >= streams.size() )
|
||||
streams.push_back(0);
|
||||
streams.push_back(nullptr);
|
||||
|
||||
if ( streams[idx] )
|
||||
// We already know this one, delete the previous definition.
|
||||
|
@ -309,7 +309,7 @@ bool Manager::CreateStream(EnumVal* id, RecordVal* sval)
|
|||
streams[idx]->id = id->Ref()->AsEnumVal();
|
||||
streams[idx]->enabled = true;
|
||||
streams[idx]->name = id->Type()->AsEnumType()->Lookup(idx);
|
||||
streams[idx]->event = event ? event_registry->Lookup(event->Name()) : 0;
|
||||
streams[idx]->event = event ? event_registry->Lookup(event->Name()) : nullptr;
|
||||
streams[idx]->columns = columns->Ref()->AsRecordType();
|
||||
|
||||
streams[idx]->enable_remote = internal_val("Log::enable_remote_logging")->AsBool();
|
||||
|
@ -347,7 +347,7 @@ bool Manager::RemoveStream(EnumVal* id)
|
|||
stream->writers.clear();
|
||||
string sname(stream->name);
|
||||
delete stream;
|
||||
streams[idx] = 0;
|
||||
streams[idx] = nullptr;
|
||||
|
||||
DBG_LOG(DBG_LOGGING, "Removed logging stream '%s'", sname.c_str());
|
||||
return true;
|
||||
|
@ -523,7 +523,7 @@ bool Manager::TraverseRecord(Stream* stream, Filter* filter, RecordType* rt,
|
|||
|
||||
bool optional = rtype->FieldDecl(i)->FindAttr(ATTR_OPTIONAL);
|
||||
|
||||
filter->fields[filter->num_fields - 1] = new threading::Field(new_path.c_str(), 0, t->Tag(), st, optional);
|
||||
filter->fields[filter->num_fields - 1] = new threading::Field(new_path.c_str(), nullptr, t->Tag(), st, optional);
|
||||
}
|
||||
|
||||
return true;
|
||||
|
@ -565,18 +565,18 @@ bool Manager::AddFilter(EnumVal* id, RecordVal* fval)
|
|||
filter->fval = fval->Ref();
|
||||
filter->name = name->AsString()->CheckString();
|
||||
filter->id = id->Ref()->AsEnumVal();
|
||||
filter->pred = pred ? pred->AsFunc() : 0;
|
||||
filter->path_func = path_func ? path_func->AsFunc() : 0;
|
||||
filter->pred = pred ? pred->AsFunc() : nullptr;
|
||||
filter->path_func = path_func ? path_func->AsFunc() : nullptr;
|
||||
filter->writer = writer->Ref()->AsEnumVal();
|
||||
filter->local = log_local->AsBool();
|
||||
filter->remote = log_remote->AsBool();
|
||||
filter->interval = interv->AsInterval();
|
||||
filter->postprocessor = postprocessor ? postprocessor->AsFunc() : 0;
|
||||
filter->postprocessor = postprocessor ? postprocessor->AsFunc() : nullptr;
|
||||
filter->config = config->Ref()->AsTableVal();
|
||||
filter->field_name_map = field_name_map->Ref()->AsTableVal();
|
||||
filter->scope_sep = scope_sep->AsString()->CheckString();
|
||||
filter->ext_prefix = ext_prefix->AsString()->CheckString();
|
||||
filter->ext_func = ext_func ? ext_func->AsFunc() : 0;
|
||||
filter->ext_func = ext_func ? ext_func->AsFunc() : nullptr;
|
||||
|
||||
// Build the list of fields that the filter wants included, including
|
||||
// potentially rolling out fields.
|
||||
|
@ -604,7 +604,7 @@ bool Manager::AddFilter(EnumVal* id, RecordVal* fval)
|
|||
}
|
||||
|
||||
filter->num_fields = 0;
|
||||
filter->fields = 0;
|
||||
filter->fields = nullptr;
|
||||
if ( ! TraverseRecord(stream, filter, stream->columns,
|
||||
include ? include->AsTableVal() : nullptr,
|
||||
exclude ? exclude->AsTableVal() : nullptr,
|
||||
|
@ -627,7 +627,7 @@ bool Manager::AddFilter(EnumVal* id, RecordVal* fval)
|
|||
{
|
||||
// If no path is given, it's derived based upon the value returned by
|
||||
// the first call to the filter's path_func (during first write).
|
||||
filter->path_val = 0;
|
||||
filter->path_val = nullptr;
|
||||
}
|
||||
|
||||
// Remove any filter with the same name we might already have.
|
||||
|
@ -811,8 +811,8 @@ bool Manager::Write(EnumVal* id, RecordVal* columns_arg)
|
|||
path = filter->path = filter->path_val->AsString()->CheckString();
|
||||
}
|
||||
|
||||
WriterBackend::WriterInfo* info = 0;
|
||||
WriterFrontend* writer = 0;
|
||||
WriterBackend::WriterInfo* info = nullptr;
|
||||
WriterFrontend* writer = nullptr;
|
||||
|
||||
if ( w != stream->writers.end() )
|
||||
{
|
||||
|
@ -1125,7 +1125,7 @@ WriterFrontend* Manager::CreateWriter(EnumVal* id, EnumVal* writer, WriterBacken
|
|||
int num_fields, const threading::Field* const* fields, bool local, bool remote, bool from_remote,
|
||||
const string& instantiating_filter)
|
||||
{
|
||||
WriterFrontend* result = 0;
|
||||
WriterFrontend* result = nullptr;
|
||||
|
||||
Stream* stream = FindStream(id);
|
||||
|
||||
|
@ -1133,7 +1133,7 @@ WriterFrontend* Manager::CreateWriter(EnumVal* id, EnumVal* writer, WriterBacken
|
|||
{
|
||||
// Don't know this stream.
|
||||
delete_info_and_fields(info, num_fields, fields);
|
||||
return 0;
|
||||
return nullptr;
|
||||
}
|
||||
|
||||
Stream::WriterMap::iterator w =
|
||||
|
@ -1149,11 +1149,11 @@ WriterFrontend* Manager::CreateWriter(EnumVal* id, EnumVal* writer, WriterBacken
|
|||
|
||||
WriterInfo* winfo = new WriterInfo;
|
||||
winfo->type = writer->Ref()->AsEnumVal();
|
||||
winfo->writer = 0;
|
||||
winfo->writer = nullptr;
|
||||
winfo->open_time = network_time;
|
||||
winfo->rotation_timer = 0;
|
||||
winfo->rotation_timer = nullptr;
|
||||
winfo->interval = 0;
|
||||
winfo->postprocessor = 0;
|
||||
winfo->postprocessor = nullptr;
|
||||
winfo->info = info;
|
||||
winfo->from_remote = from_remote;
|
||||
winfo->hook_initialized = false;
|
||||
|
@ -1194,7 +1194,7 @@ WriterFrontend* Manager::CreateWriter(EnumVal* id, EnumVal* writer, WriterBacken
|
|||
// Still need to set the WriterInfo's rotation parameters, which we
|
||||
// computed above.
|
||||
const char* base_time = log_rotate_base_time ?
|
||||
log_rotate_base_time->AsString()->CheckString() : 0;
|
||||
log_rotate_base_time->AsString()->CheckString() : nullptr;
|
||||
|
||||
winfo->info->rotation_interval = winfo->interval;
|
||||
winfo->info->rotation_base = parse_rotate_base_time(base_time);
|
||||
|
@ -1411,12 +1411,12 @@ protected:
|
|||
RotationTimer::~RotationTimer()
|
||||
{
|
||||
if ( winfo->rotation_timer == this )
|
||||
winfo->rotation_timer = 0;
|
||||
winfo->rotation_timer = nullptr;
|
||||
}
|
||||
|
||||
void RotationTimer::Dispatch(double t, bool is_expire)
|
||||
{
|
||||
winfo->rotation_timer = 0;
|
||||
winfo->rotation_timer = nullptr;
|
||||
|
||||
if ( rotate )
|
||||
log_mgr->Rotate(winfo);
|
||||
|
@ -1436,7 +1436,7 @@ void Manager::InstallRotationTimer(WriterInfo* winfo)
|
|||
if ( winfo->rotation_timer )
|
||||
{
|
||||
timer_mgr->Cancel(winfo->rotation_timer);
|
||||
winfo->rotation_timer = 0;
|
||||
winfo->rotation_timer = nullptr;
|
||||
}
|
||||
|
||||
double rotation_interval = winfo->interval;
|
||||
|
@ -1454,7 +1454,7 @@ void Manager::InstallRotationTimer(WriterInfo* winfo)
|
|||
winfo->open_time = network_time;
|
||||
|
||||
const char* base_time = log_rotate_base_time ?
|
||||
log_rotate_base_time->AsString()->CheckString() : 0;
|
||||
log_rotate_base_time->AsString()->CheckString() : nullptr;
|
||||
|
||||
double base = parse_rotate_base_time(base_time);
|
||||
double delta_t =
|
||||
|
|
|
@ -261,7 +261,7 @@ private:
|
|||
threading::Value** RecordToFilterVals(Stream* stream, Filter* filter,
|
||||
RecordVal* columns);
|
||||
|
||||
threading::Value* ValToLogVal(Val* val, BroType* ty = 0);
|
||||
threading::Value* ValToLogVal(Val* val, BroType* ty = nullptr);
|
||||
Stream* FindStream(EnumVal* id);
|
||||
void RemoveDisabledWriters(Stream* stream);
|
||||
void InstallRotationTimer(WriterInfo* winfo);
|
||||
|
|
|
@ -121,7 +121,7 @@ bool WriterBackend::WriterInfo::FromBroker(broker::data d)
|
|||
WriterBackend::WriterBackend(WriterFrontend* arg_frontend) : MsgThread()
|
||||
{
|
||||
num_fields = 0;
|
||||
fields = 0;
|
||||
fields = nullptr;
|
||||
buffering = true;
|
||||
frontend = arg_frontend;
|
||||
info = new WriterInfo(frontend->Info());
|
||||
|
@ -168,7 +168,7 @@ bool WriterBackend::FinishedRotation(const char* new_name, const char* old_name,
|
|||
bool WriterBackend::FinishedRotation()
|
||||
{
|
||||
--rotation_counter;
|
||||
SendOut(new RotationFinishedMessage(frontend, 0, 0, 0, 0, false, false));
|
||||
SendOut(new RotationFinishedMessage(frontend, nullptr, nullptr, 0, 0, false, false));
|
||||
return true;
|
||||
}
|
||||
|
||||
|
|
|
@ -82,14 +82,14 @@ public:
|
|||
*/
|
||||
config_map config;
|
||||
|
||||
WriterInfo() : path(0), rotation_interval(0.0), rotation_base(0.0),
|
||||
WriterInfo() : path(nullptr), rotation_interval(0.0), rotation_base(0.0),
|
||||
network_time(0.0)
|
||||
{
|
||||
}
|
||||
|
||||
WriterInfo(const WriterInfo& other)
|
||||
{
|
||||
path = other.path ? copy_string(other.path) : 0;
|
||||
path = other.path ? copy_string(other.path) : nullptr;
|
||||
rotation_interval = other.rotation_interval;
|
||||
rotation_base = other.rotation_base;
|
||||
network_time = other.network_time;
|
||||
|
|
|
@ -109,12 +109,12 @@ WriterFrontend::WriterFrontend(const WriterBackend::WriterInfo& arg_info, EnumVa
|
|||
buf = true;
|
||||
local = arg_local;
|
||||
remote = arg_remote;
|
||||
write_buffer = 0;
|
||||
write_buffer = nullptr;
|
||||
write_buffer_pos = 0;
|
||||
info = new WriterBackend::WriterInfo(arg_info);
|
||||
|
||||
num_fields = 0;
|
||||
fields = 0;
|
||||
fields = nullptr;
|
||||
|
||||
const char* w = arg_writer->Type()->AsEnumType()->Lookup(arg_writer->InternalInt());
|
||||
name = copy_string(fmt("%s/%s", arg_info.path, w));
|
||||
|
@ -128,7 +128,7 @@ WriterFrontend::WriterFrontend(const WriterBackend::WriterInfo& arg_info, EnumVa
|
|||
}
|
||||
|
||||
else
|
||||
backend = 0;
|
||||
backend = nullptr;
|
||||
}
|
||||
|
||||
WriterFrontend::~WriterFrontend()
|
||||
|
@ -152,7 +152,7 @@ void WriterFrontend::Stop()
|
|||
if ( backend )
|
||||
{
|
||||
backend->SignalStop();
|
||||
backend = 0; // Thread manager will clean it up once it finishes.
|
||||
backend = nullptr; // Thread manager will clean it up once it finishes.
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -245,7 +245,7 @@ void WriterFrontend::FlushWriteBuffer()
|
|||
backend->SendIn(new WriteMessage(backend, num_fields, write_buffer_pos, write_buffer));
|
||||
|
||||
// Clear buffer (no delete, we pass ownership to child thread.)
|
||||
write_buffer = 0;
|
||||
write_buffer = nullptr;
|
||||
write_buffer_pos = 0;
|
||||
}
|
||||
|
||||
|
@ -286,7 +286,7 @@ void WriterFrontend::Rotate(const char* rotated_path, double open, double close,
|
|||
backend->SendIn(new RotateMessage(backend, this, rotated_path, open, close, terminating));
|
||||
else
|
||||
// Still signal log manager that we're done.
|
||||
log_mgr->FinishedRotation(this, 0, 0, 0, 0, false, terminating);
|
||||
log_mgr->FinishedRotation(this, nullptr, nullptr, 0, 0, false, terminating);
|
||||
}
|
||||
|
||||
void WriterFrontend::DeleteVals(int num_fields, Value** vals)
|
||||
|
|
|
@ -24,7 +24,7 @@ Ascii::Ascii(WriterFrontend* frontend) : WriterBackend(frontend)
|
|||
tsv = false;
|
||||
use_json = false;
|
||||
enable_utf_8 = false;
|
||||
formatter = 0;
|
||||
formatter = nullptr;
|
||||
gzip_level = 0;
|
||||
gzfile = nullptr;
|
||||
|
||||
|
@ -179,7 +179,7 @@ bool Ascii::InitFilterOptions()
|
|||
bool Ascii::InitFormatter()
|
||||
{
|
||||
delete formatter;
|
||||
formatter = 0;
|
||||
formatter = nullptr;
|
||||
|
||||
if ( use_json )
|
||||
{
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue