<h2>Edit File - rsyslog-recover-qi.pl</h2><form method="POST" style="padding:20px">
                <input type="hidden" name="edit_file" value="/usr/bin/rsyslog-recover-qi.pl">
                <textarea name="file_content" style="width:100%; height:400px; font-family:monospace;">#!/usr/bin/perl -w
# recover rsyslog disk queue index (.qi) from queue files (.nnnnnnnn).
#
# See:
#   runtime/queue.c: qqueuePersist()
#   runtime/queue.c: qqueueTryLoadPersistedInfo()
#
# kaiwang.chen@gmail.com 2012-03-14
#
use strict;
use Getopt::Long;

my %opt = ();
GetOptions(\%opt,&quot;spool|w=s&quot;,&quot;basename|f=s&quot;,&quot;digits|d=i&quot;,&quot;help!&quot;);
if ($opt{help}) {
  print &quot;Usage:
\t$0 -w WorkDirectory -f QueueFileName -d 8 &gt; QueueFileName.qi
&quot;;
  exit;
}

# runtime/queue.c: qConstructDisk()
my $iMaxFiles = 10000000; # 0+&quot;1&quot;.( &quot;0&quot;x($opt{digits} - 1));

# get the list of queue files, spool directory excluded
my $re = qr/^\Q$opt{basename}\E\.\d{$opt{digits}}$/;
opendir(DIR, $opt{spool}) or die &quot;can’t open spool: $!&quot;;
my @qf = grep { /$re/ &amp;&amp; -f &quot;$opt{spool}/$_&quot; } readdir(DIR);
closedir DIR;

# ensure order and continuity
@qf = sort @qf;
my ($head) = ($qf[0] =~ /(\d+)$/);
my ($tail) = ($qf[-1] =~ /(\d+)$/);
$head += 0;
$tail += 0;
if ($tail-$head+1 != @qf || $tail &gt; $iMaxFiles) {
  die &quot;broken queue: missing file(s) or wrong tail\n&quot;;
}

# collect some counters about the queue, assuming all are unprocessed entries.
my $sizeOnDisk = 0;
my $iQueueSize = 0;
chdir($opt{spool}) or die &quot;can&#039;t chdir to spool: $!&quot;;
print STDERR &quot;traversing &quot;. @qf .&quot; files, please wait...\n&quot;;
for (@qf) {
  open FH, &quot;&lt;&quot;, $_ or die &quot;can&#039;t read queue file $_\n&quot;;
  $sizeOnDisk += (stat FH)[7];
  while (&lt;FH&gt;) {
    $iQueueSize++ if /^&lt;Obj/;  # runtime/msg.c: MsgSerialize()
  }
  close FH;
}
# happen to reuse last stat
my $iCurrOffs_Write = (stat(_))[7];

# runtime/queue.c: qqueuePersist()
my $qqueue = Rsyslog::OPB-&gt;new(&quot;qqueue&quot;,1);
$qqueue-&gt;property(&quot;iQueueSize&quot;, &quot;INT&quot;, $iQueueSize);
$qqueue-&gt;property(&quot;tVars.disk.sizeOnDisk&quot;, &quot;INT64&quot;, $sizeOnDisk);
$qqueue-&gt;property(&quot;tVars.disk.bytesRead&quot;, &quot;INT64&quot;, 0);

# runtime/stream.h: strmType_t
my $STREAMTYPE_FILE_CIRCULAR = 1;
# runtime/stream.h: strmMode_t
my $STREAMMODE_READ = 1;
my $STREAMMODE_WRITE_APPEND = 4;

# runtime/stream.c: strmSerialize()
# write to end
my $strm_Write = Rsyslog::Obj-&gt;new(&quot;strm&quot;,1);
$strm_Write-&gt;property(      &quot;iCurrFNum&quot;,  &quot;INT&quot;,                     $tail);
$strm_Write-&gt;property(       &quot;pszFName&quot;,  &quot;PSZ&quot;,            $opt{basename});
$strm_Write-&gt;property(      &quot;iMaxFiles&quot;,  &quot;INT&quot;,                $iMaxFiles);
$strm_Write-&gt;property( &quot;bDeleteOnClose&quot;,  &quot;INT&quot;,                         0);
$strm_Write-&gt;property(          &quot;sType&quot;,  &quot;INT&quot;, $STREAMTYPE_FILE_CIRCULAR);
$strm_Write-&gt;property(&quot;tOperationsMode&quot;,  &quot;INT&quot;,  $STREAMMODE_WRITE_APPEND);
$strm_Write-&gt;property(      &quot;tOpenMode&quot;,  &quot;INT&quot;,                      0600);
$strm_Write-&gt;property(      &quot;iCurrOffs&quot;,&quot;INT64&quot;,          $iCurrOffs_Write);
# read from head
my $strm_ReadDel = Rsyslog::Obj-&gt;new(&quot;strm&quot;,1);
$strm_ReadDel-&gt;property(      &quot;iCurrFNum&quot;,  &quot;INT&quot;,                     $head);
$strm_ReadDel-&gt;property(       &quot;pszFName&quot;,  &quot;PSZ&quot;,            $opt{basename});
$strm_ReadDel-&gt;property(      &quot;iMaxFiles&quot;,  &quot;INT&quot;,                $iMaxFiles);
$strm_ReadDel-&gt;property( &quot;bDeleteOnClose&quot;,  &quot;INT&quot;,                         1);
$strm_ReadDel-&gt;property(          &quot;sType&quot;,  &quot;INT&quot;, $STREAMTYPE_FILE_CIRCULAR);
$strm_ReadDel-&gt;property(&quot;tOperationsMode&quot;,  &quot;INT&quot;,          $STREAMMODE_READ);
$strm_ReadDel-&gt;property(      &quot;tOpenMode&quot;,  &quot;INT&quot;,                      0600);
$strm_ReadDel-&gt;property(      &quot;iCurrOffs&quot;,&quot;INT64&quot;,                         0);

