diff options
| author | ume <ume@FreeBSD.org> | 2006-12-04 17:08:43 +0000 |
|---|---|---|
| committer | ume <ume@FreeBSD.org> | 2006-12-04 17:08:43 +0000 |
| commit | 6c7489287679b434b86791746d54586a0a6befd4 (patch) | |
| tree | 2c1b15dc4527f043177ea6bd6433d4e5caf4c550 /lib/libc/net | |
| parent | 12956f1daaf69458d84752b662210d76d515b35f (diff) | |
| download | FreeBSD-src-6c7489287679b434b86791746d54586a0a6befd4.zip FreeBSD-src-6c7489287679b434b86791746d54586a0a6befd4.tar.gz | |
Use _kevent() instead of kevent().
Requested by: nork
Diffstat (limited to 'lib/libc/net')
| -rw-r--r-- | lib/libc/net/nscachedcli.c | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/lib/libc/net/nscachedcli.c b/lib/libc/net/nscachedcli.c index d95a0e8..1323805 100644 --- a/lib/libc/net/nscachedcli.c +++ b/lib/libc/net/nscachedcli.c @@ -72,7 +72,7 @@ safe_write(struct cached_connection_ *connection, const void *data, timeout.tv_nsec = 0; result = 0; do { - nevents = kevent(connection->write_queue, NULL, 0, &eventlist, + nevents = _kevent(connection->write_queue, NULL, 0, &eventlist, 1, &timeout); if ((nevents == 1) && (eventlist.filter == EVFILT_WRITE)) { s_result = _write(connection->sockfd, data + result, @@ -114,7 +114,7 @@ safe_read(struct cached_connection_ *connection, void *data, size_t data_size) timeout.tv_nsec = 0; result = 0; do { - nevents = kevent(connection->read_queue, NULL, 0, &eventlist, + nevents = _kevent(connection->read_queue, NULL, 0, &eventlist, 1, &timeout); if (nevents == 1 && eventlist.filter == EVFILT_READ) { s_result = _read(connection->sockfd, data + result, @@ -170,16 +170,16 @@ send_credentials(struct cached_connection_ *connection, int type) EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, NOTE_LOWAT, sizeof(int), NULL); - res = kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); + res = _kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); - nevents = kevent(connection->write_queue, NULL, 0, &eventlist, 1, + nevents = _kevent(connection->write_queue, NULL, 0, &eventlist, 1, NULL); if (nevents == 1 && eventlist.filter == EVFILT_WRITE) { result = (_sendmsg(connection->sockfd, &cred_hdr, 0) == -1) ? -1 : 0; EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD, 0, 0, NULL); - kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); + _kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL); return (result); } else return (-1); @@ -224,13 +224,13 @@ __open_cached_connection(struct cached_connection_params const *params) assert(retval->write_queue != -1); EV_SET(&eventlist, retval->sockfd, EVFILT_WRITE, EV_ADD, 0, 0, NULL); - res = kevent(retval->write_queue, &eventlist, 1, NULL, 0, NULL); + res = _kevent(retval->write_queue, &eventlist, 1, NULL, 0, NULL); retval->read_queue = kqueue(); assert(retval->read_queue != -1); EV_SET(&eventlist, retval->sockfd, EVFILT_READ, EV_ADD, 0, 0, NULL); - res = kevent(retval->read_queue, &eventlist, 1, NULL, 0, NULL); + res = _kevent(retval->read_queue, &eventlist, 1, NULL, 0, NULL); return (retval); } |
