/dports/emulators/ppsspp-qt5/ppsspp-1.12.3/Common/Net/ |
H A D | HTTPServer.cpp | 291 int conn_fd = accept(listener_, &client_addr.sa, &client_addr_size); in RunSlice() local 292 if (conn_fd >= 0) { in RunSlice() 293 executor_->Run(std::bind(&Server::HandleConnection, this, conn_fd)); in RunSlice() 297 ERROR_LOG(IO, "socket accept failed: %i", conn_fd); in RunSlice() 319 void Server::HandleConnection(int conn_fd) { in HandleConnection() argument 320 Request request(conn_fd); in HandleConnection()
|
/dports/emulators/ppsspp/ppsspp-1.12.3/Common/Net/ |
H A D | HTTPServer.cpp | 291 int conn_fd = accept(listener_, &client_addr.sa, &client_addr_size); in RunSlice() local 292 if (conn_fd >= 0) { in RunSlice() 293 executor_->Run(std::bind(&Server::HandleConnection, this, conn_fd)); in RunSlice() 297 ERROR_LOG(IO, "socket accept failed: %i", conn_fd); in RunSlice() 319 void Server::HandleConnection(int conn_fd) { in HandleConnection() argument 320 Request request(conn_fd); in HandleConnection()
|
/dports/emulators/libretro-ppsspp/ppsspp-1.12.3/Common/Net/ |
H A D | HTTPServer.cpp | 291 int conn_fd = accept(listener_, &client_addr.sa, &client_addr_size); in RunSlice() local 292 if (conn_fd >= 0) { in RunSlice() 293 executor_->Run(std::bind(&Server::HandleConnection, this, conn_fd)); in RunSlice() 297 ERROR_LOG(IO, "socket accept failed: %i", conn_fd); in RunSlice() 319 void Server::HandleConnection(int conn_fd) { in HandleConnection() argument 320 Request request(conn_fd); in HandleConnection()
|
/dports/www/mini_httpd/mini_httpd-1.30/ |
H A D | mini_httpd.c | 214 static int conn_fd; variable 836 if ( conn_fd < 0 ) in main() 867 (void) close( conn_fd ); in main() 1200 SSL_set_fd( ssl, conn_fd ); in handle_request() 1446 FD_SET( conn_fd, &rfds ); in finish_request() 1806 if ( conn_fd == STDIN_FILENO || conn_fd == STDOUT_FILENO || conn_fd == STDERR_FILENO ) in do_cgi() 1810 conn_fd = newfd; in do_cgi() 1857 if ( conn_fd != STDIN_FILENO ) in do_cgi() 1900 if ( conn_fd != STDOUT_FILENO ) in do_cgi() 2034 set_ndelay( conn_fd ); in post_post_garbage_hack() [all …]
|
/dports/sysutils/fusefs-smbnetfs/smbnetfs-0.6.1/src/ |
H A D | smb_conn.c | 121 process_kill_by_smb_conn_fd(ctx->conn_fd); 122 ctx->conn_fd = -1; 134 if (ctx->conn_fd != -1){ 139 return (ctx->conn_fd != -1) ? 0 : -1; 149 ctx->conn_fd = -1; in ReportRuns() 207 bytes = writev(ctx->conn_fd, iov, 5); 302 if ((ctx == NULL) || (ctx->conn_fd == -1) || in AddChecker() 339 bytes = writev(ctx->conn_fd, iov, iov_cnt); in AddChecker() 353 FD_SET(ctx->conn_fd, &readfds); in AddChecker() 356 FD_SET(ctx->conn_fd, &exceptfds); in AddChecker() [all …]
|
H A D | smb_conn_srv.c | 102 bytes = writev(srv_ctx->conn_fd, iov, 4); 109 FD_SET(srv_ctx->conn_fd, &readfds); 112 FD_SET(srv_ctx->conn_fd, &exceptfds); 115 retval = select(srv_ctx->conn_fd + 1, &readfds, NULL, &exceptfds, &tv); 119 bytes = read(srv_ctx->conn_fd, buf, COMM_BUF_SIZE); 206 FD_SET(ctx->conn_fd, &readfds); 209 FD_SET(ctx->conn_fd, &exceptfds); 212 retval = select(ctx->conn_fd + 1, &readfds, NULL, &exceptfds, &tv); 220 if (FD_ISSET(ctx->conn_fd, &exceptfds)) goto error; 223 query_len = read(ctx->conn_fd, buf, COMM_BUF_SIZE); [all …]
|
/dports/net/http_ping/http_ping/ |
H A D | http_ping.c | 69 static int conn_fd; variable 415 conn_fd = open_client_socket(); in start_connection() 416 if ( conn_fd < 0 ) in start_connection() 438 SSL_set_fd( ssl, conn_fd ); in start_connection() 478 r = write( conn_fd, buf, b ); in start_connection() 480 r = write( conn_fd, buf, b ); in start_connection() 652 bytes_read = read( conn_fd, buf, bytes_to_read ); in handle_read() 654 bytes_read = read( conn_fd, buf, bytes_to_read ); in handle_read() 1132 (void) close( conn_fd ); in close_connection()
|
/dports/math/reduce/Reduce-svn5758-src/psl/dist/kernel/win32/ |
H A D | pslsocke.c | 73 unixclosesocket (conn_fd) in unixclosesocket() argument 74 int conn_fd; in unixclosesocket()
|
/dports/www/trafficserver/trafficserver-9.1.1/tools/http_load/ |
H A D | http_load.c | 211 int conn_fd; member 1030 if (connections[cnum].conn_fd < 0) { in start_socket() 1037 flags = fcntl(connections[cnum].conn_fd, F_GETFL, 0); in start_socket() 1040 (void)close(connections[cnum].conn_fd); in start_socket() 1045 (void)close(connections[cnum].conn_fd); in start_socket() 1054 (void)close(connections[cnum].conn_fd); in start_socket() 1065 (void)close(connections[cnum].conn_fd); in start_socket() 1081 (void)close(connections[cnum].conn_fd); in start_socket() 1186 flags = fcntl(connections[cnum].conn_fd, F_GETFL, 0); in handle_connect() 1208 (void)close(connections[cnum].conn_fd); in handle_connect() [all …]
|
/dports/security/sslsniffer/sslsniffer/ |
H A D | net_utilities.c | 207 int conn_fd; in utlnet_Accept() local 213 if((conn_fd = accept(sock_fd,(struct sockaddr *) from_addr, &size)) < 0) in utlnet_Accept() 217 return conn_fd; in utlnet_Accept()
|
/dports/www/thttpd/thttpd-2.29/ |
H A D | thttpd.c | 805 if ( ! fdwatch_check_fd( hc->conn_fd ) ) in main() 1569 httpd_set_ndelay( c->hc->conn_fd ); in handle_newconnect() 1571 fdwatch_add_fd( c->hc->conn_fd, c, FDW_READ ); in handle_newconnect() 1602 hc->conn_fd, &(hc->read_buf[hc->read_idx]), in handle_read() 1697 fdwatch_del_fd( hc->conn_fd ); in handle_read() 1769 sz = writev( hc->conn_fd, iv, 2 ); in handle_send() 1791 fdwatch_del_fd( hc->conn_fd ); in handle_send() 1876 fdwatch_del_fd( hc->conn_fd ); in handle_send() 2060 fdwatch_del_fd( c->hc->conn_fd ); in clear_connection() 2062 shutdown( c->hc->conn_fd, SHUT_WR ); in clear_connection() [all …]
|
H A D | libhttpd.c | 568 httpd_clear_ndelay( hc->conn_fd ); in httpd_write_response() 1713 if ( hc->conn_fd < 0 ) in httpd_get_conn() 1727 close( hc->conn_fd ); in httpd_get_conn() 1728 hc->conn_fd = -1; in httpd_get_conn() 2494 if ( hc->conn_fd >= 0 ) in httpd_close_conn() 2496 (void) close( hc->conn_fd ); in httpd_close_conn() 2497 hc->conn_fd = -1; in httpd_close_conn() 3262 httpd_set_ndelay( hc->conn_fd ); in post_post_garbage_hack() 3423 … if ( hc->conn_fd == STDIN_FILENO || hc->conn_fd == STDOUT_FILENO || hc->conn_fd == STDERR_FILENO ) in cgi_child() 3427 hc->conn_fd = newfd; in cgi_child() [all …]
|
/dports/net/tn5250/tn5250-0.17.4/slang/ |
H A D | slangterm.c | 129 r->conn_fd = -1; in tn5250_slang_terminal_new() 412 if (This->conn_fd >= 0) { in slang_terminal_waitevent() 413 FD_SET(This->conn_fd, &fdr); in slang_terminal_waitevent() 414 sm = This->conn_fd + 1; in slang_terminal_waitevent() 422 if (This->conn_fd >= 0 && FD_ISSET(This->conn_fd, &fdr)) in slang_terminal_waitevent()
|
/dports/net/ocserv/ocserv-1.1.3/src/ |
H A D | tlslib.c | 63 ret = setsockopt(ws->conn_fd, IPPROTO_TCP, TCP_CORK, &state, sizeof(state)); in cstp_cork() 65 ret = setsockopt(ws->conn_fd, IPPROTO_TCP, TCP_NOPUSH, &state, sizeof(state)); in cstp_cork() 80 ret = setsockopt(ws->conn_fd, IPPROTO_TCP, TCP_CORK, &state, sizeof(state)); in cstp_uncork() 82 ret = setsockopt(ws->conn_fd, IPPROTO_TCP, TCP_NOPUSH, &state, sizeof(state)); in cstp_uncork() 118 return force_write(ws->conn_fd, data, data_size); in cstp_send() 202 ret = recv_remaining(ws->conn_fd, p, 8); in _cstp_recv_packet() 214 ret = recv_remaining(ws->conn_fd, p+8, pktlen); in _cstp_recv_packet() 265 ret = recv(ws->conn_fd, data, data_size, 0); in cstp_recv() 327 close(ws->conn_fd); in cstp_close() 338 close(ws->conn_fd); in cstp_fatal_close()
|
/dports/emulators/qemu-utils/qemu-4.2.1/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 530 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu42/qemu-4.2.1/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 530 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu5/qemu-5.2.0/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 531 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu-guest-agent/qemu-5.0.1/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 530 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu-powernv/qemu-powernv-3.0.50/tests/ |
H A D | vhost-user-bridge.c | 504 int conn_fd; in vubr_accept_cb() local 508 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 509 if (conn_fd == -1) { in vubr_accept_cb() 512 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 515 conn_fd, in vubr_accept_cb() 521 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu-devel/qemu-de8ed1055c2ce18c95f597eb10df360dcb534f99/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 531 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu/qemu-6.2.0/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 531 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu-cheri/qemu-0a323821042c36e21ea80e58b9545dfc3b0cb8ef/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 530 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/emulators/qemu60/qemu-6.0.0/tests/ |
H A D | vhost-user-bridge.c | 509 int conn_fd; in vubr_accept_cb() local 513 conn_fd = accept(sock, (struct sockaddr *) &un, &len); in vubr_accept_cb() 514 if (conn_fd == -1) { in vubr_accept_cb() 517 DPRINT("Got connection from remote peer on sock %d\n", conn_fd); in vubr_accept_cb() 521 conn_fd, in vubr_accept_cb() 531 dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb); in vubr_accept_cb()
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmd/slurmd/ |
H A D | req.c | 3529 if (msg->conn_fd >= 0) in _rpc_step_complete_aggr() 3668 if (msg->conn_fd >= 0) in _rpc_stat_jobacct() 3829 if (msg->conn_fd >= 0) in _rpc_list_pids() 3903 close(msg->conn_fd); in _rpc_timelimit() 3904 msg->conn_fd = -1; in _rpc_timelimit() 4902 msg->conn_fd); in _rpc_suspend_job() 4903 msg->conn_fd = -1; in _rpc_suspend_job() 5108 msg->conn_fd = -1; in _rpc_abort_job() 5310 msg->conn_fd = -1; in _rpc_terminate_job() 5332 msg->conn_fd = -1; in _rpc_terminate_job() [all …]
|
/dports/sysutils/slurm-wlm/slurm-20.02.7/src/slurmctld/ |
H A D | proc_req.c | 1037 } else if (msg->conn_fd >= 0 && in _set_hostname() 1038 !slurm_get_peer_addr(msg->conn_fd, &addr)) { in _set_hostname() 2009 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_dump_jobs_user() 2069 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_get_shares() 2093 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_get_priority_factors() 2151 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_get_fed() 2300 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_dump_node_single() 2925 slurm_send_node_msg(msg->conn_fd, &resp); in _slurm_rpc_job_step_create() 3378 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_het_job_alloc_info() 3656 slurm_send_node_msg(msg->conn_fd, &response_msg); in _slurm_rpc_config_request() [all …]
|