NetPing.cpp

/*
ISSA¿¡ ´ëÇÑ ¶óÀ̼¾½º ¸í½ÃÀÔ´Ï´Ù.
¾Æ·¡ ¶óÀ̼¾½º¿¡ µ¿ÀÇÇϽô ºÐ¸¸ ISSA ½Ã¸®Á »ç¿ëÇÒ¼ö ÀÖ½À´Ï´Ù.

  ÇÁ·Î±×·¥¸í : ISSA
  ÀúÀÚ±Ç : °æÈñ´ëÇб³ ½Ç½Ã°£¸ÖƼ¹Ìµð¾î ¿¬±¸½Ç ¹× °³¹ßÀÚ
  ¹èÆ÷ Homepage   : http://www.open-streaming.org
  °ü·Ã Homepage   : http://oslab.kyunghee.ac.kr
  ¹®ÀÇÀÚ E-Mail   : kimth@oslab.kyunghee.ac.kr
  
        1. ISSA ½Ã¸®ÁîÀÇ ¸ðµç ÀúÀÛ±ÇÀº "°æÈñ´ëÇб³ ½Ç½Ã°£¸ÖƼ¹Ìµð¾î¿¬±¸½Ç"¿¡ ÀÖ½À´Ï´Ù.
        2. ISSA ½Ã¸®ÁîÀÇ ¹èÆ÷±ÇÀº ÀÏÂ÷ÀûÀ¸·Î "°æÈñ´ëÇб³ ½Ç½Ã°£ ¸ÖƼ¹Ìµð¾î ¿¬±¸½Ç"¿¡¼­
        Çã¿ëÇÑ °÷¿¡¸¸ ÀÖ½À´Ï´Ù.
        (Çã¶ô ¸ÃÁö ¾ÊÀº Àç¹èÆ÷´Â Çã¿ëÇÏÁö ¾Ê½À´Ï´Ù. ¹«´Ü ¹èÆ÷ÇÏÁö ¸¶½Ê½Ã¿À.)
        3. ISSA ½Ã¸®Áî´Â ÀúÀÛ±Ç ¸í½Ã½Ã ´©±¸³ª »ç¿ëÇÒ¼ö ÀÖ½À´Ï´Ù.
        (°³ÀÎ,ºñ¿µ¸®´Üü,»ó¾÷»çÀÌÆ® ±â¾÷À̳ª ¿µ¸®,ºñ¿µ¸® ´ÜüÆ÷ÇÔ)
        4. ISSA ½Ã¸®Áî »ç¿ë½Ã ÀúÀÛ±Ç ¸í½ÃºÎºÐÀ» ÈѼÕÇÏ¸é ¾ÈµË´Ï´Ù.
        (ÀúÀÛ±Ç Ç¥½Ã´Â ¿øº» ±×´ë·Î¸¦ À¯Áö ÇÏ¿©¾ß ÇÕ´Ï´Ù.ÀÓÀÇ ¼öÁ¤ ¹× ¾ÆÀÌÄÜÈ­ ±ÝÁö)
        5. ´Ü, Á¤½Ä ¶óÀ̼¾½º ÃëµæÀ» Çϸé ÀúÀÛ±Ç Ç¥½Ã¸¦ »èÁ¦ÇÒ¼ö ÀÖ½À´Ï´Ù.
        (Á¤½Ä µî·Ï¿¡ ´ëÇÑ ¹®ÀÇ´Â À§ÀÇ ¹®ÀÇÀÚ ¸ÞÀÏ·Î ¹®ÀÇÇÏ¿© Áֽʽÿä.)
        6. ISSA ½Ã¸®Áî´Â »ç¿ëÀ¸·Î ÀÎÇÑ µ¥ÀÌŸ ¼Õ½Ç ¹× ±âŸ ¼ÕÇØ¿¡ ´ëÇؼ­ Ã¥ÀÓÀ» ÁöÁö ¾Ê½À´Ï´Ù.
        7. ISSA ½Ã¸®Áî¿¡ ´ëÇØ À¯Áö/º¸¼öÀÇ Àǹ«°¡ ¾ø½À´Ï´Ù.
        8. ISSA ½Ã¸®ÁîÀÇ »ó¾÷Àû ¸ñÀûÀ¸·Î ÆǸÅÇÒ¼ö ¾ø½À´Ï´Ù.
        9. ISSA ½Ã¸®Áî´Â ¼Ò½º´Â °³ÀÎÀûÀ¸·Î »ç¿ë½Ã ¼öÁ¤ÇÏ¿© »ç¿ëÇÒ¼ö ÀÖ½À´Ï´Ù.
        (´Ü ¼öÁ¤¹èÆ÷´Â ¾ÈµË´Ï´Ù.)
        10. ISSA ½Ã¸®Áî¿¡ »ç¿ëµÈ °ü·Ã ¼ÒÇÁÆ®¿þ¾î ÀúÀÛ±ÇÀº °¢ ¼ÒÇÁÆ®¿þ¾î Á¦ÀÛȸ»ç ¹× Á¦ÀÛÀÚ
    ¿¡°Ô ÀÖ½À´Ï´Ù.
        11. ISSA ½Ã¸®Áî ¶óÀ̼¾½º Ãëµæ¿¡ ´ëÇÑ ¹®ÀÇ´Â ¹®ÀÇÀÚ ¸ÞÀÏ·Î
    ¹®ÀÇÇÏ¿© Áֽʽÿä.
        12. ±âŸ Àǹ®»çÇ×Àº http://www.open-streaming.org ¿¡¼­ °Ô½ÃÆÇÀ» ÀÌ¿ëÇÏ¿© ÁֽʽÿÀ.
    (ÀÏ¹Ý Áú¹®Àº ¸ÞÀÏ·Î ¹ÞÁö ¾Ê½À´Ï´Ù.)
        13. À§ »çÇ׿¡ µ¿ÀÇÇϽô ºÐ¸¸ ISSA ½Ã¸®Á »ç¿ëÇÒ¼ö ÀÖ½À´Ï´Ù.
*/

