Leaked source code of windows server 2003
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
 
 
 
 
 
 

220 lines
5.6 KiB

@rem = '-*- Perl -*-';
@rem = '
@if "%overbose%" == "" echo off
setlocal
for %%i in (oenvtest.bat) do @call %%~$PATH:i
set ARGS= %*
call perl%OPERLOPT% -w %~dpnx0 %ARGS:/?=-?%
goto :eof
';
#
# REVIEWD - Source Depot review daemon
#
# See sub Usage for details.
#
# Author: smueller
#
#
# External dependencies
#
BEGIN { if (exists $ENV{OTOOLS}) { # set library path for OTOOLS environment
my $l="$ENV{OTOOLS}\\lib\\perl"; @INC=($l,"$l\\$ENV{PROCESSOR_ARCHITECTURE}")
}}
BEGIN { if (exists $ENV{'sdxroot'}) {
require $ENV{'sdxroot'} . '\TOOLS\sendmsg.pl';
}}
require 5;
use strict;
use Getopt::Long;
use Office::SD 0.78;
use vars qw($fDebug @ports %counters $counter $sleep @describe);
#
# Utilities
#
#
# Usage - Display detailed usage information and exit.
#
sub Usage {
print <<EOT;
reviewd - Send checkin mail to users in a Source Depot server
reviewd [ -d ] [ -p port ... ] counter sleep
The 'counter' argument specifies the name of the review counter to
track.
The 'sleep' argument specifies how many minutes to sleep between
processing a set of changes and polling for the next set.
The -p port flag specifies a depot server and port to poll. Specify
multiple depots to poll by specifying multiple -p port flags.
The -d flag runs the script in debug mode and generates
additional debugging output.
EOT
exit 1;
}
#
# Debug - Print debugging output if in debug mode.
#
sub Debug {
print @_ if $fDebug;
}
#
# Collect - Collect text and info output from SDDescribe
#
sub Collect {
push @describe, @_;
}
#
# ReviewChanges - Look for changes to process and do so
#
sub ReviewChanges {
my($counter) = @_;
foreach my $port (@ports) {
# pick a depot
ConfigSD(port => $port);
# highest numbered change seen, for updating the counter each iteration
my $nclMax = 0;
# retrieve new changes
#Debug("COMMAND: sd -p $port review -t $counter\n");
my $rchanges = SDReview(\"-t $counter");
next if ! defined $rchanges; # no new submitted changes
foreach my $rc (@$rchanges) { # for each newly submitted change list
Debug("CHANGE=$rc->{Change}; USER=$rc->{User}; EMAIL=$rc->{Email}; FULLNAME=$rc->{FullName}\n");
warn "reviewd: processing port $port, change $rc->{Change}...\n";
# retrieve users interested in change
#Debug("COMMAND: sd -p $port reviews -c $rc->{Change}\n");
my $rusers = SDReviews(\"-c $rc->{Change}");
next if ! defined $rusers; # no interested users
my @reviewers;
foreach my $ru (@$rusers) { # for each user interested in this change
Debug("USER=$ru->{User}; RAWEMAIL=$ru->{Email}; FULLNAME=$ru->{FullName}\n");
my ($email) = $ru->{Email} =~ /^.*\\(\S*)\@.*$/;
$email = $ru->{Email} if ! defined $email || $email eq '';
Debug("USER=$ru->{User}; EMAIL=$email; FULLNAME=$ru->{FullName}\n");
push @reviewers, $email;
}
# send submitter and describe output to any interested parties
if (@reviewers) {
# collect raw describe output using Collect callback
my $rconfigSav = ConfigSD(echo => echoText | echoInfo, echofunc => \&Collect);
@describe = ();
my $rchange = SDDescribe(\'-s', $rc->{Change});
ConfigSD($rconfigSav);
# format header fields
my $description1 = $rchange->{Description};
$description1 =~ s/\n.*//; # get first line only
my $subject = "$rchange->{User}: #$rc->{Change}: $description1";
my $body = join '', @describe;
my $sender = 'NtSourceDepotReview';
# Send mail to the reviewers
Debug("COMMAND: sendmsg -e -m $sender, $subject, $body, @reviewers\n");
if (exists $ENV{'sdxroot'}) {
my $ret = sendmsg('-v', '-m', $sender, $subject, $body, @reviewers);
} else {
print "From: $sender\nTo: @reviewers\nSubject: $subject\n\n$body\n";
}
}
$nclMax = $rc->{Change};
Debug("TOPCHANGE: $nclMax\n");
}
#
# Update review marker to reflect changes reviewed.
#
#Debug("COMMAND: sd -p $port counter $counter $nclMax\n") if $nclMax;
SDSetCounter($counter, $nclMax) if $nclMax;
}
}
#
# Daemon - Loop, work, wait
#
sub Daemon {
my($counter, $sleep) = @_;
Debug("COUNTER: $counter\n");
Debug("SLEEP: $sleep\n");
for (;;) {
ReviewChanges($counter);
Debug("SLEEPING $sleep SECONDS...\n");
sleep($sleep);
}
}
#
# main
#
Usage if ! GetOptions('h|?', \&Usage, 'd', \$fDebug, 'p=s@', \@ports)
|| @ARGV != 2;
# enable debug output if appropriate
ConfigSD(verbose => 1) if $fDebug;
# validate ports
if (@ports == 0) {
my $rset = SDSet();
if (exists $rset->{SDPORT}) {
@ports = ($rset->{SDPORT});
warn "reviewd: no ports specified; defaulting to $ports[0]\n";
}
}
foreach my $port (@ports) {
ConfigSD(port => $port);
if (! defined SDInfo()) {
warn "reviewd: port $port appears bogus, skipping\n";
$port = 'BOGUS:0000';
}
}
@ports = grep $_ ne 'BOGUS:0000', @ports;
if (@ports == 0) {
die "reviewd: no valid ports specified\n";
}
# validate counter -- assume if first depot has it, all do
ConfigSD(port => $ports[0]);
$counter = $ARGV[0];
%counters = SDCounters();
die SDError() if SDError();
die "No such counter '$counter'.\n" if ! exists $counters{uc $counter};
$sleep = $ARGV[1];
$sleep = 1 if $sleep == 0;
$sleep *= 60; # convert to seconds
Daemon($counter, $sleep);
exit 0; # never get here