Method TailStagingLogs

cf/commands/application/start.go:238–265

(app models.Application, stopChan chan bool, doneWait *sync.WaitGroup)

)

func (cmd *Start) TailStagingLogs(app models.Application, stopChan chan bool, doneWait *sync.WaitGroup) {
	c := make(chan logs.Loggable)
	e := make(chan error)
	defer doneWait.Done()

	go cmd.logRepo.TailLogsFor(app.GUID, func() {}, c, e)
	for {
		select {
		case msg, ok := <-c:
			if !ok {
				cmd.logRepo.Close()
				return
			} else if msg.GetSourceName() == LogMessageTypeStaging {
				cmd.ui.Say(msg.ToSimpleLog())
			}

		case err, ok := <-e:
			if ok {
				cmd.ui.Warn(T("Warning: error tailing logs"))
				cmd.ui.Say("%s", err)
			}

		case <-stopChan:
			cmd.logRepo.Close()
			return
		}
	}
}

func (cmd *Start) waitForInstancesToStage(app models.Application) (bool, error) {
	stagingStartTime := time.Now()