int udp_dialog(sockaddr_in* addr, int buf_count)
{
	int err = 0;
	// инициализация сокета
	#if defined WIN32
	WSADATA wsaData;
	if(WSAStartup(MAKEWORD(2, 2), &wsaData) != NO_ERROR) {
		err = 1;
	}
	#endif
	SOCKET sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if (!err && sock == -1) {
		err = 2;
	}

	if(!err) {
		// блокирующий режим
		u_long iMode = 0; // 0 - Disabled Nonblocking mode
		int iResult = ioctlsocket(sock, FIONBIO, &iMode);
		if (iResult != NO_ERROR) {
		  printf("ioctlsocket failed with error: %ld\n", iResult);
		}
	}

	if(!err) {
 // Установка размера буфера исходящих
		int size = (1024*100) ;
		if (setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char *) &size, sizeof(size)) == -1 ) {
			printf("setsockopt SO_SNDBUF failed\n");
		}
// установка времени отправки, мс
		int time = 100;
		if (setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, (char *) &time, sizeof(time)) == -1 ) {
			printf("setsockopt SO_SNDTIMEO failed\n");
		}
	}

 	if(!err) {
		if(addr) {
			if(bind(sock, (SOCKADDR *) addr, (socklen_t) sizeof(sockaddr_in)) != 0) {
				err = 3;
			}
		} else {
			sockaddr_in addr_any;
			addr_any.sin_family = AF_INET;
			addr_any.sin_port = 0; //htons(0);
			addr_any.sin_addr.s_addr = 0; //htonl(INADDR_ANY);
			if(bind(sock, (SOCKADDR *) &addr_any, (socklen_t) sizeof(sockaddr_in)) != 0) {
				err = 3;
			}
		}
	}
	// выделение памяти под буферы приема
	buffer_t* buffers = NULL;
	if(!err && buf_count > 0) {
		buffers = (buffer_t*) calloc(buf_count, sizeof(buffer_t));
		if(!buffers) {
			err = 4;
		}
	}
	// прием и обработка сообщений
	if(!err) {
		buffer_t* buf_end = buffers + buf_count - 1; // последний буфер
		buffer_t* buf_read = buf_end; // буфер для приема
		buffer_t* buf_parse = buffers; // буфер для обработки
		bool queue_empty = true;
		timeval wait_time;
		wait_time.tv_sec = 0;
		wait_time.tv_usec = 0;
		// Ожидание сообщений
		while(true) {
			// проверка наличия входящего сообщания
			fd_set fd;	
			FD_ZERO(&fd);
			FD_SET(sock, &fd);
			int sel = select(sock + 1, &fd, NULL, NULL, &wait_time);
			wait_time.tv_usec = 0; // если поставить 0 не успевают отправляться
			if(sel == -1) {// SOCKET_ERROR
				err = 5;
				break;
			} else if(sel == 0 || buf_read == buf_parse) { // принимать нечего или некуда
				int size_to_send = 0;
				if(buf_parse->size != 0) {
					// обработка сообщения
					size_to_send = parse_udp_message(buf_parse->msg, buf_parse->size, buf_parse->addr);
					buf_parse->size = 0; // пометка буфера пустым
				} else {
					// отправка по собственной инициативе
					int sleep_msec = 100; // пауза 0.1 сек если отправитель не изменит
					size_to_send = send_udp_message(buf_parse->msg, buf_parse->addr, sleep_msec);
					if(size_to_send == 0 && sleep_msec > 0) { // установка паузы если слать нечего
						wait_time.tv_usec = sleep_msec < 1000 ? sleep_msec * 1000 : 999999;
					}
				}
				if(size_to_send >= UDP_MIN_SIZE) {
					fd_set fd;	
					FD_ZERO(&fd);
					FD_SET(sock, &fd);
					int sel = select(sock + 1, NULL, &fd, NULL, &wait_time);
					if(sel == 0) {
						printf("socket select error\n");
					}
					if(FD_ISSET(sock, &fd) == 0) {
						printf("socket send error\n");
					}

					// отправка UDP пакета
					int s = sendto(sock, buf_parse->msg, size_to_send, 0, (SOCKADDR *) &buf_parse->addr, sizeof(sockaddr_in));
					if(s != size_to_send) {
						printf("sendto() size error\n");
					}
				} else if(size_to_send < 0) {
					break; // выходим из цикла обработки сообщений
				}
				queue_empty = next_buffer(&buf_parse, buffers, buf_end, buf_read); // переходим к следующему буферу
			} else if(FD_ISSET(sock, &fd) == 0) {
				printf("socket read error\n");
			} else {
				// прием UDP пакета
				socklen_t addr_size = sizeof(sockaddr_in);
				int size = recvfrom(sock, buf_read->msg, UDP_MAX_SIZE, 0, (SOCKADDR *) &buf_read->addr, &addr_size);
				if(size >= UDP_MIN_SIZE) {
					// прочитано успешно
					buf_read->size = size;
					if(queue_empty) {
						buf_parse = buf_read;
					}
					next_buffer(&buf_read, buffers, buf_end); // переходим к следующему буферу
				}
			}
		}
	}

	// выход
	if(buffers) {
		free(buffers);
	}
	if(sock != -1) {
		#if defined WIN32
		closesocket(sock);
		#elif defined __linux__
		close(sock);
		#endif
	}
	#if defined WIN32
	WSACleanup();
	#endif
	return err;
}

	SOCKET sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if (!err && sock == -1) {
		err = 2;
	}
	if(!err) {
		// Установка размера буфера входящих
		int size = (1024*200) ;
		printf("set SO_RCVBUF = %d\n", size);
		if (setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char *) &size, sizeof(size)) == -1 ) {
			printf("setsockopt SO_RCVBUF failed\n");
		}
	}