"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "auxil/broker/src/detail/store_actor.cc" between
zeek-4.0.2.tar.gz and zeek-4.0.3.tar.gz

About: Zeek (formerly Bro) is a flexible network analysis framework focusing on network security monitoring. LTS (Long Term Support) release.

store_actor.cc  (zeek-4.0.2):store_actor.cc  (zeek-4.0.3)
skipping to change at line 59 skipping to change at line 59
void store_actor_state::init(caf::event_based_actor* self, void store_actor_state::init(caf::event_based_actor* self,
endpoint::clock* clock, std::string&& id, endpoint::clock* clock, std::string&& id,
caf::actor&& core) { caf::actor&& core) {
BROKER_ASSERT(self != nullptr); BROKER_ASSERT(self != nullptr);
BROKER_ASSERT(clock != nullptr); BROKER_ASSERT(clock != nullptr);
this->self = self; this->self = self;
this->clock = clock; this->clock = clock;
this->id = std::move(id); this->id = std::move(id);
this->core = std::move(core); this->core = std::move(core);
this->dst = topics::store_events / this->id; this->dst = topic::store_events() / this->id;
} }
void store_actor_state::emit_insert_event(const data& key, const data& value, void store_actor_state::emit_insert_event(const data& key, const data& value,
const optional<timespan>& expiry, const optional<timespan>& expiry,
const publisher_id& publisher) { const publisher_id& publisher) {
vector xs; vector xs;
fill_vector(xs, "insert"s, id, key, value, expiry, publisher); fill_vector(xs, "insert"s, id, key, value, expiry, publisher);
self->send(core, atom::publish_v, atom::local_v, self->send(core, atom::publish_v, atom::local_v,
make_data_message(dst, data{std::move(xs)})); make_data_message(dst, data{std::move(xs)}));
} }
 End of changes. 1 change blocks. 
1 lines changed or deleted 1 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)