percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-10 13:11:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Always build message queue, don't dequeue until it exists though.

Browse Source
This commit is contained in:
Daniel Nichter
2013-05-17 09:45:09 -07:00
parent e2aab02bee
commit ea481471c0
2 changed files with 73 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
bin/pt-agent
View File

@@ -4846,44 +4846,44 @@ has '_thread' => (
sub BUILD {
my $self = shift;
if ( $self->client && $self->log_link ) {
$self->_message_queue(Thread::Queue->new());
$self->_thread(
threads::async {
my @log_entries;
my $oktorun = 1;
QUEUE:
while ( $oktorun ) {
my $max_log_entries = 1_000; # for each POST + backlog
while ( $self->message_queue->pending()
&& $max_log_entries--
&& (my $entry = $self->message_queue->dequeue()) )
{
$oktorun = 0 if !defined $entry;
push @log_entries, Percona::WebAPI::Resource::LogEntry->new(
log_level => $entry->[0],
message => $entry->[1],
$self->_message_queue(Thread::Queue->new());
$self->_thread(
threads::async {
my @log_entries;
my $oktorun = 1;
QUEUE:
while ( $oktorun ) {
my $max_log_entries = 1_000; # for each POST + backlog
while ( $self->_message_queue
&& $self->_message_queue->pending()
&& $max_log_entries--
&& (my $entry = $self->message_queue->dequeue()) )
{
$oktorun = 0 if !defined $entry;
push @log_entries, Percona::WebAPI::Resource::LogEntry->new(
log_level => $entry->[0],
message => $entry->[1],
);
}
if ( scalar @log_entries ) {
eval {
$self->client->post(
link => $self->log_link,
resources => \@log_entries,
);
};
if ( my $e = $EVAL_ERROR ) {
warn "$e";
}
if ( scalar @log_entries ) {
eval {
$self->client->post(
link => $self->log_link,
resources => \@log_entries,
);
};
if ( my $e = $EVAL_ERROR ) {
warn "$e";
}
else {
@log_entries = ();
}
} # have log entries
sleep 3;
} # QUEUE
} # threads::async
);
}
else {
@log_entries = ();
}
} # have log entries
sleep ($self->_message_queue ? 3 : 5);
} # QUEUE
} # threads::async
);
return;
}

74
lib/Percona/Agent/Logger.pm
View File

@@ -75,45 +75,45 @@ has '_thread' => (
sub BUILD {
my $self = shift;
if ( $self->client && $self->log_link ) {
$self->_message_queue(Thread::Queue->new());
$self->_thread(
threads::async {
my @log_entries;
my $oktorun = 1;
QUEUE:
while ( $oktorun ) {
my $max_log_entries = 1_000; # for each POST + backlog
while ( $self->message_queue->pending()
&& $max_log_entries--
&& (my $entry = $self->message_queue->dequeue()) )
{
$oktorun = 0 if !defined $entry;
# $event = [ level, "message" ]
push @log_entries, Percona::WebAPI::Resource::LogEntry->new(
log_level => $entry->[0],
message => $entry->[1],
$self->_message_queue(Thread::Queue->new());
$self->_thread(
threads::async {
my @log_entries;
my $oktorun = 1;
QUEUE:
while ( $oktorun ) {
my $max_log_entries = 1_000; # for each POST + backlog
while ( $self->_message_queue
&& $self->_message_queue->pending()
&& $max_log_entries--
&& (my $entry = $self->message_queue->dequeue()) )
{
$oktorun = 0 if !defined $entry;
# $event = [ level, "message" ]
push @log_entries, Percona::WebAPI::Resource::LogEntry->new(
log_level => $entry->[0],
message => $entry->[1],
);
}
if ( scalar @log_entries ) {
eval {
$self->client->post(
link => $self->log_link,
resources => \@log_entries,
);
};
if ( my $e = $EVAL_ERROR ) {
warn "$e";
}
if ( scalar @log_entries ) {
eval {
$self->client->post(
link => $self->log_link,
resources => \@log_entries,
);
};
if ( my $e = $EVAL_ERROR ) {
warn "$e";
}
else {
@log_entries = ();
}
} # have log entries
sleep 3;
} # QUEUE
} # threads::async
);
}
else {
@log_entries = ();
}
} # have log entries
sleep ($self->_message_queue ? 3 : 5);
} # QUEUE
} # threads::async
);
return;
}