usermode/library/mcore/src/log/phlog_base.c

Go to the documentation of this file.

/*
    Copyright (C) 2011 Computer Sciences Department, 
    University of Wisconsin -- Madison

    ----------------------------------------------------------------------

    This file is part of Mnemosyne: Lightweight Persistent Memory, 
    originally developed at the University of Wisconsin -- Madison.

    Mnemosyne was originally developed primarily by Haris Volos
    with contributions from Andres Jaan Tack.

    ----------------------------------------------------------------------

    Mnemosyne is free software; you can redistribute it and/or
    modify it under the terms of the GNU General Public License
    as published by the Free Software Foundation, version 2
    of the License.
 
    Mnemosyne is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, write to the Free Software
    Foundation, Inc., 51 Franklin Street, Fifth Floor, 
    Boston, MA  02110-1301, USA.

### END HEADER ###
*/

/* System header files */
#include <stdio.h>
#include <stdint.h>
#include <stdlib.h>
/* Mnemosyne common header files */
#include <result.h>
#include "phlog_base.h"
#include "hal/pcm_i.h"


m_result_t
m_phlog_base_check_consistency(m_phlog_base_nvmd_t *nvmd, 
                                  pcm_word_t *nvphlog,
                                  uint64_t *stable_tail)
{
        *stable_tail = nvmd->tail;

        return M_R_SUCCESS;
}


m_result_t
m_phlog_base_format (pcm_storeset_t *set, 
                     m_phlog_base_nvmd_t *nvmd, 
                     pcm_word_t *nvphlog, 
                     int type)
{
        PCM_NT_STORE(set, (volatile pcm_word_t *) &nvmd->head, 0);
        PCM_NT_STORE(set, (volatile pcm_word_t *) &nvmd->tail, 0);
        PCM_NT_FLUSH(set);
        
        return M_R_SUCCESS;
}


m_result_t
m_phlog_base_alloc (m_phlog_base_t **phlog_basep)
{
        m_phlog_base_t      *phlog_base;
        
        if (posix_memalign((void **) &phlog_base, sizeof(uint64_t), sizeof(m_phlog_base_t)) != 0) 
        {
                return M_R_FAILURE;
        }
        *phlog_basep = phlog_base;

        return M_R_SUCCESS;
}


m_result_t
m_phlog_base_init(m_phlog_base_t *phlog, 
                  m_phlog_base_nvmd_t *nvmd,
                  pcm_word_t *nvphlog)                                    
{
        phlog->nvmd = nvmd;
        phlog->nvphlog = nvphlog;
        phlog->buffer_count = 0;
        phlog->head = phlog->nvmd->head;
        phlog->tail = phlog->nvmd->tail;
        phlog->read_index = phlog->nvmd->head;

        /* initialize statistics */
        phlog->stat_wait_for_trunc = 0;
        phlog->stat_wait_time_for_trunc = 0;

        return M_R_SUCCESS;
}


m_result_t
m_phlog_base_truncate_async(pcm_storeset_t *set, m_phlog_base_t *phlog) 
{
        phlog->head = phlog->read_index;

        PCM_NT_FLUSH(set);
        PCM_NT_STORE(set, (volatile pcm_word_t *) &phlog->nvmd->head, (pcm_word_t) phlog->head);
        PCM_NT_FLUSH(set);
        
        return M_R_SUCCESS;
}

---