3 # taskd - Clone repositories on request
5 # taskd is Girocco mirroring servant; it processes requests for clones
6 # of given URLs received over its socket.
8 # When a request is received, new process is spawned that sets up
9 # the repository, ACKs on the socket and reports further progress
10 # to .clonelog within the repository. In case the clone fails,
11 # .clone_failed is touched and .clone_in_progress is removed.
14 # Alice sets up repository and touches .cloning
15 # Alice opens connection to Bob
16 # Alice sends project name through the connection
17 # Bob opens the repository and sends back 0 if ok, error code otherwise
18 # Bob closes connection
19 # Alice polls .clonelog in case of 0.
20 # If Alice reads "@OVER@" from .clonelog, it stops polling.
22 # Based on perlipc example.
33 sub logmsg
{ print '['.(scalar localtime)."] $0 $$: @_\n" }
35 my $NAME = $Girocco::Config
::chroot.'/etc/taskd.socket';
36 my $uaddr = sockaddr_un
($NAME);
38 socket(Server
, PF_UNIX
, SOCK_STREAM
, 0) or die "socket: $!";
40 bind(Server
, $uaddr) or die "bind: $!";
41 listen(Server
, SOMAXCONN
) or die "listen: $!";
42 if ($Girocco::Config
::owning_group
) {
43 chmod 0664, $NAME or die "chmod: $!";
44 my $gid = scalar(getgrnam($Girocco::Config
::owning_group
));
45 chown(-1, $gid, $NAME) or die "chgrp $gid: $!";
47 chmod 0666, $NAME or die "chmod: $!";
51 use POSIX
":sys_wait_h";
55 while (($waitedpid = waitpid(-1, WNOHANG
)) > 0) {
56 logmsg
"reaped $waitedpid" . ($? ?
" with exit $?" : '');
58 $SIG{CHLD
} = \
&REAPER
; # loathe sysV
61 $SIG{CHLD
} = \
&REAPER
; # Apollo 440
67 if (not defined $pid) {
68 logmsg
"cannot fork: $!";
72 return; # I'm the parent
75 open STDIN
, "<&Client" or die "can't dup client to stdin";
76 open STDOUT
, ">&Client" or die "can't dup client to stdout";
82 Girocco
::Project
::does_exist
($name) or die "won't clone non-existing project $name";
84 print STDERR
"cloning $name\n";
85 open STDOUT
, ">".$Girocco::Config
::reporoot
."/".$name.".git/.clonelog" or die "cannot open clonelog: $!";
86 open STDERR
, ">&STDOUT";
87 open STDIN
, "</dev/null";
88 exec $Girocco::Config
::basedir
.'/taskd/clone.sh', "$name.git" or die "exec failed: $!";
92 unless (accept(Client
, Server
)) {
93 logmsg
"accept failed: $!";
96 logmsg
"connection on $NAME";
100 my ($cmd, $arg) = $inp =~ /^([a-zA-Z0-9-]+)\s+(.*)$/;
101 if ($cmd eq 'clone') {
104 die "unknown command: $cmd";