aboutsummaryrefslogtreecommitdiff
path: root/src/gnunet/service/namecache/module.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/gnunet/service/namecache/module.go')
-rw-r--r--src/gnunet/service/namecache/module.go9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/gnunet/service/namecache/module.go b/src/gnunet/service/namecache/module.go
index 9251a58..42d38a2 100644
--- a/src/gnunet/service/namecache/module.go
+++ b/src/gnunet/service/namecache/module.go
@@ -24,6 +24,7 @@ import (
24 "gnunet/core" 24 "gnunet/core"
25 "gnunet/service" 25 "gnunet/service"
26 "gnunet/service/dht/blocks" 26 "gnunet/service/dht/blocks"
27 "gnunet/service/store"
27) 28)
28 29
29//====================================================================== 30//======================================================================
@@ -38,7 +39,7 @@ import (
38type Module struct { 39type Module struct {
39 service.ModuleImpl 40 service.ModuleImpl
40 41
41 cache service.DHTStore // transient block cache 42 cache store.DHTStore // transient block cache
42} 43}
43 44
44// NewModule creates a new module instance. 45// NewModule creates a new module instance.
@@ -46,7 +47,7 @@ func NewModule(ctx context.Context, c *core.Core) (m *Module) {
46 m = &Module{ 47 m = &Module{
47 ModuleImpl: *service.NewModuleImpl(), 48 ModuleImpl: *service.NewModuleImpl(),
48 } 49 }
49 m.cache, _ = service.NewDHTStore(config.Cfg.Namecache.Storage) 50 m.cache, _ = store.NewDHTStore(config.Cfg.Namecache.Storage)
50 return 51 return
51} 52}
52 53
@@ -69,7 +70,9 @@ func (m *Module) Import(fcm map[string]any) {
69// Get an entry from the cache if available. 70// Get an entry from the cache if available.
70func (m *Module) Get(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) { 71func (m *Module) Get(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) {
71 var b blocks.Block 72 var b blocks.Block
72 b, err = m.cache.Get(query) 73 if b, err = m.cache.Get(query); err != nil {
74 return
75 }
73 err = blocks.Unwrap(b, block) 76 err = blocks.Unwrap(b, block)
74 return 77 return
75} 78}