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
|
package LXRng::Repo::Git::TarFile;
use strict;
use File::Temp qw(tempdir);
use Fcntl qw(F_GETFD F_SETFD FD_CLOEXEC);
use base qw(LXRng::Repo::File);
sub new {
my ($class, $tar, $ref) = @_;
return bless({tar => $tar, ref => $ref}, $class);
}
sub name {
my ($self) = @_;
return $$self{'tar'}->name();
}
sub node {
my ($self) = @_;
$self->name =~ m,.*/([^/]+), and return $1;
}
sub time {
my ($self) = @_;
return $$self{'tar'}->mtime();
}
sub size {
my ($self) = @_;
return $$self{'tar'}->size;
}
sub phys_path {
my ($self) = @_;
my $tmpdir = tempdir() or die($!);
open(my $phys, ">", $tmpdir.'/'.$self->node);
my $data = $$self{'tar'}->get_content_by_ref();
my $len = $$self{'tar'}->size();
my $pos = 0;
while ($pos < $len) {
print($phys substr($$data, $pos, 64*1024));
$pos += 64*1024;
}
close($phys);
return LXRng::Repo::Git::TarFile::Virtual->new(dir => $tmpdir,
node => $self->node);
}
sub handle {
my ($self) = @_;
my $data = $$self{'tar'}->get_content_by_ref();
open(my $fh, "<", $data);
return $fh;
}
sub revision {
my ($self) = @_;
$$self{'ref'} ||= $self->time.'.'.$self->size;
return $$self{'ref'};
}
package LXRng::Repo::Git::TarFile::Virtual;
use strict;
use overload '""' => \&filename;
sub new {
my ($class, %args) = @_;
return bless(\%args, $class);
}
sub filename {
my ($self) = @_;
return $$self{'dir'}.'/'.$$self{'node'};
}
sub DESTROY {
my ($self) = @_;
unlink($$self{'dir'}.'/'.$$self{'node'});
rmdir($$self{'dir'});
# kill(9, $$self{'pid'});
}
1;
|
