tsuna

#!/bin/bash

CACHE_DIR=/tmp/tsd

diskSpaceIsShort() {
   df -h "$CACHE_DIR" \
   | awk 'NR==2{pct=$5; sub(/%/, "", pct); if (pct < 90) exit 1; exit 0;}'
}

if diskSpaceIsShort; then

tsuna

func TestDisabledTable(t *testing.T) {
    // TODO: We leak the master client.
    master := gohbase.NewClient(*host, gohbase.Admin())
    logrus.WithFields(logrus.Fields{"table": table}).Info("Disabling table")
    _, err := master.SendRPC(hrpc.NewDisableTable(context.Background(), []byte(table)))
    if err != nil {
        t.Fatalf("Failed to disable %q: %s", table, err)
    }

    key := "TestDisabledTable"

tsuna

import java.util.Comparator;
import java.util.HashMap;
import java.util.Map;
import java.util.TreeSet;

public class t {

  static public void main(String[] args) {
    HashMap<String, Integer> hm = new HashMap<String, Integer>();
    hm.put("answer", 42);

tsuna

From 07d1425781f08799ff9ef59f9cd578fa63a2e83f Mon Sep 17 00:00:00 2001
From: Benoit Sigoure <tsuna@stumbleupon.com>
Date: Sun, 21 Nov 2010 20:42:20 -0800
Subject: [PATCH] Don't shutdown while RPCs are waiting for a -ROOT- lookup.

The following scenario led to data loss:
  1. Application starts.
  2. A PutRequest is generated, triggers a -ROOT- lookup.
  3. Application calls shutdown() on the HBaseClient, the client
     terminates and the PutRequest is lost.

tsuna

From fd1d76efba48269aaec80e90f629f01ba4581fed Mon Sep 17 00:00:00 2001
From: Benoit Sigoure <tsuna@stumbleupon.com>
Date: Tue, 18 Jan 2011 00:21:20 -0800
Subject: [PATCH] Add support for CDHb3.

This change adds support for CDHb3.  In order to enable the new code,
the JVM must be given the following system property in argument:
  -Dorg.hbase.async.cdhb3

CDHb3 includes a temporary patch that changes the format of the "hello"

tsuna

From 7a538914c93f8a92b9c80e5c533e73d97e8423c8 Mon Sep 17 00:00:00 2001
From: Benoit Sigoure <tsuna@stumbleupon.com>
Date: Thu, 27 Jan 2011 17:33:37 -0800
Subject: [PATCH] Add support for HBase 0.90.

In order to enable the new code, the JVM must be given the following
system property in argument:
  -Dorg.hbase.async.v0.90

For HBASE-3174, revision r1029115 (or 08e64aae in Git) changed the

tsuna

#!/usr/bin/python

import httplib
import json
import os
import shutil
import time

def purge_tsd_cache():
  for dir in (dir for dir in os.listdir("/tmp/tsd") if dir[0] != "."):

tsuna

diff --git a/src/core/TsdbQuery.java b/src/core/TsdbQuery.java
index 2edd53c..8776e89 100644
--- a/src/core/TsdbQuery.java
+++ b/src/core/TsdbQuery.java
@@ -401,7 +401,8 @@ final class TsdbQuery implements Query {
     // but this doesn't really matter.
     // Additionally, in case our sample_interval is large, we need to look
     // even further before/after, so use that too.
-    return getStartTime() - Const.MAX_TIMESPAN * 2 - sample_interval;
+    final long t = getStartTime() - Const.MAX_TIMESPAN * 2 - sample_interval;

tsuna

#!/usr/bin/env python

import socket
import subprocess
import sys
import time


COLLECTION_INTERVAL = 15  # seconds

tsuna

#!/usr/bin/perl -w
#
# The contents of this file are subject to the Mozilla Public
# License Version 1.1 (the "License"); you may not use this file
# except in compliance with the License. You may obtain a copy of
# the License at http://www.mozilla.org/MPL/
#
# Software distributed under the License is distributed on an "AS
# IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or
# implied. See the License for the specific language governing