prashantv’s gists

prashantv / tchannel-migrate.sh

Last active October 6, 2015 00:49

Migrate TChannel clients from the old import (github.com/uber/tchannel/golang) to the new import (github.com/uber/tchannel-go)

	# Get the new tchannel-go repository.
	go get -f -u github.com/uber/tchannel-go

	# Delete the old tchannel repository to avoid goimports importing it.
	rm -rf ${GOPATH}/src/github.com/uber/tchannel

	# Rewrite all imports to use the new repository.
	for f in `grep --include '*.go' --exclude-dir "Godeps" --exclude-dir "thrift-binaries" --exclude-dir "build_test" "tchannel/golang" -R -l .`
	do
	echo "Rewriting $f"

prashantv / gist:269a2c2f1242e8e2aff9ae2b201cac96

Created June 17, 2016 16:00

TestNoTimeout failure

	--- FAIL: TestNoTimeout (0.02s)
	<autogenerated>:31: Unexpected log: [Warn]: Failed to add connection to peer [{service relay} {process relay-58154} {hostPort 127.0.0.1:58154} {connID 370} {localAddr 127.0.0.1:58154} {remoteAddr 127.0.0.1:60664} {remoteHostPort 127.0.0.1:56950} {direction inbound} {error tchannel error ErrCodeNetwork: connection is in an invalid state}]
	<autogenerated>:29: Debug logs:
	01:01:13.311964 [D] NewChannel created at goroutine 1689 [running]:
	github.com/uber/tchannel-go.getStacks(0xc82071d300, 0x0, 0x0, 0x0)
	/home/travis/gopath/src/github.com/uber/tchannel-go/introspection.go:392 +0xb9
	github.com/uber/tchannel-go.registerNewChannel(0xc82071d320)
	/home/travis/gopath/src/github.com/uber/tchannel-go/all_channels.go:36 +0x61
	github.com/uber/tchannel-go.NewChannel(0xbd29a0, 0xb, 0xc822546a00, 0xbbaa40, 0x0, 0x0)
	/home/travis/gopath/src/github.com/uber/tchannel-go/channel.go:234 +0xf89

prashantv / handler.go

Created July 15, 2016 15:13

	package main

	import (
	"io"
	"log"
	"net/http"
	"time"

	"github.com/pkg/errors"
	"github.com/uber/tchannel-go"

prashantv / atomic_main.go

Created September 2, 2016 04:01

	package main

	import (
	"fmt"
	"sync"
	"sync/atomic"
	"time"
	)

	func main() {

prashantv / atomic_bench_test.go

Created September 2, 2016 04:04

	package main

	import (
	"sync/atomic"
	"testing"
	)

	func BenchmarkAtomicSerial(b *testing.B) {
	var n int64
	for i := 0; i < b.N; i++ {

prashantv / ratelimits.md

Last active March 30, 2025 12:39

golang.org rate limiter:

	rl := rate.NewLimiter(1000000, 1)
 
	last := time.Now()
	for i := 0; i < 10; i++ {
		rl.Wait(context.Background())
		cur := time.Now()
		fmt.Println("last", cur.Sub(last))
 last = cur

prashantv / gist:babbdbd9e41b0b04ad29a510be513d79

Created November 14, 2017 19:04

	> go test -bench . -benchmem
	goos: darwin
	goarch: amd64
	pkg: go.uber.org/atomic
	BenchmarkStress/u64/serial-8 30000000 41.7 ns/op 0 B/op 0 allocs/op
	BenchmarkStress/u64/parallel-8 10000000 169 ns/op 0 B/op 0 allocs/op
	BenchmarkStress/f64/serial-8 30000000 45.9 ns/op 0 B/op 0 allocs/op
	BenchmarkStress/f64/parallel-8 5000000 362 ns/op 0 B/op 0 allocs/op
	BenchmarkStress/bool/serial-8 50000000 38.4 ns/op 0 B/op 0 allocs/op
	BenchmarkStress/bool/parallel-8 10000000 157 ns/op 0 B/op 0 allocs/op

prashantv / gist:4360013d6ec13b16ff983390e5defe73

Created November 14, 2017 19:54

	> go test -bench .
	goos: darwin
	goarch: amd64
	pkg: go.uber.org/atomic
	BenchmarkStress/u32/std/serial-8 50000000 42.0 ns/op
	BenchmarkStress/u32/std/parallel-8 10000000 173 ns/op
	BenchmarkStress/u32/serial-8 30000000 42.9 ns/op
	BenchmarkStress/u32/parallel-8 10000000 173 ns/op
	BenchmarkStress/f64/serial-8 30000000 46.3 ns/op
	BenchmarkStress/f64/parallel-8 5000000 359 ns/op

prashantv / main.go

Created January 12, 2018 19:26

	package main

	import (
	"fmt"
	"go.uber.org/zap"
	"go.uber.org/zap/zapcore"
	lumberjack "gopkg.in/natefinch/lumberjack.v2"
	"time"
	)

prashantv / grpc-debug.log

Created December 8, 2018 02:20

	2018/12/07 18:19:24 h2c: attempting h2c with prior knowledge.
	2018/12/07 18:19:24 http2: server connection from [::1]:43354 on 0xc42008d860
	2018/12/07 18:19:24 http2: Framer 0xc4209dc380: wrote SETTINGS len=24, settings: MAX_FRAME_SIZE=1048576, MAX_CONCURRENT_STREAMS=250, MAX_HEADER_LIST_SIZE=1048896, INITIAL_WINDOW_SIZE=1048576
	2018/12/07 18:19:24 http2: server: client [::1]:43354 said hello
	2018/12/07 18:19:24 http2: Framer 0xc4209dc380: wrote WINDOW_UPDATE len=4 (conn) incr=983041
	2018/12/07 18:19:24 http2: Framer 0xc4209dc000: wrote SETTINGS len=0
	2018/12/07 18:19:24 http2: Framer 0xc4209dc380: read SETTINGS len=0
	2018/12/07 18:19:24 http2: server read frame SETTINGS len=0
	2018/12/07 18:19:24 http2: Framer 0xc4209dc380: wrote SETTINGS flags=ACK len=0
	2018/12/07 18:19:24 http2: Framer 0xc4209dc000: read SETTINGS len=24, settings: MAX_FRAME_SIZE=1048576, MAX_CONCURRENT_STREAMS=250, MAX_HEADER_LIST_SIZE=1048896, INITIAL_WINDOW_SIZE=1048576

Prashant V prashantv