summaryrefslogtreecommitdiff
path: root/fml/lib/FML/Process/ThreadTrack.pm
diff options
context:
space:
mode:
Diffstat (limited to 'fml/lib/FML/Process/ThreadTrack.pm')
-rw-r--r--fml/lib/FML/Process/ThreadTrack.pm38
1 files changed, 17 insertions, 21 deletions
diff --git a/fml/lib/FML/Process/ThreadTrack.pm b/fml/lib/FML/Process/ThreadTrack.pm
index 15d42ee5..cdeda9aa 100644
--- a/fml/lib/FML/Process/ThreadTrack.pm
+++ b/fml/lib/FML/Process/ThreadTrack.pm
@@ -3,7 +3,7 @@
# Copyright (C) 2001,2002 Ken'ichi Fukamachi
# All rights reserved.
#
-# $FML: ThreadTrack.pm,v 1.24 2002/02/27 09:20:33 tmu Exp $
+# $FML: ThreadTrack.pm,v 1.25 2002/03/17 06:24:31 fukachan Exp $
#
package FML::Process::ThreadTrack;
@@ -12,10 +12,9 @@ use vars qw($debug @ISA @EXPORT @EXPORT_OK);
use strict;
use Carp;
-use FML::Process::Kernel;
use FML::Log qw(Log LogWarn LogError);
use FML::Config;
-
+use FML::Process::Kernel;
@ISA = qw(FML::Process::Kernel);
@@ -58,7 +57,7 @@ sub new
# Descriptions: dummy to avoid to take data from STDIN
-# Arguments: OBJ($self) HASH_REF($args)
+# Arguments: OBJ($curproc) HASH_REF($args)
# Side Effects: none
# Return Value: none
sub prepare
@@ -74,8 +73,8 @@ sub prepare
}
-# Descriptions: none
-# Arguments: OBJ($self) HASH_REF($args)
+# Descriptions: dummy.
+# Arguments: OBJ($curproc) HASH_REF($args)
# Side Effects: none.
# Return Value: none
sub verify_request
@@ -99,9 +98,9 @@ call the actual thread tracking system.
=cut
-# Descriptions: switch of commands to use Mail::ThreadTrack module
+# Descriptions: switch to Mail::ThreadTrack module
# Arguments: OBJ($curproc) HASH_REF($args)
-# Side Effects: load module
+# Side Effects: load module if needed
# Return Value: none
sub run
{
@@ -199,6 +198,10 @@ sub run
}
+# Descriptions:
+# Arguments: OBJ($curproc) OBJ($thread)
+# Side Effects: none
+# Return Value: none
sub _speculate_last_id
{
my ($curproc, $thread) = @_;
@@ -213,7 +216,9 @@ sub _speculate_last_id
use File::stat;
my $st = stat($seq_file);
$sf_last_modified =
- $sf_last_modified > $st->mtime ? $sf_last_modified : $st->mtime;
+ $sf_last_modified > $st->mtime ?
+ $sf_last_modified :
+ $st->mtime;
};
}
@@ -222,18 +227,16 @@ sub _speculate_last_id
# updaiteing $seq_file.
# XXX 3600 is the magic number. How long time is appropriate ?
if (-f $seq_file &&
- ($sf_last_modified + 3600 > $db_last_modified)
- ) {
+ ($sf_last_modified + 3600 > $db_last_modified)) {
print STDERR "read seqfile\n"; sleep 3;
eval q{
use File::Sequence;
- my $sfh = new File::Sequence { sequence_file => $seq_file };
+ my $sfh = new File::Sequence { sequence_file => $seq_file };
return $sfh->get_id();
};
warn($@) if $@;
}
else {
-
my $last_id = 0;
$thread->db_open();
@@ -323,7 +326,7 @@ sub _read_filter_list
# Descriptions: change status to "closed".
# $thread_id accepts MH style format.
# MH style is expanded by C<Mail::Messsage::MH>.
-# Arguments: OBJ($self) HASH_REF($args)
+# Arguments: OBJ($thread) STR($thread_id) NUM($min) NUM($max)
# Side Effects: update thread status database
# Return Value: none
sub _close
@@ -396,13 +399,6 @@ sub finish
sub DESTROY {}
-sub AUTOLOAD
-{
- my ($curproc, $args) = @_;
- 1;
-}
-
-
package FML::Process::ThreadTrack::CUI;
use vars qw($debug @ISA @EXPORT @EXPORT_OK);