int max_timeout = MAX_CNT * MAX_SLEEP; /* 10 sec */
int fd;
- {
- std::lock_guard<std::recursive_mutex> lock(mutex_);
- fd = fd_;
- if (fd < 0 || fd >= sysconf(_SC_OPEN_MAX)) {
- _E("Invalid fd(%d)", fd);
- return RPC_PORT_ERROR_IO_ERROR;
- }
+ mutex_.lock();
+ fd = fd_;
+ mutex_.unlock();
+ if (fd < 0 || fd >= sysconf(_SC_OPEN_MAX)) {
+ _E("Invalid fd(%d)", fd);
+ return RPC_PORT_ERROR_IO_ERROR;
}
while (left) {
- {
- std::lock_guard<std::recursive_mutex> lock(mutex_);
- nb = read(fd, buffer, left);
- }
-
+ mutex_.lock();
+ nb = read(fd_, buffer, left);
+ mutex_.unlock();
if (nb == 0) {
_E("read_socket: ...read EOF, socket closed %d: nb %zd\n", fd, nb);
return RPC_PORT_ERROR_IO_ERROR;