| redbo@precise-saio:~/tmp/bitarray$ ./bitarray | |
| mmapped: 31.526328 seconds | |
| malloced: 7.485364 seconds | |
| mmapped: 32.207367 seconds | |
| malloced: 7.187762 seconds | |
| mmapped: 33.503239 seconds | |
| malloced: 7.259652 seconds |
| import time | |
| import os | |
| import uuid | |
| import random | |
| from swift.container.backend import ContainerBroker | |
| from swift.common.utils import normalize_timestamp | |
| INSERT_COUNT = 200 |
| type ObjectHandler struct { | |
| ... | |
| diskLimit int64 | |
| diskInUse map[string]*int64 | |
| diskInUseLock *sync.Mutex | |
| } | |
| func (server *ObjectHandler) AcquireDisk(disk string) bool { | |
| if val, ok := server.diskInUse[disk]; !ok { |
| package main | |
| import ( | |
| "fmt" | |
| "runtime" | |
| "sync" | |
| "sync/atomic" | |
| "time" | |
| "unsafe" | |
| ) |
| package common | |
| import ( | |
| "bytes" | |
| "encoding/json" | |
| "testing" | |
| "github.com/hydrogen18/stalecucumber" | |
| msgpack "gopkg.in/vmihailenco/msgpack.v2" | |
| ) |
| import cPickle | |
| import time | |
| metadata = {"Content-Length": "65536", | |
| "Content-Type": "application/octet-stream", | |
| "ETag": "fcd6bcb56c1689fcef28b57c22475bad", | |
| "X-Timestamp": "1422766779.57463", | |
| "name": "/someaccountname/somecontainername/5821142269423797100"} | |
| loops = 200000 |
# DOCKER-VERSION 0.6.4
# This is probably only useful if you're setting up a CI environment.
# Adding this line to /etc/default/docker will convince Docker to use btrfs:
# DOCKER_OPTS="--storage-driver=btrfs"
FROM ubuntu:14.04
RUN echo "deb http://archive.ubuntu.com/ubuntu/ trusty-backports universe" >> /etc/apt/sources.list
| package main | |
| import ( | |
| "bytes" | |
| "fmt" | |
| "io" | |
| "io/ioutil" | |
| "net" | |
| "net/http" | |
| "net/http/httptest" |
| func DoRequest(req *http.Request, c net.Conn) (*http.Response, error) { | |
| defer req.Body.Close() | |
| dumped, err := httputil.DumpRequestOut(req, false) | |
| if err != nil { | |
| return nil, err | |
| } | |
| if _, err = c.Write(dumped); err != nil { | |
| return nil, err | |
| } | |
| reader := bufio.NewReader(c) |
| package main | |
| import ( | |
| "bufio" | |
| "fmt" | |
| "io" | |
| "io/ioutil" | |
| "net" | |
| "net/http" | |
| "net/http/httptest" |