ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/ext/schmorplog.ext
(Generate patch)

Comparing deliantra/server/ext/schmorplog.ext (file contents):
Revision 1.25 by root, Sun Apr 11 04:52:07 2010 UTC vs.
Revision 1.26 by root, Sun Apr 11 21:26:36 2010 UTC

… …
2 2
3# statistics-package 3# statistics-package
4 4
5use Fcntl; 5use Fcntl;
6use Coro::AIO; 6use Coro::AIO;
7
8our %PLAYERSEEN;
7 9
8our $UPDATE_LOGINS = AE::idle sub { 10our $UPDATE_LOGINS = AE::idle sub {
9 $_[0]->stop; 11 $_[0]->stop;
10 12
11 cf::async { 13 cf::async {
… …
43); 45);
44 46
45cf::player->attach ( 47cf::player->attach (
46 on_login => sub { 48 on_login => sub {
47 my ($pl) = @_; 49 my ($pl) = @_;
50
48 $pl->ob->kv_set (schmorplog_last_login => time); 51 $pl->ob->kv_set (schmorplog_last_login => time);
49 52
50 $pl->ob->kv_set (schmorplog_login_count => 53 $pl->ob->kv_set (schmorplog_login_count =>
51 1 + $pl->ob->kv_get ("schmorplog_login_count")); 54 1 + $pl->ob->kv_get ("schmorplog_login_count"));
52 55
53 $pl->ob->kv_set (schmorplog_client => $pl->ns->{who_version}); 56 $pl->ob->kv_set (schmorplog_client => $pl->ns->{who_version});
54 57
55 ext::irc::do_notice (sprintf "%s logged in", $pl->ob->name); 58 my $name = $pl->ob->name;
56 59
60 ext::irc::do_notice $name . " logged in";
61
62 undef $PLAYERSEEN{$name};
57 $UPDATE_LOGINS->start; 63 $UPDATE_LOGINS->start;
58 64
59 warn "LOGIN: ", $pl->ob->name, " from ", $pl->ns->host; 65 warn "LOGIN: ", $pl->ob->name, " from ", $pl->ns->host;
60 }, 66 },
61 on_logout => sub { 67 on_logout => sub {
62 my ($pl, $cleanly) = @_; 68 my ($pl, $cleanly) = @_;
63 $pl->ob->kv_set (schmorplog_last_logout => time); 69 $pl->ob->kv_set (schmorplog_last_logout => time);
64 ext::irc::do_notice (sprintf "%s left", $pl->ob->name); 70 ext::irc::do_notice $pl->ob->name . " left";
65 71
66 $UPDATE_LOGINS->start; 72 $UPDATE_LOGINS->start;
67 73
68 warn "LOGOUT: ", $pl->ob->name, " from ", $pl->ns->host, " ($cleanly)"; 74 warn "LOGOUT: ", $pl->ob->name, " from ", $pl->ns->host, " ($cleanly)";
69 }, 75 },
70 on_birth => sub { 76 on_birth => sub {
71 my ($pl) = @_; 77 my ($pl) = @_;
72 ext::irc::do_notice (sprintf "%s was just born", $pl->ob->name);
73 $pl->ob->kv_set (schmorplog_birthdate => time); 78 $pl->ob->kv_set (schmorplog_birthdate => time);
79 ext::irc::do_notice $pl->ob->name . " was just born";
74 80
75 warn "BIRTH: ", $pl->ob->name, " from ", $pl->ns->host; 81 warn "BIRTH: ", $pl->ob->name, " from ", $pl->ns->host;
76 }, 82 },
77 on_quit => sub { 83 on_quit => sub {
78 my ($pl) = @_; 84 my ($pl) = @_;
79 ext::irc::do_notice (sprintf "%s quit the game", $pl->ob->name); 85 ext::irc::do_notice $pl->ob->name . " quit the game";
80 86
81 warn "QUIT: ", $pl->ob->name, " from ", $pl->ns->host; 87 warn "QUIT: ", $pl->ob->name, " from ", $pl->ns->host;
82 }, 88 },
83 on_death => sub { 89 on_death => sub {
84 my ($pl) = @_; 90 my ($pl) = @_;
85 91
86 my $msg = $pl->expand_cfpod (sprintf "%s was killed by %s.", $pl->ob->name, $pl->killer_name); 92 my $msg = $pl->expand_cfpod ($pl->ob->name . " was killed by " . $pl->killer_name . ".");
87 ext::irc::do_notice ($msg); 93 ext::irc::do_notice $msg;
88 94
89 ++$pl->ob->{stats_death}{$pl->killer_name}; 95 ++$pl->ob->{stats_death}{$pl->killer_name};
90 96
91 $pl->ob->kv_set (schmorplog_death_count => 97 $pl->ob->kv_set (schmorplog_death_count =>
92 1 + $pl->ob->kv_get ("schmorplog_death_count")); 98 1 + $pl->ob->kv_get ("schmorplog_death_count"));
… …
166 warn sprintf "clientlog [%s/%s]: %s\n", $ns->host, $name, $msg; 172 warn sprintf "clientlog [%s/%s]: %s\n", $ns->host, $name, $msg;
167 173
168 () 174 ()
169}; 175};
170 176
177# log max playercount every minute
178#############################################################################
179
180our $STATSDIR = "$LOCALDIR/maxplayers";
181
182mkdir $STATSDIR;
183
184our $WRITE_MAXPLAYERS = EV::periodic 0, 60, undef, sub {
185 my $now = AE::now;
186 my $cnt = scalar keys %PLAYERSEEN;
187
188 %PLAYERSEEN = map +($_->ob->name => undef), grep $_->ns, cf::player::list;
189
190 my @time = gmtime $now;
191
192 my $path = sprintf "%s/%04d-%02d-%02d", $STATSDIR, $time[5] + 1900, $time[4] + 1, $time[3];
193 my $offs = $time [2] * 60 + $time [1];
194
195 $cnt++;
196 $cnt = 254 if $cnt > 254;
197 $cnt = chr $cnt;
198
199 IO::AIO::aio_open $path, O_WRONLY | O_CREAT, 0666, sub {
200 my $fh = shift
201 or return;
202
203 IO::AIO::aio_write $fh, $offs, 1, $cnt, 0, sub {
204 IO::AIO::aio_close $fh;
205 };
206 };
207};
208
209

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines