|
Работа с сокетами. |
|
|
|
Sep 13 2017, 13:35
|
Профессионал
    
Группа: Участник
Сообщений: 1 778
Регистрация: 29-03-12
Пользователь №: 71 075

|
Пишу на vxWorks но наверно это не важно. Принцип везде одинаков. Создаю сокет и пытаюсь подключиться к серверу. Сервером выступает компьютер. На компьютере запускаю Hercules -> TCP Server -> Port 8200 (SERVER_PORT_NUM) -> Listen. Сервер бежит. На стороне прибора Код STATUS TCP_ClientConnect (char *serverName, int *soc_desc) { struct sockaddr_in serverAddr; /* server's socket address */ int sockAddrSize; /* size of socket address structure */ int sFd; /* socket file descriptor */ /* create client's socket */ if ((sFd = socket (AF_INET, SOCK_STREAM, 0)) == ERROR) { //perror ("socket"); printf ("SOCKET ERROR\n"); return (ERROR); } /* bind not required - port number is dynamic */ /* build server socket address */ sockAddrSize = sizeof (struct sockaddr_in); bzero ((char *) &serverAddr, sockAddrSize); serverAddr.sin_family = AF_INET; serverAddr.sin_len = (u_char) sockAddrSize; serverAddr.sin_port = htons (SERVER_PORT_NUM); if (((int)(serverAddr.sin_addr.s_addr = inet_addr (serverName)) == ERROR) && ((int)(serverAddr.sin_addr.s_addr = hostGetByName (serverName)) == ERROR)) { printf ("UNKNOWN SERVER NAME\n"); close (sFd); return (ERROR); } /* bind a port number to the socket */ if (bind(sFd, (struct sockaddr *) &serverAddr, sizeof(serverAddr)) == ERROR) { printf("BIND ERROR\n"); return (ERROR); }
/* connect to server */ if (connect (sFd, (struct sockaddr *) &serverAddr, sockAddrSize) != OK) { printf ("CONNECTION ERROR\n"); close (sFd); return (ERROR); } *soc_desc = sFd; return (OK); } И запускаю таск Код int socket_descriptor=0; char *server_ip = "10.0.0.80";
void tSpectraTaskEntryPoint() { if (TCP_ClientConnect(server_ip, &socket_descriptor)==ERROR) printf ("CLIENT CONNECT ERROR\n"); else printf("CLIENT CONNECT OK descriptor = %d\n", socket_descriptor); SpectraMain(); } Получаю ошибку BIND ERROR CLIENT CONNECT ERROR Значит не выполняется привязка сокета к серверу? Я что то не так делаю?
|
|
|
|
|
 |
Ответов
|
Sep 14 2017, 09:35
|
Профессионал
    
Группа: Участник
Сообщений: 1 778
Регистрация: 29-03-12
Пользователь №: 71 075

|
Цитата(Сергей Борщ @ Sep 14 2017, 13:01)  Все уже придумано за нас. Почитайте про SO_KEEPALIVE. Там по умолчанию довольно большие таймауты, но вы можете установить свои. нашел такой пример Код /* Set the option active */ optval = 1; optlen = sizeof(optval); if(setsockopt(s, SOL_SOCKET, SO_KEEPALIVE, &optval, optlen) < 0) { perror("setsockopt()"); close(s); exit(EXIT_FAILURE); } printf("SO_KEEPALIVE set on socket\n"); это чтоб включить SO_KEEPALIVE. компилируется без ошибок. а как теперь проверить жив сокет или нет? я так понимаю с выставленной опцией где то бежит проверка каждые tcp_keepalive_intvl и наверно выставляется флаг гдето в статусном регистре, который надо проверять. Цитата The SO_KEEPALIVE option causes a packet (called a 'keepalive probe') to be sent to the remote system if a long time (by default, more than 2 hours) passes with no other data being sent or received. This packet is designed to provoke an ACK response from the peer. This enables detection of a peer which has become unreachable (e.g. powered off or disconnected from the net). а где я вижу этот ACK response from the peer? Цитата(Эдди @ Sep 14 2017, 12:11)  Все надо проверять. Здесь я намучился с этими чертовыми сокетами! Сокет - не файл, запись в закрытый с другой стороны сокет никаких ошибок не даст! Поэтому нужно вводить таймауты и/или периодические рукопожатия. у меня этот код компилируется. Код static int waittoread(int sock){ fd_set fds, efds; struct timeval timeout; int rc; timeout.tv_sec = 1; // wait not more than 1 second timeout.tv_usec = 0; FD_ZERO(&fds); FD_ZERO(&efds); FD_SET(sock, &fds); FD_SET(sock, &efds); do{ rc = select(sock+1, &fds, NULL, &efds, &timeout); if(rc < 0){ if(errno != EINTR){ putlog("Server not available"); WARN("select()"); return -1; } continue; } break; }while(1); if(FD_ISSET(sock, &efds)) return -1; // exception - socket closed if(FD_ISSET(sock, &fds)) return 1; return 0; } это значит так можно проверить и сервер и сокет?
Сообщение отредактировал Jenya7 - Sep 14 2017, 09:10
|
|
|
|
|
Sep 14 2017, 11:19
|
Профессионал
    
Группа: Участник
Сообщений: 1 778
Регистрация: 29-03-12
Пользователь №: 71 075

|
Цитата(Сергей Борщ @ Sep 14 2017, 16:07)  Он закроется, а дальше write() и read() будут возвращать ноль - это и будет признаком того, что соединение разорвано. Кажется так. допустим сервер не посылает мне ничего но соединение живо. в read() я получу 0 но это может быть потому что сервер ничего не послал. я думаю есть какие то статусные биты которые говорят что соединение разорвано. делаю так Код #if KEEPALIVE_ON /* Set the option active */ optval = 1; optlen = sizeof(optval); if(setsockopt(sFd, SOL_SOCKET, SO_KEEPALIVE, &optval, optlen) < 0) { close(sFd); return (ERROR); } printf("SO_KEEPALIVE set on socket\n"); /* Interval (in seconds) between keepalives */ optval = 1; setsockopt(sFd, IPPROTO_TCP, TCP_KEEPINTVL, &optval, optlen); /* Maximum number of keepalives before dropping the connection */ optval = 10; setsockopt(sFd, IPPROTO_TCP, TCP_KEEPCNT, &optval, optlen); /* Send first keepalive probe when the connections been idle this time (in seconds) */ optval = 5; setsockopt(sFd, IPPROTO_TCP, TCP_KEEPIDLE, &optval, optlen); #endif теперь по идее мы должны иметь какую то индикацию, статус соединения.
Сообщение отредактировал Jenya7 - Sep 14 2017, 11:35
|
|
|
|
Сообщений в этой теме
Jenya7 Работа с сокетами. Sep 13 2017, 13:35 Jenya7 модифицировал функцию чтоб выводить информацию.
Ко... Sep 13 2017, 14:45 des333 Цитата(Jenya7 @ Sep 13 2017, 17:45) перев... Sep 13 2017, 14:59  Tarbal Цитата(des333 @ Sep 13 2017, 18:59) И как... Nov 4 2017, 02:19 gerber Клиентский сокет можно не bind-ить, так как порт в... Sep 13 2017, 15:04 Jenya7 Цитата(gerber @ Sep 13 2017, 20:04) Клиен... Sep 13 2017, 15:09  gerber Цитата(Jenya7 @ Sep 13 2017, 18:09) но я ... Sep 13 2017, 15:42 Jenya7 Тут возникает такой вопрос. Если связь с сервером ... Sep 14 2017, 06:02 Эдди Все надо проверять. Здесь я намучился с этими черт... Sep 14 2017, 07:11 Jenya7 Цитата(Эдди @ Sep 14 2017, 12:11) Все над... Sep 14 2017, 07:21 gerber Если удаленный сервер корректно закрыл TCP-соедине... Sep 14 2017, 13:41 Jenya7 Цитата(gerber @ Sep 14 2017, 19:41) Если ... Sep 14 2017, 14:02 Jenya7 Ну хорошо. Другой вопрос. Я в таске принимаю данны... Sep 17 2017, 06:01 Jenya7 Создал сокет как TCP Client. Читаю с сервера, пишу... Oct 31 2017, 08:45 Jenya7 Мой девайс присоединен к двум другим. С одним он д... Nov 12 2017, 13:11 k155la3 Цитата(Jenya7 @ Nov 12 2017, 17:11) Мой д... Nov 12 2017, 14:25  Jenya7 Цитата(k155la3 @ Nov 12 2017, 20:25) Попр... Nov 12 2017, 14:30 k155la3 Надо вместо одного сетевого интерфейса (физическог... Nov 12 2017, 14:53 Jenya7 Цитата(k155la3 @ Nov 12 2017, 20:53) Надо... Nov 12 2017, 15:23  XVR Цитата(Jenya7 @ Nov 12 2017, 18:23) а как... Nov 13 2017, 10:47   Jenya7 Цитата(XVR @ Nov 13 2017, 15:47) Никак, д... Nov 14 2017, 06:51  k155la3 Цитата(Jenya7 @ Nov 12 2017, 18:23) . . .... Nov 14 2017, 16:07 k155la3 Да, мой тезис по alias ошибочен. Два адреса у одно... Nov 14 2017, 08:24 Jenya7 Цитата(k155la3 @ Nov 14 2017, 13:24) Да, ... Nov 14 2017, 09:21  k155la3 Цитата(Jenya7 @ Nov 14 2017, 13:21) . . .... Nov 14 2017, 11:53 XVR Цитатаbind используется, когда есть несколько откр... Nov 14 2017, 12:11 Jenya7 Цитата(XVR @ Nov 14 2017, 18:11) Нет. bin... Nov 14 2017, 15:04 gosha-z Цитата(XVR @ Nov 14 2017, 15:11) Нет. bin... Nov 14 2017, 16:33 k155la3 XVR спасибо за инф. Nov 14 2017, 12:20 Jenya7 Продолжаю серию дурацких вопросов.
У меня NFS-серв... Nov 20 2017, 08:39 XVR ЦитатаТакое возможно?Переход по символической ссыл... Nov 20 2017, 10:46 Jenya7 Цитата(XVR @ Nov 20 2017, 16:46) Переход ... Nov 20 2017, 10:54 XVR Цитатая создаю папку на сервере - mkdir("/ram... Nov 20 2017, 12:35 Jenya7 Цитата(XVR @ Nov 20 2017, 18:35) Клиент у... Nov 20 2017, 12:59
1 чел. читают эту тему (гостей: 1, скрытых пользователей: 0)
Пользователей: 0
|
|
|