Skip to content

Commit

Permalink
Rename mesos_{scheduler ->}.go, {mesos ->}framework.go
Browse files Browse the repository at this point in the history
  • Loading branch information
sttts committed Oct 26, 2015
1 parent a2e34a3 commit 6774881
Show file tree
Hide file tree
Showing 8 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion cmd/hyperkube/kube-scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ limitations under the License.
*/

// CAUTION: If you update code in this file, you may need to also update code
// in contrib/mesos/cmd/km/k8sm-mesos_scheduler.go
// in contrib/mesos/cmd/km/k8sm-scheduler.go
package main

import (
Expand Down
2 changes: 1 addition & 1 deletion contrib/mesos/cmd/km/k8sm-scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ See the License for the specific language governing permissions and
limitations under the License.
*/

// clone of the upstream cmd/hypercube/k8sm-mesos_scheduler.go
// clone of the upstream cmd/hypercube/k8sm-scheduler.go
package main

import (
Expand Down
4 changes: 2 additions & 2 deletions contrib/mesos/pkg/executor/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -475,7 +475,7 @@ func (k *KubernetesMesosExecutor) launchTask(driver bindings.ExecutorDriver, tas
// TODO(k8s): use Pods interface for binding once clusters are upgraded
// return b.Pods(binding.Namespace).Bind(binding)
if pod.Spec.NodeName == "" {
//HACK(jdef): cloned binding construction from k8s plugin/pkg/scheduler/mesos_scheduler.go
//HACK(jdef): cloned binding construction from k8s plugin/pkg/scheduler/scheduler.go
binding := &api.Binding{
ObjectMeta: api.ObjectMeta{
Namespace: pod.Namespace,
Expand Down Expand Up @@ -780,7 +780,7 @@ func (k *KubernetesMesosExecutor) FrameworkMessage(driver bindings.ExecutorDrive
}

log.Infof("Receives message from framework %v\n", message)
//TODO(jdef) master reported a lost task, reconcile this! @see mesos_scheduler.go:handleTaskLost
//TODO(jdef) master reported a lost task, reconcile this! @see scheduler.go:handleTaskLost
if strings.HasPrefix(message, messages.TaskLost+":") {
taskId := message[len(messages.TaskLost)+1:]
if taskId != "" {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion contrib/mesos/pkg/scheduler/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -196,7 +196,7 @@ func (s *schedulerPlugin) Run(done <-chan struct{}) {
go runtime.Until(s.scheduleOne, pluginRecoveryDelay, done)
}

// hacked from GoogleCloudPlatform/kubernetes/plugin/pkg/scheduler/mesos_scheduler.go,
// hacked from GoogleCloudPlatform/kubernetes/plugin/pkg/scheduler/scheduler.go,
// with the Modeler stuff removed since we don't use it because we have mesos.
func (s *schedulerPlugin) scheduleOne() {
pod := s.config.NextPod()
Expand Down
File renamed without changes.

1 comment on commit 6774881

@k8s-teamcity-mesosphere

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

TeamCity OSS :: Kubernetes Mesos :: 4 - Smoke Tests Build 2441 outcome was SUCCESS
Summary: Tests passed: 1, ignored: 188 Build time: 00:04:37

Please sign in to comment.