ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/deliantra/server/lib/cf.pm
(Generate patch)

Comparing deliantra/server/lib/cf.pm (file contents):
Revision 1.58 by root, Wed Aug 30 12:08:15 2006 UTC vs.
Revision 1.61 by root, Sun Sep 3 22:45:56 2006 UTC

… …
476 } 476 }
477 } 477 }
478} 478}
479 479
480sub object_freezer_save { 480sub object_freezer_save {
481 my ($filename, $objs) = @_; 481 my ($filename, $rdata, $objs) = @_;
482 482
483 if (@$objs) { 483 if (length $$rdata) {
484 warn sprintf "saving %s (%d,%d)\n",
485 $filename, length $$rdata, scalar @$objs;
486
484 open my $fh, ">:raw", "$filename.pst~"; 487 if (open my $fh, ">:raw", "$filename~") {
488 chmod SAVE_MODE, $fh;
489 syswrite $fh, $$rdata;
490 close $fh;
491
492 if (@$objs && open my $fh, ">:raw", "$filename.pst~") {
493 chmod SAVE_MODE, $fh;
485 syswrite $fh, Storable::nfreeze { version => 1, objs => $objs }; 494 syswrite $fh, Storable::nfreeze { version => 1, objs => $objs };
486 close $fh; 495 close $fh;
487 chmod SAVE_MODE, "$filename.pst~";
488 rename "$filename.pst~", "$filename.pst"; 496 rename "$filename.pst~", "$filename.pst";
497 } else {
498 unlink "$filename.pst";
499 }
500
501 rename "$filename~", $filename;
502 } else {
503 warn "FATAL: $filename~: $!\n";
504 }
489 } else { 505 } else {
506 unlink $filename;
490 unlink "$filename.pst"; 507 unlink "$filename.pst";
491 } 508 }
492
493 chmod SAVE_MODE, "$filename~";
494 rename "$filename~", $filename;
495} 509}
496 510
497sub object_thawer_load { 511sub object_thawer_load {
498 my ($filename) = @_; 512 my ($filename) = @_;
499 513
514 local $/;
515
516 my $av;
517
518 #TODO: use sysread etc.
519 if (open my $data, "<:raw:perlio", $filename) {
520 $data = <$data>;
500 open my $fh, "<:raw:perlio", "$filename.pst" 521 if (open my $pst, "<:raw:perlio", "$filename.pst") {
501 or return; 522 $av = eval { (Storable::thaw <$pst>)->{objs} };
523 }
524 return ($data, $av);
525 }
502 526
503 eval { local $/; (Storable::thaw <$fh>)->{objs} } 527 ()
504} 528}
505 529
506attach_to_objects 530attach_to_objects
507 prio => -1000000, 531 prio => -1000000,
508 on_clone => sub { 532 on_clone => sub {
… …
704 #Symbol::delete_package __PACKAGE__; 728 #Symbol::delete_package __PACKAGE__;
705 729
706 # 7. reload cf.pm 730 # 7. reload cf.pm
707 $msg->("reloading cf.pm"); 731 $msg->("reloading cf.pm");
708 require cf; 732 require cf;
733
734 $msg->("load extensions");
735 cf::load_extensions;
709 }; 736 };
710 $msg->($@) if $@; 737 $msg->($@) if $@;
711 738
712 $msg->("reloaded"); 739 $msg->("reloaded");
713}; 740};
… …
773 800
774sub all_objects(@) { 801sub all_objects(@) {
775 @_, map all_objects ($_->inv), @_ 802 @_, map all_objects ($_->inv), @_
776} 803}
777 804
805# TODO: compatibility cruft, remove when no longer needed
778attach_to_players 806attach_to_players
779 on_load => sub { 807 on_load => sub {
780 my ($pl, $path) = @_; 808 my ($pl, $path) = @_;
781 809
782 for my $o (all_objects $pl->ob) { 810 for my $o (all_objects $pl->ob) {
… …
903 931
904############################################################################# 932#############################################################################
905# the server's main() 933# the server's main()
906 934
907sub main { 935sub main {
936 load_extensions;
908 Event::loop; 937 Event::loop;
909} 938}
910 939
911############################################################################# 940#############################################################################
912# initialisation 941# initialisation
913 942
914register "<global>", __PACKAGE__; 943register "<global>", __PACKAGE__;
915 944
916unshift @INC, $LIBDIR; 945unshift @INC, $LIBDIR;
917
918load_extensions;
919 946
920$TICK_WATCHER = Event->timer ( 947$TICK_WATCHER = Event->timer (
921 prio => 1, 948 prio => 1,
922 at => $NEXT_TICK || 1, 949 at => $NEXT_TICK || 1,
923 cb => sub { 950 cb => sub {

Diff Legend

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