| 379 | } |
| 380 | |
| 381 | ssize_t HDFSFileSystem::read(const int fd, void *buf, size_t count) |
| 382 | { |
| 383 | HDFSFSPtr fs_copy = getFS(); |
| 384 | auto fin = getHDFSFileByFd(fd); |
| 385 | ssize_t ret = hdfsRead(fs_copy.get(), fin, buf, count); |
| 386 | if (ret == -1) |
| 387 | { |
| 388 | handleError(__PRETTY_FUNCTION__); |
| 389 | } |
| 390 | return ret; |
| 391 | } |
| 392 | |
| 393 | ssize_t HDFSFileSystem::write(const int fd, const void *buf, size_t count) |
| 394 | { |