ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/AnyEvent-FastPing/FastPing.xs
(Generate patch)

Comparing AnyEvent-FastPing/FastPing.xs (file contents):
Revision 1.14 by root, Wed Oct 8 21:12:28 2014 UTC vs.
Revision 1.15 by root, Sat Nov 12 01:20:46 2016 UTC

… …
636 LEAVE; 636 LEAVE;
637} 637}
638#endif 638#endif
639 639
640static void 640static void
641boot () 641boot_protocols (void)
642{ 642{
643 if (pipe (thr_res) < 0)
644 croak ("AnyEvent::FastPing: unable to create receive pipe");
645
646 sv_setiv (get_sv ("AnyEvent::FastPing::THR_RES_FD", 1), thr_res [0]);
647
648 icmp4_fd = socket (AF_INET, SOCK_RAW, IPPROTO_ICMP); 643 icmp4_fd = socket (AF_INET, SOCK_RAW, IPPROTO_ICMP);
649 fcntl (icmp4_fd, F_SETFL, O_NONBLOCK); 644 fcntl (icmp4_fd, F_SETFL, O_NONBLOCK);
650#ifdef ICMP_FILTER 645#ifdef ICMP_FILTER
651 { 646 {
652 struct icmp_filter oval; 647 struct icmp_filter oval;
… …
665 ICMP6_FILTER_SETPASS (ICMP6_ECHO_REPLY, &oval); 660 ICMP6_FILTER_SETPASS (ICMP6_ECHO_REPLY, &oval);
666 setsockopt (icmp6_fd, IPPROTO_ICMPV6, ICMP6_FILTER, &oval, sizeof oval); 661 setsockopt (icmp6_fd, IPPROTO_ICMPV6, ICMP6_FILTER, &oval, sizeof oval);
667 } 662 }
668# endif 663# endif
669#endif 664#endif
665}
666
667static void
668boot (void)
669{
670 if (pipe (thr_res) < 0)
671 croak ("AnyEvent::FastPing: unable to create receive pipe");
672
673 sv_setiv (get_sv ("AnyEvent::FastPing::THR_RES_FD", 1), thr_res [0]);
674
675 boot_protocols ();
670 676
671 sv_setiv (get_sv ("AnyEvent::FastPing::ICMP4_FD", 1), icmp4_fd); 677 sv_setiv (get_sv ("AnyEvent::FastPing::ICMP4_FD", 1), icmp4_fd);
672 sv_setiv (get_sv ("AnyEvent::FastPing::ICMP6_FD", 1), icmp6_fd); 678 sv_setiv (get_sv ("AnyEvent::FastPing::ICMP6_FD", 1), icmp6_fd);
673} 679}
674 680
675#define NOT_RUNNING \ 681#define NOT_RUNNING \
676 if (self->running) \ 682 if (self->running) \
677 croak ("AnyEvent::FastPing object has been started - you have to sotp t first before calling this method, caught"); 683 croak ("AnyEvent::FastPing object has been started - you have to stop it first before calling this method, caught");
678 684
679MODULE = AnyEvent::FastPing PACKAGE = AnyEvent::FastPing PREFIX = pinger_ 685MODULE = AnyEvent::FastPing PACKAGE = AnyEvent::FastPing PREFIX = pinger_
680 686
687PROTOTYPES: DISABLE
688
681BOOT: 689BOOT:
682{ 690{
683 HV *stash = gv_stashpv ("AnyEvent::FastPing", 1); 691 HV *stash = gv_stashpv ("AnyEvent::FastPing", 1);
684 692
685 if (sizeof (PKT) & 3) 693 if (sizeof (PKT) & 3)
686 croak ("size of PKT structure is not a multiple of 4"); 694 croak ("size of PKT structure is not a multiple of 4");
687 695
688 boot ();
689
690 newCONSTSUB (stash, "ipv4_supported", newSViv (icmp4_fd >= 0));
691 newCONSTSUB (stash, "ipv6_supported", newSViv (icmp6_fd >= 0));
692
693 newCONSTSUB (stash, "icmp4_pktsize", newSViv (HDR_SIZE_IP4 + sizeof (PKT))); 696 newCONSTSUB (stash, "icmp4_pktsize", newSViv (HDR_SIZE_IP4 + sizeof (PKT)));
694 newCONSTSUB (stash, "icmp6_pktsize", newSViv (HDR_SIZE_IP6 + sizeof (PKT))); 697 newCONSTSUB (stash, "icmp6_pktsize", newSViv (HDR_SIZE_IP6 + sizeof (PKT)));
695}
696 698
697PROTOTYPES: DISABLE 699 boot_protocols ();
700
701 newCONSTSUB (stash, "ipv4_supported", newSViv (icmp4_fd >= 0));
702 newCONSTSUB (stash, "ipv6_supported", newSViv (icmp6_fd >= 0));
703
704 close (icmp4_fd);
705 close (icmp6_fd);
706}
707
708void
709_boot ()
710 CODE:
711 boot ();
698 712
699void 713void
700_recv_icmp4 (...) 714_recv_icmp4 (...)
701 CODE: 715 CODE:
702{ 716{

Diff Legend

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