Loading libs/protoutil/Android.bp +1 −0 Original line number Diff line number Diff line Loading @@ -33,6 +33,7 @@ cc_library { export_include_dirs: ["include"], shared_libs: [ "libbase", "libcutils", "liblog", ], Loading libs/protoutil/src/ProtoOutputStream.cpp +2 −14 Original line number Diff line number Diff line Loading @@ -17,6 +17,7 @@ #include <inttypes.h> #include <android-base/file.h> #include <android/util/protobuf.h> #include <android/util/ProtoOutputStream.h> #include <cutils/log.h> Loading Loading @@ -467,19 +468,6 @@ ProtoOutputStream::size() return mBuffer.size(); } static bool write_all(int fd, uint8_t const* buf, size_t size) { while (size > 0) { ssize_t amt = ::write(fd, buf, size); if (amt < 0) { return false; } size -= amt; buf += amt; } return true; } bool ProtoOutputStream::flush(int fd) { Loading @@ -488,7 +476,7 @@ ProtoOutputStream::flush(int fd) EncodedBuffer::iterator it = mBuffer.begin(); while (it.readBuffer() != NULL) { if (!write_all(fd, it.readBuffer(), it.currentToRead())) return false; if (!android::base::WriteFully(fd, it.readBuffer(), it.currentToRead())) return false; it.rp()->move(it.currentToRead()); } return true; Loading Loading
libs/protoutil/Android.bp +1 −0 Original line number Diff line number Diff line Loading @@ -33,6 +33,7 @@ cc_library { export_include_dirs: ["include"], shared_libs: [ "libbase", "libcutils", "liblog", ], Loading
libs/protoutil/src/ProtoOutputStream.cpp +2 −14 Original line number Diff line number Diff line Loading @@ -17,6 +17,7 @@ #include <inttypes.h> #include <android-base/file.h> #include <android/util/protobuf.h> #include <android/util/ProtoOutputStream.h> #include <cutils/log.h> Loading Loading @@ -467,19 +468,6 @@ ProtoOutputStream::size() return mBuffer.size(); } static bool write_all(int fd, uint8_t const* buf, size_t size) { while (size > 0) { ssize_t amt = ::write(fd, buf, size); if (amt < 0) { return false; } size -= amt; buf += amt; } return true; } bool ProtoOutputStream::flush(int fd) { Loading @@ -488,7 +476,7 @@ ProtoOutputStream::flush(int fd) EncodedBuffer::iterator it = mBuffer.begin(); while (it.readBuffer() != NULL) { if (!write_all(fd, it.readBuffer(), it.currentToRead())) return false; if (!android::base::WriteFully(fd, it.readBuffer(), it.currentToRead())) return false; it.rp()->move(it.currentToRead()); } return true; Loading