RetroSearch Browse

< 0) {

365

errbuf,

sizeof

(errbuf));

366 if

(strerr && *strerr)

367 return

ERR_STRDUP(strerr);

370 return

s_StrErrorInternal(

);

384

rv = FormatMessage(FORMAT_MESSAGE_ALLOCATE_BUFFER |

385

FORMAT_MESSAGE_FROM_SYSTEM |

386

FORMAT_MESSAGE_MAX_WIDTH_MASK |

387

FORMAT_MESSAGE_IGNORE_INSERTS,

389

MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),

392

LocalFree((HLOCAL)

);

420 #if defined(_DEBUG) && !defined(NDEBUG) 421 # if !defined(__GNUC__) && !defined(offsetof) 422 # define offsetof(T, F) ((size_t)((char*) &(((T*) 0)->F) - (char*) 0)) 426 #if defined(_DEBUG) && !defined(NDEBUG) 427 # define SOCK_HAVE_SHOWDATALAYOUT 1 430 #ifdef SOCK_HAVE_SHOWDATALAYOUT 432 # define extentof(T, F) (sizeof(((T*) 0)->F)) 434 # define infof(T, F) (unsigned int) offsetof(T, F), \ 435 (unsigned int) extentof(T, F) 439 static const char

kLayoutFormat[] = {

440 "SOCK data layout:\n" 441 " Sizeof(TRIGGER_struct) = %u\n" 442 " Sizeof(LSOCK_struct) = %u\n" 443 " Sizeof(SOCK_struct) = %u, offsets (sizes) follow\n" 446 "\tisset: %3u (%u)\n" 447 "\thost_: %3u (%u)\n" 449 "\tmyport: %3u (%u)\n" 452 # ifdef NCBI_OS_MSWIN 453 "\tevent: %3u (%u)\n" 455 "\tsslctx: %3u (%u)\n" 463 "\tr_buf: %3u (%u)\n" 464 "\tw_buf: %3u (%u)\n" 465 "\tr_len: %3u (%u)\n" 466 "\tw_len: %3u (%u)\n" 467 "\tn_read: %3u (%u)\n" 468 "\tn_written: %3u (%u)\n" 475 # ifdef NCBI_OS_MSWIN 476 # define SOCK_SHOWDATALAYOUT_PARAMS \ 477 infof(SOCK_struct, sock), \ 478 infof(SOCK_struct, id), \ 479 infof(TRIGGER_struct, isset), \ 480 infof(SOCK_struct, host_), \ 481 infof(SOCK_struct, port), \ 482 infof(SOCK_struct, myport), \ 483 infof(SOCK_struct, err), \ 484 infof(SOCK_struct, event), \ 485 infof(SOCK_struct, sslctx), \ 486 infof(SOCK_struct, addr), \ 487 infof(SOCK_struct, r_tv), \ 488 infof(SOCK_struct, w_tv), \ 489 infof(SOCK_struct, c_tv), \ 490 infof(SOCK_struct, r_to), \ 491 infof(SOCK_struct, w_to), \ 492 infof(SOCK_struct, c_to), \ 493 infof(SOCK_struct, r_buf), \ 494 infof(SOCK_struct, w_buf), \ 495 infof(SOCK_struct, r_len), \ 496 infof(SOCK_struct, w_len), \ 497 infof(SOCK_struct, n_read), \ 498 infof(SOCK_struct, n_written), \ 499 infof(SOCK_struct, n_in), \ 500 infof(SOCK_struct, n_out) 502 # define SOCK_SHOWDATALAYOUT_PARAMS \ 503 infof(SOCK_struct, sock), \ 504 infof(SOCK_struct, id), \ 505 infof(TRIGGER_struct, isset), \ 506 infof(SOCK_struct, host_), \ 507 infof(SOCK_struct, port), \ 508 infof(SOCK_struct, myport), \ 509 infof(SOCK_struct, err), \ 510 infof(SOCK_struct, sslctx), \ 511 infof(SOCK_struct, addr), \ 512 infof(SOCK_struct, r_tv), \ 513 infof(SOCK_struct, w_tv), \ 514 infof(SOCK_struct, c_tv), \ 515 infof(SOCK_struct, r_to), \ 516 infof(SOCK_struct, w_to), \ 517 infof(SOCK_struct, c_to), \ 518 infof(SOCK_struct, r_buf), \ 519 infof(SOCK_struct, w_buf), \ 520 infof(SOCK_struct, r_len), \ 521 infof(SOCK_struct, w_len), \ 522 infof(SOCK_struct, n_read), \ 523 infof(SOCK_struct, n_written), \ 524 infof(SOCK_struct, n_in), \ 525 infof(SOCK_struct, n_out), \ 526 infof(SOCK_struct, path) 534 # undef SOCK_SHOWDATALAYOUT_PARAMS 552 #ifdef SOCK_HAVE_SHOWDATALAYOUT 557 #if defined(_DEBUG) && !defined(NDEBUG) 559 assert

(

sizeof

(((

struct

sockaddr_in*) 0)->sin_addr.s_addr) ==

sizeof

(

unsigned int

));

566 # ifdef NCBI_OS_MSWIN 568 assert

(WSA_INVALID_EVENT == 0);

573 #if defined(NCBI_OS_UNIX) 576 if

(sigaction(SIGPIPE, 0, &sa) != 0 || sa.sa_handler == SIG_DFL) {

577

memset(&sa, 0,

sizeof

(sa));

578

sa.sa_handler = SIG_IGN;

579

sigaction(SIGPIPE, &sa, 0);

582 #elif defined(NCBI_OS_MSWIN) 585 int error

= WSAStartup(MAKEWORD(2, 2), &wsadata);

587

|| LOBYTE(wsadata.wVersion) != 2

588

|| HIBYTE(wsadata.wVersion) != 2) {

594 error

, strerr ? strerr :

""

595 "[SOCK::InitializeAPI] " 596 " Failed WSAStartup()"

);

607 #ifndef NCBI_OS_MSWIN 609 static void

volatile

s_AtExitSet = 0

;

613 "Failed to register exit handler"

);

653 const char

* what = 0;

658

what = (

const char

*)(-1L);

670 const char

* provider;

672 if

(what != (

const char

*)(-1L)) {

673

provider = *what ? what :

"???"

;

674

what =

"initialize"

;

677

what =

"re-initialize"

;

684

(

"Failed to %s SSL provider%s%s: %s"

, what,

688 static void

volatile

s_Once = 0

;

691 " been properly initialized in the NCBI Toolkit. " 692 " Have you forgotten to call SOCK_SetupSSL[Ex]()?"

);

709

memset(&

, 0,

sizeof

(

));

711 info

.status = status;

737

memset(&

, 0,

sizeof

(

));

739 info

.status = status;

771 error

, strerr ? strerr :

""

772 "[SOCK::ShutdownAPI] " 773 " Failed WSACleanup()"

);

807 error

, strerr ? strerr :

""

808 "[SOCK_gethostname] " 809 " Failed gethostname()"

);

816

(

"[SOCK_gethostname] " 817 " Buffer too small (%lu) for \"%.*s\""

825

(

"[SOCK_gethostname] " 826 " Hostname with spaces \"%s\""

));

838 failed

" (failed)"

""

));

841 return

? 0

: -1

;

852 if

empty

&& family == AF_UNSPEC)

868 return

!((

& 0xFFFF0000) ^ 0xA9FE0000);

875 for

