В общем проблема следующего характера:
есть демон, который сразу же после своего создания создает поток, который сразу же отсоединяется - этот поток будет следить за обращением других процессов по пайпу, т.е. будет ждать запрос. Демон работает с сокетами и, когда подключается новый клиент, создается для него отдельный поток, который так же отсоединяется, информация о tid и дескрипторе соединения сохраняется в векторе. Если демон запустить с параметром "-c", то по именованному пайпу передается запрос на вывод всей информации из вектора запущенного демона. Запущенный демон получает эту информацию и по другому именованному пайпу отправляет ответ-строку, содержащую требуемую информацию. Это в идеале... Вся проблема в том, что если демон стартует и тут же запустить процесс с аргументом командной строки "-c", то выводится информация о пустом векторе - что есть логично - но, если сначала законнектить клиента, стартует новый поток, который сразу же ловит segmentation violation, умирает, но дескриптор соединения специально не закрывается и информация об умершем потоке специально не удаляется из вектора, основной поток и поток слежения за пайпом остаются в живых, запускается процесс с параметром "-c" и все...  новый процесс и поток слежения в deadlock
Описание работы потока слежения:
| Код |
int clPipe::openServer()
{
// <create named pipes>
if(mkfifo(PIPE_REQUEST_FILE, S_IRUSR | S_IWUSR) == -1)
if(errno != EEXIST) // if not exists
{ my_log("can not create named pipe %s - %m", PIPE_REQUEST_FILE); return -1; }
if(mkfifo(PIPE_RESPONSE_FILE, S_IRUSR | S_IWUSR) == -1)
if(errno != EEXIST) // if not exists
{ my_log("can not create named pipe %s - %m", PIPE_RESPONSE_FILE); return -1; }
// </create named pipes>
if(this->waitRequest() == -1)
this->die();
return 0;
}
int clPipe::waitRequest()
{
int n;
string buffer;
char recv_line[MAXLINE];
while(true)
{
// <open named pipe>
my_log("here"); // ЭТО ЕЩЕ ПЕЧАТАЕТСЯ
if( (this->pipe_request_fd = open(PIPE_REQUEST_FILE, O_RDONLY)) == -1)
{ my_log("can not open named pipe for reading - %s - %m", PIPE_REQUEST_FILE); return -1; }
// </open named pipe>
my_log("here"); // А ЭТО УЖЕ НЕТ :(
while( (n = _read(this->pipe_request_fd, recv_line, MAXLINE)) > 0)
{
recv_line[n] = 0;
try
{ buffer += recv_line; }
catch(exception)
{ my_log("can not save data into buffer"); return -1; }
if(strchr(recv_line, CTERM) != NULL) // wait for term char
break;
}
if(n < 0)
{ my_log("can not read from pipe - %m"); return -1; }
if(buffer[buffer.length() -1] == CTERM)
buffer[buffer.length() -1] = 0;
this->workupPipeAction(buffer.c_str());
buffer.clear();
close(this->pipe_request_fd);
close(this->pipe_response_fd);
}
}
void clPipe::die()
{
close(this->pipe_response_fd);
close(this->pipe_request_fd);
unlink(PIPE_RESPONSE_FILE);
unlink(PIPE_REQUEST_FILE);
pthread_exit(NULL);
}
|
CTERM - терминатор, введенный искусственно для разделения данных.
Описание работы клиента
| Код |
int clPipe::openClient(const char *buffer, size_t buffer_size)
{
ssize_t n;
// <open named pipes>
if( (this->pipe_request_fd = open(PIPE_REQUEST_FILE, O_WRONLY)) == -1) // pipe открывается в любом случае
{
my_log("can not open named pipe for writting - %s - %m", PIPE_REQUEST_FILE);
return -1;
}
// </open named pipes>
_write(this->pipe_request_fd, buffer, buffer_size);
_write(this->pipe_request_fd, &CTERM, 1);
n = this->getResponse();
close(this->pipe_request_fd);
close(this->pipe_response_fd);
return n;
}
int clPipe::getResponse()
{
int n;
char recv_line[MAXLINE];
printf("here\n"); // ЭТО ПЕЧАТАЕТСЯ
// <open named pipe>
if( (this->pipe_response_fd = open(PIPE_RESPONSE_FILE, O_RDONLY)) == -1)
{
protei_log(EL_SYSTEM, PR_INFO, "can not open named pipe for reading - %s - %m", PIPE_RESPONSE_FILE);
close(this->pipe_request_fd);
return -1;
}
// </open named pipe>
this->response.clear();
printf("here\n"); // А ЭТО УЖЕ НЕТ :(
while( (n = _read(this->pipe_response_fd, recv_line, MAXLINE)) > 0)
{
recv_line[n] = 0;
try
{ this->response += recv_line; }
catch(exception)
{ sprintf(this->errstr, "can not save data into buffer"); return -1; }
if(strchr(recv_line, CTERM) != NULL) // wait for term char
break;
}
if(n < 0)
{ sprintf(this->errstr, "can not read from pipe - %m"); return -1; }
if(this->response[this->response.length() -1] == CTERM)
this->response[this->response.length() -1] = 0;
return 0;
}
|
все помечено комментариями. Еще раз повторюсь. Если демон стартовать и сразу же запустить еще один процесс с параметром "-c" - все прекрасно работает, т.е. выводится информация о пустом векторе, если же демон запустить и подконнектить к нему клиента, поток которого сразу же умрет по SIGSEGV, то демон залочится в open() на чтении С какого такого перепугу, непонятно, ибо в манах четко написано, что если это пайп, то поток, открывающий его на чтение, будет залочен до тех пор, пока кто-нибудь его не откроет на запись и наоборот. Как видно по каментам, новый процесс (с параметром "-c") открывает пайп на запись, но поток слежения все равно остается залоченным  |
