设为首页收藏本站

就爱编程论坛

 找回密码
 注册

人人连接登陆

无需注册,直接登录

用新浪微博连接

一步搞定

QQ登录

只需一步,快速开始

查看: 595|回复: 3
打印 上一主题 下一主题

微软ping命令的源代码 [复制链接]

Rank: 9Rank: 9Rank: 9

  • TA的每日心情
    无聊
    2025-5-27 03:37:20
  • 签到天数: 366 天

    [LV.9]以坛为家II

    论坛先锋 学习至圣 荣誉成员 论坛元老 活跃之星 终极领袖

    我玩的应用:

    跳转到指定楼层
    楼主
    发表于 2011-3-30 03:34:12 |只看该作者 |倒序浏览

    代码:/******************************************************************************\
    * ping.c - Simple ping utility using SOCK_RAW
    *
    * This is a part of the Microsoft Source Code Samples.
    * Copyright 1996-1997 Microsoft Corporation.
    * All rights reserved.
    * This source code is only intended as a supplement to
    * Microsoft Development Tools and/or WinHelp documentation.
    * See these sources for detailed information regarding the
    * Microsoft samples programs.
    \******************************************************************************/

    #pragma pack(4)

    #define WIN32_LEAN_AND_MEAN
    #include <winsock2.h>
    #include <stdio.h>
    #include <stdlib.h>

    #define ICMP_ECHO 8
    #define ICMP_ECHOREPLY 0

    #define ICMP_MIN 8 // minimum 8 byte icmp packet (just header)

    /* The IP header */
    typedef struct iphdr {
    unsigned int h_len:4; // length of the header
    unsigned int version:4; // Version of IP
    unsigned char tos; // Type of service
    unsigned short total_len; // total length of the packet
    unsigned short ident; // unique identifier
    unsigned short frag_and_flags; // flags
    unsigned char ttl;
    unsigned char proto; // protocol (TCP, UDP etc)
    unsigned short checksum; // IP checksum

    unsigned int sourceIP;
    unsigned int destIP;

    }IpHeader;

    //
    // ICMP header
    //
    typedef struct _ihdr {
    BYTE i_type;
    BYTE i_code; /* type sub code */
    USHORT i_cksum;
    USHORT i_id;
    USHORT i_seq;
    /* This is not the std header, but we reserve space for time */
    ULONG timestamp;
    }IcmpHeader;

    #define STATUS_FAILED 0xFFFF
    #define DEF_PACKET_SIZE 32
    #define MAX_PACKET 1024

    #define xmalloc(s) HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,(s))
    #define xfree(p) HeapFree (GetProcessHeap(),0,(p))

    void fill_icmp_data(char *, int);
    USHORT checksum(USHORT *, int);
    void decode_resp(char *,int ,struct sockaddr_in *);

    void Usage(char *progname){

    fprintf(stderr,"Usage:\n");
    fprintf(stderr,"%s <host> [data_size]\n",progname);
    fprintf(stderr,"datasize can be up to 1Kb\n");
    ExitProcess(STATUS_FAILED);

    }
    int main(int argc, char **argv){

    WSADATA wsaData;
    SOCKET sockRaw;
    struct sockaddr_in dest,from;
    struct hostent * hp;
    int bread,datasize;
    int fromlen = sizeof(from);
    int timeout = 1000;
    char *dest_ip;
    char *icmp_data;
    char *recvbuf;
    unsigned int addr=0;
    USHORT seq_no = 0;

    if (WSAStartup(MAKEWORD(2,1),&wsaData) != 0){
    fprintf(stderr,"WSAStartup failed: %d\n",GetLastError());
    ExitProcess(STATUS_FAILED);
    }

    if (argc <2 ) {
    Usage(argv[0]);
    }
    sockRaw = WSASocket (AF_INET,
    SOCK_RAW,
    IPPROTO_ICMP,
    NULL, 0,0);

    if (sockRaw == INVALID_SOCKET) {
    fprintf(stderr,"WSASocket() failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    bread = setsockopt(sockRaw,SOL_SOCKET,SO_RCVTIMEO,(char*)&timeout,
    sizeof(timeout));
    if(bread == SOCKET_ERROR) {
    fprintf(stderr,"failed to set recv timeout: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    timeout = 1000;
    bread = setsockopt(sockRaw,SOL_SOCKET,SO_SNDTIMEO,(char*)&timeout,
    sizeof(timeout));
    if(bread == SOCKET_ERROR) {
    fprintf(stderr,"failed to set send timeout: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    memset(&dest,0,sizeof(dest));

    hp = gethostbyname(argv[1]);

    if (!hp){
    addr = inet_addr(argv[1]);
    }
    if ((!hp) && (addr == INADDR_NONE) ) {
    fprintf(stderr,"Unable to resolve %s\n",argv[1]);
    ExitProcess(STATUS_FAILED);
    }

    if (hp != NULL)
    memcpy(&(dest.sin_addr),hp->h_addr,hp->h_length);
    else
    dest.sin_addr.s_addr = addr;

    if (hp)
    dest.sin_family = hp->h_addrtype;
    else
    dest.sin_family = AF_INET;

    dest_ip = inet_ntoa(dest.sin_addr);

    if (argc >2) {
    datasize = atoi(argv[2]);
    if (datasize == 0)
    datasize = DEF_PACKET_SIZE;

    }
    else
    datasize = DEF_PACKET_SIZE;

    datasize += sizeof(IcmpHeader);

    icmp_data = xmalloc(MAX_PACKET);
    recvbuf = xmalloc(MAX_PACKET);

    if (!icmp_data) {
    fprintf(stderr,"HeapAlloc failed %d\n",GetLastError());
    ExitProcess(STATUS_FAILED);
    }


    memset(icmp_data,0,MAX_PACKET);
    fill_icmp_data(icmp_data,datasize);

    while(1) {
    int bwrote;

    ((IcmpHeader*)icmp_data)->i_cksum = 0;
    ((IcmpHeader*)icmp_data)->timestamp = GetTickCount();

    ((IcmpHeader*)icmp_data)->i_seq = seq_no++;
    ((IcmpHeader*)icmp_data)->i_cksum = checksum((USHORT*)icmp_data,
    datasize);

    bwrote = sendto(sockRaw,icmp_data,datasize,0,(struct sockaddr*)&dest,
    sizeof(dest));
    if (bwrote == SOCKET_ERROR){
    if (WSAGetLastError() == WSAETIMEDOUT) {
    printf("timed out\n");
    continue;
    }
    fprintf(stderr,"sendto failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    if (bwrote < datasize ) {
    fprintf(stdout,"Wrote %d bytes\n",bwrote);
    }
    bread = recvfrom(sockRaw,recvbuf,MAX_PACKET,0,(struct sockaddr*)&from,
    &fromlen);
    if (bread == SOCKET_ERROR){
    if (WSAGetLastError() == WSAETIMEDOUT) {
    printf("timed out\n");
    continue;
    }
    fprintf(stderr,"recvfrom failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    decode_resp(recvbuf,bread,&from);
    Sleep(1000);

    }
    return 0;

    }
    /*
    The response is an IP packet. We must decode the IP header to locate
    the ICMP data
    */
    void decode_resp(char *buf, int bytes,struct sockaddr_in *from) {

    IpHeader *iphdr;
    IcmpHeader *icmphdr;
    unsigned short iphdrlen;

    iphdr = (IpHeader *)buf;

    iphdrlen = iphdr->h_len * 4 ; // number of 32-bit words *4 = bytes

    if (bytes < iphdrlen + ICMP_MIN) {
    printf("Too few bytes from %s\n",inet_ntoa(from->sin_addr));
    }

    icmphdr = (IcmpHeader*)(buf + iphdrlen);

    if (icmphdr->i_type != ICMP_ECHOREPLY) {
    fprintf(stderr,"non-echo type %d recvd\n",icmphdr->i_type);
    return;
    }
    if (icmphdr->i_id != (USHORT)GetCurrentProcessId()) {
    fprintf(stderr,"someone else's packet!\n");
    return ;
    }
    printf("%d bytes from %s:",bytes, inet_ntoa(from->sin_addr));
    printf(" icmp_seq = %d. ",icmphdr->i_seq);
    printf(" time: %d ms ",GetTickCount()-icmphdr->timestamp);
    printf("\n");

    }


    USHORT checksum(USHORT *buffer, int size) {

    unsigned long cksum=0;

    while(size >1) {
    cksum+=*buffer++;
    size -=sizeof(USHORT);
    }

    if(size ) {
    cksum += *(UCHAR*)buffer;
    }

    cksum = (cksum >> 16) + (cksum & 0xffff);
    cksum += (cksum >>16);
    return (USHORT)(~cksum);
    }
    /*
    Helper function to fill in various stuff in our ICMP request.
    */
    void fill_icmp_data(char * icmp_data, int datasize){

    IcmpHeader *icmp_hdr;
    char *datapart;

    icmp_hdr = (IcmpHeader*)icmp_data;

    icmp_hdr->i_type = ICMP_ECHO;
    icmp_hdr->i_code = 0;
    icmp_hdr->i_id = (USHORT)GetCurrentProcessId();
    icmp_hdr->i_cksum = 0;
    icmp_hdr->i_seq = 0;

    datapart = icmp_data + sizeof(IcmpHeader);
    //
    // Place some junk in the buffer.
    //
    memset(datapart,'E', datasize - sizeof(IcmpHeader));

    }


    文章出处:风云剑侠Swords 复制内容到剪贴板 代码:/******************************************************************************\
    * ping.c - Simple ping utility using SOCK_RAW
    *
    * This is a part of the Microsoft Source Code Samples.
    * Copyright 1996-1997 Microsoft Corporation.
    * All rights reserved.
    * This source code is only intended as a supplement to
    * Microsoft Development Tools and/or WinHelp documentation.
    * See these sources for detailed information regarding the
    * Microsoft samples programs.
    \******************************************************************************/

    #pragma pack(4)

    #define WIN32_LEAN_AND_MEAN
    #include <winsock2.h>
    #include <stdio.h>
    #include <stdlib.h>

    #define ICMP_ECHO 8
    #define ICMP_ECHOREPLY 0

    #define ICMP_MIN 8 // minimum 8 byte icmp packet (just header)

    /* The IP header */
    typedef struct iphdr {
    unsigned int h_len:4; // length of the header
    unsigned int version:4; // Version of IP
    unsigned char tos; // Type of service
    unsigned short total_len; // total length of the packet
    unsigned short ident; // unique identifier
    unsigned short frag_and_flags; // flags
    unsigned char ttl;
    unsigned char proto; // protocol (TCP, UDP etc)
    unsigned short checksum; // IP checksum

    unsigned int sourceIP;
    unsigned int destIP;

    }IpHeader;

    //
    // ICMP header
    //
    typedef struct _ihdr {
    BYTE i_type;
    BYTE i_code; /* type sub code */
    USHORT i_cksum;
    USHORT i_id;
    USHORT i_seq;
    /* This is not the std header, but we reserve space for time */
    ULONG timestamp;
    }IcmpHeader;

    #define STATUS_FAILED 0xFFFF
    #define DEF_PACKET_SIZE 32
    #define MAX_PACKET 1024

    #define xmalloc(s) HeapAlloc(GetProcessHeap(),HEAP_ZERO_MEMORY,(s))
    #define xfree(p) HeapFree (GetProcessHeap(),0,(p))

    void fill_icmp_data(char *, int);
    USHORT checksum(USHORT *, int);
    void decode_resp(char *,int ,struct sockaddr_in *);

    void Usage(char *progname){

    fprintf(stderr,"Usage:\n");
    fprintf(stderr,"%s <host> [data_size]\n",progname);
    fprintf(stderr,"datasize can be up to 1Kb\n");
    ExitProcess(STATUS_FAILED);

    }
    int main(int argc, char **argv){

    WSADATA wsaData;
    SOCKET sockRaw;
    struct sockaddr_in dest,from;
    struct hostent * hp;
    int bread,datasize;
    int fromlen = sizeof(from);
    int timeout = 1000;
    char *dest_ip;
    char *icmp_data;
    char *recvbuf;
    unsigned int addr=0;
    USHORT seq_no = 0;

    if (WSAStartup(MAKEWORD(2,1),&wsaData) != 0){
    fprintf(stderr,"WSAStartup failed: %d\n",GetLastError());
    ExitProcess(STATUS_FAILED);
    }

    if (argc <2 ) {
    Usage(argv[0]);
    }
    sockRaw = WSASocket (AF_INET,
    SOCK_RAW,
    IPPROTO_ICMP,
    NULL, 0,0);

    if (sockRaw == INVALID_SOCKET) {
    fprintf(stderr,"WSASocket() failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    bread = setsockopt(sockRaw,SOL_SOCKET,SO_RCVTIMEO,(char*)&timeout,
    sizeof(timeout));
    if(bread == SOCKET_ERROR) {
    fprintf(stderr,"failed to set recv timeout: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    timeout = 1000;
    bread = setsockopt(sockRaw,SOL_SOCKET,SO_SNDTIMEO,(char*)&timeout,
    sizeof(timeout));
    if(bread == SOCKET_ERROR) {
    fprintf(stderr,"failed to set send timeout: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    memset(&dest,0,sizeof(dest));

    hp = gethostbyname(argv[1]);

    if (!hp){
    addr = inet_addr(argv[1]);
    }
    if ((!hp) && (addr == INADDR_NONE) ) {
    fprintf(stderr,"Unable to resolve %s\n",argv[1]);
    ExitProcess(STATUS_FAILED);
    }

    if (hp != NULL)
    memcpy(&(dest.sin_addr),hp->h_addr,hp->h_length);
    else
    dest.sin_addr.s_addr = addr;

    if (hp)
    dest.sin_family = hp->h_addrtype;
    else
    dest.sin_family = AF_INET;

    dest_ip = inet_ntoa(dest.sin_addr);

    if (argc >2) {
    datasize = atoi(argv[2]);
    if (datasize == 0)
    datasize = DEF_PACKET_SIZE;

    }
    else
    datasize = DEF_PACKET_SIZE;

    datasize += sizeof(IcmpHeader);

    icmp_data = xmalloc(MAX_PACKET);
    recvbuf = xmalloc(MAX_PACKET);

    if (!icmp_data) {
    fprintf(stderr,"HeapAlloc failed %d\n",GetLastError());
    ExitProcess(STATUS_FAILED);
    }


    memset(icmp_data,0,MAX_PACKET);
    fill_icmp_data(icmp_data,datasize);

    while(1) {
    int bwrote;

    ((IcmpHeader*)icmp_data)->i_cksum = 0;
    ((IcmpHeader*)icmp_data)->timestamp = GetTickCount();

    ((IcmpHeader*)icmp_data)->i_seq = seq_no++;
    ((IcmpHeader*)icmp_data)->i_cksum = checksum((USHORT*)icmp_data,
    datasize);

    bwrote = sendto(sockRaw,icmp_data,datasize,0,(struct sockaddr*)&dest,
    sizeof(dest));
    if (bwrote == SOCKET_ERROR){
    if (WSAGetLastError() == WSAETIMEDOUT) {
    printf("timed out\n");
    continue;
    }
    fprintf(stderr,"sendto failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    if (bwrote < datasize ) {
    fprintf(stdout,"Wrote %d bytes\n",bwrote);
    }
    bread = recvfrom(sockRaw,recvbuf,MAX_PACKET,0,(struct sockaddr*)&from,
    &fromlen);
    if (bread == SOCKET_ERROR){
    if (WSAGetLastError() == WSAETIMEDOUT) {
    printf("timed out\n");
    continue;
    }
    fprintf(stderr,"recvfrom failed: %d\n",WSAGetLastError());
    ExitProcess(STATUS_FAILED);
    }
    decode_resp(recvbuf,bread,&from);
    Sleep(1000);

    }
    return 0;

    }
    /*
    The response is an IP packet. We must decode the IP header to locate
    the ICMP data
    */
    void decode_resp(char *buf, int bytes,struct sockaddr_in *from) {

    IpHeader *iphdr;
    IcmpHeader *icmphdr;
    unsigned short iphdrlen;

    iphdr = (IpHeader *)buf;

    iphdrlen = iphdr->h_len * 4 ; // number of 32-bit words *4 = bytes

    if (bytes < iphdrlen + ICMP_MIN) {
    printf("Too few bytes from %s\n",inet_ntoa(from->sin_addr));
    }

    icmphdr = (IcmpHeader*)(buf + iphdrlen);

    if (icmphdr->i_type != ICMP_ECHOREPLY) {
    fprintf(stderr,"non-echo type %d recvd\n",icmphdr->i_type);
    return;
    }
    if (icmphdr->i_id != (USHORT)GetCurrentProcessId()) {
    fprintf(stderr,"someone else's packet!\n");
    return ;
    }
    printf("%d bytes from %s:",bytes, inet_ntoa(from->sin_addr));
    printf(" icmp_seq = %d. ",icmphdr->i_seq);
    printf(" time: %d ms ",GetTickCount()-icmphdr->timestamp);
    printf("\n");

    }


    USHORT checksum(USHORT *buffer, int size) {

    unsigned long cksum=0;

    while(size >1) {
    cksum+=*buffer++;
    size -=sizeof(USHORT);
    }

    if(size ) {
    cksum += *(UCHAR*)buffer;
    }

    cksum = (cksum >> 16) + (cksum & 0xffff);
    cksum += (cksum >>16);
    return (USHORT)(~cksum);
    }
    /*
    Helper function to fill in various stuff in our ICMP request.
    */
    void fill_icmp_data(char * icmp_data, int datasize){

    IcmpHeader *icmp_hdr;
    char *datapart;

    icmp_hdr = (IcmpHeader*)icmp_data;

    icmp_hdr->i_type = ICMP_ECHO;
    icmp_hdr->i_code = 0;
    icmp_hdr->i_id = (USHORT)GetCurrentProcessId();
    icmp_hdr->i_cksum = 0;
    icmp_hdr->i_seq = 0;

    datapart = icmp_data + sizeof(IcmpHeader);
    //
    // Place some junk in the buffer.
    //
    memset(datapart,'E', datasize - sizeof(IcmpHeader));

    }
    分享到: QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
    分享分享0 收藏收藏0 支持支持0 反对反对0 分享到人人 转发到微博
    [img=http://mail.qq.com/cgi-bin/qm_share?t=qm_mailme&email=fRUcHhYWGAQ9GxIFEBwUEVMeEhA]http://rescdn.qqmail.com/zh_CN/htmledition/images/function/qm_open/ico_mailme_02.png[/img]

    使用道具 举报

    Rank: 2

    升级 
     
    38.67%

    该用户从未签到

    沙发
    发表于 2011-9-2 06:20:08 |只看该作者
    共同发展!学习才会进步,谢了













    使用道具 举报

    Rank: 2

    升级 
     
    22%

    该用户从未签到

    板凳
    发表于 2011-9-17 20:13:20 |只看该作者
    所谓忠诚、只是因为背叛的筹码不够。http://www.zhwang.org
                                                   
                           
                           
                           
                           
                           
                           
                           
                           












    正味网正在热播[文化]--唐之韵:唐诗

    使用道具 举报

    Rank: 3Rank: 3

    升级 
     
    46.33%

    该用户从未签到

    地板
    发表于 2011-10-5 19:14:54 |只看该作者

    使用道具 举报

    您需要登录后才可以回帖 登录 | 注册 人人连接登陆

    晴云孤魂's Blog|就爱编程搜帖|手机版|Archiver|就爱编程论坛     

    GMT+8, 2025-7-2 00:41 , Processed in 0.103517 second(s), 32 queries .

    Powered by Discuz! X2

    © 2001-2011 Comsenz Inc.

    回顶部