// NetPing.cpp: implementation of the NetPing class.
//

#include "NetPing.h"

#if defined(WIN32)
        #include <stdlib.h>             // MS-Windows 32

        LPHOSTENT       NetPing::m_lpstHost     = NULL;
        char*           NetPing::m_pDestAddr = NULL;
        IN_ADDR         NetPing::m_stDestAddr;

        char    *m_paszSendEchoErr[] = {
                "IP_STATUS_BASE (11000)",
                        "IP_BUF_TOO_SMALL (11001)",
                        "IP_DEST_NET_UNREACHABLE (11002)",
                        "IP_DEST_HOST_UNREACHABLE (11003)",
                        "IP_DEST_PROT_UNREACHABLE (11004)",
                        "IP_DEST_PORT_UNREACHABLE (11005)",
                        "IP_NO_RESOURCES (11006)",
                        "IP_BAD_OPTION (11007)",
                        "IP_HW_ERROR (11008)",
                        "IP_PACKET_TOO_BIG (11009)",
                        "IP_REQ_TIMED_OUT (11010)",
                        "IP_BAD_REQ (11011)",
                        "IP_BAD_ROUTE (11012)",
                        "IP_TTL_EXPIRED_TRANSIT (11013)",
                        "IP_TTL_EXPIRED_REASSEM (11014)",
                        "IP_PARAM_PROBLEM (11015)",
                        "IP_SOURCE_QUENCH (11016)",
                        "IP_OPTION_TOO_BIG (11017)",
                        "IP_BAD_DESTINATION (11018)",
                        "IP_ADDR_DELETED (11019)",
                        "IP_SPEC_MTU_CHANGE (11020)",
                        "IP_MTU_CHANGE (11021)",
                        "IP_UNLOAD (11022)"
        };

#elif defined(SOLARIS2)         // SOLARIS2

#endif // defined( WIN32 & SOLARIS2 )

// Construction/Destruction
NetPing::NetPing()
{
        m_pachBCastAddr = "255.255.255.255";
    m_nDataLen = DEFAULT_LEN;
    m_nLoopLimit = LOOPLIMIT;
    m_nTimeOut = TIMEOUT;
    m_plpstIPInfo = NULL;
    m_nTTL = DEFAULT_TTL;
    m_nTOS = 0;
        m_AvrPingTime = 0;
}

