2012-06-01 14:02:15 +04:00
/* -------------------------------------------------------------------------- */
2021-02-09 18:07:56 +03:00
/* Copyright 2002-2021, OpenNebula Project, OpenNebula Systems */
2012-06-01 14:02:15 +04:00
/* */
/* 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>
2020-07-24 17:00:59 +03:00
# include "Listener.h"
2012-06-01 14:02:15 +04:00
/**
* Base class to implement synchronous operation in the MadManagers . This class
* cannot be directly instantiated .
*/
2020-07-24 17:00:59 +03:00
class SyncRequest : public Listener
2012-06-01 14:02:15 +04:00
{
public :
SyncRequest ( ) :
2020-07-24 17:00:59 +03:00
Listener ( " " ) ,
2012-06-01 14:02:15 +04:00
result ( false ) ,
message ( " " ) ,
timeout ( false ) ,
id ( - 1 ) ,
2017-09-15 01:38:54 +03:00
time_out ( 0 )
2012-06-01 14:02:15 +04:00
{
2020-07-24 17:00:59 +03:00
}
2012-06-01 14:02:15 +04:00
2020-07-24 17:00:59 +03:00
virtual ~ SyncRequest ( ) = default ;
2012-06-01 14:02:15 +04:00
/**
2015-07-01 22:15:40 +03:00
* The result of the request , true if the operation succeeded
2012-06-01 14:02:15 +04:00
*/
bool result ;
/**
* Error message for negative results
*/
2017-04-20 17:13:41 +03:00
std : : string message ;
2012-06-01 14:02:15 +04:00
/**
* Time out , true if the request ended because of a time out
*/
bool timeout ;
2015-07-01 22:15:40 +03:00
2012-06-01 14:02:15 +04:00
/**
* Identification of this request
*/
int id ;
/**
* Notify client that we have an answer for the request
*/
void notify ( )
{
2020-07-24 17:00:59 +03:00
finalize ( ) ;
}
2012-06-01 14:02:15 +04:00
/**
* Wait for the AuthRequest to be completed
*/
void wait ( )
{
time_out = time ( 0 ) + 90 ; //Requests will expire in 1.5 minutes
2020-07-24 17:00:59 +03:00
loop ( ) ;
}
2017-04-20 17:13:41 +03:00
2012-06-01 14:02:15 +04:00
/**
* Time in seconds when this request will expire
*/
time_t time_out ;
} ;
# endif /*SYNC_REQUEST_H_*/