Здравствуйте, уважаемые!
Достаточно давно и не спеша пишу приложение на "pure" C под Linux.
Предварительная история болезни:
Общий алгоритм работы такой:
В бесконечном цикле:
1. через popen я вызываю внешний fping я пингую устройство, делаю pclose.
2. создаю сетевое соединение к устройству (через socket и connect), опрашиваю его, получаю данные, закрываю сетевое соединение (через close)
3. после чего через pipe и fork - передаю данные во внешнее приложение и получаю обратно от него результат так же через pipe. Все pipe старательно закрываю при завершении использования в каждом из потоков порожденном fork.
И так далее по кругу в бесконечном цикле.
В определенный момент через длительный период после запуска, при попытке создать pipe приложение падает с ошибкой "Too many open files". (получил из errno при создании pipe).
Воспользовавшись вот http://oroboro.com/file-handle-leaks-server/ я получаю дамп открытых файловых дескрипторов на момент падения следующего вида:
| Код |
0 (/dev/pts/0): read-write
1 (pipe:[740693603]): write-only
2 (pipe:[740693603]): write-only
3 (socket:[741154750]): cloexec read-write
4 (socket:[740694443]): read-write
5 (socket:[740693894]): read-write
6 (socket:[740694792]): read-write
7 (socket:[740692936]): read-write
...много-много строк и везде socket...
1014 (socket:[741343642]): read-write
1015 (socket:[741343645]): read-write
1016 (socket:[741343647]): read-write
1017 (socket:[741343652]): read-write
1018 (socket:[741347779]): read-write
1019 (socket:[741345080]): read-write
1020 (socket:[741343930]): read-write
1021 (pipe:[741348340]):
1022 (pipe:[741348340]): write-only
|
Из чего следует, что, судя по всему, у меня длительное время не закрывались сокеты сетевого соединения.
Но, сокеты я регулярно закрываю после использования и в случае ошибок с помощью close().
| Код |
int closeSocket(int nSocket) {
int ret = close(nSocket);
/*TODO удалить*/
fprintf(stderr, "STDERR: Socket (%i) close status: %i\n", nSocket, ret);
printf("STDOUT: Socket (%i) close status: %i\n", nSocket, ret);
return ret;//close(nSocket);
}
|
Подскажите, в какую сторону можно копать? С чем может быть связана эта ситуация?
Дополнительная информация, которая может помочь.
1. Создаю я сокеты вот так:
| Код |
int createSocket(const char* sHostname, const char* sPortnumber) {
int result = EXIT_FAILURE;
if (ping(sHostname) != 0) return EC_HOST_DOES_NOT_PINGED;
struct hostent* server;
struct sockaddr_in socketAddress;
int socketConnection = socket(AF_INET, SOCK_STREAM, 0);
if (socketConnection < 0) return EC_SOCKET_OPENING;
server = gethostbyname(sHostname);
if (server == NULL) return EC_NO_SUCH_HOST;
bzero((char*) &socketAddress, sizeof(socketAddress));
socketAddress.sin_family = AF_INET;
bcopy((char*) server->h_addr, (char*) &socketAddress.sin_addr.s_addr, server->h_length);
socketAddress.sin_port = htons(atoi(sPortnumber));
if (connect(socketConnection, (struct sockaddr *) &socketAddress, sizeof(socketAddress)) < 0) {
result = EC_CONNECTING_FAIL;
} else {
result = socketConnection;
}
return result;
}
|
2. У меня уже возникал http://forum.vingrad.ru/forum/topic-384476/anchor-entry2644213/0.html, связанный с тем, как методически верно следует идетифицировать закрытый сокет.
3. Я не использую setsockopt и SO_REUSEADDR - может ли быть ошибка связана с этим? |
)