swarm/storage/feed/handler.go

@@ -23,7 +23,6 @@ import (
 	"context"
 	"fmt"
 	"sync"
-	"time"
 
 	"github.com/ethereum/go-ethereum/swarm/storage/feed/lookup"
 
@@ -32,12 +31,10 @@ import (
 )
 
 type Handler struct {
-	chunkStore      *storage.NetStore
+	chunkStore *storage.NetStore
-	HashSize        int
+	HashSize   int
-	cache           map[uint64]*cacheEntry
+	cache      map[uint64]*cacheEntry
-	cacheLock       sync.RWMutex
+	cacheLock  sync.RWMutex
-	storeTimeout    time.Duration
-	queryMaxPeriods uint32
 }
 
 // HandlerParams pass parameters to the Handler constructor NewHandler

swarm/storage/feed/handler_test.go

@@ -40,7 +40,6 @@ var (
 	}
 	cleanF       func()
 	subtopicName = "føø.bar"
-	hashfunc     = storage.MakeHashFunc(storage.DefaultHash)
 )
 
 func init() {

swarm/storage/feed/timestampprovider.go

@@ -17,7 +17,6 @@
 package feed
 
 import (
-	"encoding/binary"
 	"encoding/json"
 	"time"
 )
@@ -30,32 +29,11 @@ type Timestamp struct {
 	Time uint64 `json:"time"` // Unix epoch timestamp, in seconds
 }
 
-// 8 bytes uint64 Time
-const timestampLength = 8
-
 // timestampProvider interface describes a source of timestamp information
 type timestampProvider interface {
 	Now() Timestamp // returns the current timestamp information
 }
 
-// binaryGet populates the timestamp structure from the given byte slice
-func (t *Timestamp) binaryGet(data []byte) error {
-	if len(data) != timestampLength {
-		return NewError(ErrCorruptData, "timestamp data has the wrong size")
-	}
-	t.Time = binary.LittleEndian.Uint64(data[:8])
-	return nil
-}
-
-// binaryPut Serializes a Timestamp to a byte slice
-func (t *Timestamp) binaryPut(data []byte) error {
-	if len(data) != timestampLength {
-		return NewError(ErrCorruptData, "timestamp data has the wrong size")
-	}
-	binary.LittleEndian.PutUint64(data, t.Time)
-	return nil
-}
-
 // UnmarshalJSON implements the json.Unmarshaller interface
 func (t *Timestamp) UnmarshalJSON(data []byte) error {
 	return json.Unmarshal(data, &t.Time)