pool

package
v0.0.0-...-66c8e8d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 12, 2019 License: MIT Imports: 32 Imported by: 0

Documentation

Overview

Package pool is an implementation of the pool module, and is responsible for creating a mining pool, accepting incoming potential block solutions and rewarding the submitters proportionally for their shares.

Index

Constants

View Source 
const (

	// MajorVersion is the significant version of the pool module
	MajorVersion = 0
	// MinorVersion is the minor version of the pool module
	MinorVersion = 3
	// SiaCoinID is the coin id used by yiimp to associate various records
	// with Siacoin
	SiaCoinID = 1318
	// SiaCoinSymbol is the coin symbol used by yiimp to associate various records
	// with Siacoin
	SiaCoinSymbol = "SCP"
	// SiaCoinAlgo is the algo used by yiimp to associate various records
	// with blake2b mining
	SiaCoinAlgo = "blake2b"
)

Variables

View Source 
var (
	// ErrDuplicateUserInDifferentCoin is an error when a address used in
	// different coin
	//ErrDuplicateUserInDifferentCoin = errors.New("duplicate user in different coin, you need use a different address")
	// ErrNoUsernameInDatabase is an error when can't find a username in db
	ErrNoUsernameInDatabase = errors.New("user is not found in db")
	// ErrCreateClient is an error when can't create a new client
	ErrCreateClient = errors.New("Error when creating a new client")
	ErrQueryTimeout = errors.New("DB query timeout")
	ErrConnectDB    = errors.New("error in connecting redis")
	DB              = []string{"accounts", "workers", "shares", "blocks"}
)
View Source 
var (

	// HeaderMemory is the number of previous calls to 'header'
	// that are remembered. Additionally, 'header' will only poll for a
	// new block every 'headerMemory / blockMemory' times it is
	// called. This reduces the amount of memory used, but comes at the cost of
	// not always having the most recent transactions.
	HeaderMemory = build.Select(build.Var{
		Standard: 10000,
		Dev:      500,
		Testing:  50,
	}).(int)

	// BlockMemory is the maximum number of blocks the miner will store
	// Blocks take up to 2 megabytes of memory, which is why this number is
	// limited.
	BlockMemory = build.Select(build.Var{
		Standard: 50,
		Dev:      10,
		Testing:  5,
	}).(int)

	// MaxSourceBlockAge is the maximum amount of time that is allowed to
	// elapse between generating source blocks.
	MaxSourceBlockAge = build.Select(build.Var{
		Standard: 30 * time.Second,
		Dev:      5 * time.Second,
		Testing:  1 * time.Second,
	}).(time.Duration)

	// ShiftDuration is how often we commit mining data to persistent
	// storage when a block hasn't been found.
	ShiftDuration = build.Select(build.Var{
		Standard: 20 * time.Second,
		Dev:      20 * time.Second,
		Testing:  1 * time.Second,
	}).(time.Duration)
)

Functions

func BigToCompact 

func BigToCompact(n *big.Int) uint32

BigToCompact converts a whole number N to a compact representation using an unsigned 32-bit number. The compact representation only provides 23 bits of precision, so values larger than (2^23 - 1) only encode the most significant digits of the number. See CompactToBig for details.

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

A Client represents a user and may have one or more workers associated with it. It is primarily used for accounting and statistics.

func (*Client) GetID 

func (c *Client) GetID() uint64

func (*Client) Name 

func (c *Client) Name() string

Name returns the client's name, which is usually the wallet address

func (*Client) Pool 

func (c *Client) Pool() *Pool

Pool returns the client's pool no lock needed, a client's pool won't change

func (*Client) SetID 

func (c *Client) SetID(id uint64)

func (*Client) SetName 

func (c *Client) SetName(n string)

SetName sets the client's name

func (*Client) SetWallet 

func (c *Client) SetWallet(w types.UnlockHash)

SetWallet sets the unlockhash associated with the client

func (*Client) Wallet 

