Lines Matching refs:sock
45 #define read(sock,buf,len) recv(sock,buf,len,0) argument
46 #define write(sock,buf,len) send(sock,buf,len,0) argument
160 i = read(client->sock, client->buf + client->buffered, RFB_BUF_SIZE - client->buffered); in ReadFromRFBServer()
198 i = read(client->sock, out, n); in ReadFromRFBServer()
264 j = write(client->sock, buf + i, (n - i)); in WriteToRFBServer()
276 FD_SET(client->sock,&fds); in WriteToRFBServer()
278 if (select(client->sock+1, NULL, &fds, NULL, NULL) <= 0) { in WriteToRFBServer()
322 int sock; in ConnectClientToTcpAddr() local
333 sock = socket(AF_INET, SOCK_STREAM, 0); in ConnectClientToTcpAddr()
334 if (sock < 0) { in ConnectClientToTcpAddr()
342 if (connect(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { in ConnectClientToTcpAddr()
344 close(sock); in ConnectClientToTcpAddr()
348 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, in ConnectClientToTcpAddr()
351 close(sock); in ConnectClientToTcpAddr()
355 return sock; in ConnectClientToTcpAddr()
362 int sock; in ConnectClientToTcpAddr6() local
382 sock = -1; in ConnectClientToTcpAddr6()
385 sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol); in ConnectClientToTcpAddr6()
386 if (sock >= 0) in ConnectClientToTcpAddr6()
388 if (connect(sock, res->ai_addr, res->ai_addrlen) == 0) in ConnectClientToTcpAddr6()
390 close(sock); in ConnectClientToTcpAddr6()
391 sock = -1; in ConnectClientToTcpAddr6()
397 if (sock == -1) in ConnectClientToTcpAddr6()
403 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, in ConnectClientToTcpAddr6()
406 close(sock); in ConnectClientToTcpAddr6()
410 return sock; in ConnectClientToTcpAddr6()
427 int sock; in ConnectClientToUnixSock()
432 sock = socket(AF_UNIX, SOCK_STREAM, 0); in ConnectClientToUnixSock()
433 if (sock < 0) { in ConnectClientToUnixSock()
438 …if (connect(sock, (struct sockaddr *)&addr, sizeof(addr.sun_family) + strlen(addr.sun_path)) < 0) { in ConnectClientToUnixSock()
440 close(sock); in ConnectClientToUnixSock()
444 return sock; in ConnectClientToUnixSock()
458 int sock, port; in FindFreeTcpPort() local
467 sock = socket(AF_INET, SOCK_STREAM, 0); in FindFreeTcpPort()
468 if (sock < 0) { in FindFreeTcpPort()
475 if (bind(sock, (struct sockaddr *)&addr, sizeof(addr)) == 0) { in FindFreeTcpPort()
476 close(sock); in FindFreeTcpPort()
481 close(sock); in FindFreeTcpPort()
506 int sock; in ListenAtTcpPortAndAddress() local
522 sock = socket(AF_INET, SOCK_STREAM, 0); in ListenAtTcpPortAndAddress()
523 if (sock < 0) { in ListenAtTcpPortAndAddress()
528 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, in ListenAtTcpPortAndAddress()
531 close(sock); in ListenAtTcpPortAndAddress()
535 if (bind(sock, (struct sockaddr *)&addr, sizeof(addr)) < 0) { in ListenAtTcpPortAndAddress()
537 close(sock); in ListenAtTcpPortAndAddress()
563 if ((sock = socket(p->ai_family, p->ai_socktype, p->ai_protocol)) < 0) { in ListenAtTcpPortAndAddress()
569 …if (p->ai_family == AF_INET6 && setsockopt(sock, IPPROTO_IPV6, IPV6_V6ONLY, (char *)&one, sizeof(o… in ListenAtTcpPortAndAddress()
571 close(sock); in ListenAtTcpPortAndAddress()
577 if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *)&one, sizeof(one)) < 0) { in ListenAtTcpPortAndAddress()
579 close(sock); in ListenAtTcpPortAndAddress()
584 if (bind(sock, p->ai_addr, p->ai_addrlen) < 0) { in ListenAtTcpPortAndAddress()
585 close(sock); in ListenAtTcpPortAndAddress()
601 if (listen(sock, 5) < 0) { in ListenAtTcpPortAndAddress()
603 close(sock); in ListenAtTcpPortAndAddress()
607 return sock; in ListenAtTcpPortAndAddress()
618 int sock; in AcceptTcpConnection() local
623 sock = accept(listenSock, (struct sockaddr *) &addr, &addrlen); in AcceptTcpConnection()
624 if (sock < 0) { in AcceptTcpConnection()
629 if (setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, in AcceptTcpConnection()
632 close(sock); in AcceptTcpConnection()
636 return sock; in AcceptTcpConnection()
645 SetNonBlocking(int sock) argument
649 if(ioctlsocket(sock, FIONBIO, &block) == SOCKET_ERROR) {
652 int flags = fcntl(sock, F_GETFL);
653 if(flags < 0 || fcntl(sock, F_SETFL, flags | O_NONBLOCK) < 0) {
668 SetDSCP(int sock, int dscp) argument
678 if(getsockname(sock, &addr, &addrlen) != 0) {
700 if(setsockopt(sock, level, cmd, (void*)&dscp, sizeof(dscp)) != 0) {
749 SameMachine(int sock) argument
754 getpeername(sock, (struct sockaddr *)&peeraddr, &addrlen);
755 getsockname(sock, (struct sockaddr *)&myaddr, &addrlen);
818 FD_SET(client->sock,&fds);
820 num=select(client->sock+1, &fds, NULL, NULL, &timeout);