Forgot to add PUT example source files

/*

* kinetic-c

* Copyright (C) 2014 Seagate Technology.

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

*

*/

#include "noop.h"

int Put(const char* host, int port, int64_t clusterVersion, int64_t identity, const char* key, const uint8_t* data, int64_t length)

{

    KineticExchange exchange;

    KineticOperation operation;

    KineticPDU request, response;

    KineticConnection connection;

    KineticMessage requestMsg;

    KineticProto_Status_StatusCode status;

    bool success;

    uint8_t value[1024*1024];

    int i;

    for (i = 0; i < sizeof(value); i++)

    {

        value[i] = (uint8_t)(0x0ff & i);

    }

    KineticApi_Init(NULL);

    success = KineticApi_Connect(&connection, host, port, true);

    assert(success);

    assert(connection.socketDescriptor >= 0);

    success = KineticApi_ConfigureExchange(&exchange, &connection, clusterVersion, identity, key, strlen(key));

    assert(success);

    operation = KineticApi_CreateOperation(&exchange, &request, &requestMsg, &response);

    status = KineticApi_Put(&operation, value, sizeof(value));

    if (status == KINETIC_PROTO_STATUS_STATUS_CODE_SUCCESS)

    {

        printf("Put operation completed successfully. Your data is now stored!\n");

        return 0;

    }

    else

    {

        const KineticProto_Status* protoStatus = response.proto->command->status;

        const ProtobufCMessage* protoMessage = (ProtobufCMessage*)protoStatus;

        const ProtobufCMessageDescriptor* protoMessageDescriptor = protoMessage->descriptor;

        // Output status code short name

        const ProtobufCFieldDescriptor* statusCodeDescriptor =

            protobuf_c_message_descriptor_get_field_by_name(protoMessageDescriptor, "code");

        const ProtobufCEnumDescriptor* statusCodeEnumDescriptor =

            (ProtobufCEnumDescriptor*)statusCodeDescriptor->descriptor;

        const ProtobufCEnumValue* eStatusCodeVal =

            protobuf_c_enum_descriptor_get_value(statusCodeEnumDescriptor, status);

        printf("NoOp operation completed but failed w/error: %s=%d(%s)\n",

            statusCodeDescriptor->name, status, eStatusCodeVal->name);

        // Output status message, if supplied

        if (protoStatus->statusmessage)

        {

            const ProtobufCFieldDescriptor* statusMsgFieldDescriptor =

                protobuf_c_message_descriptor_get_field_by_name(protoMessageDescriptor, "statusMessage");

            const ProtobufCMessageDescriptor* statusMsgDescriptor =

                (ProtobufCMessageDescriptor*)statusMsgFieldDescriptor->descriptor;

            printf("  %s: '%s'", statusMsgDescriptor->name, protoStatus->statusmessage);

        }

        // Output detailed message, if supplied

        if (protoStatus->has_detailedmessage)

        {

            int i;

            char tmp[8], msg[256];

            const ProtobufCFieldDescriptor* statusDetailedMsgFieldDescriptor =

                protobuf_c_message_descriptor_get_field_by_name(protoMessageDescriptor, "detailedMessage");

            const ProtobufCMessageDescriptor* statusDetailedMsgDescriptor =

                (ProtobufCMessageDescriptor*)statusDetailedMsgFieldDescriptor->descriptor;

            sprintf(msg, "  %s: ", statusDetailedMsgDescriptor->name);

            for (i = 0; i < protoStatus->detailedmessage.len; i++)

            {

                sprintf(tmp, "%02hhX", protoStatus->detailedmessage.data[i]);

                strcat(msg, tmp);

            }

            printf("  %s", msg);

        }

        return status;

    }

}

/*

* kinetic-c

* Copyright (C) 2014 Seagate Technology.

*

* This program is free software; you can redistribute it and/or

* modify it under the terms of the GNU General Public License

* as published by the Free Software Foundation; either version 2

* of the License, or (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

*

*/

#ifndef _NOOP_H

#define _NOOP_H

#include "kinetic.h"

/**

 * @brief Connects to the specified Kinetic host/port and executes a NoOp (ping) operation

 *

 * @param host              Host name or IP address to connect to

 * @param port              Port to establish socket connection on

 * @param clusterVersion    Cluster version to use for the operation

 * @param identity          Identity to use for the operation (Must have ACL setup on Kinetic Device)

 * @param key               Shared secret key used for the identity for HMAC calculation

 * @param data              Pointer to data buffer to write

 * @param len               Length of data buffer to write

 *

 * @return                  Returns true if operation succeeded, false otherwise

 */

int Put(const char* host,

        int port,

        int64_t clusterVersion,

        int64_t identity,

        const char* key,

        const uint8_t* data,

        int64_t len);

#endif // _NOOP_H