https://www.opennet.ru/openforum/vsluhforumID9/8651.html Задача: UDP сервер, на двух тредах.<br>Для взаимодействия между тредами решили использовать pipe();<br><br>1-й тред: Слушает UDP сокет, по приходу данных пишет в трубу.<br>2-й тред: Считывает из другого конца трубы, и пишет буфер.<br><br>Ниче не работает. <br>С синтаксисом и типами всё в порядке. <br><br>Запор на второй итерации while (1) в udp_thread. <br>Запор решается с помощью poll(), тогда появляется <br>запор в read(), говорит не верный дискриптор. <br><br>Много артефактов, сокращал для понимания на форуме... <br>[code]<br>/*<br> * <br> */<br>#include &lt;stdio.h&gt;<br>#include &lt;stdlib.h&gt;<br>#include &lt;unistd.h&gt;<br>#include &lt;netdb.h&gt;<br>#include &lt;string.h&gt;<br>#include &lt;fcntl.h&gt;<br>#include &lt;errno.h&gt;<br>#include &lt;pthread.h&gt;<br>#include &lt;sys/types.h&gt;<br>#include &lt;sys/socket.h&gt;<br>#include &lt;netinet/in.h&gt;<br><br>#define UDP_BUFF_SZ (2 &lt;&lt; 8) /* 256b */<br>#define PACKET_SIZE (2 &lt;&lt; 5) /* 32Kb */<br><br>/* Global pipe */<br>int pipefd[2] = {EOF, EOF};<br><br>/* for setsockopt */<br>const unsigned long value = PACKET_SIZE;<br><br>/* считать ровно 32 кб из pipefd[0] , в буфер */<br>void https://www.opennet.ru/openforum/vsluhforumID9/8651.html#6 Tue, 23 Mar 2010 02:21:14 GMT Нахрена тебе shm? Shm - для связи между процессами, а между потоками вся память общая автоматически.<br> https://www.opennet.ru/openforum/vsluhforumID9/8651.html#5 Sat, 20 Mar 2010 22:25:28 GMT &gt;[оверквотинг удален]<br>&gt;&gt;Для взаимодействия между тредами решили использовать pipe(); <br>&gt;<br>&gt;Зачем? Треды на то и создани, что у них shared resources и <br>&gt;т.д. Pipe - это классический System V IPC дотредовских времен (там <br>&gt;же семафоры и т.п.) <br>&gt;<br>&gt;Если у вас треды, пользуйтесь тем, что, у дла них нативного есть; <br>&gt;если у вас fork()+exec(), тогда и pipe() подойдет. <br>&gt;<br>&gt;WWell, <br><br>Во, нарыл!!! <br><br>http://mij.oltrelinux.com/devel/unixprg/#ipc__posix_shm<br><br>C вторника займусь...<br> https://www.opennet.ru/openforum/vsluhforumID9/8651.html#4 Sat, 20 Mar 2010 22:09:00 GMT &gt;&gt;Для взаимодействия между тредами решили использовать pipe(); <br>&gt;Зачем? Треды на то и созданы, что у них shared resources и <br><br>Я уж, подумывал,... сейчас на две недели на другую тему переключён,...<br><br>SHARED это которые:<br><br>void *shmat(int, const void *, int);<br>int shmctl(int, int, struct shmid_ds *);<br>int shmdt(const void *);<br>int shmget(key_t, size_t, int);<br><br>... как я понял, они переползли в Linux из IRIX... <br>Я раньше никогда не писал софтину для массивного межпроцессного обмена.<br>На многонитьевых вполне обходились флагами, семафорами, глобальной переменной, и т.п.<br><br>&gt; Pipe - это классический System V IPC дотредовских времен (там же семафоры и т.п.) <br>&gt;Если у вас треды, пользуйтесь тем, что, у для них нативного есть; <br>&gt;если у вас fork()+exec(), тогда и pipe() подойдет. <br><br>ну от UDP не отделаюсь, хотя в обозримом будущем может SCTP ... ладно, не об этом...<br><br>Алгоритма: <br><br>1. poll/select - ждут данных на порту.<br>2. получили, считали ....<br><br>Далее надо писать данные в shared memory или <br>на делат https://www.opennet.ru/openforum/vsluhforumID9/8651.html#3 Sat, 20 Mar 2010 21:33:50 GMT Привет,<br><br>&gt;Для взаимодействия между тредами решили использовать pipe(); <br><br>Зачем? Треды на то и создани, что у них shared resources и т.д. Pipe - это классический System V IPC дотредовских времен (там же семафоры и т.п.)<br><br>Если у вас треды, пользуйтесь тем, что, у дла них нативного есть; если у вас fork()+exec(), тогда и pipe() подойдет.<br><br>WWell,<br><br><br> https://www.opennet.ru/openforum/vsluhforumID9/8651.html#2 Wed, 17 Mar 2010 12:47:06 GMT dup2 в цикле зачем?<br> https://www.opennet.ru/openforum/vsluhforumID9/8651.html#1 Wed, 17 Mar 2010 12:12:32 GMT попробуй использовать socketpair+select<br>