BroadcastServer.h

Go to the documentation of this file.

/*****************************************************************************
 *                                                                           *
 *  Copyright 2018 Rice University                                           *
 *                                                                           *
 *  Licensed under the Apache License, Version 2.0 (the "License");          *
 *  you may not use this file except in compliance with the License.         *
 *  You may obtain a copy of the License at                                  *
 *                                                                           *
 *      http://www.apache.org/licenses/LICENSE-2.0                           *
 *                                                                           *
 *  Unless required by applicable law or agreed to in writing, software      *
 *  distributed under the License is distributed on an "AS IS" BASIS,        *
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. *
 *  See the License for the specific language governing permissions and      *
 *  limitations under the License.                                           *
 *                                                                           *
 *****************************************************************************/
#ifndef OBJECTQUERYMODEL_BROADCASTSERVER_H
#define OBJECTQUERYMODEL_BROADCASTSERVER_H

#include "ServerFunctionality.h"
#include "Configuration.h"
#include <mutex>

namespace pdb {

class BroadcastServer : public ServerFunctionality {

public:
    BroadcastServer(PDBLoggerPtr logger, ConfigurationPtr conf);

    BroadcastServer(PDBLoggerPtr logger);
    ~BroadcastServer();

    void registerHandlers(PDBServer& forMe) override;  // no-op

    template <class MsgType, class PayloadType, class ResponseType>
    void broadcast(Handle<MsgType> broadcastMsg,
                   Handle<Vector<Handle<PayloadType>>> broadCastData,
                   std::vector<std::string> receivers,
                   std::function<void(Handle<ResponseType>, std::string)> successCallBack,
                   std::function<void(std::string, std::string)> errorCallBack =
                       [](std::string errMsg, std::string serverName) { /* no-op */ });

private:
    template <class DataType>
    Handle<DataType> deepCopy(const Handle<DataType>& original);

    std::mutex lock;

    // Jia added a configuration object as protected member
protected:
    PDBLoggerPtr logger;
    ConfigurationPtr conf;
    pthread_mutex_t connection_mutex;
};
}

#include "BroadcastServerTemplate.cc"

#endif  // OBJECTQUERYMODEL_BROADCASTSERVER_H