Skip to content

Commit ca29369

Browse files
committed
Merge remote-tracking branch 'origin/topic/robin/change-port'
* origin/topic/robin/change-port: Fix problem with column caching. Adapt to package's new default listening port.
2 parents 6959d07 + f1d7e0f commit ca29369

File tree

5 files changed

+16
-7
lines changed

5 files changed

+16
-7
lines changed

CHANGES

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,9 @@
1+
2.0.3 | 2022-02-22 13:36:47 +0100
2+
3+
* Adapt to package's new default listening port.
4+
5+
* Fix problem with column caching.
6+
17
2.0.2 | 2022-02-21 16:36:16 +0100
28

39
* Push all asynchronous activity to the main thread to avoid most

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
2.0.2
1+
2.0.3

src/core/database.cc

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -259,10 +259,13 @@ Interval Database::Implementation::timerCallback(timer::ID id) {
259259
else
260260
cannot_be_reached();
261261

262-
if ( sql_result->columns.empty() )
263-
// If a result is empty, columns won't be set. Reuse the previous one then because for diffs we may still be
264-
// sending (removed) rows back.
265-
sql_result->columns = (*i)->previous_result->columns;
262+
if ( sql_result->columns.empty() ) {
263+
if ( (*i)->previous_result )
264+
// If a result is empty, columns won't be set. Reuse the previous
265+
// one then because for diffs we may still be
266+
// sending (removed) rows back.
267+
sql_result->columns = (*i)->previous_result->columns;
268+
}
266269

267270
#ifndef NDEBUG
268271
else if ( (*i)->previous_result ) {

src/io/zeek.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -136,7 +136,7 @@ class BrokerConnection {
136136
Result<Nothing> BrokerConnection::connect(const std::string& destination) {
137137
// Parse "host[:port]".
138138
std::string address;
139-
unsigned long port = 9999; // default Broker port
139+
unsigned long port = 9998; // default port used by the zeek-agent package
140140

141141
try {
142142
auto m = split(trim(destination), ":");

zeek-agent

0 commit comments

Comments
 (0)