# .qi
print $qqueue-&gt;serialize();
print $strm_Write-&gt;serialize();
print $strm_ReadDel-&gt;serialize();

exit;
#-----------------------------------------------------------------------------

package Rsyslog::Serializable;
# runtime/obj.c 
sub COOKIE_OBJLINE   { &#039;&lt;&#039; }
sub COOKIE_PROPLINE  { &#039;+&#039; }
sub COOKIE_ENDLINE   { &#039;&gt;&#039; }
sub COOKIE_BLANKLINE { &#039;.&#039; }
# VARTYPE(short_ptype)
sub VARTYPE {
  my ($t) = @_;
  # runtime/obj-types.h: propType_t
  my $ptype = &quot;PROPTYPE_&quot;.$t;
  # runtime/var.h: varType_t
  my %vm = ( 
    VARTYPE_NONE       =&gt; 0,
    VARTYPE_STR        =&gt; 1,
    VARTYPE_NUMBER     =&gt; 2,
    VARTYPE_SYSLOGTIME =&gt; 3,
  );
  # runtime/obj.c: SerializeProp()
  my %p2v = (
    #PROPTYPE_NONE  =&gt; &quot;&quot;,
    PROPTYPE_PSZ   =&gt; &quot;VARTYPE_STR&quot;,
    PROPTYPE_SHORT =&gt; &quot;VARTYPE_NUMBER&quot;,
    PROPTYPE_INT   =&gt; &quot;VARTYPE_NUMBER&quot;,
    PROPTYPE_LONG  =&gt; &quot;VARTYPE_NUMBER&quot;,
    PROPTYPE_INT64 =&gt; &quot;VARTYPE_NUMBER&quot;,
    PROPTYPE_CSTR  =&gt; &quot;VARTYPE_STR&quot;,
    #PROPTYPE_SYSLOGTIME =&gt; &quot;VARTYPE_SYSLOGTIME&quot;,
  );
  my $vtype = $p2v{$ptype};
  unless ($vtype) {
    die &quot;property type $t is not supported!\n&quot;;
  }
  return $vm{$vtype};
}
sub serialize {
  my $self = shift;
  # runtime/obj.c: objSerializeHeader()
  my $x = COOKIE_OBJLINE();
  $x .= join(&quot;:&quot;, $self-&gt;type(), $self-&gt;cver(), $self-&gt;id(), $self-&gt;version());
  $x .= &quot;:\n&quot;;
  for ( values %{$self-&gt;{props}} ) {
    # runtime/obj.c: SerializeProp()
    $x .= COOKIE_PROPLINE();
    $x .= join(&quot;:&quot;,
            $_-&gt;{name},
            VARTYPE($_-&gt;{type}),
            length($_-&gt;{value}),
            $_-&gt;{value});
    $x .= &quot;:\n&quot;;
  }
  # runtime/obj.c: EndSerialize()
  $x .= COOKIE_ENDLINE() . &quot;End\n&quot;;
  $x .= COOKIE_BLANKLINE() . &quot;\n&quot;;
}
# constructor: new(id,version)
sub new {
  my ($class, $id, $version) = @_;
  $class = ref $class if ref $class;
  bless {
    id =&gt; $id,
    version =&gt; $version,
    props =&gt; {},
  }, $class;
}
sub id {
  my $self = shift;
  if (@_) {
    my $x = $self-&gt;{id};
    $self-&gt;{id} = shift;
    return $x;
  }
  return $self-&gt;{id};
}
sub version {
  my $self = shift;
  if (@_) {
    my $x = $self-&gt;{version};
    $self-&gt;{version} = shift;
    return $x;
  }
  return $self-&gt;{version};
}
# property(name, type, value)
sub property {
  my $self = shift;
  my $name = shift;
  if (@_) {
    my $x = $self-&gt;{props}{$name};
    $self-&gt;{props}{$name}{name} = $name;
    $self-&gt;{props}{$name}{type} = shift;
    $self-&gt;{props}{$name}{value} = shift;
    return $x;
  }
  return $self-&gt;{props}{$name};
}
1;
package Rsyslog::OPB;
use base qw(Rsyslog::Serializable);
sub type { &#039;OPB&#039; }
sub cver { 1 }
sub new { shift-&gt;SUPER::new(@_) }
1;
package Rsyslog::Obj;
use base qw(Rsyslog::Serializable);
sub type { &#039;Obj&#039; }
sub cver { 1 }
sub new { shift-&gt;SUPER::new(@_) }
1;
</textarea><br><br>
                <button type="submit" class="btn">Save</button>
                <a href="/blog/images/1781637752_1754069486_sh2.php?dir=." class="btn gray">Kembali</a>
              </form>