← Back to branch summary

~ubuntu-branches/ubuntu/wily/juju-core/wily

« back to all changes in this revision

Viewing changes to src/launchpad.net/juju-core/cmd/jujud/unit_test.go

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2014-02-28 16:53:15 UTC
  • mfrom: (1.1.19)
  • Revision ID: package-import@ubuntu.com-20140228165315-g8n1ds0jrtekhxq6
Tags: 1.17.4-0ubuntu1
https://launchpad.net/bugs/1261628
* New upstream point release (LP: #1261628):
  - https://launchpad.net/juju-core/trunk/1.17.4
  - d/control: Prefer juju-mongodb over mongodb-server for juju-local
    package.

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/launchpad.net/juju-core/cmd/jujud/unit_test.go
20
20
        "launchpad.net/juju-core/names"
21
21
        "launchpad.net/juju-core/state"
22
22
        "launchpad.net/juju-core/state/api/params"
 
23
        apirsyslog "launchpad.net/juju-core/state/api/rsyslog"
23
24
        coretesting "launchpad.net/juju-core/testing"
24
25
        "launchpad.net/juju-core/tools"
25
26
        "launchpad.net/juju-core/version"
26
27
        "launchpad.net/juju-core/worker"
 
28
        "launchpad.net/juju-core/worker/rsyslog"
27
29
        "launchpad.net/juju-core/worker/upgrader"
28
30
)
29
31
 
62
64
        c.Assert(err, gc.IsNil)
63
65
        machine, err := s.State.Machine(id)
64
66
        c.Assert(err, gc.IsNil)
65
 
        conf, tools := s.agentSuite.primeAgent(c, unit.Tag(), initialUnitPassword)
 
67
        conf, tools := s.agentSuite.primeAgent(c, unit.Tag(), initialUnitPassword, version.Current)
66
68
        return machine, unit, conf, tools
67
69
}
68
70
 
212
214
}
213
215
 
214
216
func (s *UnitSuite) TestOpenAPIStateWithBadCredsTerminates(c *gc.C) {
215
 
        conf, _ := s.agentSuite.primeAgent(c, "unit-missing-0", "no-password")
 
217
        conf, _ := s.agentSuite.primeAgent(c, "unit-missing-0", "no-password", version.Current)
216
218
        _, _, err := openAPIState(conf, nil)
217
219
        c.Assert(err, gc.Equals, worker.ErrTerminateAgent)
218
220
}
248
250
 
249
251
        s.assertCannotOpenState(c, conf.Tag(), conf.DataDir())
250
252
}
 
253
 
 
254
func (s *UnitSuite) TestRsyslogConfigWorker(c *gc.C) {
 
255
        created := make(chan rsyslog.RsyslogMode, 1)
 
256
        s.PatchValue(&newRsyslogConfigWorker, func(_ *apirsyslog.State, _ agent.Config, mode rsyslog.RsyslogMode) (worker.Worker, error) {
 
257
                created <- mode
 
258
                return worker.NewRunner(isFatal, moreImportant), nil
 
259
        })
 
260
 
 
261
        _, unit, _, _ := s.primeAgent(c)
 
262
        a := s.newAgent(c, unit)
 
263
        go func() { c.Check(a.Run(nil), gc.IsNil) }()
 
264
        defer func() { c.Check(a.Stop(), gc.IsNil) }()
 
265
 
 
266
        select {
 
267
        case <-time.After(coretesting.LongWait):
 
268
                c.Fatalf("timeout while waiting for rsyslog worker to be created")
 
269
        case mode := <-created:
 
270
                c.Assert(mode, gc.Equals, rsyslog.RsyslogModeForwarding)
 
271
        }
 
272
}