From ba0f7d703e7b61472f92f25a915c25b21d34f47c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Wed, 8 Jul 2020 12:52:37 +0200 Subject: [PATCH] Set lower polling interval for deal client --- markets/storageadapter/provider.go | 2 +- node/modules/client.go | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/markets/storageadapter/provider.go b/markets/storageadapter/provider.go index 3a872a792..1f8af59f5 100644 --- a/markets/storageadapter/provider.go +++ b/markets/storageadapter/provider.go @@ -35,7 +35,7 @@ import ( sealing "github.com/filecoin-project/storage-fsm" ) -var log = logging.Logger("provideradapter") +var log = logging.Logger("storageadapter") type ProviderNodeAdapter struct { api.FullNode diff --git a/node/modules/client.go b/node/modules/client.go index b67cb6014..5a8e97a04 100644 --- a/node/modules/client.go +++ b/node/modules/client.go @@ -3,6 +3,7 @@ package modules import ( "context" "path/filepath" + "time" blockstore "github.com/ipfs/go-ipfs-blockstore" "github.com/ipfs/go-merkledag" @@ -130,7 +131,7 @@ func NewClientRequestValidator(deals dtypes.ClientDealStore) dtypes.ClientReques func StorageClient(lc fx.Lifecycle, h host.Host, ibs dtypes.ClientBlockstore, r repo.LockedRepo, dataTransfer dtypes.ClientDataTransfer, discovery *discovery.Local, deals dtypes.ClientDatastore, scn storagemarket.StorageClientNode) (storagemarket.StorageClient, error) { net := smnet.NewFromLibp2pHost(h) - c, err := storageimpl.NewClient(net, ibs, dataTransfer, discovery, deals, scn) + c, err := storageimpl.NewClient(net, ibs, dataTransfer, discovery, deals, scn, storageimpl.DealPollingInterval(time.Second)) if err != nil { return nil, err }