This is the mail archive of the
ecos-discuss@sources.redhat.com
mailing list for the eCos project.
DEBUG: Circular MBUF
- From: "Kevin S. Martin" <ksmartin at fnal dot gov>
- To: ecos-discuss at sources dot redhat dot com
- Date: Fri, 25 Jun 2004 11:38:51 -0500
- Subject: [ECOS] 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