func (c *Client) Wallet() *types.UnlockHash

Wallet returns the unlockhash associated with the client

type ClientRecord 

type ClientRecord struct {
	// contains filtered or unexported fields
}

A ClientRecord represents the persistent data portion of the Client record

type Dispatcher 

type Dispatcher struct {
	// contains filtered or unexported fields
}

Dispatcher contains a map of ip addresses to handlers Dispatcher contains a map of ip addresses to handlers

func (*Dispatcher) AddHandler 

func (d *Dispatcher) AddHandler(conn net.Conn)

AddHandler connects the incoming connection to the handler which will handle it

func (*Dispatcher) AddNotifier 

func (d *Dispatcher) AddNotifier(h *Handler)

func (*Dispatcher) ClearJobAndNotifyClients 

func (d *Dispatcher) ClearJobAndNotifyClients()

ClearJobAndNotifyClients clear all stale jobs and tells the dispatcher to notify all clients that the block has changed

func (*Dispatcher) IncrementConnectionsOpened 

func (d *Dispatcher) IncrementConnectionsOpened()

IncrementConnectionsOpened increments the number of tcp connections that the pool has ever opened

func (*Dispatcher) ListenHandlers 

func (d *Dispatcher) ListenHandlers(port string)

ListenHandlers listens on a passed port and upon accepting the incoming connection, adds the handler to deal with it

func (*Dispatcher) NotifyClients 

func (d *Dispatcher) NotifyClients()

NotifyClients tells the dispatcher to notify all clients that the block has changed

func (*Dispatcher) NumConnections 

func (d *Dispatcher) NumConnections() int

NumConnections returns the number of open tcp connections

func (*Dispatcher) NumConnectionsOpened 

func (d *Dispatcher) NumConnectionsOpened() uint64

NumConnectionsOpened returns the number of tcp connections that the pool has ever opened

type Handler 

type Handler struct {
	// contains filtered or unexported fields
}

Handler represents the status (open/closed) of each connection

func (*Handler) GetSession 

func (h *Handler) GetSession() *Session

func (*Handler) Listen 

func (h *Handler) Listen()

Listen listens on a connection for incoming data and acts on it

func (*Handler) SetSession 

func (h *Handler) SetSession(s *Session)

type Job 

type Job struct {
	JobID           uint64
	MarshalledBlock []byte
	MerkleRoot      crypto.Hash
	SubmitedNonce   map[string]bool
}

A Job in the stratum server is a unit of work which is passed to the client miner to solve. It is primarily identified by a Job ID and this is used to keep track of what work has been assigned to each client

type Pool 

type Pool struct {
	modules.StorageManager
	// contains filtered or unexported fields
}

A Pool contains all the fields necessary for storing status for clients and performing the evaluation and rewarding on submitted shares

func New 

func New(cs modules.ConsensusSet, tpool modules.TransactionPool, gw modules.Gateway, wallet modules.Wallet, persistDir string, initConfig config.MiningPoolConfig) (*Pool, error)

New returns an initialized Pool.

func (*Pool) AddClient 

func (p *Pool) AddClient(c *Client)

AddClient stores the client with the specified name into memory

func (*Pool) AddClientDB 

func (p *Pool) AddClientDB(c *Client) error

AddClientDB add user into accounts

func (*Pool) Client 

func (p *Pool) Client(name string) *Client

Client returns the client with the specified name that has been stored in memory

func (*Pool) Close 

func (p *Pool) Close() error

Close shuts down the pool.

func (*Pool) DeleteAllWorkerRecords 

func (p *Pool) DeleteAllWorkerRecords() error

func (*Pool) FindClientDB 

func (p *Pool) FindClientDB(name string) (*Client, error)

FindClientDB find user in accounts

func (*Pool) InternalSettings 

func (p *Pool) InternalSettings() modules.PoolInternalSettings

InternalSettings returns the settings of a pool.

func (*Pool) NumConnections 

