How to use executeMessage method of runner Package

Best Gauge code snippet using runner.executeMessage

grpcRunner.go

Source:grpcRunner.go Github

copy

Full Screen

...159 } else {160 resChan <- res161 }162}163func (r *GrpcRunner) executeMessage(message *gm.Message, timeout time.Duration) (*gm.Message, error) {164 resChan := make(chan *gm.Message)165 errChan := make(chan error)166 go r.invokeRPC(message, resChan, errChan)167 timer := setupTimer(timeout, errChan, message.GetMessageType().String())168 defer stopTimer(timer)169 select {170 case response := <-resChan:171 return response, nil172 case err := <-errChan:173 return nil, err174 }175}176// ExecuteMessageWithTimeout process request and give back the response177func (r *GrpcRunner) ExecuteMessageWithTimeout(message *gm.Message) (*gm.Message, error) {178 return r.executeMessage(message, r.Timeout)179}180// ExecuteAndGetStatus executes a given message and response without timeout.181func (r *GrpcRunner) ExecuteAndGetStatus(m *gm.Message) *gm.ProtoExecutionResult {182 if r.Info().Killed {183 return &gauge_messages.ProtoExecutionResult{Failed: true, ErrorMessage: "Runner is not Alive"}184 }185 res, err := r.executeMessage(m, 0)186 if err != nil {187 e, ok := status.FromError(err)188 if ok {189 var stackTrace = ""190 for _, detail := range e.Details() {191 if t, ok := detail.(*errdetails.DebugInfo); ok {192 for _, entry := range t.GetStackEntries() {193 stackTrace = fmt.Sprintf("%s%s\n", stackTrace, entry)194 }195 }196 }197 var data = strings.Split(e.Message(), "||")198 var message = data[0]199 if len(data) > 1 && stackTrace == "" {200 stackTrace = data[1]201 }202 if e.Code() == codes.Unavailable {203 r.Info().Killed = true204 return &gauge_messages.ProtoExecutionResult{Failed: true, ErrorMessage: message, StackTrace: stackTrace}205 }206 return &gauge_messages.ProtoExecutionResult{Failed: true, ErrorMessage: message, StackTrace: stackTrace}207 }208 return &gauge_messages.ProtoExecutionResult{Failed: true, ErrorMessage: err.Error()}209 }210 return res.ExecutionStatusResponse.ExecutionResult211}212// Alive check if the runner process is still alive213func (r *GrpcRunner) Alive() bool {214 ps := r.cmd.ProcessState215 return ps == nil || !ps.Exited()216}217// Kill closes the grpc connection and kills the process218func (r *GrpcRunner) Kill() error {219 if r.IsExecuting {220 return nil221 }222 m := &gm.Message{223 MessageType: gm.Message_KillProcessRequest,224 KillProcessRequest: &gm.KillProcessRequest{},225 }226 m, err := r.executeMessage(m, r.Timeout)227 if m == nil || err != nil {228 return err229 }230 if r.conn == nil && r.cmd == nil {231 return nil232 }233 defer r.conn.Close()234 if r.Alive() {235 exited := make(chan bool, 1)236 go func() {237 for {238 if r.Alive() {239 time.Sleep(100 * time.Millisecond)240 } else {...

Full Screen

Full Screen

runner.go

Source:runner.go Github

copy

Full Screen

