From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

TOMMY / App-dupfind-0.140200-TRIAL / lib / App / dupfind / Threaded / Overrides.pm 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
—
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126

              
# ABSTRACT: Methods and attributes that have to be overridden when threading
# Overriding from:
#  - App::dupfind::Common
#  - App::dupfind::Guts
use strict;
use warnings;
package App::dupfind::Threaded::Overrides;
{
  $App::dupfind::Threaded::Overrides::VERSION = '0.140200'; # TRIAL
}
use 5.010;
use threads;
use threads::shared;
use Moo::Role;
use lib 'lib';
requires 'opts';
{
   my $stats = {}; &share( $stats );
   sub stats
   {
      my ( $self, $key, $val ) = @_;
      return $stats unless $key;
      lock $stats;
      $stats->{ $key } = $val;
   }
   sub add_stats
   {
      my ( $self, $key, $val ) = @_;
      return $stats unless $key;
      lock $stats;
      $stats->{ $key } += $val;
   }
}
sub sort_dups
{
   my ( $self, $dups ) = @_;
   # sort dup groupings
   for my $identifier ( keys %$dups )
   {
      my @group = @{ $dups->{ $identifier } };
      $dups->{ $identifier } = &shared_clone( [ sort { $a cmp $b } @group ] );
   }
   return $dups;
}
1;
__END__
=pod
=head1 NAME
App::dupfind::Threaded::Overrides - Methods and attributes that have to be overridden when threading
=head1 VERSION
version 0.140200
=head1 DESCRIPTION
Some of the methods in App::dupfind::Common and App::dupfind::Guts need to
be overridden here in order to make thread-safe versions of them, and/or
versions of the methods that implement support for shared variables that
will be passed around between threads during the map-reduce operations
implemented by App::dupfind::Threaded::MapReduce
Please don't use this module by itself.  It is for internal use only.
Because there are no functional differences between these methods and the
ones they override, please refer to the original documentation for them in
the POD of these classes:
=over
=item *
=back
=head1 METHODS THIS CLASS OVERRIDES
=over
=item add_stats
Not overridden, but necessary in order to implement the simple hashref of
stats that is used in the non-threaded version in App::dupfind::Common.
$self->add_stats allows App::dupfind::Threaded::MapReduce::Digest to
accomplish the same thing, but in a thread-safe way.
The stats mechanism is simply there to keep track of cache hits and misses
while calculating file digests.
=item sort_dups
Overridden from App::dupfind::Common
=item stats
The sibling method to add_stats.  The same concept and description applies
(see above).
=back
=cut