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.23 by root, Sun Sep 21 23:21:49 2008 UTC vs.
Revision 1.28 by root, Thu Apr 29 07:52:02 2010 UTC

… …
3# statistics-package 3# statistics-package
4 4
5use Fcntl; 5use Fcntl;
6use Coro::AIO; 6use Coro::AIO;
7 7
8our %PLAYERSEEN;
9
8our $UPDATE_LOGINS = EV::idle sub { 10our $UPDATE_LOGINS = AE::idle sub {
9 $_[0]->stop; 11 $_[0]->stop;
10 12
11 cf::async { 13 cf::async {
12 my ($status, @pl) = ext::commands::who_listing; 14 my ($status, @pl) = ext::commands::who_listing;
13 15
… …
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 (my $client = $pl->ns->version) =~ s/\n/\\n/g;
54
55 $pl->ob->kv_set (schmorplog_client => $client); 56 $pl->ob->kv_set (schmorplog_client => $pl->ns->{who_version});
56 57
57 ext::irc::do_notice (sprintf "%s logged in", $pl->ob->name); 58 my $name = $pl->ob->name;
58 59
60 ext::irc::do_notice $name . " logged in";
61
62 undef $PLAYERSEEN{$name};
59 $UPDATE_LOGINS->start; 63 $UPDATE_LOGINS->start;
60 64
61 warn "LOGIN: ", $pl->ob->name, " from ", $pl->ns->host; 65 cf::trace "LOGIN: ", $pl->ob->name, " from ", $pl->ns->host;
62 }, 66 },
63 on_logout => sub { 67 on_logout => sub {
64 my ($pl, $cleanly) = @_; 68 my ($pl, $cleanly) = @_;
65 $pl->ob->kv_set (schmorplog_last_logout => time); 69 $pl->ob->kv_set (schmorplog_last_logout => time);
66 ext::irc::do_notice (sprintf "%s left", $pl->ob->name); 70 ext::irc::do_notice $pl->ob->name . " left";
67 71
68 $UPDATE_LOGINS->start; 72 $UPDATE_LOGINS->start;
69 73
70 warn "LOGOUT: ", $pl->ob->name, " from ", $pl->ns->host, " ($cleanly)"; 74 cf::trace "LOGOUT: ", $pl->ob->name, " from ", $pl->ns->host, " ($cleanly)";
71 }, 75 },
72 on_birth => sub { 76 on_birth => sub {
73 my ($pl) = @_; 77 my ($pl) = @_;
74 ext::irc::do_notice (sprintf "%s was just born", $pl->ob->name);
75 $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";
76 80
77 warn "BIRTH: ", $pl->ob->name, " from ", $pl->ns->host; 81 cf::trace "BIRTH: ", $pl->ob->name, " from ", $pl->ns->host;
78 }, 82 },
79 on_quit => sub { 83 on_quit => sub {
80 my ($pl) = @_; 84 my ($pl) = @_;
81 ext::irc::do_notice (sprintf "%s quit the game", $pl->ob->name); 85 ext::irc::do_notice $pl->ob->name . " quit the game";
82 86
83 warn "QUIT: ", $pl->ob->name, " from ", $pl->ns->host; 87 cf::trace "QUIT: ", $pl->ob->name, " from ", $pl->ns->host;
84 }, 88 },
85 on_death => sub { 89 on_death => sub {
86 my ($pl) = @_; 90 my ($pl) = @_;
87 91
88 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 . ".");
89 ext::irc::do_notice ($msg); 93 ext::irc::do_notice $msg;
90 94
91 ++$pl->ob->{stats_death}{$pl->killer_name}; 95 ++$pl->ob->{stats_death}{$pl->killer_name};
92 96
93 $pl->ob->kv_set (schmorplog_death_count => 97 $pl->ob->kv_set (schmorplog_death_count =>
94 1 + $pl->ob->kv_get ("schmorplog_death_count")); 98 1 + $pl->ob->kv_get ("schmorplog_death_count"));
… …
163 my $name = $ns->pl && $ns->pl->ob ? $ns->pl->ob->name : "<unknown>"; 167 my $name = $ns->pl && $ns->pl->ob ? $ns->pl->ob->name : "<unknown>";
164 168
165 $msg =~ y/\x0a\x20-\x7f//cd; 169 $msg =~ y/\x0a\x20-\x7f//cd;
166 $msg =~ s/\s+$//; 170 $msg =~ s/\s+$//;
167 171
168 warn sprintf "clientlog [%s/%s]: %s\n", $ns->host, $name, $msg; 172 cf::error sprintf "clientlog [%s/%s]: %s\n", $ns->host, $name, $msg;
169 173
170 () 174 ()
171}; 175};
172 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 # the truncate is 1440 extra syscalls, but saves 1439
204 # slow metadata updates.
205 IO::AIO::aio_truncate $fh, 1440, sub {
206 IO::AIO::aio_write $fh, $offs, 1, $cnt, 0, sub {
207 IO::AIO::aio_close $fh;
208 };
209 };
210 };
211};
212
213

Diff Legend

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