(

= 0; addrs[

]; ++

) {

877

memcpy(&

, addrs[

sizeof

(

));

900

memset(

, 0,

sizeof

));

910

family == AF_INET ?

"(IPv4)"

911

family == AF_INET6 ?

"(IPv6)"

""

914 if

(family != AF_INET6) {

915 #ifdef NCBI_OS_DARWIN 916 if

(strspn(host,

".0123456789"

) ==

) {

919

memset(

, 0,

sizeof

));

925 if

(!not_ip && (ipv4 = inet_addr(host)) != htonl(

INADDR_NONE

)) {

933

memset(

, 0,

sizeof

));

944 if

(family == AF_INET6) {

950

}

else if

(family == AF_INET)

955

memset(

, 0,

sizeof

));

961 #if defined(HAVE_GETADDRINFO) 963

memset(&hints, 0,

sizeof

(hints));

964

hints.ai_family = family;

967 const struct

sockaddr* sa;

968 const struct

sockaddr_in*

;

969 const struct

sockaddr_in6* in6;

972 if

(family != AF_INET6) {

978

u.sa =

->ai_addr;

979 if

(u.sa->sa_family == AF_INET) {

980

addrs[

++] = (

char

*) &u.in->sin_addr;

984 if

(!(

->ai_next))

986

}

while

(

sizeof

(addrs) /

sizeof

(addrs[0]) - 1);

990

: addrs[0],

sizeof

(ipv4));

999

u.sa =

->ai_addr;

1000 if

(u.sa->sa_family == AF_INET6) {

1005 if

((temp->

[0] & 0xE0) &&

1006

(temp->

[0] ^ 0xE0)) {

1015

u.sa =

->ai_addr;

1016 if

(u.sa->sa_family == AF_INET6) {

1017

memcpy(

, &u.in6->sin6_addr,

sizeof

));

1020 assert

(family == AF_INET6 || family == AF_UNSPEC);

1024 const char

* strerr;

1026 if

(

== EAI_SYSTEM)

1036 error

, strerr ? strerr :

""

1037

(

"[SOCK_gethostbyname] " 1038 " Failed getaddrinfo(\"%.*s\")"

1047 # ifdef NCBI_HAVE_GETHOSTBYNAME_R 1048 static const char

suffix[] =

"_r"

;

1049 struct

hostent x_he;

1053 # if NCBI_HAVE_GETHOSTBYNAME_R == 5 1054

he = gethostbyname_r(host, &x_he, x_buf,

sizeof

(x_buf), &

);

1055 # elif NCBI_HAVE_GETHOSTBYNAME_R == 6 1056 if

(gethostbyname_r(host, &x_he, x_buf,

sizeof

(x_buf), &he, &

) != 0) {

1062 # error "Unknown NCBI_HAVE_GETHOSTBYNAME_R value" 1071 static const char

suffix[] =

""

;

1073 # ifndef SOCK_GHBX_MT_SAFE 1077

he = gethostbyname(host);

1078 error

= he ? 0 : h_errno + DNS_BASE;

1082

|| (family == AF_INET6 && he->h_addrtype == AF_INET)

1083

|| (family == AF_INET && he->h_addrtype == AF_INET6)) {

1088

}

else switch

(he->h_addrtype) {

1090 if

(he->h_length !=

sizeof

(ipv4)) {

1101 if

(he->h_length !=

sizeof

)) {

1105

memcpy(

, he->h_addr,

sizeof

));

1113 # ifndef NCBI_HAVE_GETHOSTBYNAME_R 1114 # ifndef SOCK_GHBX_MT_SAFE 1120 # ifdef NETDB_INTERNAL 1121 if

(

== NETDB_INTERNAL + DNS_BASE)

1124 if

(

== ERANGE)

1129 error

, strerr ? strerr :

""

1130

(

"[SOCK_gethostbyname] " 1131 " Failed gethostbyname%s(\"%.*s\")"

1142 #if defined(_DEBUG) && !defined(NDEBUG) 1146 CORE_TRACEF

((

"[SOCK::gethostbyname%s] \"%s\" @ %s"

1147

family == AF_INET ?

"(IPv4)"

1148

family == AF_INET6 ?

"(IPv6)"

""

1152 return

parsed ?

: 0

;

1163 static volatile struct

{

1166

} s_LocalHostAddress[2] = { 0 };

1167 static void

volatile

s_Once = 0

;

1172 n

= !(family != AF_INET6);

1173 if

(reget !=

eOn

) {

1174 int i

, m = family == AF_UNSPEC ? 2 : 1;

1175 for

(

= 0;

< m; ++

) {

1178

isset = s_LocalHostAddress[

].isset;

1179

= s_LocalHostAddress[

].addr;

1181 if

(!(

| isset)) {

1192 if

(reget !=

eOff

) {

1198

s_LocalHostAddress[

].addr = *

;

1199

s_LocalHostAddress[

].isset = 1;

1207

(

"[SOCK::GetLocalHostAddress%s] " 1208 " Cannot obtain local host address%s"

1209

family == AF_INET ?

"(IPv4)"

1210

family == AF_INET6 ?

"(IPv6)"

""

1211

reget ==

eDefault

", using loopback instead"

""

));

1214 if

(family == AF_INET6)

1230 static void

volatile

s_Once = 0

;

1239

memset(&

, 0,

sizeof

(

));

1246

}

else if

(!s_Once && !host

1251

(

"[SOCK::gethostbyname] " 1252 " Got loopback address %s for local host name"

, addrstr));

1278

family == AF_INET ?

"(IPv4)"

1279

family == AF_INET6 ?

"(IPv6)"

""

1285 #if defined(HAVE_GETNAMEINFO) 1288 struct

sockaddr_in

;

1289 struct

sockaddr_in6 in6;

1295

memset(&u, 0, addrlen);

1296

u.sa.sa_family = ipv4 ? AF_INET : AF_INET6;

1297 # ifdef HAVE_SIN_LEN 1298

u.sa.sa_len = addrlen;

1303

memcpy(&u.in6.sin6_addr,

sizeof

(u.in6.sin6_addr));

1304 if

((ipv4 && u.in.sin_addr.s_addr == htonl(

INADDR_NONE

))

1307

0, 0, NI_NAMEREQD)) != 0

1310 if

(

== EAI_NONAME)

1313 if

(

== EAI_SYSTEM)

1330 error

, strerr ? strerr :

""

1331

(

"[SOCK_gethostbyaddr] " 1332 " Failed getnameinfo(%s)"

1343 char

* x_addr = ipv4 ? (

char

*) &temp : (

char

;

1344 # ifdef NCBI_HAVE_GETHOSTBYADDR_R 1345 static const char

suffix[] =

"_r"

;

1346 struct

hostent x_he;

1349 # if NCBI_HAVE_GETHOSTBYADDR_R == 7 1350

he = gethostbyaddr_r(x_addr, addrlen, ipv4 ? AF_INET : AF_INET6,

1351

&x_he, x_buf,

sizeof

(x_buf), &

);

1352 # elif NCBI_HAVE_GETHOSTBYADDR_R == 8 1353 if

(gethostbyaddr_r(x_addr, addrlen, ipv4 ? AF_INET : AF_INET6,

1354

&x_he, x_buf,

sizeof

(x_buf), &he, &

) != 0) {

1360 # error "Unknown NCBI_HAVE_GETHOSTBYADDR_R value" 1369 static const char

suffix[] =

""

;

1371 # ifndef SOCK_GHBX_MT_SAFE 1375

he = gethostbyaddr(x_addr, addrlen, ipv4 ? AF_INET : AF_INET6);

1376 error

= he ? 0 : h_errno + DNS_BASE;

1381 if

(!he || (

= strlen(he->h_name)) >=

) {

1389

memcpy(

, he->h_name,

+ 1);

1391 # ifndef NCBI_HAVE_GETHOSTBYADDR_R 1392 # ifndef SOCK_GHBX_MT_SAFE 1398 # ifdef NETDB_INTERNAL 1399 if

(

== NETDB_INTERNAL + DNS_BASE)

1402 if

(

== ERANGE)

1408 error

, strerr ? strerr :

""

1409

(

"[SOCK_gethostbyaddr] " 1410 " Failed gethostbyaddr%s(%s)"

1422 #if defined(_DEBUG) && !defined(NDEBUG) 1424 CORE_TRACEF

((

"[SOCK::gethostbyaddr%s] %s @ %s%s%s"

1425

family == AF_INET ?

"(IPv4)"

1426

family == AF_INET6 ?

"(IPv6)"

""

1429

"\""

"(none)"

, &

"\""

]));

1441 static void

volatile

s_Once = 0

;

1452

(

"[SOCK::gethostbyaddr] " 1463 unsigned short

* port,

1467 const char

*s, *

, *q;

1472

memset(

, 0,

sizeof

));

1482 for

(s =

; *s; ++s) {

1483 if

((

unsigned char

)(*s)))

1489 if

(!(

= strchr(++s,

']'

)) ||

== s)

1501

}

else if

((q = strchr(s,

':'

)) == s) {

1502 if

(family == AF_INET)

1505

memset(&temp, 0,

sizeof

(temp));

1509 if

(q && *q ==

':'

) {

1512 if

isdigit

((

unsigned char

) q[1]))

1515 i

= strtol(++q, &e, 10);

1516 if

(errno || q == e || (

^ (

& 0xFFFF))

1517

|| (*e && !

((

unsigned char

)(*e)))) {

1520

p = (

unsigned

short)

;

1522

}

else if

(!q || !*q ||

((

unsigned char

)(*q))) {

1532 for

(

= s; *

&& *

':'

; ++

) {

1533 if

(

((

unsigned char

)(*

)))

1537 if

((

= (

size_t

)(

- s)) >=

sizeof

(x_buf))

1539

memcpy(x_buf, s,

);

1540

x_buf[

] =

'\0'

;

1550 assert

(family == AF_INET || family == AF_INET6);

1551 if

((ipv4 && family == AF_INET6) || (!ipv4 && family == AF_INET))

1565 unsigned short

port,

1576 int

bare = (ipv4 && family != AF_INET6) || !port;

1586 len

= (size_t)(end -

);

1592 if

(port || !

) {

1594 size_t

x_len = (size_t) sprintf(x_buf,

":%hu"

, port);

1596

memcpy(

, x_buf, x_len);

1605 #define s_HostPortToString(a,b,c,d) s_HostPortToStringEx((a),s_IPVersion,(b),(c),(d)) 1625 unsigned short

port,

1641 unsigned short

port,

1650

strcpy(

+ 1,

"::"

);

1659

sprintf(

":%hu"

, port);

1661

strcpy(

":?"

);

1678 switch

(sock->

type

) {

1692 if

(sock->

[0])

1693

sname = sock->

"SUSOCK"

"USOCK"

;

1711

cp = ((

LSOCK

) sock)->path;

1725

sprintf(fd,

"%u"

, (

unsigned int

) sock->

);

1728 len

= cp && *cp ? strlen(cp) : 0;

1730

sprintf(

"%s#%u[%s]%s%s%.*s: "

, sname, sock->

, fd,

1731

"@"

], (

size_t

)

"..."

""

, cp +

);

1741 struct

sockaddr_in

;

1742 struct

sockaddr_in6 in6;

1745

memset(&u, 0,

sizeof

(u.sa));

1747

u.sa.sa_len = addrlen;

1749 if

(getsockname(fd, &u.sa, &addrlen) == 0) {

1750 switch

(u.sa.sa_family) {

1752 return

ntohs(u.in.sin_port);

1754 return

ntohs(u.in6.sin6_port);

1766 const void

size_t size

const void

* ptr)

1769 const struct

sockaddr* sa;

1770 const struct

sockaddr_in*

;

1771 const struct

sockaddr_in6* in6;

1773 const char

* what, *strerr;

1786 unsigned short

port;

1788

what = ptr ? (

const char

*) ptr :

"Connecting"

;

1789

strcpy(

, *what ? what :

"Re-using"

);

1792

strcpy(

"Accepted"

);

1795

strcpy(

"Created"

);

1800 if

(!sock->

[0])

1805

sprintf(tail,

" @:%hu"

, port);

1813

}

else if

(!(u.sa = (

const struct

sockaddr*) ptr)) {

1814

strcpy(

"Created"

);

1816

}

else if

) {

1817 unsigned short

port;

1818 switch

(u.sa->sa_family) {

1820

port = ntohs(u.in->sin_port);

1823

port = ntohs(u.in6->sin6_port);

1830

strcpy(

"Bound @"

);

1831

sprintf(tail,

"(:%hu)"

, port);

1832

}

else if

(u.sa->sa_family) {

1834 unsigned short

port;

1835 switch

(u.sa->sa_family) {

1838

port = ntohs(u.in->sin_port);

1841

memcpy(&

, &u.in6->sin6_addr,

sizeof

(

));

1842

port = ntohs(u.in6->sin6_port);

1845

memset(&

, 0,

sizeof

(

));

1850

strcpy(

"Associated "

);

1853

strcpy(

"Disassociated"

);

1857

(

"%s%s%s"

(sock, _id),

, tail));

1867

? strerr :

"EOF hit"

)

1873 n

= (

int

) strlen(what);

1874 while

(

((

unsigned char

) what[

- 1]))

1876 if

(

> 1 && what[

- 1] ==

'.'

)

1879

u.sa = (

const struct

sockaddr*) ptr;

1881 unsigned short

port;

1882 assert

(u.sa && (u.sa->sa_family == AF_INET ||

1883

u.sa->sa_family == AF_INET6));

1884 switch

(u.sa->sa_family) {

1887

port = ntohs(u.in->sin_port);

1890

memcpy(&

, &u.in6->sin6_addr,

sizeof

(

));

1891

port = ntohs(u.in6->sin6_port);

1894

memset(&

, 0,

sizeof

(

));

1902

}

else if

(!ptr || !*((

char

*) ptr)) {

1905

strcpy(tail, !ptr ?

""

" [OOB]"

);

1912

(

"%s%.*s%s%s%s"

(sock, _id),

, what,

1914

? (event ==

eIO_Read

" from "

" to "

)

1917

" while reading"

" while writing"

)

1932

"s"

[sock->

n_in

== 1]);

1941

"s"

[sock->

n_out

== 1]);

1944

(

"%s%s (in: %s, out: %s)"

(sock, _id),

1945

ptr ? (

const char

*) ptr :

1946

sock->

"Leaving"

"Closing"

1952

(

"%s[SOCK::DoLog] " 1953 " Invalid event #%u"

1954 s_ID

(sock, _id), (

unsigned int

) event));

1975

to->

sec

= (

unsigned int

) tv->tv_sec;

1976

to->

= (

unsigned int

) tv->tv_usec;

1988

tv->tv_sec = to->

/ 1000000 + to->

sec

;

1989

tv->tv_usec = to->

% 1000000;

2052 static struct

timeval s_New;

2064 #ifndef NCBI_OS_MSWIN 2065 # if !defined(HAVE_POLL_H) || defined(NCBI_OS_DARWIN) 2068 " Poll API requested but not supported on this platform"

);

2103

memset(&

, 0,

sizeof

(

));

2117 " Seeking approval for %s %s%s%s%s%s%s"

2121

!host && !*cp ?

""

2123

"\""

[!host], host ? host :

""

, &

"\""

[!host], cp));

2129

(

"%s[SOCK::ApproveHook] " 2130 " Approval denied for %s %s%s%s%s%s%s: %s"

2134

!host && !*cp ?

""

2136

"\""

[!host], host ? host :

""

, &

"\""

[!host], cp,

2140 if

(status ==

eIO_Timeout

|| status == eIO_Closed)

2155 #if defined(NCBI_OS_MSWIN) 2156 unsigned long

arg = nonblock ? 1 : 0;

2157 return

ioctlsocket(sock, FIONBIO, &arg) == 0;

2158 #elif defined(NCBI_OS_UNIX) 2159 int flags

= fcntl(sock, F_GETFL, 0);

2162 if

(!nonblock == !(

& O_NONBLOCK))

2164 return

fcntl(sock, F_SETFL, nonblock

2165

| O_NONBLOCK

2166

& (

int

) ~O_NONBLOCK) == 0;

2168 # error "Unsupported platform" 2181 #if defined(NCBI_OS_UNIX) 2182 int flags

= fcntl(x_sock, F_GETFD, 0);

2185 if

(!cloexec == !(

& FD_CLOEXEC))

2187 return

fcntl(x_sock, F_SETFD, cloexec

2188

| FD_CLOEXEC

2189

& (

int

) ~FD_CLOEXEC) == 0;

2190 #elif defined(NCBI_OS_MSWIN) 2191 return

SetHandleInformation((

HANDLE

)x_sock, HANDLE_FLAG_INHERIT, !cloexec);

2193 # error "Unsupported platform" 2205 #if defined(NCBI_OS_UNIX) || defined(NCBI_OS_MSWIN) 2206 # ifdef NCBI_OS_MSWIN 2209 int

reuse_addr = on_off ? 1 : 0;

2211 return

setsockopt(x_sock, SOL_SOCKET, SO_REUSEADDR,

2212

(

char

*) &reuse_addr,

sizeof

(reuse_addr)) == 0;

2228 # ifdef NCBI_OS_MSWIN 2231 int

keepalive = on_off ? 1

: 0

;

2233 return

setsockopt(x_sock, SOL_SOCKET, SO_KEEPALIVE,

2234

(

char

*) &keepalive,

sizeof

(keepalive)) == 0;

2246 # ifdef NCBI_OS_MSWIN 2249 int

oobinline = on_off ? 1

: 0

;

2251 return

setsockopt(x_sock, SOL_SOCKET, SO_OOBINLINE,

2252

(

char

*) &oobinline,

sizeof

(oobinline)) == 0;

2262 const struct

timeval* t2)

2268 if

(t1->tv_sec > t2->tv_sec)

2270 if

(t1->tv_sec < t2->tv_sec)

2272 return

t1->tv_usec < t2->tv_usec;

2290 #if !defined(NCBI_OS_MSWIN) && defined(FD_SETSIZE) 2291 static int

x_TryLowerSockFileno(

sock)

2293 # ifdef STDERR_FILENO 2294 # define SOCK_DUPOVER STDERR_FILENO 2296 # define SOCK_DUPOVER 2 2298 # ifdef F_DUPFD_CLOEXEC 2299 int

fd = fcntl(sock->

, F_DUPFD_CLOEXEC, SOCK_DUPOVER + 1);

2301 int

fd = fcntl(sock->

, F_DUPFD, SOCK_DUPOVER + 1);

2306 # ifndef F_DUPFD_CLOEXEC 2307 int

cloexec = fcntl(sock->

, F_GETFD, 0);

2308 if

(cloexec == -1 || ((cloexec & FD_CLOEXEC)

2309

&& fcntl(fd, F_SETFD, cloexec) != 0)) {

2315

(

"%s[SOCK::Select] " 2316 " File descriptor has been lowered to %d"

2317 s_ID

(sock, _id), fd));

2330 #if !defined(NCBI_OS_MSWIN) || !defined(NCBI_CXX_TOOLKIT) 2336 static int

x_IsInterruptiblePoll(

sock0)

2344 const struct

timeval* tv,

2355 struct

timeval x_tv;

2358 # ifdef NCBI_OS_MSWIN 2361

tv ? tv->tv_sec * 1000 + (tv->tv_usec + 500) / 1000 : INFINITE;

2370

memset(&x_tv, 0,

sizeof

(x_tv));

2374 # ifdef NCBI_OS_MSWIN 2375 unsigned int count

= 0;

2377 struct

timeval xx_tv;

2385 for

(

= 0;

; ++

) {

2392 if

(!(sock = polls[

].sock) || !(event = polls[

].event)) {

2403 if

(polls[

].revent) {

2408 event

= (

)(event & ~polls[

].revent);

2413 # if !defined(NCBI_OS_MSWIN) && defined(FD_SETSIZE) 2415 if

(!x_TryLowerSockFileno(sock)) {

2418

(

"%s[SOCK::Select] " 2419 " Socket file descriptor must " 2445

|| (sock->r_on_w ==

eOff 2454

|| (sock->r_status != eIO_Closed && !sock->eof)) {

2462

|| sock->w_status == eIO_Closed

2463

|| !(sock->pending | sock->w_len)) {

2479 if

(nfds < (

int

) fd)

2482 # ifdef NCBI_OS_MSWIN 2484 if

(!FD_ISSET(fd, &efds)) {

2488 " Too many sockets in select()," 2489 " must be fewer than %u"

));

2505

memset(&xx_tv, 0,

sizeof

(xx_tv));

2513

write_only ? 0 : &rfds,

2514

read_only ? 0 : &wfds, &efds,

2529

x_tv.tv_usec += 1000000;

2542 error

, strerr ? strerr :

""

2543

(

"%s[SOCK::Select] " 2544 " Failed select()"

2545 n

== 1 ?

(polls[0].sock, _id) :

""

));

2549

}

else if

(x_IsInterruptiblePoll(

== 1 ? polls[0].sock : 0)) {

2563 for

(ready = 0,

= 0;

; ++

) {

2567 if

(!(sock = polls[

].sock) || !(event = polls[

].event)) {

2580 # if !defined(NCBI_OS_MSWIN) && defined(FD_SETSIZE) 2583 if

(FD_ISSET(fd, &efds)) {

2585 # ifdef NCBI_OS_MSWIN 2587

sock->readable = 1

;

2589

sock->writable = 1

;

2592 if

(!write_only && FD_ISSET(fd, &rfds)) {

2594 # ifdef NCBI_OS_MSWIN 2595

sock->readable = 1

;

2598 if

(!read_only && FD_ISSET(fd, &wfds)) {

2600 # ifdef NCBI_OS_MSWIN 2601

sock->writable = 1

;

2621 # if defined(NCBI_OS_UNIX) && defined(HAVE_POLL_H) && !defined(NCBI_OS_DARWIN) 2623 # define NPOLLS ((3 * sizeof(fd_set)) / sizeof(struct pollfd)) 2626 static size_t

x_AutoCountPolls(

size_t n

SSOCK_Poll

polls[])

2634 for

(

= 0;

; ++

) {

2635 if

(!polls[

].sock) {

2643 if

(!polls[

].event) {

2654

&& !x_TryLowerSockFileno(polls[

].sock)) {

2660 return

good && (

<= NPOLLS || bigfd) ?

: 0;

2666 const struct

timeval* tv,

2669 struct pollfd

xx_polls[NPOLLS];

2686 if

(!(m = x_AutoCountPolls(

, polls)))

2687 return

s_Select_(

, polls, tv, asis);

2691 else if

(!(x_polls = (

struct pollfd

malloc

(m *

sizeof

(*x_polls)))) {

2693

(

"%s[SOCK::Select] " 2694 " Cannot allocate poll vector(%lu)"

2695 n

== 1 ?

(polls[0].sock, _id) :

""

2696

(

unsigned long

) m));

2701

wait = tv ? (

int

)(tv->tv_sec * 1000 + (tv->tv_usec + 500) / 1000) : -1;

2707 for

(

= 0;

; ++

) {

2715 if

(!(sock = polls[

].sock) || !(

event

= polls[

)) {

2724 if

(polls[

].revent) {

2729 event

= (

)(event & ~polls[

].revent);

2741

bitset |= POLL_WRITE;

2744

|| (sock->r_on_w ==

eOff 2753

|| (sock->r_status != eIO_Closed && !sock->eof))

2754

bitset |= POLL_READ;

2756

|| sock->w_status == eIO_Closed

2757

|| !(sock->pending | sock->w_len)) {

2760

bitset |= POLL_WRITE;

2785 if

(wait != -1 && wait < slice)

2789 if

(

|| !ready) {

2790

x_ready =

poll

(x_polls,

, slice);

2793 # ifdef NCBI_OS_DARWIN 2795 if

(x_ready > (

int

)

)

2799

ready = (nfds_t) x_ready;

2822 const char

* strerr =

2825

x_ready, strerr ? strerr :

""

2826

(

"%s[SOCK::Select] " 2828 n

== 1 ?

(polls[0].sock, _id) :

""

));

2834

}

else if

(x_IsInterruptiblePoll(

== 1 ? polls[0].sock : 0)) {

2851 for

(m = 0,

= 0;

; ++

) {

2855 if

(!sock || !polls[

].event) {

2869 if

(scanned < ready) {

2870

nfds_t x_scanned = 0;

2873 for

(j = (nfds_t) m; j <

; ++j) {

2876 if

(x_polls[j].

) {

2879

scanned += x_scanned;

2887 if

(!(

revents

& POLL_ERROR)) {

2890 if

((

events

& POLL_WRITE) && (

revents

& POLL_WRITE_READY))

2901 assert

(scanned <= ready);

2902 assert

(x_ready >= ready);

2906 if

(x_polls != xx_polls)

2954 const struct

timeval* tv,

2957 #if defined(NCBI_OS_MSWIN) && defined(NCBI_CXX_TOOLKIT) 2958 DWORD

wait = tv ? tv->tv_sec * 1000 + (tv->tv_usec + 500)/1000 : INFINITE;

2959 HANDLE

what[MAXIMUM_WAIT_OBJECTS];

2960 long

want[MAXIMUM_WAIT_OBJECTS];

2970 for

(

= 0;

; ++

) {

2977 if

(!(sock = polls[

].sock) || !(

event

= polls[

)) {

2988 if

(polls[

].revent) {

2993 event

= (

)(event & ~polls[

].revent);

3007

|| sock->

!= eIO_Closed) {

3013

bitset |= FD_CONNECT

;

3014

bitset |= FD_WRITE

;

3027

|| (sock->

!= eIO_Closed && !sock->

)) {

3037

bitset |= FD_ACCEPT

;

3048

bitset |= FD_WRITE

;

3062 if

(

sizeof

(what) /

sizeof

(what[0])) {

3066 " Too many objects exceeding %u"

3067

(

unsigned int

)

));

3072

want[

] = bitset;

3086 if

(wait != INFINITE && wait < slice)

3097 r

= WaitForMultipleObjects(c,

3101 if

(

== WAIT_FAILED) {

3102 DWORD

err = GetLastError();

3105

err, strerr ? strerr :

""

3107 " Failed WaitForMultipleObjects(%u)"

3108

(

unsigned int

) c));

3112 if

(

== WAIT_TIMEOUT)

3114 if

(

< WAIT_OBJECT_0 || WAIT_OBJECT_0 + c <=

) {

3117 " WaitForMultipleObjects(%u) returned %d"

3118

(

unsigned int

) c, (

int

)(

- WAIT_OBJECT_0)));

3122

m +=

- WAIT_OBJECT_0;

3126 for

(j =

; j <

; ++j) {

3130 if

(!sock || !polls[j].event)

3142 if

(what[m] != ((

TRIGGER

) sock)->

)

3149 if

(what[m] != sock->

)

3152 if

(!WSAResetEvent(what[m])) {

3158 if

(WSAEnumNetworkEvents(sock->

, what[m], &e) != 0) {

3162 error

, strerr ? strerr :

""

3163

(

"%s[SOCK::Select] " 3164 " Failed WSAEnumNetworkEvents"

3172 if

(!(bitset = e.lNetworkEvents)) {

3173 if

(ready || !slice) {

3183 if

(lsock->

away

< 10) {

3189

(

"%s[SOCK::Select] " 3190 " Run-away connection detected"

3195 if

(bitset & FD_CLOSE

) {

3204 if

(bitset & (FD_CONNECT | FD_WRITE)) {

3208 if

(bitset & (FD_ACCEPT | FD_OOB | FD_READ))

3212 if

((bitset & (FD_CONNECT | FD_WRITE))

3218 if

((bitset & (FD_ACCEPT | FD_OOB | FD_READ))

3224 if

(!polls[j].revent) {

3226 if

((e.lNetworkEvents & FD_CLOSE)

3227

&& !e.iErrorCode[FD_CLOSE_BIT]) {

3230

}

else for

(k = 0; k < FD_MAX_EVENTS; ++k) {

3231 if

(!(e.lNetworkEvents & (1 << k)))

3233 if

(e.iErrorCode[k]) {

3235

errno = e.iErrorCode[k];

3249 if

(ready || !slice)

3251

}

while

(m <

);

3256 if

(

== WAIT_FAILED)

3264 if

(wait != INFINITE) {

3278 # if defined(NCBI_OS_UNIX) && defined(HAVE_POLL_H) && !defined(NCBI_OS_DARWIN) 3280 return

s_Poll_(

, polls, tv, asis);

3283 return

s_Select_(

, polls, tv, asis);

3289 #if defined(NCBI_COMPILER_GCC) || defined(NCBI_COMPILER_ANY_CLANG) 3290 # pragma GCC diagnostic push 3291 # pragma GCC diagnostic ignored "-Wmaybe-uninitialized" 3292 static inline void x_tvcpy

(

struct

timeval* dst,

struct

timeval* src)

3294

memcpy(dst, src,

sizeof

(*dst));

3296 # pragma GCC diagnostic warning "-Wmaybe-uninitialized" 3297 # pragma GCC diagnostic pop 3299 # define x_tvcpy(d, s) (void) memcpy((d), (s), sizeof(*(d))) 3308 const struct

timeval* tv,

3336 #if defined(NCBI_OS_UNIX) || defined(NCBI_OS_MSWIN) 3340 if

(getsockopt(sock->

, SOL_SOCKET, SO_ERROR, (

void

, &

)

3341

!= 0 || *

!= 0) {

3351 # ifdef NCBI_OS_MSWIN 3365 #if defined(_DEBUG) && !defined(NDEBUG) 3369 char

* x_m = (

char

*) &m;

3371 # if defined(IPPROTO_IP) && defined(IP_MTU) 3379 # if (defined(NCBI_OS_MSWIN) || defined(IPPROTO_IPV6)) && defined(IPV6_MTU) 3387 if

(x_m && sock->

) {

3389 if

(getsockopt(sock->

, lev, opt, x_m, &mlen) != 0) {

3391

sprintf(mtu,

", MTU ?? (%.80s)"

, strerr ? strerr :

"??"

);

3394

sprintf(mtu,

", MTU = %d"

, m);

3398 static const char

* mtu =

""

;

3401

(

"%sConnection established%s"

(sock, _id), mtu));

3411

x_error, strerr ? strerr :

""

3412

(

"%s[SOCK::IsConnected] " 3413 " Failed setsockopt(REUSEADDR)"

3428 const unsigned int

rtv_set = sock->

;

3429 const unsigned int

wtv_set = sock->

;

3440

want_desc ? &desc : 0);

3441 if

((sock->

= wtv_set & 1) != 0)

3443 if

((sock->

= rtv_set & 1) != 0)

3449

(

"%sSSL session created%s%s%s%s%s"

3454

" "

[!desc], desc ? desc :

""

));

3459

*what =

"SSL handshake"

;

3471 const struct

timeval* tv)

3479

memset(&

, 0,

sizeof

(

));

3492 info

.status = status;

3527 #ifdef NCBI_OS_MSWIN 3540 if

((x_read < 0 && sock->

eOff

) ||

3542

&& (!sock->

|| flag > 0))) {

3547

x_read < 0 ? (

void

*) &

3548

x_read > 0 ?

: 0,

3549

(

size_t

)(x_read < 0 ? 0 : x_read), 0);

3555

*n_read = (size_t) x_read;

3565 #ifdef NCBI_OS_MSWIN 3584 " Spurious false indication of read-ready"

3608 error

, strerr ? strerr :

""

3645 unsigned int

rtv_set;

3659 return

status == eIO_Closed ?

eIO_Unknown

: status;

3661 if

&& peek >= 0) {

3663 if

(status == eIO_Closed)

3665 else if

(sock->

)

3666

status = eIO_Closed;

3676 if

(

&& !*n_read) {

3682 if

(*n_read && (*n_read ==

|| !peek))

3690 if

(status == eIO_Closed) {

3692 " Socket already shut down for reading"

3701 if

((rtv_set = sock->

) != 0)

3705

memset(&sock->

, 0,

sizeof

(sock->

));

3709 assert

(!*n_read || peek > 0);

3713 size_t

x_todo, x_read, x_save;

3716

x_buf = (

char

+ *n_read;

3719

x_todo =

sizeof

(xx_buf);

3725 assert

(x_buf && x_todo);

3736

x_buf, x_todo, &x_read, &

);

3739 assert

(x_read <= x_todo);

3746

status != eIO_Closed || !sock->

3747

(

void

*) &

: 0,

3749

x_read ?

" [decrypt]"

: 0);

3752 if

(status == eIO_Closed && !sock->

)

3756

status =

s_Recv

(sock, x_buf, x_todo, &x_read, 0);

3758 assert

(x_read <= x_todo);

3764

status = eIO_Closed

;

3769 if

(x_read < x_todo)

3774

x_todo =

- *n_read;

3775 if

(x_todo > x_read)

3777 if

(

&& (p_buf || x_buf == xx_buf))

3778

memcpy((

char

+ *n_read, x_buf, x_todo);

3779

x_save = peek ? x_read : x_read - x_todo;

3786

peek ? x_buf : x_buf + x_todo,

3794

peek ? p_buf : p_buf + x_todo,

3802 " Cannot save %lu byte%s of unread data"

3803 s_ID

(sock, _id), (

unsigned long

) x_save,

3804

"s"

[x_save == 1]));

3806

x_read = peek >= 0 ? x_todo : 0;

3808

}

else if

(peek >= 0)

3817 if

((rtv_set = sock->

) != 0)

3821

memset(&sock->

, 0,

sizeof

(sock->

));

3823

}

while

(peek < 0

|| (!

&& *n_read <

));

3824 if

(!(rtv_set & 2) && (sock->

= rtv_set & 1) != 0)

3842

memset(&

, 0,

sizeof

(

));

3855 info

.status = status;

3876 const struct

timeval* tv,

3896 for

(

= 0;

; ++

) {

3901 if

(polls[

].revent & polls[

].event) {

3903

= (

)(polls[

].revent & polls[

].event);

3906 if

(polls[

].revent && !pending) {

3919 for

(

= k;

; ++

) {

3923 static const struct

timeval zero = { 0 };

3924

sock = polls[

;

3931 if

(sock->

== eIO_Closed || sock->

) {

3941

sock = polls[

;

3952 if

(sock->

== eIO_Closed) {

3964 for

( ;

; ++

) {

3967 if

(!polls[

].revent)

3988 poll

.event = event;

4001 #ifdef NCBI_OS_MSWIN 4006

tv->tv_usec += (ms_addend % 1000) * 1000;

4007

tv->tv_sec += ms_addend / 1000;

4008 if

(tv->tv_usec >= 10000000) {

4009

tv->tv_sec += tv->tv_usec / 10000000;

4010

tv->tv_usec %= 10000000;

4017 #ifdef SOCK_SEND_SLICE 4018 # define s_Send s_Send_ 4035 #ifdef NCBI_OS_MSWIN 4036 int

wait_buf_ms = 0;

4037 struct

timeval waited;

4038

memset(&waited, 0,

sizeof

(waited));

4055

(flag < 0 ? MSG_OOB : 0));

4057 if

(x_written >= 0 ||

4066 if

((x_written <= 0 && sock->

eOff

) ||

4068

&& (!sock->

|| flag > 0))) {

4073

x_written <= 0 ? (

void

*) &

4074

(

size_t

)(x_written <= 0 ? 0 : x_written),

4078 if

(x_written > 0) {

4080

*n_written = (size_t) x_written;

4084 if

(x_written < 0) {

4092 if

(flag < 0

|| !x_written)

4099

== WSAENOBUFS

4104 const struct

timeval* timeout;

4106 #ifdef NCBI_OS_MSWIN 4107 struct

timeval slice;

4108 unsigned int

writable = sock->

writable

;

4112 if

(

== WSAENOBUFS) {

4120 if

(wait_buf_ms == 0)

4122 else if

(wait_buf_ms < 500

)

4125

slice.tv_usec = wait_buf_ms * 1000;

4128

memset(&slice, 0,

sizeof

(slice));

4135

memset(&waited, 0,

sizeof

(waited));

4151 " Spurious false indication of write-ready"

4160 #ifdef NCBI_OS_MSWIN 4161 if

(

== WSAENOBUFS) {

4162 assert

(timeout == &slice);

4184 error

, strerr ? strerr :

""

4210 #ifdef SOCK_SEND_SLICE 4213 const void

* x_data,

4219 const unsigned char

= (

const unsigned char

*) x_data;

4220 unsigned int

wtv_set = 2;

4227 size_t

n_todo =

> SOCK_SEND_SLICE ? SOCK_SEND_SLICE :

;

4229

status = s_Send_(sock,

, n_todo, &n_done, flag);

4231 assert

(n_done <= n_todo);

4234

*n_written += n_done;

4235 if

(n_todo != n_done)

4237 if

(!(

-= n_done))

4241 if

((wtv_set = sock->

) != 0)

4245

memset(&sock->

, 0,

sizeof

(sock->

));

4248 if

(!(wtv_set & 2) && (sock->

= wtv_set & 1) != 0)

4270 if

(!sslwrite || oob) {

4284

*n_written > 0 ?

" [encrypt]"

: 0);

4287 if

(status == eIO_Closed)

4310 size_t

n_written = 0;

4321

n_written += x_written;

4323 data

= (

const char

+ x_written;

4333 const struct

timeval* tv,

4338 unsigned int

wtv_set;

4353 error

, strerr ? strerr :

""

4354

(

"%s[SOCK::WritePending] " 4357

what ? what :

"pending connect()"

4372 if

(tv != &sock->

) {

4373 if

((wtv_set = sock->

) != 0)

4386 if

(!(wtv_set & 2) && (sock->

= wtv_set & 1) != 0)

4419 " Failed to %s message (%lu + %lu byte%s)"

4421

oob ?

"[DSOCK::SendMsg]"

"[SOCK::Write]"

4422

oob ?

"finalize"

"store"

4424

(

unsigned long

)

, &

"s"

[

== 1]));

4431 if

(sock->

== eIO_Closed) {

4434 " Socket already shut down for writing"

4444 if

(status ==

eIO_Timeout

|| status == eIO_Closed)

4464

memset(&

, 0,

sizeof

(

));

4477 info

.status = status;

4488 const struct

timeval* tv)

4530 if

(sock->

!= eIO_Closed) {

4533 CORE_LOGF_X

(13, !tv || (tv->tv_sec | tv->tv_usec)

4536 " %s with output (%lu byte%s) still pending" 4537 " (%s)"

(sock, _id),

4541

"Shutting down for write" 4542

"Shutting down for read/write"

4543

(

unsigned long

) sock->

w_len

4544

"s"

[sock->

w_len

== 1],

4552 const unsigned int

rtv_set = sock->

;

4553 const unsigned int

wtv_set = sock->

;

4563 if

((sock->

= wtv_set & 1) != 0)

4565 if

((sock->

= rtv_set & 1) != 0)

4570 error

, strerr ? strerr :

""

4572 " Failed SSL teardown"

4575

"Shutdown"

"Close"

));

4616 error

, strerr ? strerr :

""

4617

(

"%s[SOCK::Shutdown] " 4618 " Failed shutdown(%s)"

4664 #if (defined(NCBI_OS_UNIX) && !defined(NCBI_OS_BEOS)) || defined(NCBI_OS_MSWIN) 4679 lgr

.l_linger = 120;

4681

}

else if

(sock->

.tv_sec | sock->

.tv_usec) {

4682 int

seconds = (

int

)(sock->

.tv_sec +

4683

(sock->

.tv_usec + 500000) / 1000000);

4686 lgr

.l_linger = seconds;

4693

&& setsockopt(sock->

, SOL_SOCKET, SO_LINGER,

4694

(

char

*) &

sizeof

(

)) != 0

4698 error

, strerr ? strerr :

""

4700 " Failed setsockopt(SO_LINGER)"

4702 abort

"Abort"

"Close"

));

4709 if

(setsockopt(sock->

, IPPROTO_TCP, TCP_LINGER2,

4710

(

char

*) &no,

sizeof

(no)) != 0

4714 error

, strerr ? strerr :

""

4715

(

"%s[SOCK::Close] " 4716 " Failed setsockopt(TCP_LINGER2)"

4765 #ifdef NCBI_OS_MSWIN 4767

WSAEventSelect(sock->

, sock->

, 0

);

4776 error

, strerr ? strerr :

""

4777

(

"%s[SOCK::Close] " 4778 " Cannot set socket back to blocking mode"

4789

g_MONKEY_Close(sock->

);

4798 #ifdef NCBI_OS_MSWIN 4799 if

(

== WSANOTINITIALISED) {

4814 error

, strerr ? strerr :

""

4818 abort

"Abort"

"Close"

));

4830 #ifdef NCBI_OS_MSWIN 4831

WSASetEvent(sock->

);

4836 #ifdef NCBI_OS_MSWIN 4838

WSACloseEvent(sock->

);

4853 assert

(!reclose || !keep);

4854

status =

s_Close_

(sock, reclose << 1, keep);

4858

memset(&

, 0,

sizeof

(

));

4871 info

.status = status;

4887 unsigned short

port,

4892 struct

sockaddr_in

;

4893 struct

sockaddr_in6 in6;

4895 struct

sockaddr_un un;

4916 if

(sock->

[0]) {

4917 size_t

pathlen = strlen(sock->

) + 1

;

4918 if

(

sizeof

(u.un.sun_path) < pathlen) {

4920

(

"%s[SOCK::Connect] " 4921 " Path too long (%lu vs %lu bytes allowed)"

4922 s_ID

(sock, _id), (

unsigned long

) pathlen,

4923

(

unsigned long

)

sizeof

(u.un.sun_path)));

4926

addrlen =

sizeof

(u.un);

4927

memset(&u, 0, addrlen);

4928

u.un.sun_family = AF_UNIX;

4929 # ifdef HAVE_SIN_LEN 4930

u.un.sun_len = addrlen;

4932

memcpy(u.un.sun_path, sock->

, pathlen);

4947

(

"%s[SOCK::Connect] " 4948 " Failed SOCK_gethostbyname(\"%.*s\")"

4953

addrlen = ipv4 ?

sizeof

(u.in) :

sizeof

(u.in6);

4954

memset(&u, 0, addrlen);

4955

u.sa.sa_family = ipv4 ? AF_INET : AF_INET6;

4957

u.sa.sa_len = addrlen;

4961

u.in.sin_port = htons(sock->

);

4963

memcpy(&u.in6.sin6_addr, &sock->

sizeof

(u.in6.sin6_addr));

4964

u.in6.sin6_port = htons(sock->

);

4977 #ifdef SOCK_NONBLOCK 4978 type

|= SOCK_NONBLOCK;

4982 type

|= SOCK_CLOEXEC;

4987 error

, strerr ? strerr :

""

4988

(

"%s[SOCK::Connect] " 4989 " Cannot create socket"

4999 if

(g_MONKEY_SockHasSocket)

5000

g_MONKEY_SockHasSocket(sock, fd);

5003 #if defined(NCBI_OS_MSWIN) 5005 if

(!(sock->

= WSACreateEvent())) {

5006 DWORD

err = GetLastError();

5009

err, strerr ? strerr :

""

5010

(

"%s[SOCK::Connect] " 5011 " Failed to create IO event"

5018 if

(WSAEventSelect(sock->

, sock->

, SOCK_EVENTS) != 0) {

5021 error

, strerr ? strerr :

""

5022

(

"%s[SOCK::Connect] " 5023 " Failed to bind IO event"

5029 #elif !defined(SOCK_NONBLOCK) 5034 error

, strerr ? strerr :

""

5035

(

"%s[SOCK::Connect] " 5036 " Cannot set socket to non-blocking mode"

5046 if

(sock->

keepalive

&& !s_SetKeepAlive(fd, 1

)) {

5049 error

, strerr ? strerr :

""

5050

(

"%s[SOCK::Connect] " 5051 " Failed setsockopt(KEEPALIVE)"

5057 if

(!s_SetOobInline(fd, 1

)) {

5060 error

, strerr ? strerr :

""

5061

(

"%s[SOCK::Connect] " 5062 " Failed setsockopt(OOBINLINE)"

5069 #ifndef SOCK_CLOEXEC 5071 const char

* strerr;

5072 # ifdef NCBI_OS_MSWIN 5073 DWORD

err = GetLastError();

5081 error

, strerr ? strerr :

""

5082

(

"%s[SOCK::Connect] " 5083 " Cannot set socket close-on-exec mode"

5085 # ifdef NCBI_OS_MSWIN 5098

sslctx->

= sock;

5102 if

(!sslctx->

sess

) {

5105 error

, strerr ? strerr :

""

5106

(

"%s[SOCK::Connect] " 5107 " %s to initialize secure session%s%s"

5109

sslcreate ?

"Failed"

"Unable"

5110

sslctx->

" with "

""

5111

sslctx->

? sslctx->

: 0));

5124 #ifdef NCBI_OS_MSWIN 5130 for

(

= 0; ;

= 1) {

5131 if

(connect(fd, &u.sa, addrlen) == 0) {

5152 error

, strerr ? strerr :

""

5153

(

"%s[SOCK::Connect] " 5154 " Failed connect()"

5162

status = eIO_Closed;

5172 if

|| !timeout || (timeout->

sec

| timeout->

)) {

5175 const struct

timeval* x_tv =

s_to2tv

(timeout, &tv);

5180 const char

* reason;

5183

sprintf(

"%s[%u.%06u]"

5185

(

unsigned int

) x_tv->tv_sec,

5186

(

unsigned int

) x_tv->tv_usec);

5194 error

, strerr ? strerr :

""

5195

(

"%s[SOCK::Connect] " 5196 " Failed %s: %s"

(sock, _id),

5197

what ? what :

"pending connect()"

5214 unsigned short

port,

5221

memset(&

, 0,

sizeof

(

));

5226 if

(sock->

[0]) {

5238 info

.port = port ? port : sock->

;

5240 info

.status = status;

5254 if

(!vhost || !*vhost)

5268 unsigned short

port,

5274 size_t size

= port ? 0 : strlen(hostpath);

5299

x_sock->

= sslctx;

5313

memcpy(x_sock->

, hostpath,

+ 1);

5323

(

"%s[SOCK::Create] " 5324 " Cannot store initial data (%lu byte%s)"

5325 s_ID

(x_sock, _id), (

unsigned long

)

5326

"s"

[

== 1]));

5332

status =

s_Connect

(x_sock, hostpath, port, timeout);

5345

memset(&temp, 0,

sizeof

(temp));

5348

temp.

= x_sock;

5361 struct

sockaddr_in

;

5362 struct

sockaddr_in6 in6;

5364 struct

sockaddr_un un;

5372 #ifdef NCBI_OS_MSWIN 5376 unsigned short

myport = 0;

5378 SOCK

x_sock, x_orig = 0;

5385 if

(!handle || (handle_size && handle_size !=

sizeof

(fd))) {

5387

(

"SOCK#%u[?]: [SOCK::CreateOnTop] " 5388 " Invalid handle%s %lu"

5390

handle ?

" size"

""

5391

handle ? (

unsigned long

) handle_size : 0UL));

5398

x_orig = (

) handle;

5403

fd = x_orig->

;

5406 if

(!x_orig->

) {

5414

oldctx = x_orig->

;

5417

myport = x_orig->

myport

;

5419 #ifdef NCBI_OS_MSWIN 5420 event

= x_orig->

;

5427

memcpy(&fd, handle,

sizeof

(fd));

5436

memset(&u, 0,

sizeof

(u));

5438

addrlen =

sizeof

(u);

5440

u.sa.sa_len = addrlen;

5442 if

(getpeername(fd, &u.sa, &addrlen) != 0) {

5445 error

, strerr ? strerr :

""

5446

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5448

x_id, (

unsigned int

) fd,

5450

"Unconnected"

"Invalid"

5451

x_orig ?

"SOCK"

"OS socket"

));

5456 if

(u.sa.sa_family != AF_INET && u.sa.sa_family != AF_INET6

5457

&& u.sa.sa_family != AF_UNIX)

5458 # if defined(NCBI_OS_BSD) || \ 5459 defined(NCBI_OS_DARWIN) || \ 5460 defined(NCBI_OS_IRIX) 5461 if

(u.sa.sa_family != AF_UNSPEC

)

5464 if

(u.sa.sa_family != AF_INET && u.sa.sa_family != AF_INET6)

5470 if

(x_orig && x_orig->

[0])

5471

socklen = strlen(x_orig->

);

5472 else if

(!x_orig && (

5473

if

defined(NCBI_OS_BSD) || \

5475

defined(NCBI_OS_IRIX)

5476

u.sa.sa_family == AF_UNSPEC

5478

u.sa.sa_family == AF_UNIX)) {

5479 if

(addrlen ==

sizeof

(u.sa.sa_family) || !u.un.sun_path[0]) {

5480

memset(&u, 0,

sizeof

(u));

5481

addrlen =

sizeof

(u);

5482 # ifdef HAVE_SIN_LEN 5483

u.sa.sa_len = addrlen;

5485 if

(getsockname(fd, &u.sa, &addrlen) != 0)

5487 assert

(u.sa.sa_family == AF_UNIX);

5488 if

(addrlen ==

sizeof

(u.sa.sa_family) || !u.un.sun_path[0]) {

5490

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5491 " %s UNIX socket handle"

5492

x_id, (

unsigned int

) fd,

5493

addrlen ==

sizeof

(u.sa.sa_family)

5494

"Unnamed"

"Abstract"

));

5498

socklen =

strnlen

(u.un.sun_path,

sizeof

(u.un.sun_path));

5507 #ifdef NCBI_OS_MSWIN 5510 if

(!(event = WSACreateEvent())) {

5511 DWORD

err = GetLastError();

5514

err, strerr ? strerr :

""

5515

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5516 " Failed to create IO event"

5517

x_id, (

unsigned int

) fd));

5522 if

(WSAEventSelect(fd, event, SOCK_EVENTS) != 0) {

5525 error

, strerr ? strerr :

""

5526

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5527 " Failed to bind IO event"

5528

x_id, (

unsigned int

) fd));

5539 error

, strerr ? strerr :

""

5540

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5541 " Cannot set socket to non-blocking mode"

5542

x_id, (

unsigned int

) fd));

5556

(

"SOCK#%u[%u]: [SOCK::CreateOnTop] " 5557 " Cannot store initial data (%lu byte%s)"

5558

x_id, (

unsigned int

) fd, (

unsigned long

)

5559

"s"

[

== 1]));

5568 if

(!(x_sock = (

)

(1,

sizeof

(*x_sock) + socklen)))

5575

x_orig ? x_orig->

: u.un.sun_path, socklen);

5579 assert

(x_orig || u.sa.sa_family == AF_INET || u.sa.sa_family == AF_INET6);

5583

}

else switch

(u.sa.sa_family) {

5586

x_sock->

= ntohs(u.in.sin_port);

5589

memcpy(&x_sock->

, &u.in6.sin6_addr,

sizeof

(x_sock->

));

5590

x_sock->

= ntohs(u.in6.sin6_port);

5598

x_sock->

myport

= myport;

5606 #ifdef NCBI_OS_MSWIN 5607

x_sock->

= event;

5614

x_sock->

w_buf

= w_buf;

5615 if

(oldctx && sslctx) {

5618 if

(!oldctx->sess &&

) {

5623

cred = oldctx->cred;

5624

host = oldctx->host;

5627

x_sock->

= oldctx;

5629

x_orig->

= sslctx;

5634

sslctx = x_sock->

;

5635

}

else if

(sslctx) {

5638

x_sock->

= sslctx;

5646 if

(!sslctx->

sess

) {

5654 if

(!sslctx->

sess

) {

5657 error

, strerr ? strerr :

""

5658

(

"%s[SOCK::CreateOnTop] " 5659 " %s to initialize secure session%s%s"

5661

sslcreate ?

"Failed"

"Unable"

5662

sslctx->

" with "

""

5663

sslctx->

? sslctx->

""

));

5666 #ifdef NCBI_OS_MSWIN 5667

WSAEventSelect(fd, event, 0

);

5668

WSACloseEvent(event);

5679

(

"%sSSL session re-acquired%s%s%s"

5681

sslctx->

" \""

""

5682

sslctx->

? sslctx->

""

5683

"\""

[!sslctx->

]));

5697 if

(x_sock->

w_buf

) {

5702

x_sock->

w_buf

= w_buf;

5707 if

(!x_orig && x_sock->

) {

5709 if

(!s_SetKeepAlive(fd, x_sock->

keepalive

)) {

5712 error

, strerr ? strerr :

""

5713

(

"%s[SOCK::CreateOnTop] " 5714 " Failed setsockopt(KEEPALIVE)"

5715 s_ID

(x_sock, _id)));

5720 if

(!s_SetOobInline(fd, 1

)) {

5723 error

, strerr ? strerr :

""

5724

(

"%s[SOCK::CreateOnTop] " 5725 " Failed setsockopt(OOBINLINE)"

5726 s_ID

(x_sock, _id)));

5736 const char

* strerr;

5737 #ifdef NCBI_OS_MSWIN 5738 DWORD

err = GetLastError();

5746 error

, strerr ? strerr :

""

5747

(

"%s[SOCK::CreateOnTop] " 5748 " Cannot modify socket close-on-exec mode"

5749 s_ID

(x_sock, _id)));

5750 #ifdef NCBI_OS_MSWIN 5759

memset(&

, 0,

sizeof

(

));

5760 if

(setsockopt(fd, SOL_SOCKET, SO_LINGER,

5761

(

char

*) &

sizeof

(

)) != 0) {

5764 error

, strerr ? strerr :

""

5765

(

"%s[SOCK::CreateOnTop] " 5766 " Failed setsockopt(SO_NOLINGER)"

5767 s_ID

(x_sock, _id)));

5783 assert

(!oldctx || oldctx != sslctx);

5791

x_orig->

= oldfd;

5792 #ifdef NCBI_OS_MSWIN 5793

x_orig->

= event;

5802 unsigned short

port,

5803 unsigned short

backlog,

5810 struct

sockaddr_in

;

5811 struct

sockaddr_in6 in6;

5813 struct

sockaddr_un un;

5823 #ifdef NCBI_OS_MSWIN 5839

pathlen = strlen(path) + 1

;

5840 if

(

sizeof

(u.un.sun_path) < pathlen) {

5842

(

"LSOCK#%u[?]@%s: [LSOCK::Create] " 5843 " Path too long (%lu vs %lu bytes allowed)"

5844

x_id, path, (

unsigned long

) pathlen,

5845

(

unsigned long

)

sizeof

(u.un.sun_path)));

5849

addrlen =

sizeof

(u.un);

5850

memset(&

, 0,

sizeof

(

));

5875

addrlen =

sizeof

(u.in);

5881

memset(&

, 0,

sizeof

(

));

5882

addrlen =

sizeof

(u.in6);

5900 #ifdef SOCK_NONBLOCK 5901 type

|= SOCK_NONBLOCK;

5905 type

|= SOCK_CLOEXEC;

5911 error

, strerr ? strerr :

""

5912

(

"LSOCK#%u[?]@%s: [LSOCK::Create] " 5913 " Failed socket()"

, x_id, cp));

5920 #if defined(NCBI_OS_MSWIN) && defined(SO_EXCLUSIVEADDRUSE) 5930 if

(setsockopt(fd, SOL_SOCKET, SO_EXCLUSIVEADDRUSE,

5931

(

char

*) &excl,

sizeof

(excl)) != 0) {

5932 failed

"EXCLUSIVEADDRUSE"

;

5934 #elif !defined(NCBI_OS_MSWIN) 5953 error

, strerr ? strerr :

""

5954

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 5955 " Failed setsockopt(%s)"

, x_id,

5956

(

unsigned int

) fd, cp,

failed

));

5964

memset(&u, 0, addrlen);

5965

u.sa.sa_family = family;

5967

u.sa.sa_len = addrlen;

5971 assert

(family == AF_UNIX);

5972

memcpy(u.un.sun_path, path, pathlen);

5978 assert

(family == AF_INET);

5980

u.in.sin_port = htons(port);

5982 assert

(family == AF_INET6);

5983

u.in6.sin6_port = htons(port);

5984

memcpy(&u.in6.sin6_addr, &

sizeof

(u.in6.sin6_addr));

6001 error

, strerr ? strerr :

""

6002

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6004

x_id, (

unsigned int

) fd, cp));

6011 # if !defined(NCBI_OS_BSD) && !defined(NCBI_OS_DARWIN) && \ 6012 !defined(NCBI_OS_IRIX) && !defined(NCBI_OS_CYGWIN) 6013

(void) fchmod(fd, S_IRWXU | S_IRWXG | S_IRWXO);

6015 # ifdef NCBI_OS_CYGWIN 6016

(void) chmod(path, S_IRWXU | S_IRWXG | S_IRWXO);

6021 assert

(u.sa.sa_family == AF_INET || u.sa.sa_family == AF_INET6);

6023 if

(

|| u.sa.sa_family != family

6024

|| (family == AF_INET && !(port = ntohs(u.in.sin_port)))

6025

|| (family == AF_INET6 && !(port = ntohs(u.in6.sin6_port)))) {

6029 error

, strerr ? strerr :

""

6030

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6031 " Cannot obtain free listening port"

6032

x_id, (

unsigned int

) fd, cp));

6038 assert

((path && !port) ||

6041 #if defined(NCBI_OS_MSWIN) 6042 if

(!(event = WSACreateEvent())) {

6043 DWORD

err = GetLastError();

6048

err, strerr ? strerr :

""

6049

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6050 " Failed to create IO event"

6051

x_id, (

unsigned int

) fd, cp));

6057 if

(WSAEventSelect(fd, event, FD_CLOSE

| FD_ACCEPT

) != 0) {

6062 error

, strerr ? strerr :

""

6063

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6064 " Failed to bind IO event"

6065

x_id, (

unsigned int

) fd, cp));

6068

WSACloseEvent(event);

6071 #elif !defined(SOCK_NONBLOCK) 6077 error

, strerr ? strerr :

""

6078

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6079 " Cannot set socket to non-blocking mode"

6080

x_id, (

unsigned int

) fd, cp));

6088 if

(listen(fd, backlog) != 0) {

6092 error

, strerr ? strerr :

""

6093

(

"LSOCK#%u[%u]@%s: [LSOCK::Create] " 6094 " Failed listen(%hu)"

6095

x_id, (

unsigned int

) fd, cp, backlog));

6098 #ifdef NCBI_OS_MSWIN 6099

WSACloseEvent(event);

6105 if

(!(x_lsock =(

LSOCK

)

(1,

sizeof

(*x_lsock) + (path?strlen(path):0)))){

6107 #ifdef NCBI_OS_MSWIN 6108

WSACloseEvent(event);

6112

x_lsock->

= fd;

6113

x_lsock->

= x_id;

6114

x_lsock->

= port;

6120 #if defined(NCBI_OS_UNIX) 6122

strcpy(x_lsock->

, path);

6123 #elif defined(NCBI_OS_MSWIN) 6124

x_lsock->

= event;

6128 #ifndef SOCK_CLOEXEC 6130 const char

* strerr;

6131 # ifdef NCBI_OS_MSWIN 6132 DWORD

err = GetLastError();

6140 error

, strerr ? strerr :

""

6141

(

"%s[LSOCK::Create] " 6142 " Cannot set socket close-on-exec mode"

6144 # ifdef NCBI_OS_MSWIN 6155

(

"%sListening"

((

) x_lsock, _id)));

6170 struct

sockaddr_in

;

6171 struct

sockaddr_in6 in6;

6173 struct

sockaddr_un un;

6180 unsigned short

port;

6181 #ifdef NCBI_OS_MSWIN 6193

(

"%s[LSOCK::Accept] " 6226 if

(lsock->

[0]) {

6227

addrlen =

sizeof

(u.un);

6232

addrlen =

sizeof

(u);

6234 #ifdef NCBI_OS_MSWIN 6241

fd = accept4(lsock->

, &u.sa, &addrlen,

);

6243

fd = accept (lsock->

, &u.sa, &addrlen);

6248 error

, strerr ? strerr :

""

6249

(

"%s[LSOCK::Accept] " 6250 " Failed accept()"

6258 if

(lsock->

[0]) {

6259 assert

(u.un.sun_family == AF_UNIX);

6260

memset(&

, 0,

sizeof

(

));

6261

path = lsock->

;

6266 switch

(u.sa.sa_family) {

6269

port = ntohs(u.in.sin_port);

6272

memcpy(&

, &u.in6.sin6_addr,

sizeof

(

));

6273

port = ntohs(u.in6.sin6_port);

6293 #if defined(NCBI_OS_MSWIN) 6294 if

(!(event = WSACreateEvent())) {

6295 DWORD

err = GetLastError();

6298

err, strerr ? strerr :

""

6299

(

"SOCK#%u[%u]@%s: [LSOCK::Accept] " 6300 " Failed to create IO event"

6301

x_id, (

unsigned int

) fd,

6302 s_CP

, port, path, _id,

sizeof

(_id))));

6308 if

(WSAEventSelect(fd, event, SOCK_EVENTS) != 0) {

6312 error

, strerr ? strerr :

""

6313

(

"SOCK#%u[%u]@%s: [LSOCK::Accept] " 6314 " Failed to bind IO event"

6315

x_id, (

unsigned int

) fd,

6316 s_CP

, port, path, _id,

sizeof

(_id))));

6319

WSACloseEvent(event);

6322 #elif !defined(HAVE_ACCEPT4) 6327 error

, strerr ? strerr :

""

6328

(

"SOCK#%u[%u]@%s: [LSOCK::Accept] " 6329 " Cannot set socket to non-blocking mode"

6330

x_id, (

unsigned int

) fd,

6331 s_CP

, port, path, _id,

sizeof

(_id))));

6340 if

(!(x_sock = (

)

(1,

sizeof

(*x_sock) + addrlen))) {

6342 #ifdef NCBI_OS_MSWIN 6343

WSACloseEvent(event);

6352

strcpy(x_sock->

, path);

6358

x_sock->

= port;

6369 #ifdef NCBI_OS_MSWIN 6370

x_sock->

= event;

6384 error

, strerr ? strerr :

""

6385

(

"%s[LSOCK::Accept] " 6386 " Failed setsockopt(REUSEADDR)"

6387 s_ID

(*sock, _id)));

6391 if

(x_sock->

keepalive

&& !s_SetKeepAlive(fd, 1)) {

6394 error

, strerr ? strerr :

""

6395

(

"%s[LSOCK::Accept] " 6396 " Failed setsockopt(KEEPALIVE)"

6397 s_ID

(*sock, _id)));

6402 if

(!s_SetOobInline(fd, 1

)) {

6405 error

, strerr ? strerr :

""

6406

(

"%s[LSOCK::Accept] " 6407 " Failed setsockopt(OOBINLINE)"

6408 s_ID

(*sock, _id)));

6414 #ifndef HAVE_ACCEPT4 6416 const char

* strerr;

6417 # ifdef NCBI_OS_MSWIN 6418 DWORD

err = GetLastError();

6426 error

, strerr ? strerr :

""

6427

(

"%s[LSOCK::Accept] " 6428 " Cannot set socket close-on-exec mode"

6429 s_ID

(*sock, _id)));

6430 # ifdef NCBI_OS_MSWIN 6455 #if defined(NCBI_OS_UNIX) 6456 if

(!lsock->

&& lsock->

[0]) {

6460 #elif defined(NCBI_OS_MSWIN) 6462

WSAEventSelect(lsock->

, lsock->

, 0

);

6468

(

"%s%s (%u accept%s total)"

6470

lsock->

"Leaving"

"Closing"

6471

lsock->n_accept, lsock->n_accept == 1 ?

""

"s"

));

6475 if

(!lsock->

) {

6485 #ifdef NCBI_OS_MSWIN 6486 if

(

== WSANOTINITIALISED) {

6494 error

, strerr ? strerr :

""

6495

(

"%s[LSOCK::Close] " 6504 #ifdef NCBI_OS_MSWIN 6505

WSASetEvent(lsock->

);

6511 #ifdef NCBI_OS_MSWIN 6512

WSACloseEvent(lsock->

);

6525 unsigned short

* sender_port)

6535

x_msgsize = (msgsize && msgsize < ((1 << 16) - 1))

6536

? msgsize : ((1 << 16) - 1);

6538 if

(!(x_msg = (x_msgsize <=

bufsize 6539

: (x_msgsize <=

sizeof

(w)

6540

? w :

malloc

(x_msgsize))))) {

6551 struct

sockaddr_in

;

6552 struct

sockaddr_in6 in6;

6555

memset(&u, 0,

sizeof

(u.sa));

6557

u.sa.sa_len = addrlen;

6561 #ifdef NCBI_OS_MSWIN 6569 unsigned short

port;

6573

*msglen = (size_t) x_read;

6574 switch

(u.sa.sa_family) {

6577

port = ntohs(u.in.sin_port);

6580

memcpy(&

, &u.in6.sin6_addr,

sizeof

(

));

6581

port = ntohs(u.in6.sin6_port);

6584

memset(&

, 0,

sizeof

(

));

6590

*sender_addr =

;

6592

*sender_port = port;

6599 if

((

size_t

) x_read >

bufsize 6602

(

size_t

)x_read -

)) {

6604

(

"%s[DSOCK::RecvMsg] " 6605 " Message truncated: %lu/%lu"

6607

(

unsigned long

)

, (

unsigned long

) x_read));

6612

memcpy(

, x_msg,

6654 error

, strerr ? strerr :

""

6655

(

"%s[DSOCK::RecvMsg] " 6656 " Failed recvfrom()"

6665 if

(x_msgsize >

&& x_msg != w)

6673 unsigned short

port,

6686 struct

sockaddr_in

;

6687 struct

sockaddr_in6 in6;

6691

status =

s_Write_

(sock,

, datalen, &x_msgsize, 1

);

6694 assert

(x_msgsize == datalen);

6706

(

"%s[DSOCK::SendMsg] " 6707 " Failed SOCK_gethostbyname(\"%.*s\")"

6712

port = sock->

;

6715 if

(!x_msgsize || !port) {

6718

(

"%s[DSOCK::SendMsg] " 6719 " Address \"%s\" incomplete, missing %s"

6720 s_ID

(sock, w +

sizeof

(w)/2), w,

6721

port ?

"host"

: &

"host:port"

[x_msgsize ? 5 : 0]));

6735 if

(x_msgsize <=

sizeof

(w))

6737 else if

(!(x_msg =

malloc

(x_msgsize)))

6744

addrlen = ipv4 ?

sizeof

(u.in) :

sizeof

(u.in6);

6745

memset(&u, 0, addrlen);

6746

u.sa.sa_family = ipv4 ? AF_INET : AF_INET6;

6748

u.sa.sa_len = addrlen;

6752

u.in.sin_port = htons(port);

6754

memcpy(&u.in6.sin6_addr, &

sizeof

(u.in6.sin6_addr));

6755

u.in6.sin6_port = htons(port);

6763

&u.sa, addrlen)) >= 0) {

6771 if

((

size_t

) x_written != x_msgsize) {

6772

sock->

= status = eIO_Closed;

6778

(

"%s[DSOCK::SendMsg] " 6779 " Partial datagram sent (%lu out of %lu)%s%s"

6780 s_ID

(sock, w +

sizeof

(w)/2),

6781

(

unsigned long

) x_written,

6782

(

unsigned long

) x_msgsize, *w ?

" to "

""

, w));

6790 #ifdef NCBI_OS_MSWIN 6828 error

, strerr ? strerr :

""

6829

(

"%s[DSOCK::SendMsg] " 6830 " Failed sendto(%s)"

6831 s_ID

(sock, w +

sizeof

(w)/2), w));

6839 if

(x_msg && x_msg != w)

6850 #ifndef NCBI_CXX_TOOLKIT 6855 #elif defined(NCBI_OS_UNIX) 6858 # define MAX_TRIGGER_BUF PIPE_SIZE 6860 # define MAX_TRIGGER_BUF 8192 6866 ssize_t

x_read = read(trigger->

, x_buf,

sizeof

(x_buf));

6873 if

((

= errno) == EAGAIN ||

== EWOULDBLOCK)

6881 #elif defined(NCBI_OS_MSWIN) 6883 switch

(WaitForSingleObject(trigger->

, 0)) {

6917 #ifndef NCBI_CXX_TOOLKIT 6921 #elif defined(NCBI_OS_UNIX) 6927

err = pipe2(fd, O_NONBLOCK | O_CLOEXEC);

6933

(

"TRIGGER#%u[?]: [TRIGGER::Create] " 6934 " Cannot create pipe"

, x_id));

6941 # ifdef F_DUPFD_CLOEXEC 6942

fd[2] = fcntl(fd[1], F_DUPFD_CLOEXEC,

FD_SETSIZE

);

6949 # if defined(RLIMIT_NOFILE) 6951 if

(getrlimit(RLIMIT_NOFILE, &rl) == 0

6955 # elif defined(NCBI_OS_BSD) || defined(NCBI_OS_DARWIN) 6961

(

"TRIGGER#%u[?]: [TRIGGER::Create] " 6962 " Failed to dup(%d) to higher fd(%d+)"

6970 # ifdef F_DUPFD_CLOEXEC 6971 assert

((fd[2]=fcntl(fd[1],F_GETFD,0))!=-1 && (fd[2] & FD_CLOEXEC));

6975

(

"TRIGGER#%u[?]: [TRIGGER::Create] " 6976 " Failed to set close-on-exec"

, x_id));

6987

(

"TRIGGER#%u[?]: [TRIGGER::Create] " 6988 " Failed to set non-blocking mode"

, x_id));

7002 if

(err && err != -1) {

7004

(

"TRIGGER#%u[?]: [TRIGGER::Create] " 7005 " Failed to set close-on-exec"

, x_id));

7008 if

(!(*trigger = (

TRIGGER

)

(1,

sizeof

(**trigger)))) {

7013

(*trigger)->fd = fd[0];

7014

(*trigger)->id = x_id;

7015

(*trigger)->out = fd[1];

7017

(*trigger)->log =

;

7023

(

"TRIGGER#%u[%u, %u]: Ready"

, x_id, fd[0], fd[1]));

7028 #elif defined(NCBI_OS_MSWIN) 7030 HANDLE event

= WSACreateEvent();

7032 DWORD

err = GetLastError();

7035

err, strerr ? strerr :

""

7036

(

"TRIGGER#%u: [TRIGGER::Create] " 7037 " Cannot create event object"

, x_id));

7041 if

(!(*trigger = (

TRIGGER

)

(1,

sizeof

(**trigger)))) {

7042

WSACloseEvent(event);

7045

(*trigger)->fd = event;

7046

(*trigger)->id = x_id;

7048

(*trigger)->log =

;

7054

(

"TRIGGER#%u: Ready"

, x_id));

7060 # error "Unsupported platform" 7070 #ifndef NCBI_CXX_TOOLKIT 7079

(

"TRIGGER#%u[%u]: Closing"

, trigger->

));

7082 # if defined(NCBI_OS_UNIX) 7088 # elif defined(NCBI_OS_MSWIN) 7090

WSACloseEvent(trigger->

);

7106 #ifndef NCBI_CXX_TOOLKIT 7110 #elif defined(NCBI_OS_UNIX) 7113 if

(write(trigger->

out

""

, 1) < 0 && errno != EAGAIN)

7119 #elif defined(NCBI_OS_MSWIN) 7139

trigger->

isset

ptr

= (

void

*) 1

;

7146 return

status ==

eIO_Timeout

? eIO_Closed : status;

7161 #if defined(NCBI_OS_UNIX) 7163

trigger->

isset

ptr

= (

void

*) 0

;

7165 #elif defined(NCBI_OS_MSWIN) 7167 if

(!WSAResetEvent(trigger->

))

7183 unsigned short

backlog,

7193 unsigned short

backlog,

7204 unsigned short

backlog,

7215 unsigned short

backlog,

7227 unsigned short

backlog,

7232 if

(!path || !*path)

7279 if

(!handle || handle_size !=

sizeof

(lsock->

)) {

7281

(

"LSOCK#%u[%u]: [LSOCK::GetOSHandle] " 7282 " Invalid handle%s %lu"

7283

lsock->

, (

unsigned int

) lsock->

7284

handle ?

" size"

""

7285

handle ? (

unsigned long

) handle_size : 0UL));

7291

memcpy(handle, &fd, handle_size);

7295

memcpy(handle, &fd, handle_size);

7297

status = eIO_Closed;

7320 unsigned short

port;

7327 unsigned int

* host,

7328 unsigned short

* port,

7337 unsigned short

* port,

7366 unsigned short

port,

7383 unsigned short

port,

7392 unsigned short

port,

7400

memset(&

, 0,

sizeof

(

));

7416 if

(!path || !*path)

7418 #ifndef NCBI_OS_UNIX 7423

memset(&

, 0,

sizeof

(

));

7465

memset(&

, 0,

sizeof

(

));

7475 unsigned short

port,

7482

(

"%s[SOCK::Reconnect] " 7483 " Datagram socket"

7490 if

(sock->

[0] && (host || port)) {

7492

(

"%s[SOCK::Reconnect] " 7493 " Unable to reconnect UNIX socket as INET at \"%s:%hu\""

7494 s_ID

(sock, _id), host ? host :

""

, port));

7503

(

"%s[SOCK::Reconnect] " 7504 " Attempt to reconnect server-side socket as" 7505 " client one to its peer address"

7527 return s_Connect

(sock, host, port, timeout);

7539

(

"%s[SOCK::Shutdown] " 7546

(

"%s[SOCK::Shutdown] " 7547 " Datagram socket"

7554

(

"%s[SOCK::Shutdown] " 7555 " Invalid direction #%u"

7556 s_ID

(sock, _id), (

unsigned int

) dir));

7564

memset(&

, 0,

sizeof

(

));

7577 info

.status = status;

7591

status = eIO_Closed;

7633 if

(!handle || handle_size !=

sizeof

(sock->

)) {

7636

(

"%s[SOCK::GetOSHandle] " 7637 " Invalid handle%s %lu"

7639

handle ?

" size"

""

7640

handle ? (

unsigned long

) handle_size : 0UL));

7646

memcpy(handle, &fd, handle_size);

7650

memcpy(handle, &fd, handle_size);

7652

status = eIO_Closed;

7678 if

(!handle || handle_size !=

sizeof

(fd))

7681

memcpy(&fd, handle,

sizeof

(fd));

7688

setsockopt(fd, SOL_SOCKET, SO_LINGER, (

char

*) &

sizeof

(

));

7692

setsockopt(fd, IPPROTO_TCP, TCP_LINGER2, (

char

*) &no,

sizeof

(no));

7707 #ifdef NCBI_OS_MSWIN 7708 if

(

== WSANOTINITIALISED) {

7717

status = eIO_Closed;

7774 if

(sock->

== eIO_Closed) {

7776

(

"%s[SOCK::Wait(R)] " 7777 " Socket already %s"

7778 s_ID

(sock, _id), sock->

"closed"

"shut down"

));

7788 if

(sock->

== eIO_Closed) {

7790

(

"%s[SOCK::Wait(W)] " 7791 " Socket already shut down"

7800 if

((sock->

== eIO_Closed || sock->

) &&

7802 if

(sock->

== eIO_Closed) {

7804

(

"%s[SOCK::Wait(RW)] " 7805 " Socket already shut down"

7810 if

(sock->

== eIO_Closed || sock->

) {

7811 if

(sock->

== eIO_Closed) {

7813

(

"%s[SOCK::Wait(RW)] " 7814 " Socket already %s"

7816

"closed"

"shut down for reading"

));

7821 if

(sock->

== eIO_Closed) {

7823

(

"%s[SOCK::Wait(RW)] " 7824 " Socket already shut down for writing"

7834 " Invalid event #%u"

7835 s_ID

(sock, _id), (

unsigned int

) event));

7841

status =

s_Wait

(sock, event, timeout);

7845

memset(&

, 0,

sizeof

(

));

7857 info

.event = event;

7858 info

.status = status;

7881

g_MONKEY_Poll(&

, &polls, &mnk_status);

7895 for

(

= 0;

; ++

) {

7898 if

(!(sock = polls[

].sock) || !(event = polls[

].event)) {

7925

&& (sock->

== eIO_Closed || sock->

)) ||

7927

&& sock->

== eIO_Closed)) {

7943 for

(

= 0;

; ++

) {

7951 if

(orig_polls != polls) {

7953 size_t

orig_iter, new_iter;

7954 for

(orig_iter = 0; orig_iter < orig_n; ++orig_iter) {

7955 for

(new_iter = 0; new_iter <

; ++new_iter) {

7956 if

(orig_polls[orig_iter].sock == polls[new_iter].sock) {

7957

orig_polls[orig_iter] = polls[new_iter];

7966 if

(mnk_status != -1)

7967

status = mnk_status;

8002

(

"%s[SOCK::SetTimeout] " 8003 " Invalid event #%u"

8004 s_ID

(sock, _id), (

unsigned int

) event));

8024 if

(sock->

.tv_sec > sock->

.tv_sec)

8026 if

(sock->

.tv_sec > sock->

.tv_sec)

8029 return

sock->

.tv_usec > sock->

.tv_usec

8043

(

"%s[SOCK::GetTimeout] " 8044 " Invalid event #%u"

8045 s_ID

(sock, _id), (

unsigned int

) event));

8074

x_buf = (

char

;

8078

status =

s_Read

(sock, x_buf,

8079 size

, &xx_read, 0

);

8090 " Unsupported read method #%u"

8091 s_ID

(sock, _id), (

unsigned int

) how));

8112 #define s_Pushback(s, d, n) BUF_Pushback(&(s)->r_buf, d, n) 8120 unsigned int

cr_seen,

done

;

8127 if

|| !line) {

8133

(

"%s[SOCK::ReadLine] " 8140

cr_seen =

done

= 0

;

8144 char

* x_buf =

sizeof

(w) - cr_seen ? w : line +

;

8146 x_size

sizeof

(w) - cr_seen;

8162

line[

++] =

'\r'

;

8186

(

"%s[SOCK::ReadLine] " 8187 " Cannot pushback extra CR"

8203

(

"%s[SOCK::ReadLine] " 8204 " Cannot pushback extra data (%lu byte%s)"

8217

line[

] =

'\0'

;

8236

(

"%s[SOCK::Pushback] " 8249 switch

(direction) {

8290 const char

* x_data;

8295

(

"%s[SOCK::Write] " 8296 " OOB not supported for datagrams"

8311

x_data = (

const char

;

8314

status =

s_Write

(sock, x_data,

8315 size

, &xx_written, 0);

8316

x_written += xx_written;

8317

x_data += xx_written;

8324

(

"%s[SOCK::Write] " 8325 " Unsupported write method #%u"

8326 s_ID

(sock, _id), (

unsigned int

) how));

8334

(

"%s[SOCK::Write] " 8337

status = eIO_Closed;

8342

*n_written = x_written;

8353

(

"%s[SOCK::Abort] " 8360

(

"%s[SOCK::Abort] " 8361 " Datagram socket"

8375 unsigned short

port;

8381 if

(sock->

[0])

8385 if

(trueport || !sock->

myport

) {

8403 unsigned int

* host,

8404 unsigned short

* port,

8417

? ntohl(x_host) : x_host;

8421

? sock->

: ntohs(sock->

);

8428 unsigned short

* port,

8433

memset(

, 0,

sizeof

));

8443

? sock->

: ntohs(sock->

);

8451 unsigned short

port;

8479

memcpy(

, path,

+ 1);

8493 if

((

= (

size_t

) sprintf(port,

"%hu"

, sock->

)) <

)

8494

memcpy(

, port,

+ 1);

8553

(

"%s[SOCK::DisableOSSendDelay] " 8560

(

"%s[SOCK::DisableOSSendDelay] " 8561 " Datagram socket"

8568 if

(setsockopt(sock->

, IPPROTO_TCP, TCP_NODELAY,

8569

(

char

*) &on_off,

sizeof

(on_off)) != 0) {

8573 error

, strerr ? strerr :

""

8574

(

"%s[SOCK::DisableOSSendDelay] " 8575 " Failed setsockopt(%sTCP_NODELAY)"

8576 s_ID

(sock, _id), on_off ?

""

"!"

));

8593

(

"%s[SOCK::SetCork] " 8600

(

"%s[SOCK::SetCork] " 8601 " Datagram socket"

8607 #if defined(TCP_CORK) && !defined(NCBI_OS_CYGWIN) 8608 if

(setsockopt(sock->

, IPPROTO_TCP, TCP_CORK,

8609

(

char

*) &on_off,

sizeof

(on_off)) != 0) {

8613 error

, strerr ? strerr :

""

8614

(

"%s[SOCK::SetCork] " 8615 " Failed setsockopt(%sTCP_CORK)"

8616 s_ID

(sock, _id), on_off ?

""

"!"

));

8622

(void) send(sock->

, _id

, 0, 0);

8641 #ifdef NCBI_OS_MSWIN 8656 #ifdef SOCK_NONBLOCK 8657 type

|= SOCK_NONBLOCK;

8661 type

|= SOCK_CLOEXEC;

8669 error

, strerr ? strerr :

""

8670

(

"DSOCK#%u[?]: [DSOCK::Create] " 8671 " Cannot create socket"

8677 #if defined(NCBI_OS_MSWIN) 8678 if

(!(event = WSACreateEvent())) {

8679 DWORD

err = GetLastError();

8682

err, strerr ? strerr :

""

8683

(

"DSOCK#%u[%u]: [DSOCK::Create] " 8684 " Failed to create IO event"

8685

x_id, (

unsigned int

) fd));

8691 if

(WSAEventSelect(fd, event, SOCK_EVENTS) != 0) {

8694 error

, strerr ? strerr :

""

8695

(

"DSOCK#%u[%u]: [DSOCK::Create] " 8696 " Failed to bind IO event"

8697

x_id, (

unsigned int

) fd));

8700

WSACloseEvent(event);

8703 #elif !defined(SOCK_NONBLOCK) 8708 error

, strerr ? strerr :

""

8709

(

"DSOCK#%u[%u]: [DSOCK::Create] " 8710 " Cannot set socket to non-blocking mode"

8711

x_id, (

unsigned int

) fd));

8718 if

(!(x_sock = (

)

(1,

sizeof

(*x_sock)))) {

8720 #ifdef NCBI_OS_MSWIN 8721

WSACloseEvent(event);

8735 #ifdef NCBI_OS_MSWIN 8736

x_sock->

= event;

8744 #ifndef SOCK_CLOEXEC 8746 const char

* strerr;

8748 # ifdef NCBI_OS_MSWIN 8749 DWORD

err = GetLastError();

8757 error

, strerr ? strerr :

""

8758

(

"%s[DSOCK::Create] Cannot set" 8759 " socket close-on-exec mode"

8760 s_ID

(*sock, _id)));

8761 # ifdef NCBI_OS_MSWIN 8785 unsigned short

port,

8792 struct

sockaddr_in

;

8793 struct

sockaddr_in6 in6;

8800

(

"%s[DSOCK::Bind] " 8807

(

"%s[DSOCK::Bind] " 8808 " Not a datagram socket"

8831 assert

(family == AF_INET || family == AF_INET6);

8832

addrlen = family == AF_INET6 ?

sizeof

(u.in6) :

sizeof

(u.in);

8834

memset(&u, 0, addrlen);

8835

u.sa.sa_family = family;

8837

u.sa.sa_len = addrlen;

8839 if

(family == AF_INET) {

8841

u.in.sin_port = htons(port);

8843

u.in6.sin6_port = htons(port);

8844 if

(bind(sock->

, &u.sa, addrlen) != 0) {

8854 error

, strerr ? strerr :

""

8855

(

"%s[DSOCK::Bind] " 8856 " Failed bind(:%hu)"

8857 s_ID

(sock, _id), port));

8862 assert

(u.sa.sa_family == family);

8863 error

= getsockname(sock->

, &u.sa, &addrlen) != 0

8866 switch

(u.sa.sa_family) {

8868

port = htons(u.in.sin_port);

8871

port = htons(u.in6.sin6_port);

8878 if

(

|| !port) {

8881 error

, strerr ? strerr :

""

8882

(

"%s[DSOCK::Bind] " 8883 " Cannot obtain a free socket port"

8901 unsigned short

port)

8909 unsigned short

port)

8914 struct

sockaddr_in

;

8915 struct

sockaddr_in6 in6;

8923

(

"%s[DSOCK::Connect] " 8930

(

"%s[DSOCK::Connect] " 8931 " Not a datagram socket"

8947 if

(!host != !port) {

8950

sprintf(addrstr,

":%hu"

, port);

8954

(

"%s[DSOCK::Connect] " 8955 " Address \"%.*s%s\" incomplete, missing %s"

8957

addrstr, port ?

"host"

"port"

));

8961

memset(&

, 0,

sizeof

(

));

8964

(

"%s[DSOCK::Connect] " 8965 " Failed SOCK_gethostbyname(\"%.*s\")"

8974

addrlen = ipv4 ?

sizeof

(u.in) :

sizeof

(u.in6);

8975

memset(&u, 0, addrlen);

8976

u.sa.sa_family = ipv4 ? AF_INET : AF_INET6;

8979

u.in.sin_port = htons(port);

8981

memcpy(&u.in6.sin6_addr, &

sizeof

(u.in6.sin6_addr));

8982

u.in6.sin6_port = htons(port);

8985

addrlen =

sizeof

(u.sa);

8986

memset(&u, 0, addrlen);

8987

u.sa.sa_family = AF_UNSPEC;

8990

u.sa.sa_len = addrlen;

8992 if

(connect(sock->

, &u.sa, addrlen) != 0) {

8995 if

(port | sock->

) {

8998

port ? port : sock->

8999

addrstr,

sizeof

(addrstr));

9003 error

, strerr ? strerr :

""

9004

(

"%s[DSOCK::Connect] " 9005 " Failed %sconnect%s%s"

9006 s_ID

(sock, _id), port ?

""

"to dis"

9007

!*addrstr ?

""

: port ?

" to "

" from "

9008

!*addrstr ? addrstr :

" (not connected)"

));

9033

(

"%s[DSOCK::WaitMsg] " 9040

(

"%s[DSOCK::WaitMsg] " 9041 " Not a datagram socket"

9054

status = eIO_Closed;

9059

memset(&

, 0,

sizeof

(

));

9066 info

.status = status;

9079 unsigned short

* sender_port)

9087

memset(sender_addr, 0,

sizeof

(*sender_addr));

9093

(

"%s[DSOCK::RecvMsg] " 9100

(

"%s[DSOCK::RecvMsg] " 9101 " Not a datagram socket"

9108

sender_addr, sender_port);

9112

memset(&

, 0,

sizeof

(

));

9119 info

.status = status;

9131 unsigned int

* sender_addr,

9132 unsigned short

* sender_port)

9136

, sender_port);

9145 unsigned short

port,

9154

(

"%s[DSOCK::SendMsg] " 9161

(

"%s[DSOCK::SendMsg] " 9162 " Not a datagram socket"

9174

memset(&

, 0,

sizeof

(

));

9182 info

.port = port ? port : sock->

;

9184 info

.status = status;

9199

(

"%s[DSOCK::WipeMsg] " 9206

(

"%s[DSOCK::WipeMsg] " 9207 " Not a datagram socket"

9213 switch

(direction) {

9226

(

"%s[DSOCK::WipeMsg] " 9227 " Invalid direction #%u"

9228 s_ID

(sock, _id), (

unsigned int

) direction));

9245

(

"%s[DSOCK::SetBroadcast] " 9252

(

"%s[DSOCK::SetBroadcast] " 9253 " Not a datagram socket"

9259 #if defined(NCBI_OS_UNIX) || defined(NCBI_OS_MSWIN) 9262 # ifdef NCBI_OS_MSWIN 9263 BOOL

bcast = !!on_off;

9265 int

bcast = !!on_off;

9267 if

(setsockopt(sock->

, SOL_SOCKET, SO_BROADCAST,

9268

(

char

*) &bcast,

sizeof

(bcast)) != 0) {

9272 error

, strerr ? strerr :

""

9273

(

"%s[DSOCK::SetBroadcast] " 9274 " Failed setsockopt(%sBROADCAST)"

9275 s_ID

(sock, _id), bcast ?

""

"NO"

));

9291 switch

(direction) {

9293 return

sock->

n_in

;

9295 return

sock->

n_out

;

9347 error

, strerr ? strerr :

""

9348

(

"%s[SOCK::SetReuseAddress] " 9349 " Failed setsockopt(%sREUSEADDR)"

9350 s_ID

(sock, _id), on_off ?

""

"NO"

));

9432 switch

(direction) {

9454 switch

(direction) {

9472 switch

(direction) {

9562 const unsigned char

= (

const unsigned char

*) &host;

9563 int len

= sprintf(x_buf,

"%u.%u.%u.%u"

[0],

[1],

[2],

[3]);

9566

memcpy(

, x_buf, (

size_t

)

+ 1);

9590 val

= strtoul(

, &end, 0);

9591 if

(errno ||

== end)

9593 if

(fullquad && *

'0'

&& (

size_t

)(end -

) > 1)

9606

(!fullquad || dots == 3) &&

val

<= (0xFFFFFFFFUL >> (dots << 3));

9623 return

end && !*end;

9635 return

htonl(

);

9641 return

htons(

);

9647 return

htonl(

);

9653 return

htons(

);

9811

memset(loop->

, 0,

sizeof

(loop->

) - 1);

9812

loop->

[

sizeof

(loop->

) - 1] = 1;

9826 unsigned int addr

= ntohl(

);

9827 #if defined(IN_CLASSA) && defined(IN_CLASSA_NET) && defined(IN_CLASSA_NSHIFT) 9828 return

IN_CLASSA(

)

9844 if

(

->octet[

sizeof

(