Home
last modified time | relevance | path

Searched refs:sockfd (Results 1 – 25 of 61) sorted by relevance

123

/curl/lib/
H A Dnonblock.c46 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 Dmemdebug.c307 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 Dmemdebug.h80 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 Dcf-socket.c113 (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 Dnonblock.h29 int curlx_nonblock(curl_socket_t sockfd, /* operate on this */
H A Dcf-socket.h69 curl_socket_t *sockfd);
84 void Curl_sndbuf_init(curl_socket_t sockfd);
H A Dtftp.c129 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 Dgopher.c137 curl_socket_t sockfd = conn->sock[FIRSTSOCKET]; in gopher_do() local
218 what = SOCKET_WRITABLE(sockfd, timeout_ms); in gopher_do()
H A Dgetinfo.c197 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 Dexternalsocket.c76 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 Dsendrecv.c34 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 Dmulti-event.c41 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 Dephiperfifo.c106 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 Dmulti-uv.c48 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 Dhiperfifo.c106 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 Devhiperfifo.c108 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 DCURLOPT_OPENSOCKETDATA.md40 /* 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 DCURLINFO_ACTIVESOCKET.md51 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 DCURLINFO_LASTSOCKET.md51 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 DCURLOPT_OPENSOCKETFUNCTION.md81 /* 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 DCURLOPT_SOCKOPTFUNCTION.md80 /* 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 Dsockfilt.c1001 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 Dcurl_multi_assign.md23 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 Dcurl_multi_socket_action.md27 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 Dvquic_int.h38 curl_socket_t sockfd; /* connected UDP socket */ member

Completed in 74 milliseconds

123