kvu787

A distributed queue over RDMA

We implement a queue using RDMA compare-and-swap and fetch-and-add operations. It borrows ideas from the CRQ algorithm. Because it uses a single fixed size circular array, it is non-blocking only for buffered enqs, in contrast to LCRQ which is non-blocking for an arbitrary number of enqs [1].

[1] http://www.cs.technion.ac.il/~mad/publications/ppopp2013-x86queues.pdf

It satisfies the following properties:

kvu787

// Package queue implements a multi-producer, multi-consumer, unbuffered
// concurrent queue using atomic compare-and-swap operations.
// It has equivalent semantics to an unbuffered Go channel.
package queue

import (
	"runtime"
	"sync/atomic"
)

kvu787

# usage: bash gotest.sh <directory to put test results in> <count>
#
# example: 
#  cd ~/452-labs/src/paxos
#  bash gotest.sh testdir 10
# 
# to kill a gotest.sh, run:
#   ctrl-z   (pause process)
#   kill %%  (kill most recently paused process)

kvu787

package main

import (
	"fmt"
	"net"
	"os"
)

const Message string = "Hello World!\n"
const ServerPort string = "173.250.148.245"

kvu787

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;

import java.io.ByteArrayOutputStream;
import java.io.PrintStream;
import java.util.ArrayList;
import java.util.Arrays;

import org.junit.After;

kvu787

// Visit courses.cs.washington.edu/courses/cse143/13au/homework.shtml or 
// https://courses.cs.washington.edu/courses/cse143/13au/homework.shtml and run 
// this snippet of JavaScript to display otherwise hidden homework assignments.
//
// Note that the revealed assignments are probably old ones. 

(function () {
    "use strict";

    // display commented content

kvu787

import os
import glob
 
 
class Directory(object):
    """Creates wrapper object for a directory.
 
    Attributes:
        path: str, relative path to directory.
    """