1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
Last-Update: 2016-07-14
Forwarded: not-needed
Bug-Debian: https://bugs.debian.org/cgi-bin/bugreport.cgi?bug=830675
Author: Dmitry Smirnov <onlyjob@debian.org>
Description: disable networking tests.
--- a/executor/executor_intgr_test.go
+++ b/executor/executor_intgr_test.go
@@ -144,8 +144,9 @@
return &integrationTestDriver{driver}
}
func TestExecutorDriverRegisterExecutorMessage(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
reqPath, err := url.QueryUnescape(req.URL.String())
@@ -189,8 +190,9 @@
}
}
func TestExecutorDriverExecutorRegisteredEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -231,8 +233,9 @@
}
}
func TestExecutorDriverExecutorReregisteredEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -270,8 +273,9 @@
}
}
func TestExecutorDriverReconnectEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -320,8 +324,9 @@
}
func TestExecutorDriverRunTaskEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -374,8 +379,9 @@
}
func TestExecutorDriverKillTaskEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -415,8 +421,9 @@
}
}
func TestExecutorDriverStatusUpdateAcknowledgement(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -453,8 +460,9 @@
<-time.After(time.Second * 1)
}
func TestExecutorDriverFrameworkToExecutorMessageEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -496,8 +504,9 @@
}
}
func TestExecutorDriverShutdownEvent(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
@@ -536,8 +545,9 @@
assert.Equal(t, mesos.Status_DRIVER_STOPPED, driver.Status())
}
func TestExecutorDriverError(t *testing.T) {
+t.Skip("DM-disabled");
setTestEnv(t)
ch := make(chan bool, 2)
// Mock Slave process to respond to registration event.
server := testutil.NewMockSlaveHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
--- a/scheduler/scheduler_intgr_test.go
+++ b/scheduler/scheduler_intgr_test.go
@@ -152,8 +152,9 @@
// sets up a mock Mesos HTTP master listener, scheduler, and scheduler driver for testing.
// attempts to wait for a registered or re-registered callback on the suite.sched.
func (suite *SchedulerIntegrationTestSuite) configure(frameworkId *mesos.FrameworkID) bool {
t := suite.T()
+t.Skip("DM-disabled");
// start mock master server to handle connection
suite.server = testutil.NewMockMasterHttpServer(t, func(rsp http.ResponseWriter, req *http.Request) {
log.Infoln("MockMaster - rcvd ", req.RequestURI)
if suite.validator != nil {
--- a/scheduler/scheduler_unit_test.go
+++ b/scheduler/scheduler_unit_test.go
@@ -62,8 +62,9 @@
)
}
func TestSchedulerSuite(t *testing.T) {
+t.Skip("DM-disabled");
t.Logf("running scheduler test suite..")
suite.Run(t, new(SchedulerTestSuite))
}
|
