kvu787

/*
	MIT License

	Copyright (c) 2026 K

	Permission is hereby granted, free of charge, to any person obtaining a copy
	of this software and associated documentation files (the "Software"), to deal
	in the Software without restriction, including without limitation the rights
	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	copies of the Software, and to permit persons to whom the Software is

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.
    """