testBlast.cxx File Reference

#include <cassert>
#include <iostream>
#include "rutil/DnsUtil.hxx"
#include "rutil/Socket.hxx"
#include "resip/stack/UdpTransport.hxx"
#include "rutil/Timer.hxx"

Include dependency graph for testBlast.cxx:

Go to the source code of this file.

Functions
int	main (int argc, char *argv[])
Variables
	return

---

Function Documentation

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 17 of file testBlast.cxx.

References errno, resip::Timer::getTimeMicroSec(), INVALID_SOCKET, len, resip::makeSocketNonBlocking(), resip::FdSet::readyToRead(), sendto(), SOCKET_ERROR, strerror(), and WSANOTINITIALISED.

{
   if ( argc != 4 ) 
   {
      cerr << "Usage: testSelect startPort endPort rate\n";
      exit(1);
   }
   
   int startPort = atoi( argv[1] );
   int endPort = atoi( argv[2] );
   
   cout << "Doing port " << startPort << " to " << endPort << endl;
   
   int fd[0xFFFF];
   
   // open the fd 
   for( int port=startPort; port<endPort; port++)
   {
      fd[port] =  socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
      if( fd[port] ==  INVALID_SOCKET )
      {
         cerr << "Fail on creating socket for port " << port << endl;
         assert(0);
      }
      
      sockaddr_in addr4; 
      sockaddr* saddr=0;
      int saddrLen = 0;
      
      memset(&addr4, 0, sizeof(addr4));
      addr4.sin_family = AF_INET;
      addr4.sin_port = htons(port);
      addr4.sin_addr.s_addr = htonl(INADDR_ANY); 

      saddr = reinterpret_cast<sockaddr*>(&addr4);
      saddrLen = sizeof(addr4);

      if ( bind( fd[port], saddr, saddrLen) == SOCKET_ERROR )
      {
         assert(0);
      }
      
      bool ok = makeSocketNonBlocking( fd[port] );
      assert(ok);
   }
   

   while (1)
   {
      FdSet fdset;
       
      UInt64 t = Timer::getTimeMicroSec();

      for( int port=startPort; port<endPort; port++)
      {
         if (fdset.readyToRead(fd[port]))
         {
            struct sockaddr from;
            
            int MaxBufferSize=1024*4;
            
            char buffer[MaxBufferSize];
            socklen_t fromLen = sizeof(from);
            
            sockaddr_in addrin;
            addrin.sin_addr = sendData->destination.ipv4;
            addrin.sin_port = htons(port);
            addrin.sin_family = AF_INET;
            
            int len = sendto( fd[port],
                                buffer,
                                MaxBufferSize,
                                0, // flags
                                (const sockaddr*)&addrin, sizeof(sockaddr_in) );

            if ( len == SOCKET_ERROR )
            {
               assert(0);
            }
            if ( len != MaxBufferSize )
               int err = errno;
               switch (err)
               {
                  case WSANOTINITIALISED:
                     assert(0);
                     break;
                     
                  case EWOULDBLOCK:
                     //cerr << " UdpTransport recvfrom got EWOULDBLOCK";
                     break;
                     
                  case 0:
                     cerr << " UdpTransport recvfrom got error 0 ";
                     break;
                     
                  default:
                     cerr <<"Error receiving, errno="<<err << " " << strerror(err);
                     break;
               }
            }
         }
         
      }
   }

Here is the call graph for this function:

---

Variable Documentation

return

Definition at line 122 of file testBlast.cxx.