Commit bb54c349 authored by Greg Williams's avatar Greg Williams
Browse files

Added more support to implement basic NOOP command, but still need to complete implementation

parent 7c1283c2

Rakefile

+1 −1
Original line number Diff line number Diff line
@@ -103,7 +103,7 @@ namespace :doxygen do 
      git "status"

      git "commit -m 'Regenerated API docs for v#{VERSION}'"

      git "push"

      report_banner "Published updated API docs to GitHub!"

      report_banner "Published updated API docs for v#{VERSION} to GitHub!"

    end

  end

include/kinetic/kinetic.h

+4 −1
Original line number Diff line number Diff line
@@ -21,6 +21,9 @@ 
#ifndef KINETIC_C_CLIENT_KINETIC_H_

#define KINETIC_C_CLIENT_KINETIC_H_



/// Applications should only include this file

#include "KineticTypes.h"

#include "KineticAPI.h"

#include "KineticProto.h"

#include "KineticConnection.h"



#endif /* KINETIC_C_CLIENT_KINETIC_H_ */

src/lib/KineticApi.c

+9 −3
Original line number Diff line number Diff line 
#include "KineticApi.h"

#include "KineticConnection.h"

#include "KineticLogger.h"

#include <stdio.h>
@@ -28,7 +27,14 @@ const KineticConnection KineticApi_Connect(const char* host, int port, bool bloc 
	return connection;

}



KineticProto_Status_StatusCode KineticApi_SendNoop(const KineticConnection* connection)

KineticProto_Status_StatusCode KineticApi_SendNoop(

    KineticConnection* connection,

    KineticExchange* exchange,

    KineticMessage* message)

{

	return KINETIC_PROTO_STATUS_STATUS_CODE_INVALID_STATUS_CODE;

    KineticExchange_Init(exchange, 1234, 5678);

    KineticMessage_Init(message, exchange);

    KineticConnection_SendMessage(connection, message);



	return KINETIC_PROTO_STATUS_STATUS_CODE_NOT_ATTEMPTED;

}

src/lib/KineticApi.h

+4 −1
Original line number Diff line number Diff line
@@ -2,9 +2,12 @@ 
#define _KINETIC_API_H



#include "KineticTypes.h"

#include "KineticConnection.h"

#include "KineticExchange.h"

#include "KineticMessage.h"



void KineticApi_Init(const char* log_file);

const KineticConnection KineticApi_Connect(const char* host, int port, bool blocking);

KineticProto_Status_StatusCode KineticApi_SendNoop(const KineticConnection* connection);

KineticProto_Status_StatusCode KineticApi_SendNoop(KineticConnection* connection, KineticExchange* exchange, KineticMessage* message);



#endif // _KINETIC_API_H

src/lib/KineticConnection.c

+7 −0
Original line number Diff line number Diff line
@@ -24,3 +24,10 @@ bool KineticConnection_Connect(KineticConnection* connection, const char* host, 


    return connection->Connected;

}



bool KineticConnection_SendMessage(KineticConnection* connection, KineticMessage* message)

{

    connection = connection;

    message = message;

    return false;

}