diff options
Diffstat (limited to 'src/gnunet/service/namecache/module.go')
-rw-r--r-- | src/gnunet/service/namecache/module.go | 9 |
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 ( | |||
38 | type Module struct { | 39 | type 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. |
70 | func (m *Module) Get(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) { | 71 | func (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 | } |