Клиент-сервер TCP и несколько потоков.

Тебе помогут быстрее, если ты покажешь код.

От потока не зависит.

Вопрос, а как этот второй поток (send()) синхронизирован с первым, который accept()? Если send() вызывается сразу после accept(), то в одном потоке это и будет так, а если send() в другом потоке, то он точно вызывается после accept()? Блокировка по мьютексу?

Вопрос таков: допустим я открываю на сервере слушающий TCP сокет в одном потоке, и устанавливаю связь(accept()) в этом же потоке, а отсылать информацию буду в другом. Может такое сработать или другой поток будет иметь другой набор дескрипторов и ничего не получится?

У потоков все общее: и память, и дескрипторы. accept и send/recv в разных потоках — обычная практика.

Я уже такое провернул, и клиент ничего не получил, а если посылаю из того же потока, то клиент получает.

Ты что-то делаешь неправильно. Последовательность accept -> pthread_create -> send в свежесозданном потоке будет абсолютно корректно работать.

может лучше fsm на (e)poll?

__attribute__((noreturn)) void *terminal_receive_thread(void *arg)
{
	for(;;) {
		sd = accept(listen_sd, 0, 0);
		if (sd == -1) {
			warn("accept error");
			thread_exit((const int) arg);
		}

		pthread_mutex_unlock(&send_mutex);
/*
		ret = send(sd,
			   "odin dva",
			   strlen("odin dva"),
			   0
		      );
		if (ret == -1) {
			warn("send error");
			goto out;
		}
*/

		sleep(100);

		ret = recv(sd,
			   buffers.terminal_recv,
			   MAX_RECV_LEN,
			   0
			  );
		if (ret == -1) {
			warn("recv error");
			goto out;
		}
	
		pthread_mutex_lock(&send_mutex);

		ret = shutdown(sd, SHUT_RDWR);
		if (ret == -1) {
			warn("shutdown error");
			goto out;
		}
		close(sd);
	}
			
out:
	close(sd);
	thread_exit((const int) arg);
}

__attribute__((noreturn)) void *terminal_send_thread(void *arg)
{
	for(;;) {
		pthread_mutex_lock(&send_mutex);
		
		ret = send(sd,
			   "odin dva",
			   strlen("odin dva"),
			   0
			  );
		if (ret == -1) {
			warn("send error");
			goto out;
		}

		pthread_mutex_unlock(&send_mutex);

/*
...
*/
	}
out:
	thread_exit((const int) arg);
}

вот код двух потоков. если использовать только terminal_receive_thread и в нём раскоментировать функцию send(), то всё работает

Так оно и работает, я tcpdump-ом отлавливаю пакеты с правильным адресом, но они не доходят. Может есть у клиента какая-нибудь проверка на идентификатор процесса отправителя?

С синхронизацией вроде не промахнулся, иначе бы функции возвращали ошибки. Да, блокировка по мьютексу.

Странная работа с мьютексами.
Может быть я код посмотрел слишком бегло, но кто блокирует mutex до входа в поток terminal_send_thread?

Да, я его блокирую до создания потока. Это я уже экспериментировать начал.

Могу порекомендовать выставить слипы и принтэфы до и после accept и send, чтобы убедиться, что они отрабатывают в правильном порядке.

Где объявляется sd?

Глобально в файле, там же, где эти функции.

Порядок отрабатывается. Как я выше писал, проблема в том, что пакет уходит, но не доходит.

Заголовки IP пакета и TCP сегмента не содержат pid

если сам руками и telnet`ом подключаешься - всё правильно отрабатывает ?

tcp-стек в ядре, а не в программе/библиотеке. Если tcpdump показывет пакет с правильными ip-адресами/портами, значит он из нужного tcp-соединения с правильными полями заголовка и он будет принят клиентом.

Клиента ведь можно попробовать ведь запустить в режиме трассировки и посмотреть, доходят ли до него данные. Возможно, что send() из другого потока срабатывает через больший промежуток времени и клиент уже отваливается по тайм-ауту.

Здесь http://isl.storozhilov.com/ можно качнуть С++ библиотеку (ISL - Internet Server Library), которая позволит реализовать требуемое сильно не погружаясь в детали межпоточной синхронизации. Сделай своего наследника класса isl::AbstractSyncTcpService, в котором переопредели фабричный метод isl::AbstractSyncTcpService::createTask(), возвращающий указатель на экземпляр разработанного тобой же наследника класса isl::AbstractSyncTcpService::AbstractTask с переопределенным методом isl::AbstractSyncTcpService::AbstractTask::execute(), собственно и производящим отправку данных клиенту по сокету.

спасибо) я уже разобрался, сам налажал с синхронизацией(( только шухер на форуме поднял