MCPcopy Create free account
hub / github.com/DeAI-Artist/Linkis / StopForError

Method StopForError

abci/client/grpc_client.go:129–144  ·  view source on GitHub ↗
(err error)

Source from the content-addressed store, hash-verified

127}
128
129func (cli *grpcClient) StopForError(err error) {
130 if !cli.IsRunning() {
131 return
132 }
133
134 cli.mtx.Lock()
135 if cli.err == nil {
136 cli.err = err
137 }
138 cli.mtx.Unlock()
139
140 cli.Logger.Error(fmt.Sprintf("Stopping abci.grpcClient for error: %v", err.Error()))
141 if err := cli.Stop(); err != nil {
142 cli.Logger.Error("Error stopping abci.grpcClient", "err", err)
143 }
144}
145
146func (cli *grpcClient) Error() error {
147 cli.mtx.Lock()

Callers 15

EchoAsyncMethod · 0.95
FlushAsyncMethod · 0.95
InfoAsyncMethod · 0.95
SetOptionAsyncMethod · 0.95
DeliverTxAsyncMethod · 0.95
CheckTxAsyncMethod · 0.95
QueryAsyncMethod · 0.95
CommitAsyncMethod · 0.95
InitChainAsyncMethod · 0.95
BeginBlockAsyncMethod · 0.95
EndBlockAsyncMethod · 0.95
ListSnapshotsAsyncMethod · 0.95

Calls 5

IsRunningMethod · 0.65
LockMethod · 0.65
UnlockMethod · 0.65
ErrorMethod · 0.65
StopMethod · 0.65

Tested by

no test coverage detected