func (p *Pool) NumConnections() int

NumConnections returns the number of tcp connections from clients the pool currently has open

func (*Pool) NumConnectionsOpened 

func (p *Pool) NumConnectionsOpened() uint64

NumConnectionsOpened returns the total number of tcp connections from clients the pool has opened since startup

func (*Pool) ProcessConsensusChange 

func (p *Pool) ProcessConsensusChange(cc modules.ConsensusChange)

ProcessConsensusChange will update the pool's most recent block.

func (*Pool) ReceiveUpdatedUnconfirmedTransactions 

func (p *Pool) ReceiveUpdatedUnconfirmedTransactions(diff *modules.TransactionPoolDiff)

ReceiveUpdatedUnconfirmedTransactions will replace the current unconfirmed set of transactions with the input transactions.

func (*Pool) SetInternalSettings 

func (p *Pool) SetInternalSettings(settings modules.PoolInternalSettings) error

SetInternalSettings updates the pool's internal PoolInternalSettings object.

type Session 

type Session struct {
	ExtraNonce1 uint32

	SessionID uint64

	Client        *Client
	CurrentWorker *Worker
	CurrentShift  *Shift

	CurrentJobs []*Job
	// contains filtered or unexported fields
}

A Session captures the interaction with a miner client from when they connect until the connection is closed. A session is tied to a single client and has many jobs associated with it

func (*Session) Authorized 

func (s *Session) Authorized() bool

Authorized returns whether or not the session has been authorized

func (*Session) CurrentDifficulty 

func (s *Session) CurrentDifficulty() float64

CurrentDifficulty returns the session's current difficulty

func (*Session) DetectDisconnected 

func (s *Session) DetectDisconnected() bool

DetectDisconnected checks to see if we haven't heard from a client for too long of a time. It does this via 2 mechanisms:

  1. how long ago was the last share submitted? (the hearbeat)
  2. how low has the difficulty dropped from the highest difficulty the client ever faced?

func (*Session) GetClient 

func (s *Session) GetClient() *Client

func (*Session) GetCurrentWorker 

func (s *Session) GetCurrentWorker() *Worker

func (*Session) GetDisableVarDiff 

func (s *Session) GetDisableVarDiff() bool

func (*Session) GetID 

func (s *Session) GetID() uint64

func (*Session) HighestDifficulty 

func (s *Session) HighestDifficulty() float64

HighestDifficulty returns the highest difficulty the session has seen

func (*Session) IsStable 

func (s *Session) IsStable() bool

IsStable checks if the session has been running long enough to fill up the vardiff buffer

func (*Session) SetAuthorized 

func (s *Session) SetAuthorized(b bool)

SetAuthorized specifies whether or not the session has been authorized

func (*Session) SetClientVersion 

func (s *Session) SetClientVersion(v string)

SetClientVersion sets the current client version for the session

func (*Session) SetCurrentDifficulty 

func (s *Session) SetCurrentDifficulty(d float64)

SetCurrentDifficulty sets the current difficulty for the session

func (*Session) SetDisableVarDiff 

func (s *Session) SetDisableVarDiff(flag bool)

SetDisableVarDiff sets the disable var diff flag for the session

func (*Session) SetHeartbeat 

func (s *Session) SetHeartbeat()

SetHeartbeat indicates that we just received a share submission

func (*Session) SetHighestDifficulty 

func (s *Session) SetHighestDifficulty(d float64)

SetHighestDifficulty records the highest difficulty the session has seen

func (*Session) SetID 

func (s *Session) SetID(id uint64)

func (*Session) SetLastShareTimestamp 

func (s *Session) SetLastShareTimestamp(t time.Time)

SetLastShareTimestamp add a new time stamp

func (*Session) ShareDurationAverage 

func (s *Session) ShareDurationAverage() (float64, float64)

ShareDurationAverage caculate the average duration of the

func (*Session) Shift 

func (s *Session) Shift() *Shift

