clientinterface.cpp File Reference

#include <clientinterface.h>
#include <extern.h>
#include <math.h>
#include <iostream>
#include <stdio.h>
#include "../interface/RioError.h"
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

Go to the source code of this file.

Functions
void	SendComplete (void *Param, int Result)
void	ReceiveComplete (void *Param, int Result)

---

Function Documentation

void ReceiveComplete	(	void *	Param,
		int	Result
	)

Definition at line 148 of file clientinterface.cpp.

{
    #ifdef RIO_DEBUG1
    RioErr << "[ClientInterface - ReceiveComplete] Start" << endl;
    #endif
    StrRequest* Request = (StrRequest*) Param;
    int FlagStatus;
    u16 Command = Request->Command;

    // Test if receiving data from client requires
    // a status message to be sent to router.
    if( ( Command & 0xf ) == MSG_RSS_WRITE )
    {
        #ifdef RIO_DEBUG2
        RioErr << "[ClientInterface - ReceiveComplete] Command: Write" << endl;
        #endif
        // if command is "write" this is the first of two steps
        // Send status message only if bit RSS_INTERMEDIATE is set
        if( Command & RSS_INTERMEDIATE )
            FlagStatus = 1;
        else
            FlagStatus = 0;
    }
    else
    {
        #ifdef RIO_DEBUG2
        RioErr << "[ClientInterface - ReceiveComplete] Command: Receive" << endl;
        #endif
        // If request is not "write" it should be "receive" (one step command)
        // Send status message if bit RSS_NOCOMPLETE is not set
        if( ( Command & RSS_NOCOMPLETE ) && ( Result == 0 ))
            FlagStatus = 0;
        else
            FlagStatus = 1;
    }

    // Reset flag bits on command
    Command = Command & 0xf;

    // Update request status
    if( Command == MSG_RSS_RECEIVE )
    {
        Request->Status = RequestStatusWaitFlushCommand;
    }
    else
    {
        Request->Status = RequestStatusReceiveDone;
    }

    StrMsg* Slot = NULL;

    // Prepare status message to router if required
    if( FlagStatus )
    {
        #ifdef RIO_DEBUG2
        RioErr << "[ClientInterface - ReceiveComplete] Preparing status message to router" << endl;
        #endif
        // Get a router message slot and fill message fields
        Slot = MsgManager.New();
        Slot->Msg.Storage.Status.Type          = MSG_RSS_RECEIVECOMPLETE;
        Slot->Msg.Storage.Status.Size          = SizeMsgRSSstatus;
        Slot->Msg.Storage.Status.RouterId      = Request->RouterId;
        Slot->Msg.Storage.Status.StorageId     = Request->Id;
        Slot->Msg.Storage.Status.ActiveThreads = 0;
        // --------------------------------------------------------------------
        if( Result == 0 )
            Slot->Msg.Storage.Status.Error     = 0;
        else
            Slot->Msg.Storage.Status.Error     = ERROR_RSS_RECEIVE_FAILED;
    }

    if( Result != 0 )
    {
        #ifdef RIO_DEBUG2
        struct in_addr clientip;
        clientip.s_addr = Request->IPaddress;
        RioErr << "clientinterface.ReceiveComplete - bad result : "
               << (int *) Result
               << " " << (unsigned int) Result
               << " : Reqid  " << Request->ClientId
               << " IP "       << inet_ntoa(clientip)
               << " Port "     << ntohs( Request->Port )
               << endl;
        #endif

        // If receive failed Free request
        RequestManager.Free(Request);
    }

    // Send status message to router if required
    if( FlagStatus )
    {
        #ifdef RIO_DEBUG2
        RioErr << "[ClientInterface - ReceiveComplete] Sending status message "
               << "to router" << endl;
        #endif

        Router.Send(Slot);
    }

    if( Result == 0 )
    {
        // For write command send data to device
        if( Command == MSG_RSS_WRITE )
        {
            #ifdef RIO_DEBUG2
            RioErr << "[ClientInterface - ReceiveComplete] Sending data to device" << endl;
            #endif
            Device[Request->Disk].ProcessRequest(Request);
        }
    }
    #ifdef RIO_DEBUG1
    RioErr << "[ClientInterface - ReceiveComplete] Finish" << endl;
    #endif
}

void SendComplete	(	void *	Param,
		int	Result
	)

Definition at line 82 of file clientinterface.cpp.

{
    StrRequest* Request = (StrRequest*) Param;

    int FlagStatus;
    u16 Command = Request->Command;

    if( Result )
    {
        struct in_addr clientip;
        clientip.s_addr = Request->IPaddress;
        RioErr << "clientinterface.SendComplete - bad result : "
               << (int *) Result
               << " " << (unsigned int) Result
               << " : Reqid  " << Request->ClientId
               << " IP "       << inet_ntoa(clientip)
               << " Port "     << ntohs( Request->Port )
               << endl;
    }

    // Test if sending data to client requires a
    // status message to be sent to router.
    // Send status message if bit RSS_NOCOMPLETE is not set
    if( ( Command & RSS_NOCOMPLETE ) && ( Result == 0 ))
        FlagStatus = 0;
    else
        FlagStatus = 1;

    StrMsg* Slot = NULL;

    u32 temp;

    // If required prepare a message to be sent to router
    if( FlagStatus )
    {
        // Get a router message slot and fill message fields
        Slot = MsgManager.New();
        Slot->Msg.Storage.Status.Type          = MSG_RSS_SENDCOMPLETE;
        Slot->Msg.Storage.Status.Size          = SizeMsgRSSstatus;
        Slot->Msg.Storage.Status.RouterId      = Request->RouterId;
        Slot->Msg.Storage.Status.StorageId     = Request->Id;
        Slot->Msg.Storage.Status.ActiveThreads = 0;
        // --------------------------------------------------------------------
        if( Result == 0 )
            Slot->Msg.Storage.Status.Error     = 0;
        else
            Slot->Msg.Storage.Status.Error     = ERROR_RSS_SEND_FAILED;
        temp = Request->Id;
    }

    // Free request
    RequestManager.Free( Request );

    // If required send status message to router
    if( FlagStatus )
    {
        #ifdef RIO_DEBUG2
        RioErr <<"Sending status (SEND COMPLETE) to router " << endl;
        #endif

        Router.Send(Slot);
    }
}