Skip to contentSkip to conversation

Why doesn't UNIX/DGRAM socket allow sending more than 11 bytes w/o receiving?

DISCUSSION David Wuertele 2 participants 2 messages Mar 8, 2003 – May 23, 2003

lore
Share & tools
lore
#0 lore raw

Question: Why does this program crap out after 11 bytes? The UNIX/DGRAM receive buffer should be 64Kbytes. I expect this program to be able to use it all before blocking. But it blocks after only 11.

// dgramtest.c
// creates two unix/dgram sockets, connects them, sends a byte at a // time without recv()ing anything. demonstrates strange behavior on // Linux 2.4.18 (RedHat 8.0)

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

/////////////////////////////////////////////////////////////////////////////// // module socktest #defines

#define INPUT_SOCKET_NAME   "/tmp/sockinput"
#define OUTPUT_SOCKET_NAME  "/tmp/sockoutput"
#define BUFF_SIZE           (1)

/////////////////////////////////////////////////////////////////////////////// // module socktest function Bail
static int Bail(const char * pString)

{
    perror(pString);
    return 1;
}

/////////////////////////////////////////////////////////////////////////////// // module socktest function main
int main(int argc, const char ** argv)

{
    sockaddr_un addressInput;
    addressInput.sun_family = AF_UNIX;
    strcpy(addressInput.sun_path, INPUT_SOCKET_NAME);

    sockaddr_un addressOutput;
    addressOutput.sun_family = AF_UNIX;
    strcpy(addressOutput.sun_path, OUTPUT_SOCKET_NAME);

    int sockInput = socket(PF_UNIX, SOCK_DGRAM, 0);
    if (-1 == sockInput) return Bail("Failed to create input socket");
    
    int sockOutput = socket(PF_UNIX, SOCK_DGRAM, 0);
    if (-1 == sockOutput) return Bail("Failed to create output socket");
    
    // name (bind) the 2 sockets
    unlink(INPUT_SOCKET_NAME);
    unlink(OUTPUT_SOCKET_NAME);
    if (-1 == bind(sockInput, (const sockaddr *)&addressInput, sizeof(sockaddr_un))) return Bail("Failed to bind input socket");
    if (-1 == bind(sockOutput, (const sockaddr *)&addressOutput, sizeof(sockaddr_un))) return Bail("Failed to bind output socket");
 
    // connect the output socket to the input address
    if (-1 == connect(sockOutput, (const sockaddr *)&addressInput, sizeof(sockaddr_un))) return Bail("Failed to connect output to input socket");

    // now see how many sends we can do before send blocks
    char buff[BUFF_SIZE];
    int nNumBytes = 0;
    int nNumSends = 0;
    while (1)
    {
        if (sizeof(buff) != send(sockOutput, buff, sizeof(buff), 0)) break;
        //DON'T RECEIVE!  This is the test.  We should crap out after
        //getting 64K bytes.
        //if (sizeof(buff) != recv(sockInput, buff, sizeof(buff), 0)) break;
        nNumSends++; nNumBytes+= sizeof(buff);
        printf("Send %d, %d total bytes\n", nNumSends, nNumBytes);  fflush(stdout);
    }

    printf("Exiting after %d sends with %d total bytes\n", nNumSends, nNumBytes);
    perror("Error");
    return 0;
}
#1 lore raw

Well, this is my first experience with UNIX sockets (though I've plenty of experience with IP sockets). I've always wondered what I what the use of UNIX sockets was - so I took a look.

Simply, it looks like after sending 11 datagrams, the OS is blocking the send() call until a receiver empties out some of the buffer space before proceeding. Changing the size of buff[] to 2048, still allows for 11 buffers to be sent prior to blocking.

Changing the buffer size to 1024*32 however, allows only 2 buffers to be sent before blocking.

This appears to conform to proper UNIX socket behavior, from everthing I can find. Does this seem like improper behavior?

Nat

Quoted 86 lines · David Wuertele

Question: Why does this program crap out after 11 bytes? The UNIX/DGRAM receive buffer should be 64Kbytes. I expect this program to be able to use it all before blocking. But it blocks after only 11.

// dgramtest.c
// creates two unix/dgram sockets, connects them, sends a byte at a // time without recv()ing anything. demonstrates strange behavior on // Linux 2.4.18 (RedHat 8.0)

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/socket.h>
#include <sys/un.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>

/////////////////////////////////////////////////////////////////////////////// // module socktest #defines

#define INPUT_SOCKET_NAME   "/tmp/sockinput"
#define OUTPUT_SOCKET_NAME  "/tmp/sockoutput"
#define BUFF_SIZE           (1)

/////////////////////////////////////////////////////////////////////////////// // module socktest function Bail
static int Bail(const char * pString)

{
   perror(pString);
   return 1;
}

/////////////////////////////////////////////////////////////////////////////// // module socktest function main
int main(int argc, const char ** argv)

{
   sockaddr_un addressInput;
   addressInput.sun_family = AF_UNIX;
   strcpy(addressInput.sun_path, INPUT_SOCKET_NAME);

   sockaddr_un addressOutput;
   addressOutput.sun_family = AF_UNIX;
   strcpy(addressOutput.sun_path, OUTPUT_SOCKET_NAME);

   int sockInput = socket(PF_UNIX, SOCK_DGRAM, 0);
   if (-1 == sockInput) return Bail("Failed to create input socket");
   
   int sockOutput = socket(PF_UNIX, SOCK_DGRAM, 0);
   if (-1 == sockOutput) return Bail("Failed to create output socket");
   
   // name (bind) the 2 sockets
   unlink(INPUT_SOCKET_NAME);
   unlink(OUTPUT_SOCKET_NAME);
   if (-1 == bind(sockInput, (const sockaddr *)&addressInput, sizeof(sockaddr_un))) return Bail("Failed to bind input socket");
   if (-1 == bind(sockOutput, (const sockaddr *)&addressOutput, sizeof(sockaddr_un))) return Bail("Failed to bind output socket");

   // connect the output socket to the input address
   if (-1 == connect(sockOutput, (const sockaddr *)&addressInput, sizeof(sockaddr_un))) return Bail("Failed to connect output to input socket");

   // now see how many sends we can do before send blocks
   char buff[BUFF_SIZE];
   int nNumBytes = 0;
   int nNumSends = 0;
   while (1)
   {
       if (sizeof(buff) != send(sockOutput, buff, sizeof(buff), 0)) break;
       //DON'T RECEIVE!  This is the test.  We should crap out after
       //getting 64K bytes.
       //if (sizeof(buff) != recv(sockInput, buff, sizeof(buff), 0)) break;
       nNumSends++; nNumBytes+= sizeof(buff);
       printf("Send %d, %d total bytes\n", nNumSends, nNumBytes);  fflush(stdout);
   }

   printf("Exiting after %d sends with %d total bytes\n", nNumSends, nNumBytes);
   perror("Error");
   return 0;
}

-
To unsubscribe from this list: send the line "unsubscribe linux-c-programming" in the body of a message to [email protected]
More majordomo info at http://vger.kernel.org/majordomo-info.html

Signature · 4 lines
_________________________________________
Nat Ersoz             [email protected]  -o) Myrio Corporation     Phone: 425.897.7278  /\\
3500 Carillon Point   Cell:  425.417.5182 _\_V
Kirkland, WA 98033    Fax:   425.897.5600