#include <log0consumer.h>
◆ Log_user_consumer()
  
  
      
        
          | Log_user_consumer::Log_user_consumer  | 
          ( | 
          const std::string &  | 
          name | ) | 
           | 
         
       
   | 
  
explicit   | 
  
 
 
◆ consumption_requested()
  
  
      
        
          | void Log_user_consumer::consumption_requested  | 
          ( | 
          lsn_t  | 
          request_lsn | ) | 
           | 
         
       
   | 
  
overridevirtual   | 
  
 
Request the log consumer to consume faster. 
Implements Log_consumer.
 
 
◆ get_consumed_lsn()
  
  
      
        
          | lsn_t Log_user_consumer::get_consumed_lsn  | 
          ( | 
           | ) | 
           const | 
         
       
   | 
  
overridevirtual   | 
  
 
- Returns
 - Maximum LSN up to which this consumer has consumed redo. The caller should acquire log.files_mutex. 
 
Implements Log_consumer.
 
 
◆ get_name()
  
  
      
        
          | const std::string & Log_user_consumer::get_name  | 
          ( | 
           | ) | 
           const | 
         
       
   | 
  
overridevirtual   | 
  
 
 
◆ set_consumed_lsn()
      
        
          | void Log_user_consumer::set_consumed_lsn  | 
          ( | 
          lsn_t  | 
          consumed_lsn | ) | 
           | 
        
      
 
Set the lsn reported by get_consumed_lsn() to the given value. 
It is required that the given value is greater or equal to the value currently reported by the get_consumed_lsn(). 
- Parameters
 - 
  
    | [in] | consumed_lsn | the given lsn to report  | 
  
   
 
 
◆ m_consumed_lsn
  
  
      
        
          | lsn_t Log_user_consumer::m_consumed_lsn {} | 
         
       
   | 
  
private   | 
  
 
Value reported by get_consumed_lsn(). 
Set by set_consumed_lsn(lsn). 
 
 
◆ m_name
  
  
      
        
          | const std::string Log_user_consumer::m_name | 
         
       
   | 
  
private   | 
  
 
Name of this consumer (saved value from ctor). 
 
 
The documentation for this class was generated from the following files: