sendmail/contrib/qtool.pl

490 	my $self = {};
491 	bless $self, $class;
492 	$self->initialize(@_);
493 	return $self;
498 	my $self = shift;
500 	$self->{id} = shift;
502 	$self->{file_name} = $queue_dir . '/' . $qprefix . $self->{id};
503 	$self->{headers} = {};
516 	my $self = shift;
517 	if ($self->{parsed})
556 	open(CONTROL_FILE, "$self->{file_name}");
575 		if ($self->can($member_name))
577 			$self->$member_name($line_value);
579 		$member = $self->{$member_name};
582 			$self->{$member_name} = $line_value;
590 		$self->{$member_name} = [$member, $line_value];
594 	$self->{parsed} = 1;
599 	my $self = shift;
601 	my $headers = $self->{headers};
602 	my $last_header = $self->{last_header};
627 	$self->{last_header} = $header_name;
641 	my $self = shift;
643 	return (defined $self->{lock_handle});
648 	my $self = shift;
652 	if ($self->is_locked())
658 	($lock_handle, $result) = ::lock_file($self->{file_name});
664 	$self->{lock_handle} = $lock_handle;
671 	my $self = shift;
674 	if (!$self->is_locked())
680 	$result = ::unlock_file($self->{lock_handle});
682 	$self->{lock_handle} = undef;
689 	my $self = shift;
693 	$result = open(QUEUE_FILE, $self->{file_name});
696 		return "Unable to open '$self->{file_name}': $!";
701 		return "Unable to stat '$self->{file_name}': $!";
703 	$self->{control_size} = $result[7];
704 	$self->{control_last_mod_time} = $result[9];
709 	my $self = shift;
711 	$self->unlock();
716 	my $self = shift;
719 	$result = unlink($self->{file_name});
722 		return "Unable to delete $self->{file_name}: $!";
741 	my $self = {};
742 	bless $self, $class;
743 	$self->initialize(@_);
744 	return $self;
749 	my $self = shift;
751 	$self->{id} = shift;
754 	$self->{file_name} = $data_dir . '/df' . $self->{id};
755 	return if -e $self->{file_name};
764 	$self->{file_name} = $data_dir . '/df' . $self->{id};
769 	my $self = shift;
773 	$result = open(QUEUE_FILE, $self->{file_name});
776 		return "Unable to open '$self->{file_name}': $!";
781 		return "Unable to stat '$self->{file_name}': $!";
783 	$self->{body_size} = $result[7];
784 	$self->{body_last_mod_time} = $result[9];
789 	my $self = shift;
792 	$result = unlink($self->{file_name});
795 		return "Unable to delete $self->{file_name}: $!";
819 	my $self = {};
820 	bless $self, $class;
821 	$self->initialize(@_);
822 	return $self;
827 	my $self = shift;
832 	$self->{id} = $id;
833 	$self->{control_file} = new ControlFile($queue_dir, $id);
838 	$self->{data_file} = new DataFile($data_dir, $id, $self->{control_file});
843 	my $self = shift;
845 	@result = stat($self->{data_file}->{file_name});
853 	my $self = shift;
854 	return $self;
859 	my $self = shift;
862 	if (exists $self->{control_file}->{$key})
864 		return $self->{control_file}->{$key};
866 	if (exists $self->{data_file}->{$key})
868 		return $self->{data_file}->{$key};
876 	my $self = shift;
878 	return $self->{control_file}->lock();
883 	my $self = shift;
885 	return $self->{control_file}->unlock();
890 	my $self = shift;
896 	$result = $self->lock();
917 	if (-e File::Spec->catfile($qf_dest, "$qprefix$self->{id}"))
919 		$result = "There is already a queued message with id '$self->{id}' in '$destination'";
924 		$result = ::move_file($self->{data_file}->{file_name},
930 		$result = ::move_file($self->{control_file}->{file_name},
934 	$self->unlock();
941 	my $self = shift;
943 	return $self->{control_file}->parse();
948 	my $self = shift;
950 	$self->{control_file}->do_stat();
951 	$self->{data_file}->do_stat();
956 	my $self = shift;
958 	$self->parse();
959 	$self->do_stat();
964 	my $self = shift;
967 	$result = $self->{control_file}->delete();
972 	$result = $self->{data_file}->delete();
983 	my $self = shift;
986 	$command = "sendmail -qI$self->{id} -O Timeout.queuereturn=now";
1003 	my $self = {};
1004 	bless $self, $class;
1005 	$self->initialize(@_);
1006 	return $self;
1011 	my $self = shift;
1013 	$self->{queue_dir} = shift;
1014 	$self->{files} = {};
1027 	my $self = shift;
1036 	$control_dir = File::Spec->catfile($self->{queue_dir}, 'qf');
1040 		$data_dir = File::Spec->catfile($self->{queue_dir}, 'df');
1043 			$data_dir = $self->{queue_dir};
1048 		$data_dir = $self->{queue_dir};
1049 		$control_dir = $self->{queue_dir};
1065 		$self->{files}->{$id} = $queued_message;
1081 	my $self = shift;
1085 	$result = $queued_message->move($self->{queue_dir});
1091 	$self->{files}->{$queued_message->{id}} = $queued_message;
1105 	my $self = shift;
1113 		$result = $self->add_queued_message($queued_message);
1129 	my $self = shift;
1138 		return $self->add_queued_message($source);
1143 		return $self->add_queue($source);
1151 	my $self = shift;
1155 	while (($id, $queued_message) = each %{$self->{files}})
1167 	my $self = shift;
1171 	while (($id, $queued_message) = each %{$self->{files}})
1205 	my $self = {};
1206 	bless $self, $class;
1207 	$self->initialize(@_);
1208 	return $self;
1213 	my $self = shift;
1215 	$self->{age_in_seconds} = shift;
1220 	my $self = shift;
1223 	if ((time() - $source->last_modified_time()) > $self->{age_in_seconds})
1245 	my $self = {};
1246 	bless $self, $class;
1247 	$self->initialize(@_);
1248 	return $self;
1253 	my $self = shift;
1255 	$self->{condition_list} = [];
1260 	my $self = shift;
1263 	push(@{$self->{condition_list}}, $new_condition);
1268 	my $self = shift;
1274 	foreach $condition (@{$self->{condition_list}})
1298 	my $self = {};
1299 	bless $self, $class;
1300 	$self->initialize(@_);
1301 	return $self;
1306 	my $self = shift;
1308 	$self->{expression} = shift;
1313 	my $self = shift;
1321 	$result = eval($self->{expression});