1package conformance2import (3 "bytes"4 "compress/gzip"5 "context"6 "encoding/base64"7 "fmt"8 "io/ioutil"9 "math"10 "os"11 "os/exec"12 "strconv"13 "github.com/fatih/color"14 "github.com/filecoin-project/go-state-types/abi"15 "github.com/filecoin-project/go-state-types/exitcode"16 "github.com/filecoin-project/go-state-types/network"17 "github.com/hashicorp/go-multierror"18 blocks "github.com/ipfs/go-block-format"19 "github.com/ipfs/go-blockservice"20 "github.com/ipfs/go-cid"21 ds "github.com/ipfs/go-datastore"22 offline "github.com/ipfs/go-ipfs-exchange-offline"23 format "github.com/ipfs/go-ipld-format"24 "github.com/ipfs/go-merkledag"25 "github.com/ipld/go-car"26 "github.com/filecoin-project/test-vectors/schema"27 "github.com/filecoin-project/lotus/blockstore"28 "github.com/filecoin-project/lotus/chain/consensus/filcns"29 "github.com/filecoin-project/lotus/chain/types"30 "github.com/filecoin-project/lotus/chain/vm"31)32// FallbackBlockstoreGetter is a fallback blockstore to use for resolving CIDs33// unknown to the test vector. This is rarely used, usually only needed34// when transplanting vectors across versions. This is an interface tighter35// than ChainModuleAPI. It can be backed by a FullAPI client.36var FallbackBlockstoreGetter interface {37 ChainReadObj(context.Context, cid.Cid) ([]byte, error)38}39var TipsetVectorOpts struct {40 // PipelineBaseFee pipelines the basefee in multi-tipset vectors from one41 // tipset to another. Basefees in the vector are ignored, except for that of42 // the first tipset. UNUSED.43 PipelineBaseFee bool44 // OnTipsetApplied contains callback functions called after a tipset has been45 // applied.46 OnTipsetApplied []func(bs blockstore.Blockstore, params *ExecuteTipsetParams, res *ExecuteTipsetResult)47}48type GasPricingRestoreFn func()49// adjustGasPricing adjusts the global gas price mapping to make sure that the50// gas pricelist for vector's network version is used at the vector's epoch.51// Because it manipulates a global, it returns a function that reverts the52// change. The caller MUST invoke this function or the test vector runner will53// become invalid.54func adjustGasPricing(vectorEpoch abi.ChainEpoch, vectorNv network.Version) GasPricingRestoreFn {55 // Stash the current pricing mapping.56 // Ok to take a reference instead of a copy, because we override the map57 // with a new one below.58 var old = vm.Prices59 // Resolve the epoch at which the vector network version kicks in.60 var epoch abi.ChainEpoch = math.MaxInt6461 if vectorNv == network.Version0 {62 // genesis is not an upgrade.63 epoch = 064 } else {65 for _, u := range filcns.DefaultUpgradeSchedule() {66 if u.Network == vectorNv {67 epoch = u.Height68 break69 }70 }71 }72 if epoch == math.MaxInt64 {73 panic(fmt.Sprintf("could not resolve network version %d to height", vectorNv))74 }75 // Find the right pricelist for this network version.76 pricelist := vm.PricelistByEpoch(epoch)77 // Override the pricing mapping by setting the relevant pricelist for the78 // network version at the epoch where the vector runs.79 vm.Prices = map[abi.ChainEpoch]vm.Pricelist{80 vectorEpoch: pricelist,81 }82 // Return a function to restore the original mapping.83 return func() {84 vm.Prices = old85 }86}87// ExecuteMessageVector executes a message-class test vector.88func ExecuteMessageVector(r Reporter, vector *schema.TestVector, variant *schema.Variant) (diffs []string, err error) {89 var (90 ctx = context.Background()91 baseEpoch = abi.ChainEpoch(variant.Epoch)92 nv = network.Version(variant.NetworkVersion)93 root = vector.Pre.StateTree.RootCID94 )95 // Load the CAR into a new temporary Blockstore.96 bs, err := LoadBlockstore(vector.CAR)97 if err != nil {98 r.Fatalf("failed to load the vector CAR: %w", err)99 }100 // Create a new Driver.101 driver := NewDriver(ctx, vector.Selector, DriverOpts{DisableVMFlush: true})102 // Monkey patch the gas pricing.103 revertFn := adjustGasPricing(baseEpoch, nv)104 defer revertFn()105 // Apply every message.106 for i, m := range vector.ApplyMessages {107 msg, err := types.DecodeMessage(m.Bytes)108 if err != nil {109 r.Fatalf("failed to deserialize message: %s", err)110 }111 // add the epoch offset if one is set.112 if m.EpochOffset != nil {113 baseEpoch += abi.ChainEpoch(*m.EpochOffset)114 }115 // Execute the message.116 var ret *vm.ApplyRet117 ret, root, err = driver.ExecuteMessage(bs, ExecuteMessageParams{118 Preroot: root,119 Epoch: baseEpoch,120 Message: msg,121 BaseFee: BaseFeeOrDefault(vector.Pre.BaseFee),122 CircSupply: CircSupplyOrDefault(vector.Pre.CircSupply),123 Rand: NewReplayingRand(r, vector.Randomness),124 NetworkVersion: nv,125 })126 if err != nil {127 r.Fatalf("fatal failure when executing message: %s", err)128 }129 // Assert that the receipt matches what the test vector expects.130 AssertMsgResult(r, vector.Post.Receipts[i], ret, strconv.Itoa(i))131 }132 // Once all messages are applied, assert that the final state root matches133 // the expected postcondition root.134 if expected, actual := vector.Post.StateTree.RootCID, root; expected != actual {135 ierr := fmt.Errorf("wrong post root cid; expected %v, but got %v", expected, actual)136 r.Errorf(ierr.Error())137 err = multierror.Append(err, ierr)138 diffs = dumpThreeWayStateDiff(r, vector, bs, root)139 }140 return diffs, err141}142// ExecuteTipsetVector executes a tipset-class test vector.143func ExecuteTipsetVector(r Reporter, vector *schema.TestVector, variant *schema.Variant) (diffs []string, err error) {144 var (145 ctx = context.Background()146 baseEpoch = abi.ChainEpoch(variant.Epoch)147 root = vector.Pre.StateTree.RootCID148 tmpds = ds.NewMapDatastore()149 )150 // Load the vector CAR into a new temporary Blockstore.151 bs, err := LoadBlockstore(vector.CAR)152 if err != nil {153 r.Fatalf("failed to load the vector CAR: %w", err)154 return nil, err155 }156 // Create a new Driver.157 driver := NewDriver(ctx, vector.Selector, DriverOpts{})158 // Apply every tipset.159 var receiptsIdx int160 var prevEpoch = baseEpoch161 for i, ts := range vector.ApplyTipsets {162 ts := ts // capture163 execEpoch := baseEpoch + abi.ChainEpoch(ts.EpochOffset)164 params := ExecuteTipsetParams{165 Preroot: root,166 ParentEpoch: prevEpoch,167 Tipset: &ts,168 ExecEpoch: execEpoch,169 Rand: NewReplayingRand(r, vector.Randomness),170 }171 ret, err := driver.ExecuteTipset(bs, tmpds, params)172 if err != nil {173 r.Fatalf("failed to apply tipset %d: %s", i, err)174 return nil, err175 }176 // invoke callbacks.177 for _, cb := range TipsetVectorOpts.OnTipsetApplied {178 cb(bs, &params, ret)179 }180 for j, v := range ret.AppliedResults {181 AssertMsgResult(r, vector.Post.Receipts[receiptsIdx], v, fmt.Sprintf("%d of tipset %d", j, i))182 receiptsIdx++183 }184 // Compare the receipts root.185 if expected, actual := vector.Post.ReceiptsRoots[i], ret.ReceiptsRoot; expected != actual {186 ierr := fmt.Errorf("post receipts root doesn't match; expected: %s, was: %s", expected, actual)187 r.Errorf(ierr.Error())188 err = multierror.Append(err, ierr)189 }190 prevEpoch = execEpoch191 root = ret.PostStateRoot192 }193 // Once all messages are applied, assert that the final state root matches194 // the expected postcondition root.195 if expected, actual := vector.Post.StateTree.RootCID, root; expected != actual {196 ierr := fmt.Errorf("wrong post root cid; expected %v, but got %v", expected, actual)197 r.Errorf(ierr.Error())198 err = multierror.Append(err, ierr)199 diffs = dumpThreeWayStateDiff(r, vector, bs, root)200 }201 return diffs, err202}203// AssertMsgResult compares a message result. It takes the expected receipt204// encoded in the vector, the actual receipt returned by Lotus, and a message205// label to log in the assertion failure message to facilitate debugging.206func AssertMsgResult(r Reporter, expected *schema.Receipt, actual *vm.ApplyRet, label string) {207 r.Helper()208 applyret := actual209 if expected, actual := exitcode.ExitCode(expected.ExitCode), actual.ExitCode; expected != actual {210 r.Errorf("exit code of msg %s did not match; expected: %s, got: %s", label, expected, actual)211 r.Errorf("\t\\==> actor error: %s", applyret.ActorErr)212 }213 if expected, actual := expected.GasUsed, actual.GasUsed; expected != actual {214 r.Errorf("gas used of msg %s did not match; expected: %d, got: %d", label, expected, actual)215 }216 if expected, actual := []byte(expected.ReturnValue), actual.Return; !bytes.Equal(expected, actual) {217 r.Errorf("return value of msg %s did not match; expected: %s, got: %s", label, base64.StdEncoding.EncodeToString(expected), base64.StdEncoding.EncodeToString(actual))218 }219}220func dumpThreeWayStateDiff(r Reporter, vector *schema.TestVector, bs blockstore.Blockstore, actual cid.Cid) []string {221 // check if statediff exists; if not, skip.222 if err := exec.Command("statediff", "--help").Run(); err != nil {223 r.Log("could not dump 3-way state tree diff upon test failure: statediff command not found")224 r.Log("install statediff with:")225 r.Log("$ git clone https://github.com/filecoin-project/statediff.git")226 r.Log("$ cd statediff")227 r.Log("$ go generate ./...")228 r.Log("$ go install ./cmd/statediff")229 return nil230 }231 tmpCar, err := writeStateToTempCAR(bs,232 vector.Pre.StateTree.RootCID,233 vector.Post.StateTree.RootCID,234 actual,235 )236 if err != nil {237 r.Fatalf("failed to write temporary state CAR: %s", err)238 return nil239 }240 defer os.RemoveAll(tmpCar) //nolint:errcheck241 color.NoColor = false // enable colouring.242 var (243 a = color.New(color.FgMagenta, color.Bold).Sprint("(A) expected final state")244 b = color.New(color.FgYellow, color.Bold).Sprint("(B) actual final state")245 c = color.New(color.FgCyan, color.Bold).Sprint("(C) initial state")246 d1 = color.New(color.FgGreen, color.Bold).Sprint("[Δ1]")247 d2 = color.New(color.FgGreen, color.Bold).Sprint("[Δ2]")248 d3 = color.New(color.FgGreen, color.Bold).Sprint("[Δ3]")249 )250 diff := func(left, right cid.Cid) string {251 cmd := exec.Command("statediff", "car", "--file", tmpCar, left.String(), right.String())252 b, err := cmd.CombinedOutput()253 if err != nil {254 r.Fatalf("statediff failed: %s", err)255 }256 return string(b)257 }258 bold := color.New(color.Bold).SprintfFunc()259 r.Log(bold("-----BEGIN STATEDIFF-----"))260 // run state diffs.261 r.Log(bold("=== dumping 3-way diffs between %s, %s, %s ===", a, b, c))262 r.Log(bold("--- %s left: %s; right: %s ---", d1, a, b))263 diffA := diff(vector.Post.StateTree.RootCID, actual)264 r.Log(bold("----------BEGIN STATEDIFF A----------"))265 r.Log(diffA)266 r.Log(bold("----------END STATEDIFF A----------"))267 r.Log(bold("--- %s left: %s; right: %s ---", d2, c, b))268 diffB := diff(vector.Pre.StateTree.RootCID, actual)269 r.Log(bold("----------BEGIN STATEDIFF B----------"))270 r.Log(diffB)271 r.Log(bold("----------END STATEDIFF B----------"))272 r.Log(bold("--- %s left: %s; right: %s ---", d3, c, a))273 diffC := diff(vector.Pre.StateTree.RootCID, vector.Post.StateTree.RootCID)274 r.Log(bold("----------BEGIN STATEDIFF C----------"))275 r.Log(diffC)276 r.Log(bold("----------END STATEDIFF C----------"))277 r.Log(bold("-----END STATEDIFF-----"))278 return []string{diffA, diffB, diffC}279}280// writeStateToTempCAR writes the provided roots to a temporary CAR that'll be281// cleaned up via t.Cleanup(). It returns the full path of the temp file.282func writeStateToTempCAR(bs blockstore.Blockstore, roots ...cid.Cid) (string, error) {283 tmp, err := ioutil.TempFile("", "lotus-tests-*.car")284 if err != nil {285 return "", fmt.Errorf("failed to create temp file to dump CAR for diffing: %w", err)286 }287 carWalkFn := func(nd format.Node) (out []*format.Link, err error) {288 for _, link := range nd.Links() {289 if link.Cid.Prefix().Codec == cid.FilCommitmentSealed || link.Cid.Prefix().Codec == cid.FilCommitmentUnsealed {290 continue291 }292 // ignore things we don't have, the state tree is incomplete.293 if has, err := bs.Has(context.TODO(), link.Cid); err != nil {294 return nil, err295 } else if has {296 out = append(out, link)297 }298 }299 return out, nil300 }301 var (302 offl = offline.Exchange(bs)303 blkserv = blockservice.New(bs, offl)304 dserv = merkledag.NewDAGService(blkserv)305 )306 err = car.WriteCarWithWalker(context.Background(), dserv, roots, tmp, carWalkFn)307 if err != nil {308 return "", fmt.Errorf("failed to dump CAR for diffing: %w", err)309 }310 _ = tmp.Close()311 return tmp.Name(), nil312}313func LoadBlockstore(vectorCAR schema.Base64EncodedBytes) (blockstore.Blockstore, error) {314 bs := blockstore.Blockstore(blockstore.NewMemory())315 // Read the base64-encoded CAR from the vector, and inflate the gzip.316 buf := bytes.NewReader(vectorCAR)317 r, err := gzip.NewReader(buf)318 if err != nil {319 return nil, fmt.Errorf("failed to inflate gzipped CAR: %s", err)320 }321 defer r.Close() // nolint322 // Load the CAR embedded in the test vector into the Blockstore.323 _, err = car.LoadCar(context.TODO(), bs, r)324 if err != nil {325 return nil, fmt.Errorf("failed to load state tree car from test vector: %s", err)326 }327 if FallbackBlockstoreGetter != nil {328 fbs := &blockstore.FallbackStore{Blockstore: bs}329 fbs.SetFallback(func(ctx context.Context, c cid.Cid) (blocks.Block, error) {330 b, err := FallbackBlockstoreGetter.ChainReadObj(ctx, c)331 if err != nil {332 return nil, err333 }334 return blocks.NewBlockWithCid(b, c)335 })336 bs = fbs337 }338 return bs, nil339}...

