diff options
Diffstat (limited to 'src/gnunet/service/gns/service.go')
-rw-r--r-- | src/gnunet/service/gns/service.go | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/gnunet/service/gns/service.go b/src/gnunet/service/gns/service.go index 45eb700..fb6aea0 100644 --- a/src/gnunet/service/gns/service.go +++ b/src/gnunet/service/gns/service.go | |||
@@ -96,7 +96,7 @@ func (s *Service) ServeClient(ctx context.Context, id int, mc *service.Connectio | |||
96 | logger.Printf(logger.INFO, "[gns:%d:%d] Received request: %v\n", id, reqID, msg) | 96 | logger.Printf(logger.INFO, "[gns:%d:%d] Received request: %v\n", id, reqID, msg) |
97 | 97 | ||
98 | // handle message | 98 | // handle message |
99 | valueCtx := context.WithValue(ctx, service.CtxKey("label"), fmt.Sprintf(":%d:%d", id, reqID)) | 99 | valueCtx := context.WithValue(ctx, core.CtxKey("label"), fmt.Sprintf(":%d:%d", id, reqID)) |
100 | s.HandleMessage(valueCtx, nil, msg, mc) | 100 | s.HandleMessage(valueCtx, nil, msg, mc) |
101 | } | 101 | } |
102 | // close client connection | 102 | // close client connection |
@@ -136,7 +136,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me | |||
136 | logger.Printf(logger.DBG, "[gns%s] Lookup request finished.\n", label) | 136 | logger.Printf(logger.DBG, "[gns%s] Lookup request finished.\n", label) |
137 | }() | 137 | }() |
138 | 138 | ||
139 | kind := NewRRTypeList(enums.GNSType(m.Type)) | 139 | kind := NewRRTypeList(enums.GNSType(m.RType)) |
140 | recset, err := s.Resolve(ctx, label, m.Zone, kind, int(m.Options), 0) | 140 | recset, err := s.Resolve(ctx, label, m.Zone, kind, int(m.Options), 0) |
141 | if err != nil { | 141 | if err != nil { |
142 | logger.Printf(logger.ERROR, "[gns%s] Failed to lookup block: %s\n", label, err.Error()) | 142 | logger.Printf(logger.ERROR, "[gns%s] Failed to lookup block: %s\n", label, err.Error()) |
@@ -159,7 +159,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me | |||
159 | logger.Printf(logger.DBG, "[gns%s] Record #%d: %v\n", label, i, rec) | 159 | logger.Printf(logger.DBG, "[gns%s] Record #%d: %v\n", label, i, rec) |
160 | 160 | ||
161 | // is this the record type we are looking for? | 161 | // is this the record type we are looking for? |
162 | if rec.Type == m.Type || enums.GNSType(m.Type) == enums.GNS_TYPE_ANY { | 162 | if rec.RType == m.RType || enums.GNSType(m.RType) == enums.GNS_TYPE_ANY { |
163 | // add it to the response message | 163 | // add it to the response message |
164 | if err := resp.AddRecord(rec); err != nil { | 164 | if err := resp.AddRecord(rec); err != nil { |
165 | logger.Printf(logger.ERROR, "[gns%s] failed: %sv", label, err.Error()) | 165 | logger.Printf(logger.ERROR, "[gns%s] failed: %sv", label, err.Error()) |
@@ -173,7 +173,7 @@ func (s *Service) HandleMessage(ctx context.Context, sender *util.PeerID, msg me | |||
173 | //---------------------------------------------------------- | 173 | //---------------------------------------------------------- |
174 | // UNKNOWN message type received | 174 | // UNKNOWN message type received |
175 | //---------------------------------------------------------- | 175 | //---------------------------------------------------------- |
176 | logger.Printf(logger.ERROR, "[gns%s] Unhandled message of type (%d)\n", label, msg.Header().MsgType) | 176 | logger.Printf(logger.ERROR, "[gns%s] Unhandled message of type (%s)\n", label, msg.Type()) |
177 | return false | 177 | return false |
178 | } | 178 | } |
179 | return true | 179 | return true |
@@ -238,7 +238,7 @@ func (s *Service) RevokeKey(ctx context.Context, rd *revocation.RevData) (succes | |||
238 | 238 | ||
239 | // LookupNamecache returns a cached lookup (if available) | 239 | // LookupNamecache returns a cached lookup (if available) |
240 | func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) { | 240 | func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) (block *blocks.GNSBlock, err error) { |
241 | logger.Printf(logger.DBG, "[gns] LookupNamecache(%s)...\n", hex.EncodeToString(query.Key().Bits)) | 241 | logger.Printf(logger.DBG, "[gns] LookupNamecache(%s)...\n", hex.EncodeToString(query.Key().Data)) |
242 | 242 | ||
243 | // assemble Namecache request | 243 | // assemble Namecache request |
244 | req := message.NewNamecacheLookupMsg(query.Key()) | 244 | req := message.NewNamecacheLookupMsg(query.Key()) |
@@ -292,7 +292,7 @@ func (s *Service) LookupNamecache(ctx context.Context, query *blocks.GNSQuery) ( | |||
292 | break | 292 | break |
293 | } | 293 | } |
294 | default: | 294 | default: |
295 | logger.Printf(logger.ERROR, "[gns] Got invalid response type (%d)\n", m.Header().MsgType) | 295 | logger.Printf(logger.ERROR, "[gns] Got invalid response type (%s)\n", m.Type()) |
296 | err = ErrInvalidResponseType | 296 | err = ErrInvalidResponseType |
297 | } | 297 | } |
298 | return | 298 | return |
@@ -328,7 +328,7 @@ func (s *Service) StoreNamecache(ctx context.Context, query *blocks.GNSQuery, bl | |||
328 | } | 328 | } |
329 | return fmt.Errorf("failed with rc=%d", m.Result) | 329 | return fmt.Errorf("failed with rc=%d", m.Result) |
330 | default: | 330 | default: |
331 | logger.Printf(logger.ERROR, "[gns] Got invalid response type (%d)\n", m.Header().MsgType) | 331 | logger.Printf(logger.ERROR, "[gns] Got invalid response type (%s)\n", m.Type()) |
332 | err = ErrInvalidResponseType | 332 | err = ErrInvalidResponseType |
333 | } | 333 | } |
334 | return | 334 | return |
@@ -340,7 +340,7 @@ func (s *Service) StoreNamecache(ctx context.Context, query *blocks.GNSQuery, bl | |||
340 | 340 | ||
341 | // LookupDHT gets a GNS block from the DHT for the given query key. | 341 | // LookupDHT gets a GNS block from the DHT for the given query key. |
342 | func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block blocks.Block, err error) { | 342 | func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block blocks.Block, err error) { |
343 | logger.Printf(logger.DBG, "[gns] LookupDHT(%s)...\n", hex.EncodeToString(query.Key().Bits)) | 343 | logger.Printf(logger.DBG, "[gns] LookupDHT(%s)...\n", hex.EncodeToString(query.Key().Data)) |
344 | block = nil | 344 | block = nil |
345 | 345 | ||
346 | // client-connect to the DHT service | 346 | // client-connect to the DHT service |
@@ -375,7 +375,7 @@ func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block bloc | |||
375 | reqGet := message.NewDHTClientGetMsg(query.Key()) | 375 | reqGet := message.NewDHTClientGetMsg(query.Key()) |
376 | reqGet.ID = uint64(util.NextID()) | 376 | reqGet.ID = uint64(util.NextID()) |
377 | reqGet.ReplLevel = uint32(enums.GNS_REPLICATION_LEVEL) | 377 | reqGet.ReplLevel = uint32(enums.GNS_REPLICATION_LEVEL) |
378 | reqGet.Type = uint32(enums.BLOCK_TYPE_GNS_NAMERECORD) | 378 | reqGet.BType = enums.BLOCK_TYPE_GNS_NAMERECORD |
379 | reqGet.Options = uint32(enums.DHT_RO_DEMULTIPLEX_EVERYWHERE) | 379 | reqGet.Options = uint32(enums.DHT_RO_DEMULTIPLEX_EVERYWHERE) |
380 | 380 | ||
381 | if err = interact(reqGet, true); err != nil { | 381 | if err = interact(reqGet, true); err != nil { |
@@ -413,7 +413,7 @@ func (s *Service) LookupDHT(ctx context.Context, query blocks.Query) (block bloc | |||
413 | break | 413 | break |
414 | } | 414 | } |
415 | // check if result is of requested type | 415 | // check if result is of requested type |
416 | if enums.BlockType(m.Type) != enums.BLOCK_TYPE_GNS_NAMERECORD { | 416 | if enums.BlockType(m.BType) != enums.BLOCK_TYPE_GNS_NAMERECORD { |
417 | logger.Println(logger.ERROR, "[gns] DHT response has wrong type") | 417 | logger.Println(logger.ERROR, "[gns] DHT response has wrong type") |
418 | break | 418 | break |
419 | } | 419 | } |