NetPing::~NetPing()
{
        m_fRet = lpfnIcmpCloseHandle( m_hICMP );
        if ( m_fRet == FALSE ) {
                int nErr = GetLastError();                  
                PIcmpErr( nErr );
    }

    FreeLibrary((struct HINSTANCE__*)m_hICMP_DLL);

    WSACleanup();
}

bool NetPing::Init()
{
        WSADATA wsaData;
        WORD wVersionRequested = MAKEWORD ( 1, 1 );

        if ( WSAStartup( wVersionRequested, &wsaData ) == SOCKET_ERROR ) 
        {
                WSACleanup();
                return false;
        }
        LoadICMP();

        return true;
}

void NetPing::DisplayErr( int nWSAErr ) 
{
        LPVOID lpMsgBuf;
                
    FormatMessage( FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM,
                                   NULL,
                                   nWSAErr,
                                   MAKELANGID(LANG_NEUTRAL, 
                                   SUBLANG_DEFAULT), // Default language
                                   (LPTSTR) &lpMsgBuf,
                                   0,    
                                   NULL );
        
        ISSALOGF("NetPing::DisplayErr", "%s", (const char*)lpMsgBuf );

    /* Free the buffer */
        LocalFree (lpMsgBuf);
            
        return;
}

void NetPing::PIcmpErr(int nICMPErr ) 
{
        int nErrIndex = nICMPErr - IP_STATUS_BASE;
    
    if ( (nICMPErr > MAX_ICMP_ERR_STRING) || (nICMPErr < IP_STATUS_BASE+1) ) {
                /* Error value is out of range, display normally */
                ISSALOGF("NetPing::PIcmpErr","%d", nICMPErr );

                DisplayErr(nICMPErr);

    } else {
                /* Display ICMP Error String */
                ISSALOGF("NetPing::PIcmpErr","%s", m_paszSendEchoErr[nErrIndex] );     
    }
    
    return;
}

bool NetPing::LoadICMP()
{       
    m_hICMP_DLL = ::LoadLibrary("ICMP.DLL");
    if ( m_hICMP_DLL == 0 ) {
                issaLog::Log("NetPing::LoadICMP", "LoadLibrary() failed: Unable to locate ICMP.DLL!");        
        return false;
    }

    /* 
     * Get pointers to ICMP.DLL functions
     */
        lpfnIcmpCreateFile = ( HANDLE (WINAPI *)(void))::GetProcAddress((HMODULE)m_hICMP_DLL, "IcmpCreateFile" );

        lpfnIcmpCloseHandle = ( BOOL (WINAPI *)(HANDLE))::GetProcAddress((HMODULE)m_hICMP_DLL, "IcmpCloseHandle" );

        lpfnIcmpSendEcho = ( DWORD (WINAPI *)(HANDLE,DWORD,LPVOID,WORD,PIPINFO,LPVOID,DWORD,DWORD))::GetProcAddress((HMODULE)m_hICMP_DLL, "IcmpSendEcho" );

    if ( (!lpfnIcmpCreateFile) || (!lpfnIcmpCloseHandle) || (!lpfnIcmpSendEcho) ) {
                issaLog::Log("NetPing::LoadICMP", "GetProcAddr() failed for at least one function.");
                return false;
        }

    /*
     * IcmpCreateFile() - Open the ping service
     */
    m_hICMP = (HANDLE) lpfnIcmpCreateFile();
    if ( m_hICMP == INVALID_HANDLE_VALUE ) 
        {
                issaLog::Log("NetPing::LoadICMP", "IcmpCreateFile() failed, err:");       
                PIcmpErr( GetLastError() );
                return false;
    } 

    /*
     * Init data buffer printable ASCII 
     *  32 (space) through 126 (tilde)
     */
        int j, i;
    for (j=0, i=32; j < m_nDataLen; j++, i++) {
        if ( i >= 126 ) 
                        i= 32;
       m_achReqData[j] = i;
    }

        /*
     * Init IPInfo structure
     */
        m_plpstIPInfo = &m_stIPInfo;
        m_stIPInfo.Ttl      = m_nTTL;
        m_stIPInfo.Tos      = m_nTOS;
        m_stIPInfo.Flags    =  m_fDontFrag ? IPFLAG_DONT_FRAGMENT : 0;
        m_stIPInfo.OptionsSize = 0;
        m_stIPInfo.OptionsData = NULL;

            
    if ( m_lpstHost ) {
//              issaLog::LogFormat("NetPing::PIcmpErr", "Pinging %s [%s] with %d bytes of data: ", 
//                                                      m_lpstHost->h_name, inet_ntoa( m_stDestAddr ), m_nDataLen );      
    } else {
//              issaLog::LogFormat("NetPing::PIcmpErr", "Pinging %s with %d bytes of data: ", 
//                                                      inet_ntoa( m_stDestAddr ), m_nDataLen );        
    }

        return true;
}