Full Screen

Full Screen

worker.go

Source:worker.go Github

copy

Full Screen

1package task2import (3 "context"4 "fmt"5 "time"6 "github.com/palantir/stacktrace"7 "github.com/rs/xid"8 "go.uber.org/zap"9 "github.com/Raphy42/weekend/core/logger"10 "github.com/Raphy42/weekend/core/message"11 "github.com/Raphy42/weekend/core/scheduler"12 "github.com/Raphy42/weekend/core/scheduler/async"13 "github.com/Raphy42/weekend/core/supervisor"14 "github.com/Raphy42/weekend/pkg/chrono"15 "github.com/Raphy42/weekend/pkg/concurrent_set"16 "github.com/Raphy42/weekend/pkg/set"17)18type Worker struct {19 id xid.ID20 tasks map[string]Task21 bus message.Bus22 running concurrent_set.Set[xid.ID, *scheduler.Future]23 announceMailbox message.Mailbox24}25func NewWorker(bus message.Bus, tasks ...Task) *Worker {26 return &Worker{27 id: xid.New(),28 tasks: set.From(tasks, func(item Task) (string, Task) {29 return item.Name, item30 }),31 bus: bus,32 running: concurrent_set.New[xid.ID, *scheduler.Future](),33 }34}35func (w *Worker) Announce(ctx context.Context) error {36 if w.announceMailbox == nil {37 subject, err := w.bus.Subject(ctx, workerAnnounceSubject)38 if err != nil {39 return stacktrace.Propagate(err, "unable to open worker announce subject")40 }41 w.announceMailbox = subject42 }43 subject := w.announceMailbox44 jobNames := set.CollectSlice(w.tasks, func(k string, v Task) (string, bool) {45 return v.Name, true46 })47 if err := subject.Emit(ctx, NewWorkerAnnounceMessage(w.id, jobNames...)); err != nil {48 return stacktrace.Propagate(err, "could not announce worker to controller")49 }50 return nil51}52func (w *Worker) handleExecuteMessage(53 ctx context.Context,54 payload *ExecuteMessage,55 updateMailbox message.Mailbox,56) (*scheduler.Future, error) {57 task, ok := w.tasks[payload.Name]58 if !ok {59 return nil, stacktrace.NewError("no such manifest '%s' registered in this worker", payload.Name)60 }61 runner := supervisor.New(62 async.Name("wk", "task", payload.Name, "runner"),63 supervisor.NewSpec(task.AsyncManifest, &payload.Manifest,64 supervisor.WithSupervisionStrategy(supervisor.OneForOneSupervisionStrategy),65 supervisor.WithRestartStrategy(supervisor.TransientRestartStrategy),66 supervisor.WithShutdownStrategy(supervisor.ImmediateShutdownStrategy),67 ),68 )69 runnerManifest := runner.Manifest()70 future, err := scheduler.Schedule(ctx, runnerManifest, nil)71 if err != nil {72 return nil, stacktrace.Propagate(err, "could not start task")73 }74 if err := updateMailbox.Emit(ctx, NewTaskExecutingMessage(task.AsyncManifest.ID, future.ID)); err != nil {75 return future, err76 }77 return future, nil78}79func (w *Worker) PollingExecutor(ctx context.Context) (*async.Manifest, error) {80 log := logger.FromContext(ctx).With(zap.Stringer("wk.worker.id", w.id))81 log.Info("worker starting")82 for _, manifest := range w.tasks {83 log.Debug("task registered",84 zap.String("wk.task.name", manifest.Name),85 zap.Stringer("wk.task.async.id", manifest.AsyncManifest.ID),86 )87 }88 updateMailbox, err := w.bus.Subject(ctx, workerUpdateSubject)89 if err != nil {90 return nil, stacktrace.Propagate(err, "unable to create worker mailbox")91 }92 executeRoutine := async.Of(93 async.Name("wk", "worker", w.id.String(), "execute"),94 func(ctx context.Context) error {95 mailbox, err := w.bus.Subject(ctx, fmt.Sprintf(pollExecuteSubjectFmt, w.id))96 if err != nil {97 return stacktrace.Propagate(err, "unable to create worker mailbox")98 }99 msgC, cancel := mailbox.ReadC(ctx)100 defer cancel()101 for msg := range msgC {102 switch msg.Kind {103 case MTaskExecute:104 payload := msg.Payload.(*ExecuteMessage)105 future, err := w.handleExecuteMessage(ctx, payload, mailbox)106 if err != nil {107 return stacktrace.Propagate(err, "unrecoverable error")108 }109 w.running.Insert(future.ID, future)110 }111 }112 return nil113 },114 )115 pollingRoutine := async.Of(116 async.Name("wk", "worker", w.id.String(), "poll"),117 func(ctx context.Context) error {118 // todo improve this bullshit119 ticker := chrono.NewTicker(time.Second * 2)120 errC := ticker.TickErr(ctx, func() error {121 for _, future := range w.running.Values() {122 result, done, err := future.TryPoll(ctx, time.Millisecond*10)123 if done {124 log = log.With(zap.Stringer("wk.future.id", future.ID))125 if err != nil {126 log.Error("task failed", zap.Error(err))127 } else {128 log.Info("task success")129 }130 if err := updateMailbox.Emit(ctx, NewTaskExecutedMessage(future.ID, result, err)); err != nil {131 return stacktrace.Propagate(err, "could not dispatch message")132 }133 }134 }135 return nil136 })137 return <-errC138 },139 )140 super := supervisor.New(141 async.Name("wk", "worker", w.id.String(), "executor"),142 supervisor.NewSpec(pollingRoutine, nil),143 supervisor.NewSpec(executeRoutine, nil),144 )145 manifest := super.Manifest()146 return &manifest, nil147}...

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 r := runner.New(3 * time.Second)4 r.Add(createTask(), createTask(), createTask())5 if err := r.Start(); err != nil {6 switch err {7 fmt.Println("Terminating due to timeout.")8 os.Exit(1)9 fmt.Println("Terminating due to interrupt.")10 os.Exit(2)11 }12 }13 fmt.Println("Process ended.")14}15import (16var ErrTimeout = errors.New("received timeout")17var ErrInterrupt = errors.New("received interrupt")18type Runner struct {19 tasks []func(int)20}21func New(d time.Duration) *Runner {22 return &Runner{23 complete: make(chan error),24 timeout: time.After(d),25 interrupt: make(chan os.Signal, 1),26 }27}28func (r *Runner) Add(tasks ...func(int)) {29 r.tasks = append(r.tasks, tasks...)30}31func (r *Runner) Start() error {32 signal.Notify(r.interrupt, os.Interrupt)33 go func() {34 r.complete <- r.execute()35 }()36 select {37 }38}39func (r *Runner) execute() error {40 for id, task := range r.tasks {41 if r.gotInterrupt() {42 }43 task(id)44 }45}46func (r *Runner) gotInterrupt() bool {47 select {48 signal.Stop(r.interrupt)49 }50}51import (52func main() {53 rand.Seed(time.Now().UnixNano())54 r := runner.New(3 * time.Second)55 r.Add(createTask(), createTask(), createTask())56 if err := r.Start(); err != nil {57 switch err {58 fmt.Println("Terminating due to timeout

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1func main() {2 runner := &runner.Runner{}3 runner.ExecuteMessage()4}5func main() {6 runner := &runner.Runner{}7 runner.ExecuteMessage()8}9func main() {10 runner := &runner.Runner{}11 runner.ExecuteMessage()12}13func main() {14 runner := &runner.Runner{}15 runner.ExecuteMessage()16}17func main() {18 runner := &runner.Runner{}19 runner.ExecuteMessage()20}21func main() {22 runner := &runner.Runner{}23 runner.ExecuteMessage()24}25func main() {26 runner := &runner.Runner{}27 runner.ExecuteMessage()28}29func main() {30 runner := &runner.Runner{}31 runner.ExecuteMessage()32}33func main() {34 runner := &runner.Runner{}35 runner.ExecuteMessage()36}37func main() {38 runner := &runner.Runner{}39 runner.ExecuteMessage()40}41func main() {42 runner := &runner.Runner{}43 runner.ExecuteMessage()44}45func main() {46 runner := &runner.Runner{}47 runner.ExecuteMessage()48}49func main() {50 runner := &runner.Runner{}51 runner.ExecuteMessage()52}53func main() {54 runner := &runner.Runner{}55 runner.ExecuteMessage()56}

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import "fmt"2func main() {3 fmt.Println("Hello, playground")4 runner := Runner{}5 runner.executeMessage()6}7import "fmt"8func main() {9 fmt.Println("Hello, playground")10 runner := Runner{}11 runner.executeMessage()12}13import "fmt"14func main() {15 fmt.Println("Hello, playground")16 runner := Runner{}17 runner.executeMessage()18}19import "fmt"20func main() {21 fmt.Println("Hello, playground")22 runner := Runner{}23 runner.executeMessage()24}25import "fmt"26func main() {27 fmt.Println("Hello, playground")28 runner := Runner{}29 runner.executeMessage()30}31import "fmt"32func main() {33 fmt.Println("Hello, playground")34 runner := Runner{}35 runner.executeMessage()36}37import "fmt"38func main() {39 fmt.Println("Hello, playground")40 runner := Runner{}41 runner.executeMessage()42}43import "fmt"44func main() {45 fmt.Println("Hello, playground")46 runner := Runner{}47 runner.executeMessage()48}49import "fmt"50func main() {51 fmt.Println("Hello, playground")52 runner := Runner{}53 runner.executeMessage()54}55import "fmt"56func main() {57 fmt.Println("Hello, playground")58 runner := Runner{}59 runner.executeMessage()60}61import "fmt"62func main() {63 fmt.Println("Hello, playground

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1func main() {2 r := runner.New(30 * time.Second)3 r.Add(createTask(), createTask(), createTask())4 if err := r.Start(); err != nil {5 switch err {6 fmt.Println("Terminating due to interrupt")7 os.Exit(2)8 fmt.Println("Terminating due to timeout")9 os.Exit(1)10 }11 }12 fmt.Println("Process ended")13}14func main() {15 r := runner.New(30 * time.Second)16 r.Add(createTask(), createTask(), createTask())17 if err := r.Start(); err != nil {18 switch err {19 fmt.Println("Terminating due to interrupt")20 os.Exit(2)21 fmt.Println("Terminating due to timeout")22 os.Exit(1)23 }24 }25 fmt.Println("Process ended")26}27func main() {28 r := runner.New(30 * time.Second)29 r.Add(createTask(), createTask(), createTask())30 if err := r.Start(); err != nil {31 switch err {32 fmt.Println("Terminating due to interrupt")33 os.Exit(2)34 fmt.Println("Terminating due to timeout")35 os.Exit(1)36 }37 }38 fmt.Println("Process ended")39}40func main() {41 r := runner.New(30 * time.Second)42 r.Add(createTask(), createTask(), createTask())43 if err := r.Start(); err != nil {44 switch err {

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 runtime.GOMAXPROCS(2)4 wg.Add(2)5 go func() {6 defer wg.Done()7 fmt.Println("In goroutine 1")8 }()9 go func() {10 defer wg.Done()11 fmt.Println("In goroutine 2")12 }()13 fmt.Println("Waiting To Finish")14 wg.Wait()15 fmt.Println("Terminating Program")16}17import (18func main() {19 runtime.GOMAXPROCS(2)20 wg.Add(2)21 go func() {22 defer wg.Done()23 for count := 0; count < 3; count++ {24 for char := 'a'; char < 'a'+26; char++ {25 fmt.Printf("%c ", char)26 }27 }28 }()29 go func() {30 defer wg.Done()31 for count := 0; count < 3; count++ {32 for char := 'A'; char < 'A'+26; char++ {33 fmt.Printf("%c ", char)34 }35 }36 }()37 fmt.Println("Waiting To Finish")38 wg.Wait()39 fmt.Println("Terminating Program")40}41import (42func main() {43 runtime.GOMAXPROCS(2)44 wg.Add(2)45 go func() {46 defer wg.Done()47 for count := 0; count < 3; count++ {48 for char := 'a'; char < 'a'+26; char++ {49 fmt.Printf("%c ", char)50 }51 }52 }()53 go func() {54 defer wg.Done()55 for count := 0; count < 3; count++ {

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 r := runner{}4 r.executeMessage()5}6import (7type runner struct{}8func (r *runner) executeMessage() {9 fmt.Println("Executing message from runner class")10}

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 fmt.Println("Welcome to the program.")4 runner.ExecuteMessage()5 fmt.Println("The program is ending.")6}7import "fmt"8func ExecuteMessage() {9 fmt.Println("Executing the message")10}11import "testing"12func TestExecuteMessage(t *testing.T) {13 ExecuteMessage()14}15import "testing"16func TestExecuteMessage(t *testing.T) {17 ExecuteMessage()18}19import (20func TestExecuteMessage(t *testing.T) {21 ExecuteMessage()22}23import (24func TestExecuteMessage(t *testing.T) {25 ExecuteMessage()26}27import (28func TestExecuteMessage(t *testing.T) {29 ExecuteMessage()30}31import (32func TestExecuteMessage(t *testing.T) {33 ExecuteMessage()34}35import (36func TestExecuteMessage(t *testing.T) {37 ExecuteMessage()38}

Full Screen

Full Screen

executeMessage

Using AI Code Generation

copy

Full Screen

1import (2func main() {3 r := new(runner)4 r.executeMessage(msg)5}6import (7type runner struct {8}9func (r *runner) executeMessage(msg string) {10 t := reflect.TypeOf(r)11 m, ok := t.MethodByName(methodName)12 if ok {13 numIn := mt.NumIn()14 numOut := mt.NumOut()15 inParams := make([]reflect.Type, numIn)16 for i := 0; i < numIn; i++ {17 inParams[i] = mt.In(i)18 }19 outParams := make([]reflect.Type, numOut)20 for i := 0; i < numOut; i++ {21 outParams[i] = mt.Out(i)22 }23 in := make([]reflect.Value, numIn)24 for i := 0; i < numIn; i++ {25 in[i] = reflect.New(inParams[i]).Elem()26 }27 in[0].SetString(msg)28 out := reflect.ValueOf(r).MethodByName(methodName).Call(in)29 fmt.Println(out[0].String())30 }31}32import (33func (r *runner) executeMessage(msg string) (result string) {34}

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Gauge automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

... View sample repo... View DocumentationSign up Free
›
_

Most used method in

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

...
Sign up with GoogleSign up with Email
Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful