offline.go 933 Bytes
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12
package bitswap

import (
	"errors"

	context "github.com/jbenet/go-ipfs/Godeps/_workspace/src/code.google.com/p/go.net/context"

	blocks "github.com/jbenet/go-ipfs/blocks"
	exchange "github.com/jbenet/go-ipfs/exchange"
	u "github.com/jbenet/go-ipfs/util"
)

Brian Tiger Chow's avatar
Brian Tiger Chow committed
13 14
var OfflineMode = errors.New("Block unavailable. Operating in offline mode")

15 16 17 18 19 20 21 22 23 24 25 26 27
func NewOfflineExchange() exchange.Interface {
	return &offlineExchange{}
}

// offlineExchange implements the Exchange interface but doesn't return blocks.
// For use in offline mode.
type offlineExchange struct {
}

// Block returns nil to signal that a block could not be retrieved for the
// given key.
// NB: This function may return before the timeout expires.
func (_ *offlineExchange) Block(context.Context, u.Key) (*blocks.Block, error) {
Brian Tiger Chow's avatar
Brian Tiger Chow committed
28
	return nil, OfflineMode
29 30 31 32 33 34
}

// HasBlock always returns nil.
func (_ *offlineExchange) HasBlock(context.Context, blocks.Block) error {
	return nil
}