pages

Documentation

Overview

Pages is an exercise in concurrency. It is intended to mimic part of what a DBMS has to do when storing a row in a table. This almost always involves fetching the page which is the primary location and also other pages where indexes are stored. For the purposes of the exercise, I assume that all pages have to be fetched before processing can continue - this allows deadlock to occur. The processing is controlled by the values in the "constants" file. Note that these are compile-time constants, not run-time.

Index

• func Gendata(txnChan chan request)
• func Run(runAck chan int64)
• func RunTxn(txnChan chan request, runAck chan int64)
• func Worker(input chan workreq)

Functions

func Gendata

func Gendata(txnChan chan request)

Gendata generates the transaction data and sends the txns to the scheduler.

func Run

func Run(runAck chan int64)

Run starts the data generation and transaction run processes, then passes page counts back to the driver process.

func RunTxn

func RunTxn(txnChan chan request, runAck chan int64)

RunTxn processes transactions.

func Worker

func Worker(input chan workreq)

Pretend to fetch the database page.