Commit 062ed419 authored by Manuel Wudka-Robles's avatar Manuel Wudka-Robles
Browse files

ACL and PIN examples use blocking API

parent d1433ec8
Loading
Loading
Loading
Loading
+2 −2
Original line number Diff line number Diff line
@@ -61,8 +61,8 @@ endmacro(add_example_target)
add_example_target(kineticstat)
add_example_target(ise)
add_example_target(setclusterversion)
#add_example_target(setpin)
#add_example_target(set_acls)
add_example_target(setpin)
add_example_target(set_acls)
add_example_target(write_file_blocking)
add_example_target(read_file_blocking)
add_example_target(read_file_nonblocking)
+8 −6
Original line number Diff line number Diff line
@@ -38,22 +38,22 @@ int main(int argc, char* argv[]) {

    kinetic::KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();

    kinetic::KineticConnection* kinetic_connection;
    if (!kinetic_connection_factory.NewConnection(options, &kinetic_connection).ok()) {
    kinetic::BlockingKineticConnection* kinetic_connection;
    if (!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {
        printf("Unable to connect\n");
        return 1;
    }

    Domain domain1 = {.offset = 0, .value = "", .roles = {kinetic::GETLOG}};
    std::list<Domain> acl1_domains = {
        {.offset = 0, .value = "", .roles = {kinetic::GETLOG}},
        domain1,
    };
    ACL acl1;
    acl1.client_id = 1000;
    acl1.hmac_key = "foobarbaz";
    acl1.domains = acl1_domains;

    std::list<Domain> acl2_domains = {
        {.offset = 0, .value = "", .roles = {
    Domain domain2 = {.offset = 0, .value = "", .roles = {
            kinetic::READ,
            kinetic::WRITE,
            kinetic::DELETE,
@@ -62,7 +62,9 @@ int main(int argc, char* argv[]) {
            kinetic::P2POP,
            kinetic::GETLOG,
            kinetic::SECURITY},
        }
    };
    std::list<Domain> acl2_domains = {
        domain2
    };
    ACL acl2;
    acl2.client_id = 1;
+4 −4
Original line number Diff line number Diff line
@@ -37,8 +37,8 @@ int main(int argc, char* argv[]) {

    kinetic::KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();

    kinetic::KineticConnection* kinetic_connection;
    if (!kinetic_connection_factory.NewConnection(options, &kinetic_connection).ok()) {
    kinetic::BlockingKineticConnection* kinetic_connection;
    if (!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {
        printf("Unable to connect\n");
        return 1;
    }
@@ -48,8 +48,8 @@ int main(int argc, char* argv[]) {
    if (argc == 4) {
        success = kinetic_connection->SetPin(argv[3]).ok();
    } else {
        const std::string pin(argv[4]);
        success = kinetic_connection->SetPin(argv[3], &pin).ok();
        const std::string pin(argv[3]);
        success = kinetic_connection->SetPin(argv[4], &pin).ok();
    }

    if (success) {