ipc_banking.c

#include "ipc_banking.h"
#include "banking.h"
#include "ipc.h"
#include "ipc_proc.h"

#include <stdlib.h>
#include <string.h>

BalanceState balance_state_init(balance_t balance, balance_t pending, timestamp_t timestamp) {
	BalanceState state = {0};
	state.s_balance = balance;
	state.s_time = timestamp;
	state.s_balance_pending_in = pending;
	return state;
}

BalanceHistory *balance_history_init(local_id id, balance_t init_balance) {
	BalanceHistory *history = malloc(sizeof(BalanceHistory));
	history->s_id = id;
	history->s_history_len = 1;
	history->s_history[0] = balance_state_init(init_balance, 0, 0);
	return history;
}

void balance_history_add_state(BalanceHistory *history, timestamp_t start, timestamp_t finish, balance_t balance) {
	uint8_t history_len = history->s_history_len;
	balance_t last_balance = history->s_history[history_len - 1].s_balance;
	balance_t pending = balance - last_balance;
	for(; history_len < start; history_len++) {
		history->s_history[history_len] = balance_state_init(last_balance, 0, history_len);
	}
	for (; history_len < finish; history_len++) {
		history->s_history[history_len] = balance_state_init(last_balance, pending, history_len);
	}
	history->s_history[finish] = balance_state_init(balance, 0, finish);
	history->s_history_len = finish + 1;
}

void transfer(void * parent_data, local_id src, local_id dst, balance_t amount) {
	
}

timestamp_t get_lamport_time() {
	static timestamp_t time = 0;
	return ++time;
}