schedule_rewrite_rpc_handler.h

Go to the documentation of this file.

// Copyright 2016 Google Inc.

#ifndef PAGESPEED_CONTROLLER_SCHEDULE_REWRITE_RPC_HANDLER_H_
#define PAGESPEED_CONTROLLER_SCHEDULE_REWRITE_RPC_HANDLER_H_

#include "pagespeed/controller/controller.pb.h"
#include "pagespeed/controller/controller.grpc.pb.h"
#include "pagespeed/controller/rpc_handler.h"
#include "pagespeed/kernel/base/basictypes.h"
#include "pagespeed/kernel/base/function.h"
#include "pagespeed/kernel/util/grpc.h"
#include "pagespeed/kernel/base/string.h"
#include "pagespeed/controller/schedule_rewrite_controller.h"
#include "pagespeed/controller/request_result_rpc_handler.h"

namespace net_instaweb {


class ScheduleRewriteRpcHandler
    : public RequestResultRpcHandler<
          ScheduleRewriteRpcHandler, ScheduleRewriteController,
          grpc::CentralControllerRpcService::AsyncService,
          ScheduleRewriteRequest, ScheduleRewriteResponse> {
 protected:
  ScheduleRewriteRpcHandler(
      grpc::CentralControllerRpcService::AsyncService* service,
      ::grpc::ServerCompletionQueue* cq, ScheduleRewriteController* controller);

  void HandleClientRequest(const ScheduleRewriteRequest& req,
                           Function* cb) override;
  void HandleClientResult(const ScheduleRewriteRequest& req) override;
  void HandleOperationFailed() override;

  void InitResponder(grpc::CentralControllerRpcService::AsyncService* service,
                     ::grpc::ServerContext* ctx, ReaderWriterT* responder,
                     ::grpc::ServerCompletionQueue* cq,
                     void* callback) override;

 private:
  GoogleString key_; 

  friend class RequestResultRpcHandler;
  friend class ScheduleRewriteRpcHandlerTest;

  
};

}  

#endif