Skip to content

Commit

Permalink
Removing old unused lines
Browse files Browse the repository at this point in the history
  • Loading branch information
jcarreira committed Dec 26, 2017
1 parent efa9cf9 commit bca32a2
Showing 1 changed file with 0 additions and 13 deletions.
13 changes: 0 additions & 13 deletions examples/ml/S3Iterator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,6 @@ S3Iterator::S3Iterator(
s3_initialize_aws();
s3_client.reset(s3_create_client_ptr());

//cur = left_id;
last = left_id; // last is exclusive

for (uint64_t i = 0; i < read_ahead; ++i) {
Expand All @@ -36,7 +35,6 @@ S3Iterator::S3Iterator(

std::shared_ptr<double> S3Iterator::get_next() {
//std::cout << "Get next "
// //<< " cur: " << cur
// << " last: " << last
// << "\n";
while (1) {
Expand All @@ -51,10 +49,6 @@ std::shared_ptr<double> S3Iterator::get_next() {

std::shared_ptr<double> ret = ring.front();
ring.pop_front();
//cur++;
//if (cur == right_id) {
// cur = left_id;
//}

uint64_t ring_size = ring.size();
ring_lock.unlock();
Expand All @@ -64,11 +58,6 @@ std::shared_ptr<double> S3Iterator::get_next() {
pref_sem.signal();
}

//std::cout << "Returning prefetched batch"
// //<< " cur: " << cur
// << " last: " << last
// << " ring size: " << ring_size
// << std::endl;
return ret;
}

Expand Down Expand Up @@ -135,8 +124,6 @@ void S3Iterator::thread_function() {

// update index
last++;
//if (last == cur)
// throw std::runtime_error("Error in iterator");
if (last == right_id)
last = left_id;

Expand Down

0 comments on commit bca32a2

Please sign in to comment.