unsigned int *bytes_write,
int *sequence)
{
-#define SEND_TIMEOUT 5 /* milliseconds */
-
unsigned int left = nbytes;
ssize_t nb;
int retry_cnt = 0;
- struct pollfd fds[1];
- int ret;
*sequence += 1;
*bytes_write = 0;
- fds[0].fd = fd;
- fds[0].events = POLLOUT;
- fds[0].revents = 0;
-
- ret = poll(fds, 1, SEND_TIMEOUT);
- if (ret == 0) {
- LOGE("write_socket: : fd %d poll timeout", fd);
- return MESSAGE_PORT_ERROR_RESOURCE_UNAVAILABLE;
- }
-
while (left && (retry_cnt < MAX_RETRY_CNT)) {
nb = write(fd, buffer, left);
if (nb == -1) {