Commit 6bc4d012 authored by Manuel Wudka-Robles's avatar Manuel Wudka-Robles
Browse files

Switch to unique_ptr_output

parent 6b622339

src/delete_file_nonblocking.cc

+1 −2
Original line number Diff line number Diff line
@@ -64,14 +64,13 @@ int main(int argc, char* argv[]) { 
        return 1;

    }



    KineticRecord* record;

    std::unique_ptr<KineticRecord> record;

    if(!connection->blocking().Get(kinetic_key, &record).ok()) {

        printf("Unable to get metadata\n");

        return 1;

    }



    long long file_size = std::stoll(record->value());

    delete record;

    printf("Deleting file of size %llu\n", file_size);



    char key_buffer[100];

src/read_file_blocking.cc

+3 −5
Original line number Diff line number Diff line
@@ -48,14 +48,14 @@ int main(int argc, char* argv[]) { 
    }





    KineticRecord* record;

    std::unique_ptr<KineticRecord> record;

    if(!connection->blocking().Get(kinetic_key, &record).ok()) {

        printf("Unable to get metadata\n");

        return 1;

    }



    ssize_t file_size = std::stoll(record->value());

    delete record;



    printf("Reading file of size %zd\n", file_size);



    int file = open(output_file_name, O_RDWR | O_CREAT | O_TRUNC, S_IRUSR | S_IWUSR);
@@ -82,14 +82,12 @@ int main(int argc, char* argv[]) { 
        sprintf(key_buffer, "%s-%10" PRId64, kinetic_key, i);

        std::string key(key_buffer);



        KineticRecord* record;

        if(!connection->blocking().Get(key, &record).ok()) {

            printf("Unable to get chunk\n");

            return 1;

        }

        

        record->value().copy(output_buffer + i, block_length);

        delete record;



        printf(".");

        fflush(stdout);

src/read_file_nonblocking.cc

+1 −2
Original line number Diff line number Diff line
@@ -79,14 +79,13 @@ int main(int argc, char* argv[]) { 
    }





    KineticRecord* record;

    std::unique_ptr<KineticRecord> record;

    if(!connection->blocking().Get(kinetic_key, &record).ok()) {

        printf("Unable to get metadata\n");

        return 1;

    }



    long long file_size = std::stoll(record->value());

    delete record;

    printf("Reading file of size %llu\n", file_size);