mirror of
https://github.com/OpenNebula/one.git
synced 2024-12-24 21:34:01 +03:00
102 lines
2.8 KiB
C++
102 lines
2.8 KiB
C++
/* -------------------------------------------------------------------------- */
|
|
/* Copyright 2002-2014, OpenNebula Project (OpenNebula.org), C12G Labs */
|
|
/* */
|
|
/* 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 SYNC_REQUEST_H_
|
|
#define SYNC_REQUEST_H_
|
|
|
|
#include <time.h>
|
|
|
|
#include "ActionManager.h"
|
|
|
|
/**
|
|
* Base class to implement synchronous operation in the MadManagers. This class
|
|
* cannot be directly instantiated.
|
|
*/
|
|
class SyncRequest: public ActionListener
|
|
{
|
|
public:
|
|
SyncRequest():
|
|
result(false),
|
|
message(""),
|
|
timeout(false),
|
|
id(-1),
|
|
time_out(0)
|
|
{
|
|
am.addListener(this);
|
|
};
|
|
|
|
virtual ~SyncRequest(){};
|
|
|
|
/**
|
|
* The result of the request, true if the operation succeeded
|
|
*/
|
|
bool result;
|
|
|
|
/**
|
|
* Error message for negative results
|
|
*/
|
|
string message;
|
|
|
|
/**
|
|
* Time out, true if the request ended because of a time out
|
|
*/
|
|
bool timeout;
|
|
|
|
/**
|
|
* Identification of this request
|
|
*/
|
|
int id;
|
|
|
|
/**
|
|
* Notify client that we have an answer for the request
|
|
*/
|
|
void notify()
|
|
{
|
|
am.trigger(ActionListener::ACTION_FINALIZE,0);
|
|
};
|
|
|
|
/**
|
|
* Wait for the AuthRequest to be completed
|
|
*/
|
|
void wait()
|
|
{
|
|
time_out = time(0) + 90;//Requests will expire in 1.5 minutes
|
|
|
|
am.loop(0,0);
|
|
};
|
|
|
|
protected:
|
|
|
|
friend class MadManager;
|
|
|
|
/**
|
|
* Time in seconds when this request will expire
|
|
*/
|
|
time_t time_out;
|
|
|
|
/**
|
|
* The ActionManager that will be notify when the request is ready.
|
|
*/
|
|
ActionManager am;
|
|
|
|
/**
|
|
* No actions defined for the request, just FINALIZE when done
|
|
*/
|
|
void do_action(const string &name, void *args){};
|
|
};
|
|
|
|
#endif /*SYNC_REQUEST_H_*/
|