Skip to content
This repository has been archived by the owner on Nov 8, 2022. It is now read-only.

Commit

Permalink
Revert "Simplified interaction between scheduler and control"
Browse files Browse the repository at this point in the history
  • Loading branch information
IRCody committed Aug 17, 2016
1 parent 367020b commit 3e91e77
Show file tree
Hide file tree
Showing 44 changed files with 1,691 additions and 3,021 deletions.
1 change: 0 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -230,7 +230,6 @@ Documentation for Snap will be kept in this repository for now with an emphasis
* [build and test](docs/BUILD_AND_TEST.md)
* [REST API](docs/REST_API.md)
* [tasks](docs/TASKS.md)
* [plugin life cycle](docs/PLUGIN_LIFECYCLE.md)
* [plugin signing](docs/PLUGIN_SIGNING.md)
* [tribe](docs/TRIBE.md)

Expand Down
3 changes: 0 additions & 3 deletions control/available_plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,6 @@ const (
var (
ErrPoolNotFound = errors.New("plugin pool not found")
ErrBadKey = errors.New("bad key")
ErrBadTaskId = errors.New("bad task id")
)

// availablePlugin represents a plugin which is
Expand Down Expand Up @@ -539,8 +538,6 @@ func (ap *availablePlugins) findLatestPool(pType, name string) (strategy.Pool, s
}

func (ap *availablePlugins) getOrCreatePool(key string) (strategy.Pool, error) {
ap.Lock()
defer ap.Unlock()
var err error
pool, ok := ap.table[key]
if ok {
Expand Down
1 change: 0 additions & 1 deletion control/available_plugin_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,6 @@ func TestAvailablePlugin(t *testing.T) {
Convey("Stop()", t, func() {
Convey("returns nil if plugin successfully stopped", func() {
r := newRunner()
r.SetEmitter(new(MockEmitter))
a := plugin.Arg{
PluginLogPath: "/tmp/snap-test-plugin-stop.log",
}
Expand Down
Loading

0 comments on commit 3e91e77

Please sign in to comment.