Home
last modified time | relevance | path

Searched refs:conn_fd (Results 51 – 75 of 160) sorted by relevance

1234567

/dports/emulators/ppsspp-qt5/ppsspp-1.12.3/Common/Net/
H A DHTTPServer.cpp291 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 DHTTPServer.cpp291 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 DHTTPServer.cpp291 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 Dmini_httpd.c214 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 Dsmb_conn.c121 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 Dsmb_conn_srv.c102 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 Dhttp_ping.c69 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 Dpslsocke.c73 unixclosesocket (conn_fd) in unixclosesocket() argument
74 int conn_fd; in unixclosesocket()
/dports/www/trafficserver/trafficserver-9.1.1/tools/http_load/
H A Dhttp_load.c211 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 Dnet_utilities.c207 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 Dthttpd.c805 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 Dlibhttpd.c568 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 Dslangterm.c129 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 Dtlslib.c63 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c504 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dvhost-user-bridge.c509 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 Dreq.c3529 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 Dproc_req.c1037 } 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 …]

1234567