| # Copyright (C) 2002-2024 Free Software Foundation, Inc. | |
| # This program is free software; you can redistribute it and/or modify | |
| # it under the terms of the GNU General Public License as published by | |
| # the Free Software Foundation; either version 2, or (at your option) | |
| # any later version. | |
| # This program is distributed in the hope that it will be useful, | |
| # but WITHOUT ANY WARRANTY; without even the implied warranty of | |
| # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
| # GNU General Public License for more details. | |
| # You should have received a copy of the GNU General Public License | |
| # along with this program. If not, see <https://www.gnu.org/licenses/>. | |
| ################################################################## | |
| # The master copy of this file is in Automake's source repository. | |
| # Please send updates to automake-patches@gnu.org. | |
| ################################################################## | |
| package Autom4te::Channels; | |
| =head1 NAME | |
| Autom4te::Channels - support functions for error and warning management | |
| =head1 SYNOPSIS | |
| use Autom4te::Channels; | |
| # Register a channel to output warnings about unused variables. | |
| register_channel 'unused', type => 'warning'; | |
| # Register a channel for system errors. | |
| register_channel 'system', type => 'error', exit_code => 4; | |
| # Output a message on channel 'unused'. | |
| msg 'unused', "$file:$line", "unused variable '$var'"; | |
| # Make the 'unused' channel silent. | |
| setup_channel 'unused', silent => 1; | |
| # Turn on all channels of type 'warning'. | |
| setup_channel_type 'warning', silent => 0; | |
| # Redirect all channels to push messages on a Thread::Queue using | |
| # the specified serialization key. | |
| setup_channel_queue $queue, $key; | |
| # Output a message pending in a Thread::Queue. | |
| pop_channel_queue $queue; | |
| # Treat all warnings as errors. | |
| $warnings_are_errors = 1; | |
| # Exit with the greatest exit code encountered so far. | |
| exit $exit_code; | |
| =head1 DESCRIPTION | |
| This perl module provides support functions for handling diagnostic | |
| channels in programs. Channels can be registered to convey fatal, | |
| error, warning, or debug messages. Each channel has various options | |
| (e.g. is the channel silent, should duplicate messages be removed, | |
| etc.) that can also be overridden on a per-message basis. | |
| =cut | |
| use 5.006; | |
| use strict; | |
| use warnings FATAL => 'all'; | |
| use Carp; | |
| use Exporter; | |
| use File::Basename; | |
| our @ISA = qw (Exporter); | |
| our @EXPORT = qw ($exit_code $warnings_are_errors | |
| &reset_local_duplicates &reset_global_duplicates | |
| ®ister_channel &msg &exists_channel &channel_type | |
| &setup_channel &setup_channel_type | |
| &dup_channel_setup &drop_channel_setup | |
| &buffer_messages &flush_messages | |
| &setup_channel_queue &pop_channel_queue | |
| US_GLOBAL US_LOCAL | |
| UP_NONE UP_TEXT UP_LOC_TEXT); | |
| our %channels; | |
| our $me = basename $0; | |
| =head2 Global Variables | |
| =over 4 | |
| =item C<$exit_code> | |
| The greatest exit code seen so far. C<$exit_code> is updated from | |
| the C<exit_code> options of C<fatal> and C<error> channels. | |
| =cut | |
| our $exit_code = 0; | |
| =item C<$warnings_are_errors> | |
| Set this variable to 1 if warning messages should be treated as | |
| errors (i.e. if they should update C<$exit_code>). | |
| =cut | |
| our $warnings_are_errors = 0; | |
| =back | |
| =head2 Constants | |
| =over 4 | |
| =item C<UP_NONE>, C<UP_TEXT>, C<UP_LOC_TEXT> | |
| Possible values for the C<uniq_part> options. This selects the part | |
| of the message that should be considered when filtering out duplicates. | |
| If C<UP_LOC_TEXT> is used, the location and the explanation message | |
| are used for filtering. If C<UP_TEXT> is used, only the explanation | |
| message is used (so the same message will be filtered out if it appears | |
| at different locations). C<UP_NONE> means that duplicate messages | |
| should be output. | |
| =cut | |
| use constant UP_NONE => 0; | |
| use constant UP_TEXT => 1; | |
| use constant UP_LOC_TEXT => 2; | |
| =item C<US_LOCAL>, C<US_GLOBAL> | |
| Possible values for the C<uniq_scope> options. | |
| Use C<US_GLOBAL> for error messages that should be printed only | |
| once during the execution of the program, C<US_LOCAL> for message that | |
| should be printed only once per file. (Actually, C<Channels> does not | |
| do this now when files are changed, it relies on you calling | |
| C<reset_local_duplicates> when this happens.) | |
| =cut | |
| # possible values for uniq_scope | |
| use constant US_LOCAL => 0; | |
| use constant US_GLOBAL => 1; | |
| =back | |
| =head2 Options | |
| Channels accept the options described below. These options can be | |
| passed as a hash to the C<register_channel>, C<setup_channel>, and C<msg> | |
| functions. The possible keys, with their default value are: | |
| =over | |
| =item C<type =E<gt> 'warning'> | |
| The type of the channel. One of C<'debug'>, C<'warning'>, C<'error'>, or | |
| C<'fatal'>. Fatal messages abort the program when they are output. | |
| Error messages update the exit status. Debug and warning messages are | |
| harmless, except that warnings are treated as errors if | |
| C<$warnings_are_errors> is set. | |
| =item C<exit_code =E<gt> 1> | |
| The value to update C<$exit_code> with when a fatal or error message | |
| is emitted. C<$exit_code> is also updated for warnings output | |
| when C<$warnings_are_errors> is set. | |
| =item C<file =E<gt> \*STDERR> | |
| The file where the error should be output. | |
| =item C<silent =E<gt> 0> | |
| Whether the channel should be silent. Use this do disable a | |
| category of warning, for instance. | |
| =item C<ordered =E<gt> 1> | |
| Whether, with multi-threaded execution, the message should be queued | |
| for ordered output. | |
| =item C<uniq_part =E<gt> UP_LOC_TEXT> | |
| The part of the message subject to duplicate filtering. See the | |
| documentation for the C<UP_NONE>, C<UP_TEXT>, and C<UP_LOC_TEXT> | |
| constants above. | |
| C<uniq_part> can also be set to an arbitrary string that will be used | |
| instead of the message when considering duplicates. | |
| =item C<uniq_scope =E<gt> US_LOCAL> | |
| The scope of duplicate filtering. See the documentation for the | |
| C<US_LOCAL>, and C<US_GLOBAL> constants above. | |
| =item C<header =E<gt> ''> | |
| A string to prepend to each message emitted through this channel. | |
| With partial messages, only the first part will have C<header> | |
| prepended. | |
| =item C<footer =E<gt> ''> | |
| A string to append to each message emitted through this channel. | |
| With partial messages, only the final part will have C<footer> | |
| appended. | |
| =item C<backtrace =E<gt> 0> | |
| Die with a stack backtrace after displaying the message. | |
| =item C<partial =E<gt> 0> | |
| When set, indicates a partial message that should | |
| be output along with the next message with C<partial> unset. | |
| Several partial messages can be stacked this way. | |
| Duplicate filtering will apply to the I<global> message resulting from | |
| all I<partial> messages, using the options from the last (non-partial) | |
| message. Linking associated messages is the main reason to use this | |
| option. | |
| For instance the following messages | |
| msg 'channel', 'foo:2', 'redefinition of A ...'; | |
| msg 'channel', 'foo:1', '... A previously defined here'; | |
| msg 'channel', 'foo:3', 'redefinition of A ...'; | |
| msg 'channel', 'foo:1', '... A previously defined here'; | |
| will result in | |
| foo:2: redefinition of A ... | |
| foo:1: ... A previously defined here | |
| foo:3: redefinition of A ... | |
| where the duplicate "I<... A previously defined here>" has been | |
| filtered out. | |
| Linking these messages using C<partial> as follows will prevent the | |
| fourth message to disappear. | |
| msg 'channel', 'foo:2', 'redefinition of A ...', partial => 1; | |
| msg 'channel', 'foo:1', '... A previously defined here'; | |
| msg 'channel', 'foo:3', 'redefinition of A ...', partial => 1; | |
| msg 'channel', 'foo:1', '... A previously defined here'; | |
| Note that because the stack of C<partial> messages is printed with the | |
| first non-C<partial> message, most options of C<partial> messages will | |
| be ignored. | |
| =back | |
| =cut | |
| # Default options for a channel. | |
| our %_default_options = | |
| ( | |
| type => 'warning', | |
| exit_code => 1, | |
| file => \*STDERR, | |
| silent => 0, | |
| ordered => 1, | |
| queue => 0, | |
| queue_key => undef, | |
| uniq_scope => US_LOCAL, | |
| uniq_part => UP_LOC_TEXT, | |
| header => '', | |
| footer => '', | |
| backtrace => 0, | |
| partial => 0, | |
| ); | |
| # Filled with output messages as keys, to detect duplicates. | |
| # The value associated with each key is the number of occurrences | |
| # filtered out. | |
| our %_local_duplicate_messages = (); | |
| our %_global_duplicate_messages = (); | |
| sub _reset_duplicates (\%) | |
| { | |
| my ($ref) = @_; | |
| my $dup = 0; | |
| foreach my $k (keys %$ref) | |
| { | |
| $dup += $ref->{$k}; | |
| } | |
| %$ref = (); | |
| return $dup; | |
| } | |
| =head2 Functions | |
| =over 4 | |
| =item C<reset_local_duplicates ()> | |
| Reset local duplicate messages (see C<US_LOCAL>), and | |
| return the number of messages that have been filtered out. | |
| =cut | |
| sub reset_local_duplicates () | |
| { | |
| return _reset_duplicates %_local_duplicate_messages; | |
| } | |
| =item C<reset_global_duplicates ()> | |
| Reset local duplicate messages (see C<US_GLOBAL>), and | |
| return the number of messages that have been filtered out. | |
| =cut | |
| sub reset_global_duplicates () | |
| { | |
| return _reset_duplicates %_global_duplicate_messages; | |
| } | |
| sub _merge_options (\%%) | |
| { | |
| my ($hash, %options) = @_; | |
| local $_; | |
| foreach (keys %options) | |
| { | |
| if (exists $hash->{$_}) | |
| { | |
| $hash->{$_} = $options{$_} | |
| } | |
| else | |
| { | |
| confess "unknown option '$_'"; | |
| } | |
| } | |
| if ($hash->{'ordered'}) | |
| { | |
| confess "fatal messages cannot be ordered" | |
| if $hash->{'type'} eq 'fatal'; | |
| confess "backtrace cannot be output on ordered messages" | |
| if $hash->{'backtrace'}; | |
| } | |
| } | |
| =item C<register_channel ($name, [%options])> | |
| Declare channel C<$name>, and override the default options | |
| with those listed in C<%options>. | |
| =cut | |
| sub register_channel ($;%) | |
| { | |
| my ($name, %options) = @_; | |
| my %channel_opts = %_default_options; | |
| _merge_options %channel_opts, %options; | |
| $channels{$name} = \%channel_opts; | |
| } | |
| =item C<exists_channel ($name)> | |
| Returns true iff channel C<$name> has been registered. | |
| =cut | |
| sub exists_channel ($) | |
| { | |
| my ($name) = @_; | |
| return exists $channels{$name}; | |
| } | |
| =item C<channel_type ($name)> | |
| Returns the type of channel C<$name> if it has been registered. | |
| Returns the empty string otherwise. | |
| =cut | |
| sub channel_type ($) | |
| { | |
| my ($name) = @_; | |
| return $channels{$name}{'type'} if exists_channel $name; | |
| return ''; | |
| } | |
| # _format_sub_message ($LEADER, $MESSAGE) | |
| # --------------------------------------- | |
| # Split $MESSAGE at new lines and add $LEADER to each line. | |
| sub _format_sub_message ($$) | |
| { | |
| my ($leader, $message) = @_; | |
| return $leader . join ("\n" . $leader, split ("\n", $message)) . "\n"; | |
| } | |
| # Store partial messages here. (See the 'partial' option.) | |
| our $partial = ''; | |
| # _format_message ($LOCATION, $MESSAGE, %OPTIONS) | |
| # ----------------------------------------------- | |
| # Format the message. Return a string ready to print. | |
| sub _format_message ($$%) | |
| { | |
| my ($location, $message, %opts) = @_; | |
| my $msg = ($partial eq '' ? $opts{'header'} : '') . $message | |
| . ($opts{'partial'} ? '' : $opts{'footer'}); | |
| if (ref $location) | |
| { | |
| # If $LOCATION is a reference, assume it's an instance of the | |
| # Autom4te::Location class and display contexts. | |
| my $loc = $location->get || $me; | |
| $msg = _format_sub_message ("$loc: ", $msg); | |
| for my $pair ($location->get_contexts) | |
| { | |
| $msg .= _format_sub_message ($pair->[0] . ": ", $pair->[1]); | |
| } | |
| } | |
| else | |
| { | |
| $location ||= $me; | |
| $msg = _format_sub_message ("$location: ", $msg); | |
| } | |
| return $msg; | |
| } | |
| # _enqueue ($QUEUE, $KEY, $UNIQ_SCOPE, $TO_FILTER, $MSG, $FILE) | |
| # ------------------------------------------------------------- | |
| # Push message on a queue, to be processed by another thread. | |
| sub _enqueue ($$$$$$) | |
| { | |
| my ($queue, $key, $uniq_scope, $to_filter, $msg, $file) = @_; | |
| $queue->enqueue ($key, $msg, $to_filter, $uniq_scope); | |
| confess "message queuing works only for STDERR" | |
| if $file ne \*STDERR; | |
| } | |
| # _dequeue ($QUEUE) | |
| # ----------------- | |
| # Pop a message from a queue, and print, similarly to how | |
| # _print_message would do it. Return 0 if the queue is | |
| # empty. Note that the key has already been dequeued. | |
| sub _dequeue ($) | |
| { | |
| my ($queue) = @_; | |
| my $msg = $queue->dequeue || return 0; | |
| my $to_filter = $queue->dequeue; | |
| my $uniq_scope = $queue->dequeue; | |
| my $file = \*STDERR; | |
| if ($to_filter ne '') | |
| { | |
| # Do we want local or global uniqueness? | |
| my $dups; | |
| if ($uniq_scope == US_LOCAL) | |
| { | |
| $dups = \%_local_duplicate_messages; | |
| } | |
| elsif ($uniq_scope == US_GLOBAL) | |
| { | |
| $dups = \%_global_duplicate_messages; | |
| } | |
| else | |
| { | |
| confess "unknown value for uniq_scope: " . $uniq_scope; | |
| } | |
| # Update the hash of messages. | |
| if (exists $dups->{$to_filter}) | |
| { | |
| ++$dups->{$to_filter}; | |
| return 1; | |
| } | |
| else | |
| { | |
| $dups->{$to_filter} = 0; | |
| } | |
| } | |
| print $file $msg; | |
| return 1; | |
| } | |
| # _print_message ($LOCATION, $MESSAGE, %OPTIONS) | |
| # ---------------------------------------------- | |
| # Format the message, check duplicates, and print it. | |
| sub _print_message ($$%) | |
| { | |
| my ($location, $message, %opts) = @_; | |
| return 0 if ($opts{'silent'}); | |
| my $msg = _format_message ($location, $message, %opts); | |
| if ($opts{'partial'}) | |
| { | |
| # Incomplete message. Store, don't print. | |
| $partial .= $msg; | |
| return; | |
| } | |
| else | |
| { | |
| # Prefix with any partial message send so far. | |
| $msg = $partial . $msg; | |
| $partial = ''; | |
| } | |
| msg ('note', '', 'warnings are treated as errors', uniq_scope => US_GLOBAL) | |
| if ($opts{'type'} eq 'warning' && $warnings_are_errors); | |
| # Check for duplicate message if requested. | |
| my $to_filter; | |
| if ($opts{'uniq_part'} ne UP_NONE) | |
| { | |
| # Which part of the error should we match? | |
| if ($opts{'uniq_part'} eq UP_TEXT) | |
| { | |
| $to_filter = $message; | |
| } | |
| elsif ($opts{'uniq_part'} eq UP_LOC_TEXT) | |
| { | |
| $to_filter = $msg; | |
| } | |
| else | |
| { | |
| $to_filter = $opts{'uniq_part'}; | |
| } | |
| # Do we want local or global uniqueness? | |
| my $dups; | |
| if ($opts{'uniq_scope'} == US_LOCAL) | |
| { | |
| $dups = \%_local_duplicate_messages; | |
| } | |
| elsif ($opts{'uniq_scope'} == US_GLOBAL) | |
| { | |
| $dups = \%_global_duplicate_messages; | |
| } | |
| else | |
| { | |
| confess "unknown value for uniq_scope: " . $opts{'uniq_scope'}; | |
| } | |
| # Update the hash of messages. | |
| if (exists $dups->{$to_filter}) | |
| { | |
| ++$dups->{$to_filter}; | |
| return 0; | |
| } | |
| else | |
| { | |
| $dups->{$to_filter} = 0; | |
| } | |
| } | |
| my $file = $opts{'file'}; | |
| if ($opts{'ordered'} && $opts{'queue'}) | |
| { | |
| _enqueue ($opts{'queue'}, $opts{'queue_key'}, $opts{'uniq_scope'}, | |
| $to_filter, $msg, $file); | |
| } | |
| else | |
| { | |
| print $file $msg; | |
| } | |
| return 1; | |
| } | |
| =item C<msg ($channel, $location, $message, [%options])> | |
| Emit a message on C<$channel>, overriding some options of the channel with | |
| those specified in C<%options>. Obviously C<$channel> must have been | |
| registered with C<register_channel>. | |
| C<$message> is the text of the message, and C<$location> is a location | |
| associated to the message. | |
| For instance to complain about some unused variable C<mumble> | |
| declared at line 10 in F<foo.c>, one could do: | |
| msg 'unused', 'foo.c:10', "unused variable 'mumble'"; | |
| If channel C<unused> is not silent (and if this message is not a duplicate), | |
| the following would be output: | |
| foo.c:10: unused variable 'mumble' | |
| C<$location> can also be an instance of C<Autom4te::Location>. In this | |
| case, the stack of contexts will be displayed in addition. | |
| If C<$message> contains newline characters, C<$location> is prepended | |
| to each line. For instance, | |
| msg 'error', 'somewhere', "1st line\n2nd line"; | |
| becomes | |
| somewhere: 1st line | |
| somewhere: 2nd line | |
| If C<$location> is an empty string, it is replaced by the name of the | |
| program. Actually, if you don't use C<%options>, you can even | |
| elide the empty C<$location>. Thus | |
| msg 'fatal', '', 'fatal error'; | |
| msg 'fatal', 'fatal error'; | |
| both print | |
| progname: fatal error | |
| =cut | |
| # See buffer_messages() and flush_messages() below. | |
| our %buffering = (); # The map of channel types to buffer. | |
| our @backlog = (); # The buffer of messages. | |
| sub msg ($$;$%) | |
| { | |
| my ($channel, $location, $message, %options) = @_; | |
| if (! defined $message) | |
| { | |
| $message = $location; | |
| $location = ''; | |
| } | |
| if (!exists $channels{$channel}) | |
| { | |
| # This can happen as a result of e.g. m4_warn([nonsense], [message]) | |
| # so it should not crash. | |
| report_bad_channel($channel, $location); | |
| $channel = 'syntax'; | |
| } | |
| my %opts = %{$channels{$channel}}; | |
| _merge_options (%opts, %options); | |
| if (exists $buffering{$opts{'type'}}) | |
| { | |
| push @backlog, [$channel, $location->clone, $message, %options]; | |
| return; | |
| } | |
| # Print the message if needed. | |
| if (_print_message ($location, $message, %opts)) | |
| { | |
| # Adjust exit status. | |
| if ($opts{'type'} eq 'error' | |
| || $opts{'type'} eq 'fatal' | |
| || ($opts{'type'} eq 'warning' && $warnings_are_errors)) | |
| { | |
| my $es = $opts{'exit_code'}; | |
| $exit_code = $es if $es > $exit_code; | |
| } | |
| # Die on fatal messages. | |
| confess if $opts{'backtrace'}; | |
| if ($opts{'type'} eq 'fatal') | |
| { | |
| # flush messages explicitly here, needed in worker threads. | |
| STDERR->flush; | |
| exit $exit_code; | |
| } | |
| } | |
| } | |
| sub report_bad_channel ($$) | |
| { | |
| my ($channel, $location) = @_; | |
| my $message; | |
| my $report_as = 'error'; | |
| # quotemeta is both too aggressive (e.g. it escapes '-') and | |
| # too generous (it turns control characters into \ + themselves, | |
| # not into symbolic escapes). | |
| my $q_channel = $channel; | |
| $q_channel =~ s/(?=[\"\$\'\@\`\\])/\\/g; | |
| $q_channel =~ s/([^\x20-\x7e])/sprintf('\\x%02X', ord $1)/eg; | |
| $q_channel = '"' . $q_channel . '"'; | |
| if ($channel eq '' || $channel eq 'all') | |
| { | |
| # Prior to version 2.70, the Autoconf manual said it was valid to use | |
| # "all" and the empty string as the category argument to m4_warn, so | |
| # don't treat those cases as errors. | |
| $report_as = 'obsolete'; | |
| $message = "use of $q_channel as a diagnostic category is obsolete\n"; | |
| $message .= "(see automake --help for a list of valid categories)"; | |
| } | |
| elsif ($channel eq 'none' | |
| || ($channel =~ /^no-/ && exists $channels{substr($channel, 3)})) | |
| { | |
| # Also recognize "none" and "no-[category]", as someone might have | |
| # thought anything acceptable to -W is also acceptable to m4_warn. | |
| # Note: m4_warn([error], [...]) does actually issue an error. | |
| $message = "-W accepts $q_channel, but it is not a diagnostic category"; | |
| } | |
| else | |
| { | |
| $message = "unknown diagnostic category " . $q_channel; | |
| } | |
| msg $report_as, $location, $message; | |
| } | |
| =item C<setup_channel ($channel, %options)> | |
| Override the options of C<$channel> with those specified by C<%options>. | |
| =cut | |
| sub setup_channel ($%) | |
| { | |
| my ($name, %opts) = @_; | |
| confess "unknown channel $name" unless exists $channels{$name}; | |
| _merge_options %{$channels{$name}}, %opts; | |
| } | |
| =item C<setup_channel_type ($type, %options)> | |
| Override the options of any channel of type C<$type> | |
| with those specified by C<%options>. | |
| =cut | |
| sub setup_channel_type ($%) | |
| { | |
| my ($type, %opts) = @_; | |
| foreach my $channel (keys %channels) | |
| { | |
| setup_channel $channel, %opts | |
| if $channels{$channel}{'type'} eq $type; | |
| } | |
| } | |
| =item C<dup_channel_setup ()>, C<drop_channel_setup ()> | |
| Sometimes it is necessary to make temporary modifications to channels. | |
| For instance one may want to disable a warning while processing a | |
| particular file, and then restore the initial setup. These two | |
| functions make it easy: C<dup_channel_setup ()> saves a copy of the | |
| current configuration for later restoration by | |
| C<drop_channel_setup ()>. | |
| You can think of this as a stack of configurations whose first entry | |
| is the active one. C<dup_channel_setup ()> duplicates the first | |
| entry, while C<drop_channel_setup ()> just deletes it. | |
| =cut | |
| our @_saved_channels = (); | |
| our @_saved_werrors = (); | |
| sub dup_channel_setup () | |
| { | |
| my %channels_copy; | |
| foreach my $k1 (keys %channels) | |
| { | |
| $channels_copy{$k1} = {%{$channels{$k1}}}; | |
| } | |
| push @_saved_channels, \%channels_copy; | |
| push @_saved_werrors, $warnings_are_errors; | |
| } | |
| sub drop_channel_setup () | |
| { | |
| my $saved = pop @_saved_channels; | |
| %channels = %$saved; | |
| $warnings_are_errors = pop @_saved_werrors; | |
| } | |
| =item C<buffer_messages (@types)>, C<flush_messages ()> | |
| By default, when C<msg> is called, messages are processed immediately. | |
| Sometimes it is necessary to delay the output of messages. | |
| For instance you might want to make diagnostics before | |
| channels have been completely configured. | |
| After C<buffer_messages(@types)> has been called, messages sent with | |
| C<msg> to a channel whose type is listed in C<@types> will be stored in a | |
| list for later processing. | |
| This backlog of messages is processed when C<flush_messages> is | |
| called, with the current channel options (not the options in effect, | |
| at the time of C<msg>). So for instance, if some channel was silenced | |
| in the meantime, messages to this channel will not be printed. | |
| C<flush_messages> cancels the effect of C<buffer_messages>. Following | |
| calls to C<msg> are processed immediately as usual. | |
| =cut | |
| sub buffer_messages (@) | |
| { | |
| foreach my $type (@_) | |
| { | |
| $buffering{$type} = 1; | |
| } | |
| } | |
| sub flush_messages () | |
| { | |
| %buffering = (); | |
| foreach my $args (@backlog) | |
| { | |
| &msg (@$args); | |
| } | |
| @backlog = (); | |
| } | |
| =item C<setup_channel_queue ($queue, $key)> | |
| Set the queue to fill for each channel that is ordered, | |
| and the key to use for serialization. | |
| =cut | |
| sub setup_channel_queue ($$) | |
| { | |
| my ($queue, $key) = @_; | |
| foreach my $channel (keys %channels) | |
| { | |
| setup_channel $channel, queue => $queue, queue_key => $key | |
| if $channels{$channel}{'ordered'}; | |
| } | |
| } | |
| =item C<pop_channel_queue ($queue)> | |
| pop a message off the $queue; the key has already been popped. | |
| =cut | |
| sub pop_channel_queue ($) | |
| { | |
| my ($queue) = @_; | |
| return _dequeue ($queue); | |
| } | |
| =back | |
| =head1 SEE ALSO | |
| L<Autom4te::Location> | |
| =head1 HISTORY | |
| Written by Alexandre Duret-Lutz E<lt>F<adl@gnu.org>E<gt>. | |
| =cut | |
| 1; |