Named Pipe problem again

[rahul_c]

Hi guys,
I posted a few years ago about a named pipe issue, and I am having the same problem again.

So here is a quick description of what I am trying to do:

I have a socket, where my process is waiting for either more incoming data coming to it, or waiting on outgoing data being ready via a named pipe. For this I am using a select on a named pipe, and on the socket, and both have been opened in non-blocking mode.

Now, when i do the select, the named pipe fd always says unblocked, but the socket is fine, in that the select does not return. If I don't open the named pipe in non-blocking mode, then the open command for the named pipe will block itself, and I won't be able to wait for incoming socket data.

What should I do?? Should opening/closing the named pipe for each select solve this?

A second question about the write to the named pipe. i am also opening it in non-blocking mode, and then waiting on the select to pick up that there is data to be read. Would this work?

This is quite urgent, so any help would be greatly appreciated.

[Salem]

One of the things you could do is post some code so we can see what you're trying to do.

[rahul_c]

Ok, here it is:

void DUAL_Select(AUTH_IFE_STR *pAuth_Ife_Str)
{
   fd_set readset;
   int  select_result,result;
   int named_pipe;
   int maxSOCK;
   char *envPATH;
   char nnamedPIPE[256];
   char buffer[8];


     named_pipe = open(nnamedPIPE, O_RDONLY | O_NONBLOCK);
        pAuth_Ife_Str->sread_named_pipe=named_pipe;

      FD_ZERO(&readset);
      FD_CLR(pAuth_Ife_Str->sread_named_pipe,&readset);
      FD_CLR(pAuth_Ife_Str->sSocketfd,&readset);
      FD_SET(pAuth_Ife_Str->sread_named_pipe,&readset);
      FD_SET(pAuth_Ife_Str->sSocketfd,&readset);
      if ((pAuth_Ife_Str->sSocketfd - pAuth_Ife_Str->sread_named_pipe) > 0)
      {
         maxSOCK = pAuth_Ife_Str->sSocketfd;
      }                                                                                                                          
      else
      {                                                                    
         maxSOCK = pAuth_Ife_Str->sread_named_pipe;
      }
      select_result = select(maxSOCK + 1, &readset, NULL, NULL, NULL);
   if (FD_ISSET(pAuth_Ife_Str->sread_named_pipe, &readset))
   {   
        FD_CLR(pAuth_Ife_Str->sread_named_pipe, &readset);
        bzero(buffer,8);
        result = read(pAuth_Ife_Str->sread_named_pipe,buffer,8);

   if (FD_ISSET(pAuth_Ife_Str->sSocketfd, &readset))
   {   
       FD_CLR(pAuth_Ife_Str->sSocketfd, &readset);
       //printf("Socket is ready for read\n");
       pAuth_Ife_Str->sSockReadAve = '1';
   };

   result = close (pAuth_Ife_Str->sread_named_pipe);

When closing the socket each time, it does seem to be fine, but that is what I am having to do. Is that correct?

What should I do when opening the npipe for write, open it in blocking or non-blocking mode?

[oogabooga]

Just to make sure, you're real code isn't missing the brace on line 34, right?
(And you have an extraneous semicolon on line 40.)

[rahul_c]

Sorry, yes you are right, the ';' issues are to do with taking code fragments and pasting it here. Apologies...