host

package
v2.1.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 3, 2019 License: LGPL-3.0 Imports: 14 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")
	ErrCancelDelayForbid = errors.New("cancel delaytx forbid")
)

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),
		"OpPrice":      contract.NewCost(0, 0, 1),
		"ErrPrice":     contract.NewCost(0, 0, 1),
	}
)

var costs

Functions

func Auth added in v1.1.0

func Auth(vi *database.Visitor, id, permission string, auth, reenter map[string]int) (bool, contract.Cost)

Auth check auth

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

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

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
	Info
	Teller
	APIDelegate
	EventPoster
	DNS
	Authority
	GasManager
	// contains filtered or unexported fields
}

Host host struct, used as isolate of vm

func NewHost

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

NewHost get a new host

func (*Host) Call

func (h *Host) Call(cont, api, jarg string, withAuth ...bool) ([]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) DestroyCode

func (h *Host) DestroyCode(contractName string) (contract.Cost, error)

DestroyCode delete code

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 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 ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL