host

package
v3.3.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Dec 13, 2019 License: LGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DNSTable      = "dns_table"
	DNSRTable     = "dns_revert_table"
	DNSOwnerTable = "dns_owner_table"
)

const table name

Variables

View Source 
var (
	ErrBalanceNotEnough = errors.New("balance not enough")
	ErrTransferNegValue = errors.New("trasfer amount less than zero")
	ErrReenter          = errors.New("re-entering")
	ErrPermissionLost   = errors.New("transaction has no permission")
	ErrInvalidData      = errors.New("invalid data")
	ErrInvalidAmount    = errors.New("invalid amount")
	ErrOutOfGas         = errors.New("out of gas")

	ErrContractNotFound   = errors.New("contract not exists")
	ErrContractExists     = errors.New("contract exists")
	ErrAbiHasInternalFunc = errors.New("abi has internal function")
	ErrUpdateRefused      = errors.New("update refused")
	ErrDestroyRefused     = errors.New("destroy refused")

	ErrCoinExists         = errors.New("coin exists")
	ErrCoinNotExists      = errors.New("coin not exists")
	ErrCoinIssueRefused   = errors.New("coin issue refused")
	ErrCoinSetRateRefused = errors.New("coin set rate refused")

	ErrTokenExists               = errors.New("token exists")
	ErrTokenNotExists            = errors.New("token not exists")
	ErrAmountLimitTokenNotExists = errors.New("token not exists in amountLimit")
	ErrTokenNoTransfer           = errors.New("token can't transfer")
	ErrTokenIssueRefused         = errors.New("token issue refused")
	ErrMemoTooLarge              = errors.New("memo too large")

	ErrDelaytxNotFound   = errors.New("delaytx not exists")
	ErrCannotCancelDelay = errors.New("can not cancel delaytx")
)

var errors

View Source 
var (
	Costs = map[string]contract.Cost{
		"JSCost":           contract.NewCost(0, 0, 30000),
		"PutCost":          contract.NewCost(0, 0, 300),
		"GetCost":          contract.NewCost(0, 0, 300),
		"DelCost":          contract.NewCost(0, 0, 300),
		"KeysCost":         contract.NewCost(0, 0, 300),
		"ContextCost":      contract.NewCost(0, 0, 10),
		"EventPrice":       contract.NewCost(0, 0, 1),
		"ReceiptPrice":     contract.NewCost(0, 1, 0),
		"CodePrice":        contract.NewCost(0, 0, 1),
		"SetCodeBasePrice": contract.NewCost(0, 0, 200000),
		"SetCodePrice":     contract.NewCost(0, 0, 70),
		"OpPrice":          contract.NewCost(0, 0, 1),
		"ErrPrice":         contract.NewCost(0, 0, 1),
	}
)

var costs

Functions

func CodeSavageCost 

func CodeSavageCost(size int) contract.Cost

CodeSavageCost cost in deploy contract based on code size

func CommonErrorCost 

func CommonErrorCost(layer int) contract.Cost

CommonErrorCost returns cost increased by stack layer

func CommonOpCost added in v1.1.0 

func CommonOpCost(layer int) contract.Cost

CommonOpCost returns cost increased by stack layer

func DelDelayTxCost 

func DelDelayTxCost(dataLen int, payer string) contract.Cost

DelDelayTxCost returns cost of a delay transaction.

func DelayTxCost 

func DelayTxCost(dataLen int, payer string) contract.Cost

DelayTxCost returns cost of a delay transaction.

func EventCost 

func EventCost(size int) contract.Cost

EventCost return cost based on event size

func IsValidKey added in v1.1.0 

func IsValidKey(key string) error

IsValidKey return error if the key is invalid as state db key or field

func ReadAuth added in v1.1.0 

func ReadAuth(vi *database.Visitor, id string) (*account.Account, contract.Cost)

ReadAuth read auth

func ReceiptCost 

func ReceiptCost(size int) contract.Cost

ReceiptCost based on receipt size

func SetCodeCost 

func SetCodeCost(size int) contract.Cost

SetCodeCost calculate set code cost based on code size

Types

type APIDelegate 

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

APIDelegate ...

func NewAPI 

func NewAPI(h *Host) APIDelegate

NewAPI ...

func (*APIDelegate) Receipt 

func (h *APIDelegate) Receipt(s string) contract.Cost

Receipt ...

type Authority added in v1.1.0 

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

Authority module of ...

func (*Authority) IsContract added in v1.1.0 

func (h *Authority) IsContract(id string) bool

IsContract to judge the id is contract format

func (*Authority) RequireAuth added in v1.1.0 

func (h *Authority) RequireAuth(id, p string) (bool, contract.Cost)

RequireAuth check auth

func (*Authority) RequirePublisherAuth 

func (h *Authority) RequirePublisherAuth(id string) (bool, contract.Cost)

RequirePublisherAuth check publisher auth

func (*Authority) RequireSignerAuth 

func (h *Authority) RequireSignerAuth(id, p string) (bool, contract.Cost)

RequireSignerAuth check signer auth

type Caller 

type Caller struct {
	Name      string `json:"name"`
	IsAccount bool   `json:"is_account"`
}

Caller ...

type Context 

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

Context thread unsafe context with global fields

func NewContext 

func NewContext(base *Context) *Context

NewContext new context based on base

func (*Context) Base 

func (c *Context) Base() *Context

Base get base of context

func (*Context) GClear added in v1.1.0 

func (c *Context) GClear()

GClear clear global values

func (*Context) GSet 

func (c *Context) GSet(key string, value interface{})

GSet set global value of key, thread unsafe

func (*Context) GValue 

func (c *Context) GValue(key string) (value interface{})

GValue get global value of key

func (*Context) Set 

func (c *Context) Set(key string, value interface{})

Set set value of k

func (*Context) String added in v1.1.0 

func (c *Context) String() string

func (*Context) Value 

func (c *Context) Value(key string) (value interface{})

Value get value of key

type DBHandler 

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

DBHandler is an application layer abstraction of our base basic_handler and map_handler. it offers interface which has an interface{} type value and ramPayer semantic it also handles the Marshal and Unmarshal work and determine the cost of each operation

func NewDBHandler 

func NewDBHandler(h *Host) DBHandler

NewDBHandler ...

func (*DBHandler) Del 

func (h *DBHandler) Del(key string) (contract.Cost, error)

Del delete key

func (*DBHandler) Get 

func (h *DBHandler) Get(key string) (value interface{}, cost contract.Cost)

Get get value of key from db

func (*DBHandler) GlobalGet 

func (h *DBHandler) GlobalGet(con, key string) (value interface{}, cost contract.Cost)

GlobalGet get another contract's data

func (*DBHandler) GlobalHas added in v1.1.0 

func (h *DBHandler) GlobalHas(con, key string) (bool, contract.Cost)

GlobalHas if another contract's db has key

func (*DBHandler) GlobalMapGet 

func (h *DBHandler) GlobalMapGet(con, key, field string) (value interface{}, cost contract.Cost)

GlobalMapGet get another contract's map data

func (*DBHandler) GlobalMapHas added in v1.1.0 

func (h *DBHandler) GlobalMapHas(con, key, field string) (bool, contract.Cost)

GlobalMapHas if another contract's map has field

func (*DBHandler) GlobalMapKeys 

func (h *DBHandler) GlobalMapKeys(con, key string) (keys []string, cost contract.Cost)

GlobalMapKeys get another contract's map keys

func (*DBHandler) GlobalMapLen 

func (h *DBHandler) GlobalMapLen(con, key string) (length int, cost contract.Cost)

GlobalMapLen get another contract's map length

func (*DBHandler) Has 

func (h *DBHandler) Has(key string) (bool, contract.Cost)

Has if db has key

func (*DBHandler) MapDel 

func (h *DBHandler) MapDel(key, field string) (contract.Cost, error)

MapDel delete field

func (*DBHandler) MapGet 

func (h *DBHandler) MapGet(key, field string) (value interface{}, cost contract.Cost)

MapGet get value by kf from db

func (*DBHandler) MapHas 

func (h *DBHandler) MapHas(key, field string) (bool, contract.Cost)

MapHas if has field

func (*DBHandler) MapKeys 

func (h *DBHandler) MapKeys(key string) (fields []string, cost contract.Cost)

MapKeys list keys

func (*DBHandler) MapLen 

func (h *DBHandler) MapLen(key string) (int, contract.Cost)

MapLen get length of map

func (*DBHandler) MapPut 

func (h *DBHandler) MapPut(key, field string, value interface{}, ramPayer ...string) (contract.Cost, error)

MapPut put kfv to db

func (*DBHandler) Put 

func (h *DBHandler) Put(key string, value interface{}, ramPayer ...string) (contract.Cost, error)

Put put kv to db

type DNS added in v1.1.0 

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

DNS dns server handler

func NewDNS added in v1.1.0 

func NewDNS(h *Host) DNS

NewDNS make a dns

func (*DNS) ContractID added in v1.1.0 

func (d *DNS) ContractID(url string) string

ContractID find cid from url

func (*DNS) IsDomain added in v1.1.0 

func (d *DNS) IsDomain(s string) bool

IsDomain determine if s is a domain 

func (d *DNS) RemoveLink(url, cid string)

RemoveLink remove a url

func (*DNS) URL added in v1.1.0 

func (d *DNS) URL(cid string) string

URL get url of cid

func (*DNS) URLOwner added in v1.1.0 

func (d *DNS) URLOwner(url string) string

URLOwner find owner of url

func (*DNS) URLTransfer added in v1.1.0 

func (d *DNS) URLTransfer(url, to string)

URLTransfer give url to another id 

func (d *DNS) WriteLink(url, cid, owner string)

WriteLink add url and url owner to contract

type EventPoster 

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

EventPoster the event handler in host

func NewEventPoster added in v1.1.0 

func NewEventPoster(h *Host) EventPoster

NewEventPoster returns a new EventPoster instance.

func (*EventPoster) PostEvent added in v1.1.0 

func (p *EventPoster) PostEvent(data string) contract.Cost

PostEvent post the event

type GasManager added in v1.1.0 

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

GasManager handle the logic of gas. It should be called in a contract

func NewGasManager added in v1.1.0 

func NewGasManager(h *Host) GasManager

NewGasManager new gas manager

func (*GasManager) ChangeTGas added in v1.1.0 

func (g *GasManager) ChangeTGas(name string, delta *common.Fixed, changeQuota bool) contract.Cost

ChangeTGas ...

func (*GasManager) ChangeTGasQuota 

func (g *GasManager) ChangeTGasQuota(name string, delta *common.Fixed) contract.Cost

ChangeTGasQuota ...

func (*GasManager) CostGas added in v1.1.0 

func (g *GasManager) CostGas(name string, gasCost *common.Fixed) error

CostGas subtract gas of a user. It is not called in a contract. Need a better design here

func (*GasManager) DelGasPledge added in v1.1.0 

func (g *GasManager) DelGasPledge(name string, pledger string) contract.Cost

DelGasPledge ...

func (*GasManager) GasLimit added in v1.1.0 

func (g *GasManager) GasLimit(name string) (*common.Fixed, contract.Cost)

GasLimit ...

func (*GasManager) GasPledge added in v1.1.0 

func (g *GasManager) GasPledge(name string, pledger string) (*common.Fixed, contract.Cost)

GasPledge ...

func (*GasManager) GasPledgeTotal 

func (g *GasManager) GasPledgeTotal(name string) (*common.Fixed, contract.Cost)

GasPledgeTotal ...

func (*GasManager) GasStock added in v1.1.0 

func (g *GasManager) GasStock(name string) (*common.Fixed, contract.Cost)

GasStock `gasStock` means the gas amount at last update time.

func (*GasManager) GasUpdateTime added in v1.1.0 

func (g *GasManager) GasUpdateTime(name string) (int64, contract.Cost)

GasUpdateTime ...

func (*GasManager) PGas added in v1.1.0 

func (g *GasManager) PGas(name string) *common.Fixed

PGas returns the current total gas of a user. It is dynamically calculated

func (*GasManager) RefreshPGas added in v1.1.0 

func (g *GasManager) RefreshPGas(name string) (contract.Cost, error)

RefreshPGas update the gas status

func (*GasManager) SetGasLimit added in v1.1.0 

func (g *GasManager) SetGasLimit(name string, l *common.Fixed) contract.Cost

SetGasLimit ...

func (*GasManager) SetGasPledge added in v1.1.0 

func (g *GasManager) SetGasPledge(name string, pledger string, p *common.Fixed) contract.Cost

SetGasPledge ...

func (*GasManager) SetGasPledgeTotal 

func (g *GasManager) SetGasPledgeTotal(name string, r *common.Fixed) contract.Cost

SetGasPledgeTotal ...

func (*GasManager) SetGasStock added in v1.1.0 

func (g *GasManager) SetGasStock(name string, gas *common.Fixed) contract.Cost

SetGasStock ...

func (*GasManager) SetGasUpdateTime added in v1.1.0 

func (g *GasManager) SetGasUpdateTime(name string, t int64) contract.Cost

SetGasUpdateTime ...

func (*GasManager) TGas added in v1.1.0 

func (g *GasManager) TGas(name string) (*common.Fixed, contract.Cost)

TGas ...

func (*GasManager) TGasQuota 

func (g *GasManager) TGasQuota(name string) (*common.Fixed, contract.Cost)

TGasQuota Since TGas can only be transferred once, 'TGasQuota' means 'how much TGas one account can transfer out'

func (*GasManager) TotalGas added in v1.1.0 

func (g *GasManager) TotalGas(name string) *common.Fixed

TotalGas ...

type Host 

type Host struct {
	DBHandler
	Stack
	Info
	Teller
	APIDelegate
	EventPoster
	DNS
	Authority
	GasManager
	*version.Rules
	// contains filtered or unexported fields
}

Host host struct, used as isolate of vm

func NewHost 

func NewHost(ctx *Context, db *database.Visitor, rules *version.Rules, monitor Monitor, logger *ilog.Logger) *Host

NewHost get a new host

func (*Host) Call 

func (h *Host) Call(contract, api, jarg string) ([]interface{}, contract.Cost, error)

Call call a new contract in this context

func (*Host) CallWithAuth added in v1.1.0 

func (h *Host) CallWithAuth(contract, api, jarg string) ([]interface{}, contract.Cost, error)

CallWithAuth call a new contract with permission of current contract

func (*Host) CancelDelaytx added in v1.1.0 

func (h *Host) CancelDelaytx(txHash string) (contract.Cost, error)

CancelDelaytx deletes delaytx hash.

The given argument txHash is from user's input. So we should Base58Decode it first.

func (*Host) CheckAmountLimit 

func (h *Host) CheckAmountLimit(amountLimit []*contract.Amount) error

CheckAmountLimit check amountLimit of tx valid

func (*Host) CheckPublisher 

func (h *Host) CheckPublisher(t *tx.Tx) error

CheckPublisher check publisher of tx

func (*Host) CheckSigners 

func (h *Host) CheckSigners(t *tx.Tx) error

CheckSigners check signers of tx

func (*Host) Context 

func (h *Host) Context() *Context

Context get context in host

func (*Host) DB 

func (h *Host) DB() *database.Visitor

DB get current version mvccdb

func (*Host) Deadline 

func (h *Host) Deadline() time.Time

Deadline return this host's deadline

func (*Host) GetVMFlags 

func (h *Host) GetVMFlags() int64

GetVMFlags return target vm bitwise flags

func (*Host) IsValidAccount added in v1.1.0 

func (h *Host) IsValidAccount(name string) bool

IsValidAccount check whether account exists

func (*Host) Logger 

func (h *Host) Logger() *ilog.Logger

Logger get a log in host

func (*Host) PopCtx 

func (h *Host) PopCtx()

PopCtx pop current context

func (*Host) PushCtx 

func (h *Host) PushCtx()

PushCtx make a new context based on current one

func (*Host) ReadSettings added in v1.1.0 

func (h *Host) ReadSettings()

ReadSettings read settings from db

func (*Host) SetCode 

func (h *Host) SetCode(c *contract.Contract, owner string) (contract.Cost, error)

SetCode set code to storage

func (*Host) SetContext 

func (h *Host) SetContext(ctx *Context)

SetContext set a new context to host

func (*Host) SetDeadline 

func (h *Host) SetDeadline(t time.Time)

SetDeadline set this host's deadline

func (*Host) UpdateCode 

func (h *Host) UpdateCode(c *contract.Contract, id database.SerializedJSON) (contract.Cost, error)

UpdateCode update code

type Info 

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

Info current info handler of this isolate

func NewInfo 

func NewInfo(h *Host) Info

NewInfo new info

func (*Info) ABIConfig 

func (h *Info) ABIConfig(key, value string)

ABIConfig set this abi config

func (*Info) BlockInfo 

func (h *Info) BlockInfo() (info database.SerializedJSON, cost contract.Cost)

BlockInfo get block info, in json

func (*Info) BlockTime added in v1.1.0 

func (h *Info) BlockTime() (ntime int64, cost contract.Cost)

BlockTime get block time, in int64

func (*Info) ContextInfo added in v1.1.0 

func (h *Info) ContextInfo() (info database.SerializedJSON, cost contract.Cost)

ContextInfo get context info

func (*Info) ContractName added in v1.1.0 

func (h *Info) ContractName() (name string, cost contract.Cost)

ContractName get block time, in int64

func (*Info) GasLimitValue added in v1.1.0 

func (h *Info) GasLimitValue() int64

GasLimitValue get gas limit

func (*Info) TxInfo 

func (h *Info) TxInfo() (info database.SerializedJSON, cost contract.Cost)

TxInfo get tx info

type Monitor 

type Monitor interface {
	Call(host *Host, contractName, api string, jarg string) (rtn []interface{}, cost contract.Cost, err error)
	Validate(con *contract.Contract) error
	Compile(con *contract.Contract) (string, error)
}

Monitor monitor interface

type Setting added in v1.1.0 

type Setting struct {
	Costs map[string]contract.Cost `json:"costs"`
}

Setting in state db

type Stack 

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

Stack is call stack of this host

func NewStack 

func NewStack(h *Host) Stack

NewStack new stack

func (*Stack) Caller 

func (s *Stack) Caller() Caller

Caller get caller

func (*Stack) InitStack 

func (s *Stack) InitStack(publisher string)

InitStack init a new call stack

func (*Stack) PopStack 

func (s *Stack) PopStack()

PopStack pop a call stack

func (*Stack) PushStack 

func (s *Stack) PushStack(cont, api string, withAuth bool) (reenter bool, cost contract.Cost)

PushStack push a new call stack

func (*Stack) SetStackInfo 

func (s *Stack) SetStackInfo(cont, api string)

SetStackInfo set contract info

func (*Stack) StackHeight 

func (s *Stack) StackHeight() int

StackHeight get current stack height

type Teller 

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

Teller handler of iost

func NewTeller 

func NewTeller(h *Host) Teller

NewTeller new teller

func (*Teller) AddCacheCost added in v1.1.0 

func (t *Teller) AddCacheCost(c contract.Cost)

AddCacheCost ...

func (*Teller) CacheCost added in v1.1.0 

func (t *Teller) CacheCost() contract.Cost

CacheCost ...

func (*Teller) ClearCacheCost added in v1.1.0 

func (t *Teller) ClearCacheCost()

ClearCacheCost ...

func (*Teller) ClearCosts added in v1.1.0 

func (t *Teller) ClearCosts()

ClearCosts ...

func (*Teller) ClearRAMCosts added in v1.1.0 

func (t *Teller) ClearRAMCosts()

ClearRAMCosts ...

func (*Teller) Costs added in v1.1.0 

func (t *Teller) Costs() map[string]contract.Cost

Costs ...

func (*Teller) DoPay 

func (t *Teller) DoPay(witness string, gasRatio int64) (paidGas *common.Fixed, err error)

DoPay ...

func (*Teller) FlushCacheCost added in v1.1.0 

func (t *Teller) FlushCacheCost()

FlushCacheCost ...

func (*Teller) GasPaid 

func (t *Teller) GasPaid(publishers ...string) int64

GasPaid ...

func (*Teller) IsProducer added in v1.1.0 

func (t *Teller) IsProducer(acc string) bool

IsProducer check account is producer

func (*Teller) PayCost 

func (t *Teller) PayCost(c contract.Cost, who string)

PayCost ...

func (*Teller) Privilege 

func (t *Teller) Privilege(id string) int

Privilege ...

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.