void NetPing::Ping( const issaString &DestAddr, const int LoopLimit, const int& nDataLen )
{
        Init();

        m_LoopLimit = LoopLimit;

        m_pDestAddr = ( char* )DestAddr;
        m_lpstHost = gethostbyname( m_pDestAddr );
        m_nDataLen = nDataLen;

        u_long ulDestAddr = inet_addr( m_pDestAddr );
        memcpy( &m_stDestAddr, &ulDestAddr, 4 );

    /*
     * Ping Loop
     */
        int k = 0;
        double
                TotalPingTime = 0,
                TotalPacketSize = 0;
        issaString temp;

        for (k = 0; k < m_LoopLimit; k++) {         
                if ( k ) {
                        SleepEx(1000, TRUE);
                }

      /*
       * IcmpSendEcho() - Send the ICMP Echo Request
       *                   and read the Reply
       */
                m_dwReplyCount = lpfnIcmpSendEcho( m_hICMP, 
                                                                                   m_stDestAddr.s_addr,
                                                                                   m_achReqData,
                                                                                   m_nDataLen,
                                                                                   m_plpstIPInfo, 
                                                                                   m_achRepData, 
                                                                                   sizeof( m_achRepData ), 
                                                                                   m_nTimeOut );

                if ( m_dwReplyCount != 0 ) {
                        IN_ADDR stDestAddr;
                        DWORD   dwStatus;
                        stDestAddr.s_addr = *(u_long *)m_achRepData;

                        TotalPacketSize += *(u_long *) &(m_achRepData[12]);

/*                      issaLog::LogFormat( "NetPing::Ping", "Reply from %s: bytes=%d time=%ldms TTL=%u ",
                                                                inet_ntoa(stDestAddr), *(u_long *) &(m_achRepData[12]),
                                                                *(u_long *) &(m_achRepData[8]),
                                                                (*(char *)&(m_achRepData[20]))&0x00FF );
*/              
                        dwStatus = *(DWORD *) &( m_achRepData[4] );
                        
                        if (dwStatus == IP_SUCCESS) {
                                PIcmpErr(dwStatus);
                        } 
                        else {
                                ISSALOG( "NetPing::Ping", "IcmpSendEcho() failed, err: " );
                                PIcmpErr(GetLastError());
                                break;  // end loop
                        }
                }
                temp.Format( "%ld", *(u_long *) &(m_achRepData[8]) );
                TotalPingTime += temp.GetLongInteger();
        } /* end ping loop */

        m_AvrPacketSize = ( TotalPacketSize / (double)m_LoopLimit );
        m_AvrPingTime = ( TotalPingTime / (double)m_LoopLimit );
}

void NetPing::GetAvrPingTime( issaString &AvrPingTime )
{
        issaString RetVlu;
        RetVlu.Format( "%d", (int)m_AvrPingTime );
        AvrPingTime = RetVlu;
//      issaLog::LogFormat( "NetPing::Ping","AvrPingTime(str) : %s", AvrPingTime );
}

void NetPing::GetAvrPingTime( double &AvrPingTime )
{       
        AvrPingTime = m_AvrPingTime;
//      issaLog::LogFormat( "NetPing::Ping","AvrPingTime(double) : %lu", AvrPingTime );
}

void NetPing::GetAvrPacketSize( double &AvrPacketSize )
{
        AvrPacketSize = m_AvrPacketSize;
}

---