Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in
Toggle navigation
P
paho.mqtt.c
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
eclipse
paho.mqtt.c
Commits
6e79a6b0
Commit
6e79a6b0
authored
Aug 20, 2013
by
Ian Craggs
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Update test3 with better diagnostics and results
parent
9c95da1c
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
46 additions
and
13 deletions
+46
-13
test3.c
test/test3.c
+46
-13
No files found.
test/test3.c
View file @
6e79a6b0
...
@@ -342,15 +342,30 @@ long elapsed(START_TIME_TYPE start_time)
...
@@ -342,15 +342,30 @@ long elapsed(START_TIME_TYPE start_time)
#endif
#endif
START_TIME_TYPE
global_start_time
;
#define assert(a, b, c, d) myassert(__FILE__, __LINE__, a, b, c, d)
#define assert(a, b, c, d) myassert(__FILE__, __LINE__, a, b, c, d)
#define assert1(a, b, c, d, e) myassert(__FILE__, __LINE__, a, b, c, d, e)
#define assert1(a, b, c, d, e) myassert(__FILE__, __LINE__, a, b, c, d, e)
int
tests
=
0
;
int
tests
=
0
;
int
failures
=
0
;
int
failures
=
0
;
FILE
*
xml
;
START_TIME_TYPE
global_start_time
;
char
output
[
3000
];
char
*
cur_output
=
output
;
long
duration
;
void
write_test_result
()
{
duration
=
elapsed
(
global_start_time
);
fprintf
(
xml
,
" time=
\"
%d.%.3d
\"
>
\n
"
,
duration
/
1000
,
duration
%
1000
);
if
(
cur_output
!=
output
)
{
fprintf
(
xml
,
output
);
cur_output
=
output
;
}
fprintf
(
xml
,
"</testcase>
\n
"
);
}
int
myassert
(
char
*
filename
,
int
lineno
,
char
*
description
,
int
value
,
char
*
format
,
...)
int
myassert
(
char
*
filename
,
int
lineno
,
char
*
description
,
int
value
,
char
*
format
,
...)
...
@@ -366,9 +381,12 @@ int myassert(char* filename, int lineno, char* description, int value, char* for
...
@@ -366,9 +381,12 @@ int myassert(char* filename, int lineno, char* description, int value, char* for
va_start
(
args
,
format
);
va_start
(
args
,
format
);
vprintf
(
format
,
args
);
vprintf
(
format
,
args
);
va_end
(
args
);
va_end
(
args
);
cur_output
+=
sprintf
(
cur_output
,
"<failure type=
\"
%s
\"
>file %s, line %d </failure>
\n
"
,
description
,
filename
,
lineno
);
}
}
else
else
MyLog
(
LOGA_DEBUG
,
"Assertion succeeded, file %s, line %d, description: %s"
,
filename
,
lineno
,
description
);
MyLog
(
LOGA_DEBUG
,
"Assertion succeeded, file %s, line %d, description: %s"
,
filename
,
lineno
,
description
);
return
value
;
return
value
;
}
}
...
@@ -556,6 +574,8 @@ int test1(struct Options options)
...
@@ -556,6 +574,8 @@ int test1(struct Options options)
failures
=
0
;
failures
=
0
;
MyLog
(
LOGA_INFO
,
"Starting SSL test 1 - connection to nonSSL MQTT server"
);
MyLog
(
LOGA_INFO
,
"Starting SSL test 1 - connection to nonSSL MQTT server"
);
fprintf
(
xml
,
"<testcase classname=
\"
test3
\"
name=
\"
SSL connect fail to nonSSL MQTT server
\"
"
);
global_start_time
=
start_clock
();
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
connection
,
"test1"
,
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
connection
,
"test1"
,
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
...
@@ -584,7 +604,7 @@ exit:
...
@@ -584,7 +604,7 @@ exit:
MQTTClient_destroy
(
&
c
);
MQTTClient_destroy
(
&
c
);
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
write_test_result
();
return
failures
;
return
failures
;
}
}
...
@@ -608,6 +628,8 @@ int test2a_s(struct Options options)
...
@@ -608,6 +628,8 @@ int test2a_s(struct Options options)
failures
=
0
;
failures
=
0
;
MyLog
(
LOGA_INFO
,
"Starting test 2a_s - Mutual SSL authentication - single threaded client using receive"
);
MyLog
(
LOGA_INFO
,
"Starting test 2a_s - Mutual SSL authentication - single threaded client using receive"
);
fprintf
(
xml
,
"<testcase classname=
\"
test3
\"
name=
\"
test 2a_s
\"
"
);
global_start_time
=
start_clock
();
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
mutual_auth_connection
,
"test2a_s"
,
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
mutual_auth_connection
,
"test2a_s"
,
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
...
@@ -664,7 +686,7 @@ exit:
...
@@ -664,7 +686,7 @@ exit:
MQTTClient_destroy
(
&
c
);
MQTTClient_destroy
(
&
c
);
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
write_test_result
();
return
failures
;
return
failures
;
}
}
...
@@ -688,6 +710,8 @@ int test2a_m(struct Options options)
...
@@ -688,6 +710,8 @@ int test2a_m(struct Options options)
failures
=
0
;
failures
=
0
;
MyLog
(
LOGA_INFO
,
"Starting test 2a_m - Mutual SSL authentication - multi-threaded client using callbacks"
);
MyLog
(
LOGA_INFO
,
"Starting test 2a_m - Mutual SSL authentication - multi-threaded client using callbacks"
);
fprintf
(
xml
,
"<testcase classname=
\"
test3
\"
name=
\"
test 2a_m
\"
"
);
global_start_time
=
start_clock
();
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
mutual_auth_connection
,
"test2a_m"
,
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
mutual_auth_connection
,
"test2a_m"
,
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
...
@@ -741,7 +765,7 @@ exit:
...
@@ -741,7 +765,7 @@ exit:
MQTTClient_destroy
(
&
c
);
MQTTClient_destroy
(
&
c
);
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
write_test_result
();
return
failures
;
return
failures
;
}
}
...
@@ -763,6 +787,8 @@ int test2b(struct Options options)
...
@@ -763,6 +787,8 @@ int test2b(struct Options options)
failures
=
0
;
failures
=
0
;
MyLog
(
LOGA_INFO
,
"Starting test 2b - connection to SSL MQTT server with clientauth=req but server does not have client cert"
);
MyLog
(
LOGA_INFO
,
"Starting test 2b - connection to SSL MQTT server with clientauth=req but server does not have client cert"
);
fprintf
(
xml
,
"<testcase classname=
\"
test3
\"
name=
\"
test 2b
\"
"
);
global_start_time
=
start_clock
();
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
nocert_mutual_auth_connection
,
"test2b"
,
if
(
!
(
assert
(
"good rc from create"
,
(
rc
=
MQTTClient_create
(
&
c
,
options
.
nocert_mutual_auth_connection
,
"test2b"
,
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
MQTTCLIENT_PERSISTENCE_DEFAULT
,
persistenceStore
))
==
MQTTCLIENT_SUCCESS
,
"rc was %d
\n
"
,
rc
)))
...
@@ -799,7 +825,7 @@ exit:
...
@@ -799,7 +825,7 @@ exit:
MQTTClient_destroy
(
&
c
);
MQTTClient_destroy
(
&
c
);
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
MyLog
(
LOGA_INFO
,
"%s: test %s. %d tests run, %d failures."
,
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
(
failures
==
0
)
?
"passed"
:
"failed"
,
testname
,
tests
,
failures
);
write_test_result
();
return
failures
;
return
failures
;
}
}
...
@@ -1329,6 +1355,7 @@ exit:
...
@@ -1329,6 +1355,7 @@ exit:
return
failures
;
return
failures
;
}
}
/*********************************************************************
/*********************************************************************
Test5c: Anonymous ciphers - client not using anonymous ciphers
Test5c: Anonymous ciphers - client not using anonymous ciphers
...
@@ -1430,13 +1457,16 @@ int main(int argc, char** argv)
...
@@ -1430,13 +1457,16 @@ int main(int argc, char** argv)
{
{
int
*
numtests
=
&
tests
;
int
*
numtests
=
&
tests
;
int
rc
=
0
;
int
rc
=
0
;
int
(
*
tests
[])()
=
{
NULL
,
test1
,
test2a_s
,
test2a_m
,
test2b
,
test2c
,
test3a_s
,
test3a_m
,
test3b
,
test4_s
,
test4_m
,
test5a
,
test5b
,
test5c
};
int
(
*
tests
[])()
=
{
NULL
,
test1
,
test2a_s
,
test2a_m
,
test2b
,
test2c
,
test3a_s
,
test3a_m
,
test3b
,
test4_s
,
test4_m
};
//test5a, test5b, test5c};
MQTTClient_nameValue
*
info
;
xml
=
fopen
(
"TEST-test3.xml"
,
"w"
);
fprintf
(
xml
,
"<testsuite name=
\"
test3
\"
tests=
\"
%d
\"
>
\n
"
,
ARRAY_SIZE
(
tests
)
-
1
);
setenv
(
"MQTT_C_CLIENT_TRACE"
,
"ON"
,
1
);
setenv
(
"MQTT_C_CLIENT_TRACE"
,
"ON"
,
1
);
setenv
(
"MQTT_C_CLIENT_TRACE_LEVEL"
,
"ERROR"
,
1
);
getopts
(
argc
,
argv
);
getopts
(
argc
,
argv
);
char
buf
[
500
];
printf
(
"current working dir %s
\n
"
,
getcwd
(
buf
,
sizeof
(
buf
)));
if
(
options
.
test_no
==
0
)
if
(
options
.
test_no
==
0
)
{
/* run all the tests */
{
/* run all the tests */
for
(
options
.
test_no
=
1
;
options
.
test_no
<
ARRAY_SIZE
(
tests
);
++
options
.
test_no
)
for
(
options
.
test_no
=
1
;
options
.
test_no
<
ARRAY_SIZE
(
tests
);
++
options
.
test_no
)
...
@@ -1450,6 +1480,9 @@ int main(int argc, char** argv)
...
@@ -1450,6 +1480,9 @@ int main(int argc, char** argv)
MyLog
(
LOGA_INFO
,
"verdict pass"
);
MyLog
(
LOGA_INFO
,
"verdict pass"
);
else
else
MyLog
(
LOGA_INFO
,
"verdict fail"
);
MyLog
(
LOGA_INFO
,
"verdict fail"
);
fprintf
(
xml
,
"</testsuite>
\n
"
);
fclose
(
xml
);
return
rc
;
return
rc
;
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment