#include "swapserver.h"

swapserver::swapserver()
{

}

int swapserver::broadmsg(std::string strobjid,std::shared_ptr<char> pdata_ptr,int ndatasize,double fpingavg,double flatency_nodestore)
{
    int nrtn = 0;
    int i;
    for(i=0;i<(int)mvectorswap.size();i++)
    {
        nrtn = nrtn + mvectorswap[i]->sendmsg(strobjid,pdata_ptr,ndatasize,fpingavg,flatency_nodestore);
    }
    return nrtn;
}

swapunit * swapserver::AddSwapUnit(std::string strnodeid, std::string strobjnodeid, ::grpc::ServerReaderWriter<iv::CloudSwapReplyStream, iv::CloudSwapRequestStream> *stream)
{
    swapunit * pswap = new swapunit(strnodeid,strobjnodeid,stream);
    mmutex.lock();
    mvectorswap.push_back(pswap);
    mmutex.unlock();
    return pswap;
}