Home
last modified time | relevance | path

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

123

/freebsd/tests/sys/kqueue/libkqueue/
H A Dread.c19 static int sockfd[2]; variable
28 if (read(sockfd[0], &buf[0], 1) < 1) in kevent_socket_drain()
36 if (write(sockfd[1], ".", 1) < 1) in kevent_socket_fill()
48 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]); in test_kevent_socket_add()
63 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD, 0, 0, &sockfd[0]); in test_kevent_socket_get()
92 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, &sockfd[0]); in test_kevent_socket_clear()
109 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]); in test_kevent_socket_clear()
131 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_DISABLE, 0, 0, &sockfd[0]); in test_kevent_socket_disable_and_enable()
162 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_DELETE, 0, 0, &sockfd[0]); in test_kevent_socket_del()
183 EV_SET(&kev, sockfd[0], EVFILT_READ, EV_ADD | EV_ONESHOT, 0, 0, &sockfd[0]); in test_kevent_socket_oneshot()
[all …]
/freebsd/contrib/ldns/
H A Dnet.c113 ldns_sock_nonblock(int sockfd) in ldns_sock_nonblock() argument
117 if((flag = fcntl(sockfd, F_GETFL)) != -1) { in ldns_sock_nonblock()
119 if(fcntl(sockfd, F_SETFL, flag) == -1) { in ldns_sock_nonblock()
125 if(ioctlsocket(sockfd, FIONBIO, &on) != 0) { in ldns_sock_nonblock()
133 ldns_sock_block(int sockfd) in ldns_sock_block() argument
137 if((flag = fcntl(sockfd, F_GETFL)) != -1) { in ldns_sock_block()
139 if(fcntl(sockfd, F_SETFL, flag) == -1) { in ldns_sock_block()
145 if(ioctlsocket(sockfd, FIONBIO, &off) != 0) { in ldns_sock_block()
153 ldns_sock_wait(int sockfd, struct timeval timeout, int write) in ldns_sock_wait() argument
160 FD_SET(FD_SET_T sockfd, &fds); in ldns_sock_wait()
[all …]
/freebsd/tests/sys/audit/
H A Dnetwork.c44 static int sockfd, sockfd2, connectfd; variable
123 ATF_REQUIRE((sockfd = socket(PF_UNIX, SOCK_STREAM, 0)) != -1); in ATF_TC_BODY()
125 snprintf(extregex, sizeof(extregex), "socket.*ret.*success,%d", sockfd); in ATF_TC_BODY()
127 close(sockfd); in ATF_TC_BODY()
215 ATF_REQUIRE((sockfd = socket(PF_UNIX, SOCK_STREAM, 0)) != -1); in ATF_TC_BODY()
218 "setsockopt.*0x%x.*return,success", sockfd); in ATF_TC_BODY()
221 ATF_REQUIRE_EQ(0, setsockopt(sockfd, SOL_SOCKET, in ATF_TC_BODY()
224 close(sockfd); in ATF_TC_BODY()
266 ATF_REQUIRE((sockfd = socket(PF_UNIX, SOCK_STREAM, 0)) != -1); in ATF_TC_BODY()
272 ATF_REQUIRE_EQ(0, bind(sockfd, (struct sockaddr *)&server, len)); in ATF_TC_BODY()
[all …]
/freebsd/contrib/ofed/libibverbs/examples/
H A Dxsrq_pingpong.c72 int sockfd; member
320 int sockfd = ctx.rem_dest[index].sockfd; in recv_termination_ack() local
323 r = read(sockfd, msg + n, TERMINATION_MSG_SIZE - n); in recv_termination_ack()
345 int sockfd = ctx.rem_dest[index].sockfd; in send_termination_ack() local
349 if (write(sockfd, msg, TERMINATION_MSG_SIZE) != TERMINATION_MSG_SIZE) { in send_termination_ack()
384 static int send_local_dest(int sockfd, int index) in send_local_dest() argument
418 if (write(sockfd, msg, MSG_SIZE) != MSG_SIZE) { in send_local_dest()
426 static int recv_remote_dest(int sockfd, int index) in recv_remote_dest() argument
434 r = read(sockfd, msg + n, MSG_SIZE - n); in recv_remote_dest()
455 rem_dest->sockfd = sockfd; in recv_remote_dest()
[all …]
H A Duc_pingpong.c136 int sockfd = -1; in pp_client_exch_dest() local
152 sockfd = socket(t->ai_family, t->ai_socktype, t->ai_protocol); in pp_client_exch_dest()
153 if (sockfd >= 0) { in pp_client_exch_dest()
154 if (!connect(sockfd, t->ai_addr, t->ai_addrlen)) in pp_client_exch_dest()
156 close(sockfd); in pp_client_exch_dest()
157 sockfd = -1; in pp_client_exch_dest()
164 if (sockfd < 0) { in pp_client_exch_dest()
172 if (write(sockfd, msg, sizeof msg) != sizeof msg) { in pp_client_exch_dest()
177 if (read(sockfd, msg, sizeof msg) != sizeof msg || in pp_client_exch_dest()
178 write(sockfd, "done", sizeof "done") != sizeof "done") { in pp_client_exch_dest()
[all …]
H A Dud_pingpong.c136 int sockfd = -1; in pp_client_exch_dest() local
152 sockfd = socket(t->ai_family, t->ai_socktype, t->ai_protocol); in pp_client_exch_dest()
153 if (sockfd >= 0) { in pp_client_exch_dest()
154 if (!connect(sockfd, t->ai_addr, t->ai_addrlen)) in pp_client_exch_dest()
156 close(sockfd); in pp_client_exch_dest()
157 sockfd = -1; in pp_client_exch_dest()
164 if (sockfd < 0) { in pp_client_exch_dest()
172 if (write(sockfd, msg, sizeof msg) != sizeof msg) { in pp_client_exch_dest()
177 if (read(sockfd, msg, sizeof msg) != sizeof msg || in pp_client_exch_dest()
178 write(sockfd, "done", sizeof "done") != sizeof "done") { in pp_client_exch_dest()
[all …]
H A Drc_pingpong.c163 int sockfd = -1; in pp_client_exch_dest() local
179 sockfd = socket(t->ai_family, t->ai_socktype, t->ai_protocol); in pp_client_exch_dest()
180 if (sockfd >= 0) { in pp_client_exch_dest()
181 if (!connect(sockfd, t->ai_addr, t->ai_addrlen)) in pp_client_exch_dest()
183 close(sockfd); in pp_client_exch_dest()
184 sockfd = -1; in pp_client_exch_dest()
191 if (sockfd < 0) { in pp_client_exch_dest()
199 if (write(sockfd, msg, sizeof msg) != sizeof msg) { in pp_client_exch_dest()
204 if (read(sockfd, msg, sizeof msg) != sizeof msg || in pp_client_exch_dest()
205 write(sockfd, "done", sizeof "done") != sizeof "done") { in pp_client_exch_dest()
[all …]
H A Dsrq_pingpong.c158 int sockfd = -1; in pp_client_exch_dest() local
174 sockfd = socket(t->ai_family, t->ai_socktype, t->ai_protocol); in pp_client_exch_dest()
175 if (sockfd >= 0) { in pp_client_exch_dest()
176 if (!connect(sockfd, t->ai_addr, t->ai_addrlen)) in pp_client_exch_dest()
178 close(sockfd); in pp_client_exch_dest()
179 sockfd = -1; in pp_client_exch_dest()
186 if (sockfd < 0) { in pp_client_exch_dest()
195 if (write(sockfd, msg, sizeof msg) != sizeof msg) { in pp_client_exch_dest()
208 r = read(sockfd, msg + n, sizeof msg - n); in pp_client_exch_dest()
223 if (write(sockfd, "done", sizeof "done") != sizeof "done") { in pp_client_exch_dest()
[all …]
/freebsd/tools/test/stress2/misc/
H A Ddatagram2.sh64 int sockfd;
71 if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1)
74 if (bind(sockfd, (struct sockaddr *) &addr,
78 if (connect(sockfd, (struct sockaddr *) &addr,
89 m.fd = sockfd;
90 len = sendmsg(sockfd, &mh, 0);
H A Ddatagram3.sh64 int i, sockfd;
71 if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1)
74 if (bind(sockfd, (struct sockaddr *) &addr,
78 if (connect(sockfd, (struct sockaddr *) &addr,
90 m.fd = sockfd;
91 len = sendmsg(sockfd, &mh, 0);
H A Ddatagram.sh62 int sockfd;
70 if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1)
73 if (bind(sockfd, (struct sockaddr *) &addr,
77 if (connect(sockfd, (struct sockaddr *) &addr,
81 (void)read(sockfd, buf, sizeof(buf));
/freebsd/contrib/openbsm/bin/auditdistd/
H A Dproto_tls.c267 tls_loop(int sockfd, SSL *tcpssl) in tls_loop() argument
277 FD_SET(sockfd, &fds); in tls_loop()
279 maxfd = MAX(sockfd, tcpfd); in tls_loop()
287 if (FD_ISSET(sockfd, &fds)) in tls_loop()
288 tcp_recv_ssl_send(sockfd, tcpssl); in tls_loop()
290 ssl_recv_tcp_send(tcpssl, sockfd); in tls_loop()
344 int sockfd, tcpfd; in tls_exec_client() local
354 sockfd = startfd; in tls_exec_client()
412 nonblock(sockfd); in tls_exec_client()
422 switch (send(sockfd, &connected, sizeof(connected), 0)) { in tls_exec_client()
[all …]
/freebsd/usr.sbin/nscd/
H A Dnscdcli.c72 s_result = write(connection->sockfd, in safe_write()
109 s_result = read(connection->sockfd, in safe_read()
155 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, in send_credentials()
161 result = sendmsg(connection->sockfd, &mhdr, 0) == -1 ? -1 : 0; in send_credentials()
162 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, in send_credentials()
204 retval->sockfd = client_socket; in open_nscd_connection__()
209 EV_SET(&eventlist, retval->sockfd, EVFILT_WRITE, EV_ADD, in open_nscd_connection__()
216 EV_SET(&eventlist, retval->sockfd, EVFILT_READ, EV_ADD, in open_nscd_connection__()
231 close(connection->sockfd); in close_nscd_connection__()
H A Dnscd.c166 retval->sockfd = socket(PF_LOCAL, SOCK_STREAM, 0); in init_runtime_env()
178 if (bind(retval->sockfd, (struct sockaddr *)&serv_addr, in init_runtime_env()
180 close(retval->sockfd); in init_runtime_env()
196 listen(retval->sockfd, -1); in init_runtime_env()
197 fcntl(retval->sockfd, F_SETFL, O_NONBLOCK); in init_runtime_env()
202 EV_SET(&eventlist, retval->sockfd, EVFILT_READ, EV_ADD | EV_ONESHOT, in init_runtime_env()
217 close(env->sockfd); in destroy_runtime_env()
506 if ((int)event_data->ident == env->sockfd) { in processing_loop()
510 EV_SET(eventlist, s_runtime_env->sockfd, in processing_loop()
H A Dsingletons.h36 int sockfd; member
H A Dnscdcli.h36 int sockfd; member
/freebsd/contrib/ldns/ldns/
H A Dnet.h175 ssize_t ldns_tcp_send_query(ldns_buffer *qbin, int sockfd, const struct sockaddr_storage *to, sockl…
186 ssize_t ldns_udp_send_query(ldns_buffer *qbin, int sockfd, const struct sockaddr_storage *to, sockl…
197 uint8_t *ldns_tcp_read_wire_timeout(int sockfd, size_t *size, struct timeval timeout);
208 uint8_t *ldns_tcp_read_wire(int sockfd, size_t *size);
220 uint8_t *ldns_udp_read_wire(int sockfd, size_t *size, struct sockaddr_storage *fr, socklen_t *frlen…
H A Dnet.h.in170 * \param[in] sockfd the socket to use
175 ssize_t ldns_tcp_send_query(ldns_buffer *qbin, int sockfd, const struct sockaddr_storage *to, sockl…
181 * \param[in] sockfd the socket to use
186 ssize_t ldns_udp_send_query(ldns_buffer *qbin, int sockfd, const struct sockaddr_storage *to, sockl…
192 * \param[in] sockfd the socket to read from
197 uint8_t *ldns_tcp_read_wire_timeout(int sockfd, size_t *size, struct timeval timeout);
204 * \param[in] sockfd the socket to read from
208 uint8_t *ldns_tcp_read_wire(int sockfd, size_t *size);
214 * \param[in] sockfd the socket to read from
220 uint8_t *ldns_udp_read_wire(int sockfd, size_t *size, struct sockaddr_storage *fr, socklen_t *frlen…
/freebsd/lib/libc/net/
H A Dnscachedcli.c77 s_result = _sendto(connection->sockfd, data + result, in safe_write()
120 s_result = _read(connection->sockfd, data + result, in safe_read()
168 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, in send_credentials()
175 result = _sendmsg(connection->sockfd, &mhdr, in send_credentials()
177 EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, in send_credentials()
218 retval->sockfd = client_socket; in __open_cached_connection()
223 EV_SET(&eventlist, retval->sockfd, EVFILT_WRITE, EV_ADD, 0, 0, NULL); in __open_cached_connection()
229 EV_SET(&eventlist, retval->sockfd, EVFILT_READ, EV_ADD, 0, 0, NULL); in __open_cached_connection()
240 _close(connection->sockfd); in __close_cached_connection()
/freebsd/stand/libsa/
H A Dbootparam.c104 bp_whoami(int sockfd) in bp_whoami() argument
133 if (!(d = socktodesc(sockfd))) { in bp_whoami()
134 RPC_PRINTF(("bp_whoami: bad socket. %d\n", sockfd)); in bp_whoami()
232 bp_getfile(int sockfd, char *key, struct in_addr *serv_addr, char *pathname) in bp_getfile() argument
245 if (!(d = socktodesc(sockfd))) { in bp_getfile()
246 RPC_PRINTF(("bp_getfile: bad socket. %d\n", sockfd)); in bp_getfile()
/freebsd/tests/sys/kern/
H A Dunix_passfd_test.c159 sendfd_payload(int sockfd, int send_fd, void *payload, size_t paylen) in sendfd_payload() argument
178 return (sendmsg(sockfd, &msghdr, 0)); in sendfd_payload()
182 sendfd(int sockfd, int send_fd) in sendfd() argument
188 len = sendfd_payload(sockfd, send_fd, &ch, sizeof(ch)); in sendfd()
195 localcreds(int sockfd) in localcreds() argument
201 rc = getsockopt(sockfd, 0, LOCAL_CREDS, &val, &sz); in localcreds()
208 recvfd_payload(int sockfd, int *recv_fd, void *buf, size_t buflen, in recvfd_payload() argument
231 len = recvmsg(sockfd, &msghdr, recvmsg_flags); in recvfd_payload()
251 ATF_REQUIRE_MSG(!localcreds(sockfd) || foundcreds, in recvfd_payload()
260 recvfd(int sockfd, int *recv_fd, int flags) in recvfd() argument
[all …]
/freebsd/contrib/ntp/ntpdc/
H A Dntpdc.c181 static SOCKET sockfd; /* fd socket is opened on */ variable
507 closesocket(sockfd); in openhost()
537 sockfd = socket(ai->ai_family, SOCK_DGRAM, 0); in openhost()
538 if (sockfd == INVALID_SOCKET) { in openhost()
548 if (setsockopt(sockfd, SOL_SOCKET, SO_RCVBUF, in openhost()
556 if (connect(sockfd, (struct sockaddr *)&hostaddr, in openhost()
559 if (connect(sockfd, ai->ai_addr, ai->ai_addrlen) == -1) in openhost()
584 if (send(sockfd, xdata, xdatalen, 0) == -1) { in sendpkt()
665 FD_SET(sockfd, &fds); in getresponse()
666 n = select(sockfd+1, &fds, NULL, NULL, &tvo); in getresponse()
[all …]
/freebsd/contrib/capsicum-test/
H A Dsyscalls.h203 static inline int bind_(int sockfd, const struct sockaddr *addr, socklen_t addrlen) { in bind_() argument
204 …unsigned long args[3] = {(unsigned long)sockfd, (unsigned long)(intptr_t)addr, (unsigned long)addr… in bind_()
211 static inline int connect_(int sockfd, const struct sockaddr *addr, socklen_t addrlen) { in connect_() argument
212 …unsigned long args[3] = {(unsigned long)sockfd, (unsigned long)(intptr_t)addr, (unsigned long)addr… in connect_()
/freebsd/contrib/llvm-project/lldb/source/Host/common/
H A DSocket.cpp337 NativeSocket Socket::AcceptSocket(NativeSocket sockfd, struct sockaddr *addr, in AcceptSocket() argument
348 int fd = syscall(__NR_accept, sockfd, addr, addrlen); in AcceptSocket()
363 static_cast<NativeSocket>(-1), ::accept4, sockfd, addr, addrlen, flags); in AcceptSocket()
366 static_cast<NativeSocket>(-1), ::accept, sockfd, addr, addrlen); in AcceptSocket()
/freebsd/contrib/mandoc/
H A Dcatman.c53 run_mandocd(int sockfd, const char *outtype, const char* defos) in run_mandocd() argument
57 if (snprintf(sockfdstr, sizeof(sockfdstr), "%d", sockfd) == -1) in run_mandocd()

123