Dragonfly2

Форк
0
/
peerid_generator.go 
51 строка · 1.1 Кб
1
/*
2
 *     Copyright 2020 The Dragonfly Authors
3
 *
4
 * Licensed under the Apache License, Version 2.0 (the "License");
5
 * you may not use this file except in compliance with the License.
6
 * You may obtain a copy of the License at
7
 *
8
 *      http://www.apache.org/licenses/LICENSE-2.0
9
 *
10
 * Unless required by applicable law or agreed to in writing, software
11
 * distributed under the License is distributed on an "AS IS" BASIS,
12
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13
 * See the License for the specific language governing permissions and
14
 * limitations under the License.
15
 */
16

17
package peer
18

19
import "d7y.io/dragonfly/v2/pkg/idgen"
20

21
const (
22
	defaultPeerIDBufferSize = 1024
23
)
24

25
type IDGenerator interface {
26
	PeerID() string
27
}
28

29
type peerIDGenerator struct {
30
	ip string
31
	ch chan string
32
}
33

34
func NewPeerIDGenerator(ip string) IDGenerator {
35
	p := &peerIDGenerator{
36
		ip: ip,
37
		ch: make(chan string, defaultPeerIDBufferSize),
38
	}
39
	go p.run()
40
	return p
41
}
42

43
func (p *peerIDGenerator) PeerID() string {
44
	return <-p.ch
45
}
46

47
func (p *peerIDGenerator) run() {
48
	for {
49
		p.ch <- idgen.PeerIDV1(p.ip)
50
	}
51
}
52

Использование cookies

Мы используем файлы cookie в соответствии с Политикой конфиденциальности и Политикой использования cookies.

Нажимая кнопку «Принимаю», Вы даете АО «СберТех» согласие на обработку Ваших персональных данных в целях совершенствования нашего веб-сайта и Сервиса GitVerse, а также повышения удобства их использования.

Запретить использование cookies Вы можете самостоятельно в настройках Вашего браузера.