Home
last modified time | relevance | path

Searched refs:fd (Results 1 – 25 of 50) sorted by relevance

12

/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dfdevent.c121 fdn->fd = -1; in fdnode_init()
138 fdn->fd = fd; in fdevent_register()
143 ev->fdarray[fd] = fdn; in fdevent_register()
154 fdn = ev->fdarray[fd]; in fdevent_unregister()
160 ev->fdarray[fd] = NULL; in fdevent_unregister()
173 ev->fdarray[fd]->events = 0; in fdevent_event_del()
220 if (ev->fdarray[fd]->fd != fd) SEGFAULT(); in fdevent_get_handler()
229 if (ev->fdarray[fd]->fd != fd) SEGFAULT(); in fdevent_get_context()
231 return ev->fdarray[fd]->ctx; in fdevent_get_context()
241 fd); in fdevent_fcntl_set()
[all …]
H A Dfdevent_select.c30 FD_CLR(fd, &(ev->select_set_read)); in fdevent_select_event_del()
31 FD_CLR(fd, &(ev->select_set_write)); in fdevent_select_event_del()
32 FD_CLR(fd, &(ev->select_set_error)); in fdevent_select_event_del()
41 assert(fd < ((int)FD_SETSIZE)); in fdevent_select_event_set()
44 FD_SET(fd, &(ev->select_set_read)); in fdevent_select_event_set()
46 FD_CLR(fd, &(ev->select_set_read)); in fdevent_select_event_set()
49 FD_SET(fd, &(ev->select_set_write)); in fdevent_select_event_set()
51 FD_CLR(fd, &(ev->select_set_write)); in fdevent_select_event_set()
53 FD_SET(fd, &(ev->select_set_error)); in fdevent_select_event_set()
55 if (fd > ev->select_max_fd) ev->select_max_fd = fd; in fdevent_select_event_set()
[all …]
H A Dnetwork_linux_sendfile.c81 if ((r = writev(fd, chunks, num_chunks)) < 0) { in network_write_chunkqueue_linuxsendfile()
92 "writev failed:", strerror(errno), fd); in network_write_chunkqueue_linuxsendfile()
138 if (-1 == c->file.fd) { in network_write_chunkqueue_linuxsendfile()
145 fcntl(c->file.fd, F_SETFD, FD_CLOEXEC); in network_write_chunkqueue_linuxsendfile()
152 "posix_fadvise failed:", strerror(errno), c->file.fd); in network_write_chunkqueue_linuxsendfile()
158 if (-1 == (r = sendfile(fd, c->file.fd, &offset, toSend))) { in network_write_chunkqueue_linuxsendfile()
170 "sendfile failed:", strerror(errno), fd); in network_write_chunkqueue_linuxsendfile()
206 "posix_fadvise failed:", strerror(errno), c->file.fd); in network_write_chunkqueue_linuxsendfile()
221 if (c->file.fd != -1) { in network_write_chunkqueue_linuxsendfile()
222 close(c->file.fd); in network_write_chunkqueue_linuxsendfile()
[all …]
H A Dfdevent_poll.c28 static int fdevent_poll_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_poll_event_del() argument
37 if (ev->pollfds[fde_ndx].fd == fd) { in fdevent_poll_event_del()
40 ev->pollfds[k].fd = -1; in fdevent_poll_event_del()
55 "del! ", ev->pollfds[fde_ndx].fd, fd); in fdevent_poll_event_del()
70 for (j = ev->used - 1; j + 1 > 0 && ev->pollfds[j].fd == -1; j--) ev->used--;
76 static int fdevent_poll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_poll_event_set() argument
84 if (ev->pollfds[fde_ndx].fd == fd) { in fdevent_poll_event_set()
90 "set: ", fde_ndx, ev->pollfds[fde_ndx].fd); in fdevent_poll_event_set()
97 ev->pollfds[k].fd = fd; in fdevent_poll_event_set()
110 ev->pollfds[ev->used].fd = fd; in fdevent_poll_event_set()
[all …]
H A Dproc_open.c33 # define close_descriptor(fd) CloseHandle(fd) argument
40 p->fd = _open_osfhandle((long)p->parent, in pipe_close_child()
49 # define close_descriptor(fd) close(fd) argument
53 if (dup2(p->child, p->fd) != p->fd) { in pipe_close_parent()
57 p->child = p->fd; in pipe_close_parent()
62 p->fd = p->parent; in pipe_close_child()
72 close(p->fd); in pipe_close()
84 if (0 == fd) { in pipe_open()
91 p->fd = fd; in pipe_open()
309 proc_read_fd_to_buffer(proc.out.fd, out); in proc_open_buffer()
[all …]
H A Dfdevent_freebsd_kqueue.c32 oevents = ev->fdarray[fd]->events; in fdevent_freebsd_kqueue_event_del()
35 EV_SET(&kev[n], fd, EVFILT_READ, EV_DELETE, 0, 0, NULL); in fdevent_freebsd_kqueue_event_del()
39 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in fdevent_freebsd_kqueue_event_del()
67 int oevents = ev->fdarray[fd]->events; in fdevent_freebsd_kqueue_event_set()
73 if (events == oevents) return fd; in fdevent_freebsd_kqueue_event_set()
76 EV_SET(&kev[n], fd, EVFILT_READ, EV_ADD|EV_CLEAR, 0, 0, NULL); in fdevent_freebsd_kqueue_event_set()
79 EV_SET(&kev[n], fd, EVFILT_READ, EV_DELETE, 0, 0, NULL); in fdevent_freebsd_kqueue_event_set()
83 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_ADD|EV_CLEAR, 0, 0, NULL); in fdevent_freebsd_kqueue_event_set()
86 EV_SET(&kev[n], fd, EVFILT_WRITE, EV_DELETE, 0, 0, NULL); in fdevent_freebsd_kqueue_event_set()
90 if (0 == n) return fd; in fdevent_freebsd_kqueue_event_set()
[all …]
H A Dnetwork.c63 srv_socket->fd, in network_server_handle_fdevent()
145 int fd; local
174 srv_socket->fd = -1;
236 if (srv_socket->fd < 0) {
259 if (srv_socket->fd == -1) {
280 srv->cur_fds = srv_socket->fd;
370 close(fd);
536 if (srv_socket->fd != -1) {
545 close(srv_socket->fd);
562 if (srv_socket->fd != -1) {
[all …]
H A Dfdevent_linux_sysepoll.c24 static int fdevent_linux_sysepoll_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_linux_sysepoll_event_del() argument
31 ep.data.fd = fd; in fdevent_linux_sysepoll_event_del()
34 if (0 != epoll_ctl(ev->epoll_fd, EPOLL_CTL_DEL, fd, &ep)) { in fdevent_linux_sysepoll_event_del()
47 static int fdevent_linux_sysepoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_linux_sysepoll_event_set() argument
71 ep.data.fd = fd; in fdevent_linux_sysepoll_event_set()
73 if (0 != epoll_ctl(ev->epoll_fd, add ? EPOLL_CTL_ADD : EPOLL_CTL_MOD, fd, &ep)) { in fdevent_linux_sysepoll_event_set()
82 return fd; in fdevent_linux_sysepoll_event_set()
105 "fdevent_linux_sysepoll_event_get_fd: ", (int) ndx, ev->epoll_events[ndx].data.fd); in fdevent_linux_sysepoll_event_get_fd()
108 return ev->epoll_events[ndx].data.fd; in fdevent_linux_sysepoll_event_get_fd()
H A Dconnections.c131 if (closesocket(con->fd)) {
139 if (close(con->fd)) {
149 "closed()", con->fd);
681 con->fd = 0;
1277 con->fd,
1359 con->fd = cnt;
1413 con->fd,
1697 con->fd,
1705 con->fd,
1779 con->fd);
[all …]
H A Dfdevent.h95 int fd; member
170 int (*event_set)(struct fdevents *ev, int fde_ndx, int fd, int events);
171 int (*event_del)(struct fdevents *ev, int fde_ndx, int fd);
179 int (*fcntl_set)(struct fdevents *ev, int fd);
186 int fdevent_event_set(fdevents *ev, int *fde_ndx, int fd, int events); /* events can be FDEVENT_IN,…
187 int fdevent_event_del(fdevents *ev, int *fde_ndx, int fd);
190 fdevent_handler fdevent_get_handler(fdevents *ev, int fd);
191 void * fdevent_get_context(fdevents *ev, int fd);
197 int fdevent_register(fdevents *ev, int fd, fdevent_handler handler, void *ctx);
198 int fdevent_unregister(fdevents *ev, int fd);
[all …]
H A Dnetwork_write.c27 int network_write_chunkqueue_write(server *srv, connection *con, int fd, chunkqueue *cq, off_t max_… in network_write_chunkqueue_write() argument
49 if ((r = send(fd, offset, toSend, 0)) < 0) { in network_write_chunkqueue_write()
51 log_error_write(srv, __FILE__, __LINE__, "ssd", "send failed: ", strerror(errno), fd); in network_write_chunkqueue_write()
56 if ((r = write(fd, offset, toSend)) < 0) { in network_write_chunkqueue_write()
67 "write failed:", strerror(errno), fd); in network_write_chunkqueue_write()
127 if ((r = write(fd, p + offset, toSend)) <= 0) { in network_write_chunkqueue_write()
139 "write failed:", strerror(errno), fd); in network_write_chunkqueue_write()
160 if ((r = send(fd, srv->tmp_buf->ptr, toSend, 0)) < 0) { in network_write_chunkqueue_write()
162 log_error_write(srv, __FILE__, __LINE__, "ssd", "send failed: ", strerror(errno), fd); in network_write_chunkqueue_write()
167 if ((r = write(fd, srv->tmp_buf->ptr, toSend)) < 0) { in network_write_chunkqueue_write()
[all …]
H A Dfdevent_solaris_devpoll.c26 static int fdevent_solaris_devpoll_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_solaris_devpoll_event_del() argument
31 pfd.fd = fd; in fdevent_solaris_devpoll_event_del()
37 "(del) write failed: ", fd, strerror(errno)); in fdevent_solaris_devpoll_event_del()
45 static int fdevent_solaris_devpoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_solaris_devpoll_event_set() argument
55 pfd.fd = fd; in fdevent_solaris_devpoll_event_set()
61 "(set) write failed: ", fd, strerror(errno)); in fdevent_solaris_devpoll_event_set()
66 return fd; in fdevent_solaris_devpoll_event_set()
101 return ev->devpollfds[ndx].fd; in fdevent_solaris_devpoll_event_get_fd()
H A Dnetwork_mtcp_writev.c113 "writev failed:", strerror(errno), fd);
239 fcntl(c->file.fd, F_SETFD, FD_CLOEXEC);
247 strerror(errno), c->file.name, c->file.fd);
303 "write failed:", strerror(errno), fd);
368 if ((r = send(fd, offset, toSend, 0)) < 0) { in network_write_chunkqueue_mtcp_writev()
375 if ((r = mtcp_write(srv->mctx, fd, offset, toSend)) < 0) { in network_write_chunkqueue_mtcp_writev()
386 "write failed:", strerror(errno), fd); in network_write_chunkqueue_mtcp_writev()
447 if ((r = write(fd, p + offset, toSend)) <= 0) { in network_write_chunkqueue_mtcp_writev()
459 "write failed:", strerror(errno), fd); in network_write_chunkqueue_mtcp_writev()
480 if ((r = send(fd, srv->tmp_buf->ptr, toSend, 0)) < 0) { in network_write_chunkqueue_mtcp_writev()
[all …]
H A Dmod_cgi.c75 int fd; member
363 log_error_write(srv, __FILE__, __LINE__, "sdd", strerror(errno), con->fd, hctx->fd); in cgi_demux_response()
537 if (hctx->fd != -1) { in cgi_connection_close()
542 if (close(hctx->fd)) { in cgi_connection_close()
546 hctx->fd = -1; in cgi_connection_close()
629 if (hctx->fd == -1) { in cgi_handle_fdevent()
1111 close(c->file.fd); in cgi_create_env()
1112 c->file.fd = -1; in cgi_create_env()
1187 close(hctx->fd); in cgi_create_env()
1387 if (close(hctx->fd)) { in SUBREQUEST_FUNC()
[all …]
H A Dnetwork_backends.h62 int network_write_chunkqueue_write(server *srv, connection *con, int fd, chunkqueue *cq, off_t max_…
63 int network_write_chunkqueue_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_t max…
64 int network_write_chunkqueue_linuxsendfile(server *srv, connection *con, int fd, chunkqueue *cq, of…
65 int network_write_chunkqueue_freebsdsendfile(server *srv, connection *con, int fd, chunkqueue *cq, …
66 int network_write_chunkqueue_solarissendfilev(server *srv, connection *con, int fd, chunkqueue *cq,…
67 int network_write_chunkqueue_mtcp_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_…
H A Dfdevent_libev.c13 fdnode *fdn = ev->fdarray[w->fd]; in io_watcher_cb()
41 static int fdevent_libev_event_del(fdevents *ev, int fde_ndx, int fd) { in fdevent_libev_event_del() argument
47 fdn = ev->fdarray[fd]; in fdevent_libev_event_del()
59 static int fdevent_libev_event_set(fdevents *ev, int fde_ndx, int fd, int events) { in fdevent_libev_event_set() argument
60 fdnode *fdn = ev->fdarray[fd]; in fdevent_libev_event_set()
72 ev_io_init(watcher, io_watcher_cb, fd, ev_events); in fdevent_libev_event_set()
78 ev_io_set(watcher, watcher->fd, ev_events); in fdevent_libev_event_set()
83 return fd; in fdevent_libev_event_set()
H A Dnetwork_freebsd_sendfile.c34 int network_write_chunkqueue_freebsdsendfile(server *srv, connection *con, int fd, chunkqueue *cq, … in network_write_chunkqueue_freebsdsendfile() argument
83 if ((r = writev(fd, chunks, num_chunks)) < 0) { in network_write_chunkqueue_freebsdsendfile()
95 "writev failed:", strerror(errno), fd); in network_write_chunkqueue_freebsdsendfile()
147 if (-1 == c->file.fd) { in network_write_chunkqueue_freebsdsendfile()
148 if (-1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) { in network_write_chunkqueue_freebsdsendfile()
155 fcntl(c->file.fd, F_SETFD, FD_CLOEXEC); in network_write_chunkqueue_freebsdsendfile()
162 if (-1 == sendfile(c->file.fd, fd, offset, toSend, NULL, &r, 0)) { in network_write_chunkqueue_freebsdsendfile()
H A Dfdevent_libmtcp.c27 fdevent_libmtcp_epoll_event_del(fdevents *ev, int fde_ndx, int fd) in fdevent_libmtcp_epoll_event_del() argument
35 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_del()
38 if (0 != mtcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, MOS_EPOLL_CTL_DEL, fd, NULL/*&ep*/)) { in fdevent_libmtcp_epoll_event_del()
52 fdevent_libmtcp_epoll_event_set(fdevents *ev, int fde_ndx, int fd, int events) in fdevent_libmtcp_epoll_event_set() argument
75 ep.data.sock = fd; in fdevent_libmtcp_epoll_event_set()
77 …tcp_epoll_ctl(ev->srv->mctx, ev->epoll_fd, add ? MOS_EPOLL_CTL_ADD : MOS_EPOLL_CTL_MOD, fd, &ep)) { in fdevent_libmtcp_epoll_event_set()
86 return fd; in fdevent_libmtcp_epoll_event_set()
H A Dnetwork_writev.c33 int network_write_chunkqueue_writev(server *srv, connection *con, int fd, chunkqueue *cq, off_t max… in network_write_chunkqueue_writev() argument
101 if ((r = writev(fd, chunks, num_chunks)) < 0) { in network_write_chunkqueue_writev()
113 "writev failed:", strerror(errno), fd); in network_write_chunkqueue_writev()
232 if (-1 == c->file.fd) { /* open the file if not already open */ in network_write_chunkqueue_writev()
233 if (-1 == (c->file.fd = open(c->file.name->ptr, O_RDONLY))) { in network_write_chunkqueue_writev()
239 fcntl(c->file.fd, F_SETFD, FD_CLOEXEC); in network_write_chunkqueue_writev()
243 …if (MAP_FAILED == (c->file.mmap.start = mmap(NULL, to_mmap, PROT_READ, MAP_SHARED, c->file.fd, c->… in network_write_chunkqueue_writev()
247 strerror(errno), c->file.name, c->file.fd); in network_write_chunkqueue_writev()
292 if ((r = write(fd, start + (abs_offset - c->file.mmap.offset), toSend)) < 0) { in network_write_chunkqueue_writev()
303 "write failed:", strerror(errno), fd); in network_write_chunkqueue_writev()
H A Dlog.c36 int openDevNull(int fd) { in openDevNull() argument
38 close(fd); in openDevNull()
45 if (tmpfd != -1 && tmpfd != fd) { in openDevNull()
46 dup2(tmpfd, fd); in openDevNull()
53 int fd; in open_logfile_or_pipe() local
111 fd = to_log_fds[1]; in open_logfile_or_pipe()
118 } else if (-1 == (fd = open(logfile, O_APPEND | O_WRONLY | O_CREAT | O_LARGEFILE, 0644))) { in open_logfile_or_pipe()
127 fcntl(fd, F_SETFD, FD_CLOEXEC); in open_logfile_or_pipe()
130 return fd; in open_logfile_or_pipe()
H A Dstream.c18 int fd; in stream_open() local
33 if (-1 == (fd = open(fn->ptr, O_RDONLY | O_BINARY))) { in stream_open()
37 f->start = mmap(NULL, f->size, PROT_READ, MAP_SHARED, fd, 0); in stream_open()
39 close(fd); in stream_open()
H A Dserver.c839 con->fd, in start_server()
840 con->fcgi.fd, in start_server()
886 close(srv_socket->fd); in start_server()
888 srv_socket->fd = -1; in start_server()
953 int fd; in start_server() local
966 "event for", fd, revents); in start_server()
2075 con->fd, in main()
2076 con->fcgi.fd, in main()
2119 close(srv_socket->fd); in main()
2120 srv_socket->fd = -1; in main()
[all …]
/mOS-networking-stack/util/
H A Dnetlib.c115 int fd; in CreateConnectionSocket() local
126 if (setsockopt(fd, SOL_SOCKET, SO_LINGER, in CreateConnectionSocket()
128 close(fd); in CreateConnectionSocket()
133 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, in CreateConnectionSocket()
135 close(fd); in CreateConnectionSocket()
140 if (fcntl(fd, F_SETFL, O_NDELAY) < 0) { in CreateConnectionSocket()
142 close(fd); in CreateConnectionSocket()
151 if (connect(fd, (struct sockaddr *) &saddr, in CreateConnectionSocket()
154 return(fd); in CreateConnectionSocket()
157 close(fd); in CreateConnectionSocket()
[all …]
/mOS-networking-stack/core/src/include/
H A Dnetmap_user.h217 int fd; member
406 curr->win_netmap_fd = fd; in win_insert_fd_record()
566 if (fd < 0) { in win_nm_open()
571 return fd; in win_nm_open()
582 win_nm_close(int fd){ in win_nm_close() argument
583 if (fd != -1){ in win_nm_close()
584 close(fd); in win_nm_close()
738 if (d->fd < 0) { in nm_open()
868 if (d->fd != -1){ in nm_close()
869 close(d->fd); in nm_close()
[all …]
/mOS-networking-stack/core/src/
H A Dnetmap_module.c221 pfd[i].fd = npc->local_nmd[i]->fd; in netmap_select()
271 close(npc->local_nmd[i]->fd); in netmap_destroy_handle()
295 int fd, ret; in set_promisc() local
298 fd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); in set_promisc()
299 if (fd == -1) { in set_promisc()
304 ret = ioctl(fd, SIOCGIFFLAGS, &eth); in set_promisc()
308 close(fd); in set_promisc()
315 close(fd); in set_promisc()
320 ret = ioctl(fd, SIOCSIFFLAGS, &eth); in set_promisc()
323 close(fd); in set_promisc()
[all …]

12