/curl/lib/ |
H A D | nonblock.c | 46 int curlx_nonblock(curl_socket_t sockfd, /* operate on this */ in curlx_nonblock() argument 52 flags = sfcntl(sockfd, F_GETFL, 0); in curlx_nonblock() 54 return sfcntl(sockfd, F_SETFL, flags | O_NONBLOCK); in curlx_nonblock() 55 return sfcntl(sockfd, F_SETFL, flags & (~O_NONBLOCK)); in curlx_nonblock() 61 return ioctl(sockfd, FIONBIO, &flags); in curlx_nonblock() 67 return ioctlsocket(sockfd, FIONBIO, &flags); in curlx_nonblock() 73 return IoctlSocket(sockfd, FIONBIO, (char *)&flags); in curlx_nonblock() 79 return setsockopt(sockfd, SOL_SOCKET, SO_NONBLOCK, &b, sizeof(b)); in curlx_nonblock()
|
H A D | memdebug.c | 307 curl_socket_t sockfd; in curl_dbg_socket() local 312 sockfd = socket(domain, type, protocol); in curl_dbg_socket() 314 if(source && (sockfd != CURL_SOCKET_BAD)) in curl_dbg_socket() 316 source, line, sockfd); in curl_dbg_socket() 318 return sockfd; in curl_dbg_socket() 329 rc = send(sockfd, buf, len, flags); in curl_dbg_send() 343 rc = recv(sockfd, buf, len, flags); in curl_dbg_recv() 376 source, line, sockfd); in curl_dbg_accept() 378 return sockfd; in curl_dbg_accept() 386 source, line, sockfd); in curl_dbg_mark_sclose() [all …]
|
H A D | memdebug.h | 80 CURL_EXTERN void curl_dbg_mark_sclose(curl_socket_t sockfd, 82 CURL_EXTERN int curl_dbg_sclose(curl_socket_t sockfd, 93 CURL_EXTERN SEND_TYPE_RETV curl_dbg_send(SEND_TYPE_ARG1 sockfd, 98 CURL_EXTERN RECV_TYPE_RETV curl_dbg_recv(RECV_TYPE_ARG1 sockfd, 171 #define sclose(sockfd) curl_dbg_sclose(sockfd,__LINE__,__FILE__) argument 173 #define fake_sclose(sockfd) curl_dbg_mark_sclose(sockfd,__LINE__,__FILE__) argument
|
H A D | cf-socket.c | 113 (void)sockfd; in tcpnodelay() 123 curl_socket_t sockfd) in nosigpipe() argument 159 curl_socket_t sockfd) in tcpkeepalive() argument 168 sockfd, SOCKERRNO); in tcpkeepalive() 185 sockfd, SOCKERRNO); in tcpkeepalive() 195 sockfd, SOCKERRNO); in tcpkeepalive() 205 sockfd, SOCKERRNO); in tcpkeepalive() 215 sockfd, SOCKERRNO); in tcpkeepalive() 286 if(*sockfd == CURL_SOCKET_BAD) in socket_open() 321 return socket_open(data, addr, sockfd); in Curl_socket_open() [all …]
|
H A D | nonblock.h | 29 int curlx_nonblock(curl_socket_t sockfd, /* operate on this */
|
H A D | cf-socket.h | 69 curl_socket_t *sockfd); 84 void Curl_sndbuf_init(curl_socket_t sockfd);
|
H A D | tftp.c | 129 curl_socket_t sockfd; member 528 senddata = sendto(state->sockfd, (void *)state->spacket.data, in tftp_send_first() 613 sbytes = sendto(state->sockfd, (void *)state->spacket.data, in tftp_rx() 638 sbytes = sendto(state->sockfd, (void *)state->spacket.data, in tftp_rx() 664 sbytes = sendto(state->sockfd, (void *)state->spacket.data, in tftp_rx() 678 (void)sendto(state->sockfd, (void *)state->spacket.data, in tftp_rx() 785 sbytes = sendto(state->sockfd, (void *) state->spacket.data, in tftp_tx() 811 sbytes = sendto(state->sockfd, (void *)state->spacket.data, in tftp_tx() 1009 state->sockfd = conn->sock[FIRSTSOCKET]; in tftp_connect() 1111 state->rbytes = (int)recvfrom(state->sockfd, in tftp_receive_packet() [all …]
|
H A D | gopher.c | 137 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do() local 218 what = SOCKET_WRITABLE(sockfd, timeout_ms); in gopher_do()
|
H A D | getinfo.c | 197 curl_socket_t sockfd; in getinfo_long() local 278 sockfd = Curl_getconnectinfo(data, NULL); in getinfo_long() 282 if(sockfd != CURL_SOCKET_BAD) in getinfo_long() 283 *param_longp = (long)sockfd; in getinfo_long()
|
/curl/docs/examples/ |
H A D | externalsocket.c | 76 curl_socket_t sockfd; in opensocket() local 79 sockfd = *(curl_socket_t *)clientp; in opensocket() 82 return sockfd; in opensocket() 100 curl_socket_t sockfd; in main() local 120 sockfd = socket(AF_INET, SOCK_STREAM, 0); in main() 121 if(sockfd == CURL_SOCKET_BAD) { in main() 132 close(sockfd); in main() 138 close(sockfd); in main() 151 curl_easy_setopt(curl, CURLOPT_OPENSOCKETDATA, &sockfd); in main() 155 curl_easy_setopt(curl, CURLOPT_CLOSESOCKETDATA, &sockfd); in main() [all …]
|
H A D | sendrecv.c | 34 static int wait_on_socket(curl_socket_t sockfd, int for_recv, long timeout_ms) in wait_on_socket() argument 55 FD_SET(sockfd, &errfd); /* always check for error */ in wait_on_socket() 58 FD_SET(sockfd, &infd); in wait_on_socket() 61 FD_SET(sockfd, &outfd); in wait_on_socket() 68 res = select((int)sockfd + 1, &infd, &outfd, &errfd, &tv); in wait_on_socket() 90 curl_socket_t sockfd; in main() local 104 res = curl_easy_getinfo(curl, CURLINFO_ACTIVESOCKET, &sockfd); in main() 124 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 0, 60000L)) { in main() 149 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 1, 60000L)) { in main()
|
H A D | multi-event.c | 41 curl_socket_t sockfd; member 46 static curl_context_t *create_curl_context(curl_socket_t sockfd) in create_curl_context() argument 52 context->sockfd = sockfd; in create_curl_context() 54 context->event = event_new(base, sockfd, 0, curl_perform, context); in create_curl_context() 137 curl_multi_socket_action(curl_handle, context->sockfd, flags, in curl_perform() 191 event_assign(curl_context->event, base, curl_context->sockfd, events, in handle_socket()
|
H A D | ephiperfifo.c | 106 curl_socket_t sockfd; member 256 if(f->sockfd) { in remsock() 259 f->sockfd, strerror(errno)); in remsock() 275 if(f->sockfd) { in setsock() 278 f->sockfd, strerror(errno)); in setsock() 281 f->sockfd = s; in setsock() 417 curl_socket_t sockfd; in init_fifo() local 434 if(sockfd == -1) { in init_fifo() 439 g->fifofd = sockfd; in init_fifo() 440 g->input = fdopen(sockfd, "r"); in init_fifo() [all …]
|
H A D | multi-uv.c | 48 curl_socket_t sockfd; member 51 static curl_context_t *create_curl_context(curl_socket_t sockfd) in create_curl_context() argument 57 context->sockfd = sockfd; in create_curl_context() 59 uv_poll_init_socket(loop, &context->poll_handle, sockfd); in create_curl_context() 147 curl_multi_socket_action(curl_handle, context->sockfd, flags, in curl_perform()
|
H A D | hiperfifo.c | 106 curl_socket_t sockfd; member 256 f->sockfd = s; in setsock() 262 event_assign(&f->ev, g->evbase, f->sockfd, kind, event_cb, g); in setsock() 398 curl_socket_t sockfd; in init_fifo() local 413 sockfd = open(fifo, O_RDWR | O_NONBLOCK, 0); in init_fifo() 414 if(sockfd == -1) { in init_fifo() 418 g->input = fdopen(sockfd, "r"); in init_fifo() 421 event_assign(&g->fifo_event, g->evbase, sockfd, EV_READ|EV_PERSIST, in init_fifo()
|
H A D | evhiperfifo.c | 108 curl_socket_t sockfd; member 255 f->sockfd = s; in setsock() 260 ev_io_init(&f->ev, event_cb, f->sockfd, kind); in setsock() 396 curl_socket_t sockfd; in init_fifo() local 411 sockfd = open(fifo, O_RDWR | O_NONBLOCK, 0); in init_fifo() 412 if(sockfd == -1) { in init_fifo() 416 g->input = fdopen(sockfd, "r"); in init_fifo() 419 ev_io_init(&g->fifo_event, fifo_cb, sockfd, EV_READ); in init_fifo()
|
/curl/docs/libcurl/opts/ |
H A D | CURLOPT_OPENSOCKETDATA.md | 40 /* make libcurl use the already established socket 'sockfd' */ 46 curl_socket_t sockfd; 47 sockfd = *(curl_socket_t *)clientp; 50 return sockfd; 65 extern int sockfd; /* the already connected one */ 72 curl_easy_setopt(curl, CURLOPT_OPENSOCKETDATA, &sockfd);
|
H A D | CURLINFO_ACTIVESOCKET.md | 51 curl_socket_t sockfd; 64 res = curl_easy_getinfo(curl, CURLINFO_ACTIVESOCKET, &sockfd); 65 if(!res && sockfd != CURL_SOCKET_BAD) { 66 /* operate on sockfd */
|
H A D | CURLINFO_LASTSOCKET.md | 51 long sockfd; /* does not work on win64! */ 64 res = curl_easy_getinfo(curl, CURLINFO_LASTSOCKET, &sockfd); 65 if(!res && sockfd != -1) { 66 /* operate on sockfd */
|
H A D | CURLOPT_OPENSOCKETFUNCTION.md | 81 /* make libcurl use the already established socket 'sockfd' */ 87 curl_socket_t sockfd; 88 sockfd = *(curl_socket_t *)clientp; 91 return sockfd; 106 extern int sockfd; /* the already connected one */ 112 curl_easy_setopt(curl, CURLOPT_OPENSOCKETDATA, &sockfd);
|
H A D | CURLOPT_SOCKOPTFUNCTION.md | 80 /* make libcurl use the already established socket 'sockfd' */ 86 curl_socket_t sockfd; 87 sockfd = *(curl_socket_t *)clientp; 90 return sockfd; 105 int sockfd; /* our custom file descriptor */ 111 curl_easy_setopt(curl, CURLOPT_OPENSOCKETDATA, &sockfd);
|
/curl/tests/server/ |
H A D | sockfilt.c | 1001 sockfd = listenfd; in juggle() 1003 FD_SET(sockfd, &fds_read); in juggle() 1004 maxfd = (int)sockfd; in juggle() 1009 sockfd = *sockfdp; in juggle() 1018 maxfd = (int)sockfd; in juggle() 1024 sockfd = *sockfdp; in juggle() 1028 maxfd = (int)sockfd; in juggle() 1040 sockfd = CURL_SOCKET_BAD; in juggle() 1140 sclose(sockfd); in juggle() 1154 if((sockfd != CURL_SOCKET_BAD) && (FD_ISSET(sockfd, &fds_read)) ) { in juggle() [all …]
|
/curl/docs/libcurl/ |
H A D | curl_multi_assign.md | 23 CURLMcode curl_multi_assign(CURLM *multi_handle, curl_socket_t sockfd, 34 for the specific *sockfd* socket. 36 If the given *sockfd* is not already in use by libcurl, this function
|
H A D | curl_multi_socket_action.md | 27 curl_socket_t sockfd, 35 should call curl_multi_socket_action(3) with the **sockfd** argument 42 CURL_SOCKET_TIMEOUT to the **sockfd** parameter in order to initiate the 63 **sockfd** argument set to CURL_SOCKET_TIMEOUT. You can also use the
|
/curl/lib/vquic/ |
H A D | vquic_int.h | 38 curl_socket_t sockfd; /* connected UDP socket */ member
|