Searched refs:cluster_ops (Results 1 – 7 of 7) sorted by relevance
59 int64_t GetNextOpOffset(const CowOperation& op, uint32_t cluster_ops) { in GetNextOpOffset() argument62 } else if (op.type == kCowReplaceOp && cluster_ops == 0) { in GetNextOpOffset()69 int64_t GetNextDataOffset(const CowOperation& op, uint32_t cluster_ops) { in GetNextDataOffset() argument71 return cluster_ops * sizeof(CowOperation); in GetNextDataOffset()72 } else if (cluster_ops == 0) { in GetNextDataOffset()
96 header_.cluster_ops = options_.cluster_ops; in SetupHeaders()114 if (options_.cluster_ops == 1) { in ParseOptions()171 cluster_size_ = header_.cluster_ops * sizeof(CowOperation); in InitPos()172 if (header_.cluster_ops) { in InitPos()238 options_.cluster_ops = header_.cluster_ops; in OpenForAppend()506 } else if (header_.cluster_ops) { in AddOperation()511 next_data_pos_ += op.data_length + GetNextDataOffset(op, header_.cluster_ops); in AddOperation()512 next_op_pos_ += sizeof(CowOperation) + GetNextOpOffset(op, header_.cluster_ops); in AddOperation()
67 options.cluster_ops = 0; in TEST_F()145 options.cluster_ops = 0; in TEST_F()183 options.cluster_ops = 2; in TEST_F()247 options.cluster_ops = 0; in TEST_F()290 options.cluster_ops = 0; in TEST_P()320 options.cluster_ops = 0; in TEST_F()346 options.cluster_ops = 0; in TEST_F()412 options.cluster_ops = 0; in TEST_F()466 options.cluster_ops = 0; in TEST_F()519 options.cluster_ops = 0; in TEST_F()[all …]
107 if (header_.cluster_ops == 1) { in Parse()116 if (header_.cluster_ops == 1) { in Parse()157 uint64_t cluster_ops = header_.cluster_ops ?: 1; in ParseOps() local162 uint64_t to_add = std::min(cluster_ops, (fd_size_ - pos) / sizeof(CowOperation)); in ParseOps()174 pos += sizeof(CowOperation) + GetNextOpOffset(current_op, header_.cluster_ops); in ParseOps()
56 DEFINE_uint32(cluster_ops, 0, "Number of Cow Ops per cluster (0 or >1)");193 options.cluster_ops = FLAGS_cluster_ops; in ProcessPartition()
74 uint32_t cluster_ops; member
38 uint32_t cluster_ops = 200; member