Android-cuttlefish cvd tool
|
Public Member Functions | |
SyncConnection () | |
~SyncConnection () | |
bool | HaveSendRecv2 () const |
bool | HaveSendRecv2Brotli () const |
bool | HaveSendRecv2LZ4 () const |
bool | HaveSendRecv2Zstd () const |
bool | HaveSendRecv2DryRunSend () const |
CompressionType | ResolveCompressionType (CompressionType compression) const |
const FeatureSet & | Features () const |
bool | IsValid () |
void | SetQuiet (bool quiet) |
void | NewTransfer () |
void | RecordBytesTransferred (size_t bytes) |
void | RecordFileSent (std::string from, std::string to) |
void | RecordFilesTransferred (size_t files) |
void | RecordFilesSkipped (size_t files) |
void | ReportProgress (const std::string &file, uint64_t file_copied_bytes, uint64_t file_total_bytes) |
void | ReportTransferRate (const std::string &file, TransferDirection direction) |
void | ReportOverallTransferRate (TransferDirection direction) |
bool | SendRequest (int id, const std::string &path) |
bool | SendSend2 (std::string_view path, mode_t mode, CompressionType compression, bool dry_run) |
bool | SendRecv2 (const std::string &path, CompressionType compression) |
bool | SendStat (const std::string &path) |
bool | SendLstat (const std::string &path) |
bool | FinishStat (struct stat *st) |
bool | SendLs (const std::string &path) |
bool | FinishLs (const std::function< sync_ls_cb > &callback) |
bool | SendSmallFile (const std::string &path, mode_t mode, const std::string &lpath, const std::string &rpath, unsigned mtime, const char *data, size_t data_length, bool dry_run) |
bool | SendLargeFile (const std::string &path, mode_t mode, const std::string &lpath, const std::string &rpath, unsigned mtime, CompressionType compression, bool dry_run) |
bool | SendLargeFileLegacy (const std::string &path, mode_t mode, const std::string &lpath, const std::string &rpath, unsigned mtime) |
bool | ReportCopyFailure (const std::string &from, const std::string &to, const syncmsg &msg) |
void | CopyDone () |
void | ReportDeferredCopyFailure (const std::string &msg) |
bool | ReadAcknowledgements (bool read_all=false) |
void | Printf (const char *fmt,...) __attribute__((__format__(__printf__ |
va_start (ap, fmt) | |
va_end (ap) | |
line_printer_ | Print (s, LinePrinter::INFO) |
void | Println (const char *fmt,...) __attribute__((__format__(__printf__ |
va_start (ap, fmt) | |
va_end (ap) | |
line_printer_ | Print (s, LinePrinter::INFO) |
line_printer_ | KeepInfoLine () |
void | Error (const char *fmt,...) __attribute__((__format__(__printf__ |
va_start (ap, fmt) | |
va_end (ap) | |
line_printer_ | Print (s, LinePrinter::ERROR) |
void | Warning (const char *fmt,...) __attribute__((__format__(__printf__ |
va_start (ap, fmt) | |
va_end (ap) | |
line_printer_ | Print (s, LinePrinter::WARNING) |
void | ComputeExpectedTotalBytes (const std::vector< copyinfo > &file_list) |
void | SetExpectedTotalBytes (uint64_t expected_total_bytes) |
Public Attributes | |
void va_list | ap |
android::base::StringAppendV & | s |
unique_fd | fd |
size_t | max |
Private Member Functions | |
bool | SendQuit () |
bool | WriteOrDie (const std::string &from, const std::string &to, const void *data, size_t data_length) |
Static Private Member Functions | |
template<bool v2> | |
static bool | FinishLsImpl (borrowed_fd fd, const std::function< sync_ls_cb > &callback) |
Private Attributes | |
std::deque< std::pair< std::string, std::string > > | deferred_acknowledgements_ |
Block | acknowledgement_buffer_ |
const FeatureSet * | features_ = nullptr |
bool | have_stat_v2_ |
bool | have_ls_v2_ |
bool | have_sendrecv_v2_ |
bool | have_sendrecv_v2_brotli_ |
bool | have_sendrecv_v2_lz4_ |
bool | have_sendrecv_v2_zstd_ |
bool | have_sendrecv_v2_dry_run_send_ |
TransferLedger | global_ledger_ |
TransferLedger | current_ledger_ |
LinePrinter | line_printer_ |
|
inline |
|
inline |
|
inline |
|
inline |
void SyncConnection::Error | ( | const char * | fmt, |
... | |||
) |
|
inline |
|
inline |
|
inlinestaticprivate |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
line_printer_ SyncConnection::KeepInfoLine | ( | ) |
|
inline |
line_printer_ SyncConnection::Print | ( | s | , |
LinePrinter::ERROR | |||
) |
line_printer_ SyncConnection::Print | ( | s | , |
LinePrinter::INFO | |||
) |
line_printer_ SyncConnection::Print | ( | s | , |
LinePrinter::INFO | |||
) |
line_printer_ SyncConnection::Print | ( | s | , |
LinePrinter::WARNING | |||
) |
void SyncConnection::Printf | ( | const char * | fmt, |
... | |||
) |
void SyncConnection::Println | ( | const char * | fmt, |
... | |||
) |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inlineprivate |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
SyncConnection::va_end | ( | ap | ) |
SyncConnection::va_end | ( | ap | ) |
SyncConnection::va_end | ( | ap | ) |
SyncConnection::va_end | ( | ap | ) |
SyncConnection::va_start | ( | ap | , |
fmt | |||
) |
SyncConnection::va_start | ( | ap | , |
fmt | |||
) |
SyncConnection::va_start | ( | ap | , |
fmt | |||
) |
SyncConnection::va_start | ( | ap | , |
fmt | |||
) |
void SyncConnection::Warning | ( | const char * | fmt, |
... | |||
) |
|
inlineprivate |
|
private |
void va_list SyncConnection::ap |
|
private |
|
private |
unique_fd SyncConnection::fd |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
|
private |
size_t SyncConnection::max |
android::base::StringAppendV & SyncConnection::s |