This is the mail archive of the ecos-discuss@sources.redhat.com mailing list for the eCos project.


Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]
Other format: [Raw text]

DEBUG: Circular MBUF


I have a application that opens a TCP/IP socket connection and then at 1Hz writes a bunch of data out on that connection. If "bunch" is < 1000 bytes (approx) then everything works fine however when "bunch" > 1000 (i.e. 2000 or 8000+ bytes) then very quickly I get a series of messages on the console like:

DEBUG: Circular MBUF 0x004c7e80!
DEBUG: Circular MBUF 0x004c8500!
DEBUG: Circular MBUF 0x004c7e00!
DEBUG: Circular MBUF 0x004c7c80!

After I get these messages I assume that the network thread is in an infinite loop because all threads with lower priority never run again and all networking to/from the target stops.

I'm using a i386 PCMB target with a fairly recent version of eCos (April 2004) from the CVS repository. Also, I'm using the FreeBSD networking stack. I've tried increasing the amount of memory designated for networking buffers but this didn't help.

The code I'm using to open the connection and write is (abbreviated):


// open TCP socket if ( (fdListen = socket(AF_INET, SOCK_STREAM, 0)) < 0 ) { perror("can't open stream socket"); exit(1); }

// if the packet is "small" don't wait to send it (i.e. send it now)
if( setsockopt( fdListen, IPPROTO_TCP, TCP_NODELAY, (char *)&yes, sizeof(yes) ) == -1 )
{
perror("setsockopt:TCP_NODELAY");
exit(1);
}


// lose the pesky "address already in use" error message
if (setsockopt(fdListen, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(yes)) == -1)
{
perror("setsockopt:SO_REUSEADDR");
exit(1);
}


// bind our local address so client can connect to us
bzero( &serv_addr, sizeof(serv_addr) );
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(TCP_PORT1_TO_USE);
if ( (reterr = bind(fdListen, (struct sockaddr *)&serv_addr, sizeof(serv_addr))) < 0 )
{
perror("can't bind local address");
exit(1);
}


    // listen
   if (listen(fdListen, 1) == -1)
   {
     perror("listen");
     exit(1);
   }
   addrlen = sizeof(cli_addr);

// main loop
for(;;)
{
// handle new connections
if ((newfd = accept(fdListen, (struct sockaddr *)&cli_addr, &addrlen)) == -1)
{
perror("accept");
}
else
{
debug_printf("\nnew connection from %s on socket %d", inet_ntoa(cli_addr.sin_addr), newfd);
debug_printf("\nFeed is ON");
while ()
{
.
.
.
if ((nwritten = write(newfd,buffer,size)) < 0)
{
perror("\nwrite()");
break;
}
.
.
.
cyg_thread_delay(100); // delay for one second
}
debug_printf("\nFeed is OFF.");
close(newfd); // bye!
}
}


Any ideas?

Thanks,
Kevin

--
Kevin S. Martin
Fermi National Accelerator Laboratory
Accelerator Division, EE Support Department
630.840.2983
ksmartin@fnal.gov


-- Before posting, please read the FAQ: http://ecos.sourceware.org/fom/ecos and search the list archive: http://ecos.sourceware.org/ml/ecos-discuss


Index Nav: [Date Index] [Subject Index] [Author Index] [Thread Index]
Message Nav: [Date Prev] [Date Next] [Thread Prev] [Thread Next]