socket.cc revision 0f9b91e150e153229235c163861198e23600e636
1c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati/****************************************************************************** 2c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * 3c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * Copyright (C) 2014 Google, Inc. 4c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * 5c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * Licensed under the Apache License, Version 2.0 (the "License"); 6c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * you may not use this file except in compliance with the License. 7c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * You may obtain a copy of the License at: 8c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * 9c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * http://www.apache.org/licenses/LICENSE-2.0 10c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * 11c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * Unless required by applicable law or agreed to in writing, software 12c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * distributed under the License is distributed on an "AS IS" BASIS, 13c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 14c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * See the License for the specific language governing permissions and 15c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * limitations under the License. 16c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati * 17c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati ******************************************************************************/ 18c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 19c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#define LOG_TAG "bt_osi_socket" 20c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 2198bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati#include <asm/ioctls.h> 22c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <assert.h> 23c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <errno.h> 24c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <netinet/in.h> 25c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <string.h> 2698bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati#include <sys/ioctl.h> 27c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <sys/socket.h> 28c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <sys/types.h> 29c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati#include <unistd.h> 30c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 310f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/allocator.h" 320f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/osi.h" 3344802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati#include "osi/include/log.h" 340f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/reactor.h" 350f9b91e150e153229235c163861198e23600e636Sharvil Nanavati#include "osi/include/socket.h" 36c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 37c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatistruct socket_t { 38fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd; 39fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_object_t *reactor_object; 40c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_cb read_ready; 41c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_cb write_ready; 42fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void *context; // Not owned, do not free. 43c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati}; 44c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 45c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatistatic void internal_read_ready(void *context); 46c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatistatic void internal_write_ready(void *context); 47c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 48c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatisocket_t *socket_new(void) { 49384f8a948e9837475c4f504a626205334522df2aZach Johnson socket_t *ret = (socket_t *)osi_calloc(sizeof(socket_t)); 50c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati if (!ret) { 5144802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to allocate memory for socket.", __func__); 52c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati goto error; 53c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 54c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 55fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati ret->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); 56fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (ret->fd == INVALID_FD) { 5744802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to create socket: %s", __func__, strerror(errno)); 58c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati goto error; 59c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 60c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 61c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati int enable = 1; 62fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (setsockopt(ret->fd, SOL_SOCKET, SO_REUSEADDR, &enable, sizeof(enable)) == -1) { 6344802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to set SO_REUSEADDR: %s", __func__, strerror(errno)); 64c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati goto error; 65c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 66c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 67c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return ret; 68c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 69c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatierror:; 70c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati if (ret) 71fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati close(ret->fd); 72384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(ret); 73c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return NULL; 74c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 75c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 76ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavatisocket_t *socket_new_from_fd(int fd) { 77ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati assert(fd != INVALID_FD); 78ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 79384f8a948e9837475c4f504a626205334522df2aZach Johnson socket_t *ret = (socket_t *)osi_calloc(sizeof(socket_t)); 80ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati if (!ret) { 8144802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to allocate memory for socket.", __func__); 82ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati return NULL; 83ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati } 84ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 85ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati ret->fd = fd; 86ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati return ret; 87ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati} 88ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 89c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavativoid socket_free(socket_t *socket) { 90c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati if (!socket) 91c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return; 92c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 93c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_unregister(socket); 94fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati close(socket->fd); 95384f8a948e9837475c4f504a626205334522df2aZach Johnson osi_free(socket); 96c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 97c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 98c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatibool socket_listen(const socket_t *socket, port_t port) { 99c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 100c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 101c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati struct sockaddr_in addr; 102c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati addr.sin_family = AF_INET; 103c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati addr.sin_addr.s_addr = 0; 104c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati addr.sin_port = htons(port); 105fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (bind(socket->fd, (struct sockaddr *)&addr, sizeof(addr)) == -1) { 10644802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to bind socket to port %u: %s", __func__, port, strerror(errno)); 107c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return false; 108c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 109c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 110fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (listen(socket->fd, 10) == -1) { 11144802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to listen on port %u: %s", __func__, port, strerror(errno)); 112c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return false; 113c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 114c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 115c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return true; 116c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 117c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 118c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatisocket_t *socket_accept(const socket_t *socket) { 119c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 120c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 121fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati int fd = accept(socket->fd, NULL, NULL); 122fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (fd == INVALID_FD) { 12344802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to accept socket: %s", __func__, strerror(errno)); 124c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return NULL; 125c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 126c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 127384f8a948e9837475c4f504a626205334522df2aZach Johnson socket_t *ret = (socket_t *)osi_calloc(sizeof(socket_t)); 128c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati if (!ret) { 129c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati close(fd); 13044802768c447ab480d4227b3a852a97d923b816dSharvil Nanavati LOG_ERROR("%s unable to allocate memory for socket.", __func__); 131c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return NULL; 132c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati } 133c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 134fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati ret->fd = fd; 135c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati return ret; 136c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 137c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 138c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatissize_t socket_read(const socket_t *socket, void *buf, size_t count) { 139c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 140c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(buf != NULL); 141c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 142fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati return recv(socket->fd, buf, count, MSG_DONTWAIT); 143c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 144c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 145c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatissize_t socket_write(const socket_t *socket, const void *buf, size_t count) { 146c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 147c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(buf != NULL); 148c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 149fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati return send(socket->fd, buf, count, MSG_DONTWAIT); 150c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 151c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 152ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavatissize_t socket_write_and_transfer_fd(const socket_t *socket, const void *buf, size_t count, int fd) { 153ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati assert(socket != NULL); 154ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati assert(buf != NULL); 155ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 156ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati if (fd == INVALID_FD) 157ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati return socket_write(socket, buf, count); 158ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 159ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati struct msghdr msg; 160ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati struct iovec iov; 161ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati char control_buf[CMSG_SPACE(sizeof(int))]; 162ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 163ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati iov.iov_base = (void *)buf; 164ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati iov.iov_len = count; 165ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 166ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_iov = &iov; 167ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_iovlen = 1; 168ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_control = control_buf; 169ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_controllen = sizeof(control_buf); 170ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_name = NULL; 171ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati msg.msg_namelen = 0; 172ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 173ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati struct cmsghdr *header = CMSG_FIRSTHDR(&msg); 174ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati header->cmsg_level = SOL_SOCKET; 175ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati header->cmsg_type = SCM_RIGHTS; 176ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati header->cmsg_len = CMSG_LEN(sizeof(int)); 177ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati *(int *)CMSG_DATA(header) = fd; 178ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 179ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati ssize_t ret = sendmsg(socket->fd, &msg, MSG_DONTWAIT); 180ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati close(fd); 181ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati return ret; 182ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati} 183ad3067b83e4d309b4027a4e9b44b0a614f267da8Sharvil Nanavati 18498bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavatissize_t socket_bytes_available(const socket_t *socket) { 18598bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati assert(socket != NULL); 18698bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati 18798bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati int size = 0; 18898bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati if (ioctl(socket->fd, FIONREAD, &size) == -1) 18998bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati return -1; 19098bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati return size; 19198bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati} 19298bf85fea392258ba22a252eeeed1153dc3eb16fSharvil Nanavati 193fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavativoid socket_register(socket_t *socket, reactor_t *reactor, void *context, socket_cb read_cb, socket_cb write_cb) { 194c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 195c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 196c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati // Make sure the socket isn't currently registered. 197c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_unregister(socket); 198c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 199c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket->read_ready = read_cb; 200c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket->write_ready = write_cb; 201c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket->context = context; 202c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 203fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void (*read_fn)(void *) = (read_cb != NULL) ? internal_read_ready : NULL; 204fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati void (*write_fn)(void *) = (write_cb != NULL) ? internal_write_ready : NULL; 205fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati 206fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati socket->reactor_object = reactor_register(reactor, socket->fd, socket, read_fn, write_fn); 207c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 208c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 209c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavativoid socket_unregister(socket_t *socket) { 210c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(socket != NULL); 211c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 212fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati if (socket->reactor_object) 213fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati reactor_unregister(socket->reactor_object); 214fbf89085bf308a98b00da77d1538539f6dd58604Sharvil Nanavati socket->reactor_object = NULL; 215c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 216c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 217c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatistatic void internal_read_ready(void *context) { 218c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(context != NULL); 219c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 220c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_t *socket = (void *)context; 221c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket->read_ready(socket, socket->context); 222c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 223c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 224c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavatistatic void internal_write_ready(void *context) { 225c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati assert(context != NULL); 226c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati 227c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket_t *socket = (void *)context; 228c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati socket->write_ready(socket, socket->context); 229c2031c4fbab9ed2d2e51a0b287a3fab805932ca4Sharvil Nanavati} 230