swarm: clean up unused private types and functions
Those that were identified by code inspection tool.
This commit is contained in:
		| @@ -41,16 +41,9 @@ import ( | ||||
| 	"github.com/ethereum/go-ethereum/swarm/log" | ||||
| 	"github.com/ethereum/go-ethereum/swarm/storage" | ||||
| 	"github.com/ethereum/go-ethereum/swarm/storage/feed" | ||||
|  | ||||
| 	"github.com/rs/cors" | ||||
| ) | ||||
|  | ||||
| type resourceResponse struct { | ||||
| 	Manifest storage.Address `json:"manifest"` | ||||
| 	Resource string          `json:"resource"` | ||||
| 	Update   storage.Address `json:"update"` | ||||
| } | ||||
|  | ||||
| var ( | ||||
| 	postRawCount    = metrics.NewRegisteredCounter("api.http.post.raw.count", nil) | ||||
| 	postRawFail     = metrics.NewRegisteredCounter("api.http.post.raw.fail", nil) | ||||
|   | ||||
| @@ -50,10 +50,6 @@ type testStore struct { | ||||
| 	values map[string][]byte | ||||
| } | ||||
|  | ||||
| func newTestStore() *testStore { | ||||
| 	return &testStore{values: make(map[string][]byte)} | ||||
| } | ||||
|  | ||||
| func (t *testStore) Load(key string) ([]byte, error) { | ||||
| 	t.Lock() | ||||
| 	defer t.Unlock() | ||||
|   | ||||
| @@ -79,46 +79,6 @@ func (a Address) Bytes() []byte { | ||||
| 	return a[:] | ||||
| } | ||||
|  | ||||
| /* | ||||
| Proximity(x, y) returns the proximity order of the MSB distance between x and y | ||||
|  | ||||
| The distance metric MSB(x, y) of two equal length byte sequences x an y is the | ||||
| value of the binary integer cast of the x^y, ie., x and y bitwise xor-ed. | ||||
| the binary cast is big endian: most significant bit first (=MSB). | ||||
|  | ||||
| Proximity(x, y) is a discrete logarithmic scaling of the MSB distance. | ||||
| It is defined as the reverse rank of the integer part of the base 2 | ||||
| logarithm of the distance. | ||||
| It is calculated by counting the number of common leading zeros in the (MSB) | ||||
| binary representation of the x^y. | ||||
|  | ||||
| (0 farthest, 255 closest, 256 self) | ||||
| */ | ||||
| func proximity(one, other Address) (ret int, eq bool) { | ||||
| 	return posProximity(one, other, 0) | ||||
| } | ||||
|  | ||||
| // posProximity(a, b, pos) returns proximity order of b wrt a (symmetric) pretending | ||||
| // the first pos bits match, checking only bits index >= pos | ||||
| func posProximity(one, other Address, pos int) (ret int, eq bool) { | ||||
| 	for i := pos / 8; i < len(one); i++ { | ||||
| 		if one[i] == other[i] { | ||||
| 			continue | ||||
| 		} | ||||
| 		oxo := one[i] ^ other[i] | ||||
| 		start := 0 | ||||
| 		if i == pos/8 { | ||||
| 			start = pos % 8 | ||||
| 		} | ||||
| 		for j := start; j < 8; j++ { | ||||
| 			if (oxo>>uint8(7-j))&0x01 != 0 { | ||||
| 				return i*8 + j, false | ||||
| 			} | ||||
| 		} | ||||
| 	} | ||||
| 	return len(one) * 8, true | ||||
| } | ||||
|  | ||||
| // ProxCmp compares the distances a->target and b->target. | ||||
| // Returns -1 if a is closer to target, 1 if b is closer to target | ||||
| // and 0 if they are equal. | ||||
|   | ||||
| @@ -288,10 +288,6 @@ type testStore struct { | ||||
| 	values map[string][]byte | ||||
| } | ||||
|  | ||||
| func newTestStore() *testStore { | ||||
| 	return &testStore{values: make(map[string][]byte)} | ||||
| } | ||||
|  | ||||
| func (t *testStore) Load(key string) ([]byte, error) { | ||||
| 	return nil, nil | ||||
| } | ||||
|   | ||||
| @@ -976,11 +976,6 @@ func TestNetwork10000(t *testing.T) { | ||||
| } | ||||
|  | ||||
| func testNetwork(t *testing.T) { | ||||
| 	type msgnotifyC struct { | ||||
| 		id     enode.ID | ||||
| 		msgIdx int | ||||
| 	} | ||||
|  | ||||
| 	paramstring := strings.Split(t.Name(), "/") | ||||
| 	nodecount, _ := strconv.ParseInt(paramstring[1], 10, 0) | ||||
| 	msgcount, _ := strconv.ParseInt(paramstring[2], 10, 0) | ||||
|   | ||||
| @@ -169,10 +169,6 @@ type stateStore struct { | ||||
| 	values map[string][]byte | ||||
| } | ||||
|  | ||||
| func newStateStore() *stateStore { | ||||
| 	return &stateStore{values: make(map[string][]byte)} | ||||
| } | ||||
|  | ||||
| func (store *stateStore) Load(key string) ([]byte, error) { | ||||
| 	return nil, nil | ||||
| } | ||||
|   | ||||
| @@ -88,17 +88,6 @@ func mputRandomChunks(store ChunkStore, n int, chunksize int64) ([]Chunk, error) | ||||
| 	return mput(store, n, GenerateRandomChunk) | ||||
| } | ||||
|  | ||||
| func mputChunks(store ChunkStore, chunks ...Chunk) error { | ||||
| 	i := 0 | ||||
| 	f := func(n int64) Chunk { | ||||
| 		chunk := chunks[i] | ||||
| 		i++ | ||||
| 		return chunk | ||||
| 	} | ||||
| 	_, err := mput(store, len(chunks), f) | ||||
| 	return err | ||||
| } | ||||
|  | ||||
| func mput(store ChunkStore, n int, f func(i int64) Chunk) (hs []Chunk, err error) { | ||||
| 	// put to localstore and wait for stored channel | ||||
| 	// does not check delivery error state | ||||
|   | ||||
| @@ -27,7 +27,6 @@ import ( | ||||
| 	"time" | ||||
|  | ||||
| 	"github.com/ethereum/go-ethereum/crypto" | ||||
|  | ||||
| 	"github.com/ethereum/go-ethereum/log" | ||||
| 	"github.com/ethereum/go-ethereum/swarm/chunk" | ||||
| 	"github.com/ethereum/go-ethereum/swarm/storage" | ||||
| @@ -506,15 +505,3 @@ func newCharlieSigner() *GenericSigner { | ||||
| 	privKey, _ := crypto.HexToECDSA("facadefacadefacadefacadefacadefacadefacadefacadefacadefacadefaca") | ||||
| 	return NewGenericSigner(privKey) | ||||
| } | ||||
|  | ||||
| func getUpdateDirect(rh *Handler, addr storage.Address) ([]byte, error) { | ||||
| 	chunk, err := rh.chunkStore.Get(context.TODO(), addr) | ||||
| 	if err != nil { | ||||
| 		return nil, err | ||||
| 	} | ||||
| 	var r Request | ||||
| 	if err := r.fromChunk(addr, chunk.Data()); err != nil { | ||||
| 		return nil, err | ||||
| 	} | ||||
| 	return r.data, nil | ||||
| } | ||||
|   | ||||
| @@ -39,7 +39,6 @@ import ( | ||||
| 	"github.com/ethereum/go-ethereum/swarm/log" | ||||
| 	"github.com/ethereum/go-ethereum/swarm/storage/mock" | ||||
| 	"github.com/syndtr/goleveldb/leveldb" | ||||
| 	"github.com/syndtr/goleveldb/leveldb/opt" | ||||
| ) | ||||
|  | ||||
| const ( | ||||
| @@ -72,13 +71,6 @@ var ( | ||||
| 	ErrDBClosed = errors.New("LDBStore closed") | ||||
| ) | ||||
|  | ||||
| type gcItem struct { | ||||
| 	idx    *dpaDBIndex | ||||
| 	value  uint64 | ||||
| 	idxKey []byte | ||||
| 	po     uint8 | ||||
| } | ||||
|  | ||||
| type LDBStoreParams struct { | ||||
| 	*StoreParams | ||||
| 	Path string | ||||
| @@ -961,15 +953,3 @@ func (s *LDBStore) SyncIterator(since uint64, until uint64, po uint8, f func(Add | ||||
| 	} | ||||
| 	return it.Error() | ||||
| } | ||||
|  | ||||
| func databaseExists(path string) bool { | ||||
| 	o := &opt.Options{ | ||||
| 		ErrorIfMissing: true, | ||||
| 	} | ||||
| 	tdb, err := leveldb.OpenFile(path, o) | ||||
| 	if err != nil { | ||||
| 		return false | ||||
| 	} | ||||
| 	defer tdb.Close() | ||||
| 	return true | ||||
| } | ||||
|   | ||||
		Reference in New Issue
	
	Block a user