@@ -34,16 +34,16 @@ po::options_description make_usage() {
3434 return desc;
3535}
3636
37- using AioCompRef = unique_ptr<AioCompletion>;
37+ using AioCompRef = std:: unique_ptr<AioCompletion>;
3838
3939class SampleDedupWorkerThread : public Thread
4040{
4141public:
4242 struct chunk_t {
43- string oid = " " ;
43+ std:: string oid = " " ;
4444 size_t start = 0 ;
4545 size_t size = 0 ;
46- string fingerprint = " " ;
46+ std:: string fingerprint = " " ;
4747 bufferlist data;
4848 };
4949
@@ -187,7 +187,7 @@ class SampleDedupWorkerThread : public Thread
187187 }
188188 }
189189
190- bool contains (string& fp) {
190+ bool contains (std:: string& fp) {
191191 std::shared_lock lock (fingerprint_lock);
192192 return fp_map.contains (fp);
193193 }
@@ -319,11 +319,11 @@ class SampleDedupWorkerThread : public Thread
319319 void try_dedup_and_accumulate_result (ObjectItem &object, snap_t snap = 0 );
320320 int do_chunk_dedup (chunk_t &chunk, snap_t snap);
321321 bufferlist read_object (ObjectItem &object);
322- std::vector<std::tuple<bufferlist, pair<uint64_t , uint64_t >>> do_cdc (
322+ std::vector<std::tuple<bufferlist, std:: pair<uint64_t , uint64_t >>> do_cdc (
323323 ObjectItem &object,
324324 bufferlist &data);
325325 std::string generate_fingerprint (bufferlist chunk_data);
326- AioCompRef do_async_evict (string oid);
326+ AioCompRef do_async_evict (std:: string oid);
327327
328328 IoCtx io_ctx;
329329 IoCtx chunk_io_ctx;
@@ -362,7 +362,7 @@ void SampleDedupWorkerThread::crawl()
362362 op.list_snaps (&snap_set, &snap_ret);
363363 io_ctx.operate (target.oid , &op, NULL );
364364
365- for (vector<librados::clone_info_t >::const_iterator r = snap_set.clones .begin ();
365+ for (std:: vector<librados::clone_info_t >::const_iterator r = snap_set.clones .begin ();
366366 r != snap_set.clones .end ();
367367 ++r) {
368368 io_ctx.snap_set_read (r->cloneid );
@@ -378,7 +378,7 @@ void SampleDedupWorkerThread::crawl()
378378 }
379379 }
380380
381- vector<AioCompRef> evict_completions (oid_for_evict.size ());
381+ std:: vector<AioCompRef> evict_completions (oid_for_evict.size ());
382382 int i = 0 ;
383383 for (auto &oid : oid_for_evict) {
384384 if (snap) {
@@ -392,7 +392,7 @@ void SampleDedupWorkerThread::crawl()
392392 }
393393}
394394
395- AioCompRef SampleDedupWorkerThread::do_async_evict (string oid)
395+ AioCompRef SampleDedupWorkerThread::do_async_evict (std:: string oid)
396396{
397397 Rados rados;
398398 ObjectReadOperation op_tier;
@@ -432,7 +432,7 @@ std::vector<size_t> SampleDedupWorkerThread::sample_object(size_t count)
432432 for (size_t i = 0 ; i < count ; i++) {
433433 indexes[i] = i;
434434 }
435- default_random_engine generator;
435+ std:: default_random_engine generator;
436436 shuffle (indexes.begin (), indexes.end (), generator);
437437 size_t sampling_count = static_cast <double >(count) *
438438 sample_dedup_global.sampling_ratio ;
@@ -466,7 +466,7 @@ void SampleDedupWorkerThread::try_dedup_and_accumulate_result(
466466 }
467467
468468 size_t duplicated_size = 0 ;
469- list<chunk_t > redundant_chunks;
469+ std:: list<chunk_t > redundant_chunks;
470470 for (auto &chunk : chunks) {
471471 auto &chunk_data = std::get<0 >(chunk);
472472 std::string fingerprint = generate_fingerprint (chunk_data);
@@ -525,14 +525,14 @@ bufferlist SampleDedupWorkerThread::read_object(ObjectItem &object)
525525 return whole_data;
526526}
527527
528- std::vector<std::tuple<bufferlist, pair<uint64_t , uint64_t >>> SampleDedupWorkerThread::do_cdc (
528+ std::vector<std::tuple<bufferlist, std:: pair<uint64_t , uint64_t >>> SampleDedupWorkerThread::do_cdc (
529529 ObjectItem &object,
530530 bufferlist &data)
531531{
532- std::vector<std::tuple<bufferlist, pair<uint64_t , uint64_t >>> ret;
532+ std::vector<std::tuple<bufferlist, std:: pair<uint64_t , uint64_t >>> ret;
533533
534- unique_ptr<CDC> cdc = CDC::create (chunk_algo, cbits (chunk_size) - 1 );
535- vector<pair<uint64_t , uint64_t >> chunks;
534+ std:: unique_ptr<CDC> cdc = CDC::create (chunk_algo, cbits (chunk_size) - 1 );
535+ std:: vector<std:: pair<uint64_t , uint64_t >> chunks;
536536 cdc->calc_chunks (data, &chunks);
537537 for (auto &p : chunks) {
538538 bufferlist chunk;
@@ -545,7 +545,7 @@ std::vector<std::tuple<bufferlist, pair<uint64_t, uint64_t>>> SampleDedupWorkerT
545545
546546std::string SampleDedupWorkerThread::generate_fingerprint (bufferlist chunk_data)
547547{
548- string ret;
548+ std:: string ret;
549549
550550 switch (fp_type) {
551551 case pg_pool_t ::TYPE_FINGERPRINT_SHA1:
@@ -598,8 +598,8 @@ int SampleDedupWorkerThread::do_chunk_dedup(chunk_t &chunk, snap_t snap)
598598
599599int run_crawling_daemon (const po::variables_map &opts)
600600{
601- string base_pool_name = get_opts_pool_name (opts);
602- string chunk_pool_name = get_opts_chunk_pool (opts);
601+ std:: string base_pool_name = get_opts_pool_name (opts);
602+ std:: string chunk_pool_name = get_opts_chunk_pool (opts);
603603 unsigned max_thread = get_opts_max_thread (opts);
604604 uint32_t report_period = get_opts_report_period (opts);
605605 bool run_once = false ; // for debug
@@ -612,7 +612,7 @@ int run_crawling_daemon(const po::variables_map &opts)
612612 if (opts.count (" chunk-size" )) {
613613 chunk_size = opts[" chunk-size" ].as <int >();
614614 } else {
615- cout << " 8192 is set as chunk size by default" << std::endl;
615+ std:: cout << " 8192 is set as chunk size by default" << std::endl;
616616 }
617617 bool snap = false ;
618618 if (opts.count (" snap" )) {
@@ -641,14 +641,14 @@ int run_crawling_daemon(const po::variables_map &opts)
641641 if (opts.count (" wakeup-period" )) {
642642 wakeup_period = opts[" wakeup-period" ].as <int >();
643643 } else {
644- cout << " 100 second is set as wakeup period by default" << std::endl;
644+ std:: cout << " 100 second is set as wakeup period by default" << std::endl;
645645 }
646646
647647 const size_t fp_threshold = opts[" fpstore-threshold" ].as <size_t >();
648648
649649 std::string fp_algo = get_opts_fp_algo (opts);
650650
651- list<string> pool_names;
651+ std:: list<std:: string> pool_names;
652652 IoCtx io_ctx, chunk_io_ctx;
653653 pool_names.push_back (base_pool_name);
654654 ret = rados.ioctx_create (base_pool_name.c_str (), io_ctx);
@@ -731,7 +731,7 @@ int run_crawling_daemon(const po::variables_map &opts)
731731
732732 sleep (wakeup_period);
733733
734- map<string, librados::pool_stat_t > stats;
734+ std:: map<std:: string, librados::pool_stat_t > stats;
735735 ret = rados.get_pool_stats (pool_names, stats);
736736 if (ret < 0 ) {
737737 derr << " error fetching pool stats: " << cpp_strerror (ret) << dendl;
@@ -756,7 +756,7 @@ int main(int argc, const char **argv)
756756{
757757 auto args = argv_to_vec (argc, argv);
758758 if (args.empty ()) {
759- cerr << argv[0 ] << " : -h or --help for usage" << std::endl;
759+ std:: cerr << argv[0 ] << " : -h or --help for usage" << std::endl;
760760 exit (1 );
761761 }
762762
@@ -774,7 +774,7 @@ int main(int argc, const char **argv)
774774 return 1 ;
775775 }
776776 if (opts.count (" help" ) || opts.count (" h" )) {
777- cout<< desc << std::endl;
777+ std:: cout<< desc << std::endl;
778778 exit (0 );
779779 }
780780
@@ -787,7 +787,7 @@ int main(int argc, const char **argv)
787787 std::string err;
788788 int r = forker.prefork (err);
789789 if (r < 0 ) {
790- cerr << err << std::endl;
790+ std:: cerr << err << std::endl;
791791 return r;
792792 }
793793 if (forker.is_parent ()) {
0 commit comments