3 #include "fdevent_impl.h"
14 #ifdef FDEVENT_USE_SOLARIS_PORT
18 static int fdevent_solaris_port_event_del(fdevents
*ev
, fdnode
*fdn
) {
19 return port_dissociate(ev
->port_fd
, PORT_SOURCE_FD
, fdn
->fd
);
22 static int fdevent_solaris_port_event_set(fdevents
*ev
, fdnode
*fdn
, int events
) {
23 int fd
= fdn
->fdn_ndx
= fdn
->fd
;
24 intptr_t ud
= events
& (POLLIN
|POLLOUT
);
25 return port_associate(ev
->port_fd
,PORT_SOURCE_FD
,fd
,(int)ud
,(void*)ud
);
29 static void fdevent_solaris_port_free(fdevents
*ev
) {
31 free(ev
->port_events
);
34 /* if there is any error it will return the return values of port_getn, otherwise it will return number of events **/
35 static int fdevent_solaris_port_poll(fdevents
*ev
, int timeout_ms
) {
36 const int pfd
= ev
->port_fd
;
38 unsigned int available_events
, wait_for_events
= 0;
40 struct timespec timeout
;
42 timeout
.tv_sec
= timeout_ms
/1000L;
43 timeout
.tv_nsec
= (timeout_ms
% 1000L) * 1000000L;
45 /* get the number of file descriptors with events */
46 if ((ret
= port_getn(pfd
, ev
->port_events
, 0, &wait_for_events
, &timeout
)) < 0) return ret
;
48 /* wait for at least one event */
49 if (0 == wait_for_events
) wait_for_events
= 1;
51 available_events
= wait_for_events
;
53 /* get the events of the file descriptors */
54 if ((ret
= port_getn(pfd
, ev
->port_events
, ev
->maxfds
, &available_events
, &timeout
)) < 0) {
55 /* if errno == ETIME and available_event == wait_for_events we didn't get any events */
56 /* for other errors we didn't get any events either */
57 if (!(errno
== ETIME
&& wait_for_events
!= available_events
)) return ret
;
60 for (int i
= 0; i
< (int)available_events
; ++i
) {
61 int fd
= (int)ev
->port_events
[i
].portev_object
;
62 fdnode
* const fdn
= ev
->fdarray
[fd
];
63 const intptr_t ud
= (intptr_t)ev
->port_events
[i
].portev_user
;
64 int revents
= ev
->port_events
[i
].portev_events
;
65 if (0 == ((uintptr_t)fdn
& 0x3)) {
66 if (port_associate(pfd
,PORT_SOURCE_FD
,fd
,(int)ud
,(void*)ud
) < 0) {
67 log_error_write(ev
->srv
, __FILE__
, __LINE__
, "SS",
68 "port_associate failed: ", strerror(errno
));
70 (*fdn
->handler
)(ev
->srv
, fdn
->ctx
, revents
);
76 return available_events
;
80 int fdevent_solaris_port_init(fdevents
*ev
) {
81 force_assert(POLLIN
== FDEVENT_IN
);
82 force_assert(POLLPRI
== FDEVENT_PRI
);
83 force_assert(POLLOUT
== FDEVENT_OUT
);
84 force_assert(POLLERR
== FDEVENT_ERR
);
85 force_assert(POLLHUP
== FDEVENT_HUP
);
86 force_assert(POLLNVAL
== FDEVENT_NVAL
);
87 force_assert(POLLRDHUP
== FDEVENT_RDHUP
);
89 ev
->type
= FDEVENT_HANDLER_SOLARIS_PORT
;
90 ev
->event_set
= fdevent_solaris_port_event_set
;
91 ev
->event_del
= fdevent_solaris_port_event_del
;
92 ev
->poll
= fdevent_solaris_port_poll
;
93 ev
->free
= fdevent_solaris_port_free
;
94 ev
->port_events
= malloc(ev
->maxfds
* sizeof(*ev
->port_events
));
95 force_assert(NULL
!= ev
->port_events
);
97 if ((ev
->port_fd
= port_create()) < 0) return -1;