Shift returns the current Shift associated with a session

type Share 

type Share struct {
	// contains filtered or unexported fields
}

A Share is how we track each worker's submissions and their difficulty

type Shift 

type Shift struct {
	// contains filtered or unexported fields
}

A Shift is a period over which a worker submits shares. At the end of the period, we record those shares into the database.

func (*Shift) IncrementInvalid 

func (s *Shift) IncrementInvalid()

IncrementInvalid marks a share as having been invalid

func (*Shift) IncrementShares 

func (s *Shift) IncrementShares(share *Share)

IncrementShares adds a new share to the slice of shares processed during the shift

func (*Shift) LastShareTime 

func (s *Shift) LastShareTime() time.Time

LastShareTime returns the most recent time a share was submitted during this shift

func (*Shift) PoolID 

func (s *Shift) PoolID() uint64

PoolID returns the pool's unique ID. Multiple stratum servers connecting to the same database should use unique ids so that workers can be tracked as belonging to which server.

func (*Shift) SaveShift 

func (s *Shift) SaveShift() error

SaveShift periodically saves the shares for a given worker to the db

func (*Shift) SetLastShareTime 

func (s *Shift) SetLastShareTime(t time.Time)

SetLastShareTime specifies the most recent time a share was submitted during this shift

func (*Shift) Shares 

func (s *Shift) Shares() []Share

Shares returns the slice of shares submitted during the shift

func (*Shift) ShiftID 

func (s *Shift) ShiftID() uint64

ShiftID returns the shift's unique ID

func (*Shift) StartShiftTime 

func (s *Shift) StartShiftTime() time.Time

StartShiftTime returns the time this shift started

type Vardiff 

type Vardiff struct {
	// contains filtered or unexported fields
}

Vardiff is a structure representing maximum and minimum share submission times, along with the size of the buffer over which share submission times should be monitored

type Worker 

type Worker struct {
	// contains filtered or unexported fields
}

A Worker is an instance of one miner. A Client often represents a user and the worker represents a single miner. There is a one to many client worker relationship

func (*Worker) CurrentDifficulty 

func (w *Worker) CurrentDifficulty() float64

CurrentDifficulty returns the average difficulty of all instances of this worker

func (*Worker) GetID 

func (w *Worker) GetID() uint64

func (*Worker) IncrementInvalidShares 

func (w *Worker) IncrementInvalidShares()

IncrementInvalidShares adds a record of an invalid share submission

func (*Worker) IncrementShares 

func (w *Worker) IncrementShares(sessionDifficulty float64, reward float64)

IncrementShares creates a new share according to current session difficulty for the worker to work on

func (*Worker) LastShareTime 

func (w *Worker) LastShareTime() time.Time

LastShareTime returns the last time a share was submitted during the current shift

func (*Worker) Name 

func (w *Worker) Name() string

Name return the worker's name, typically a wallet address

func (*Worker) Online 

func (w *Worker) Online() bool

Online checks if the worker has a tcp session associated with it

func (*Worker) Parent 

func (w *Worker) Parent() *Client

Parent returns the worker's client

func (*Worker) Session 

func (w *Worker) Session() *Session

Session returns the tcp session associated with the worker

func (*Worker) SetID 

func (w *Worker) SetID(id uint64)

func (*Worker) SetLastShareTime 

func (w *Worker) SetLastShareTime(t time.Time)

SetLastShareTime specifies the last time a share was submitted during the current shift

func (*Worker) SetName 

func (w *Worker) SetName(n string)

SetName sets the worker's name

func (*Worker) SetParent 

func (w *Worker) SetParent(p *Client)

SetParent sets the worker's client

func (*Worker) SetSession 

func (w *Worker) SetSession(s *Session)

SetSession sets the tcp session associated with the worker

type WorkerRecord 

type WorkerRecord struct {
	// contains filtered or unexported fields
}

A WorkerRecord is used to track worker information in memory

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.