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
|
#include "test.h"
#include "tap.h"
#include "mongo-wire.h"
#include "mongo-client.h"
#include <errno.h>
#include <sys/socket.h>
#include "libmongo-private.h"
void
test_mongo_packet_send (void)
{
mongo_packet *p;
mongo_connection c, *conn;
mongo_packet_header h;
bson *b;
p = mongo_wire_cmd_kill_cursors (1, 2, (gint64)3, (gint64)4);
c.fd = -1;
ok (mongo_packet_send (NULL, p) == FALSE,
"mongo_packet_send() fails with a NULL connection");
ok (errno == ENOTCONN,
"mongo_packet_send() with a NULL connection sets errno to ENOTCONN");
ok (mongo_packet_send (&c, NULL) == FALSE,
"mongo_packet_send() fails with a NULL packet");
ok (errno == EINVAL,
"mongo_packet_send() with a NULL packet sets errno to EINVAL");
ok (mongo_packet_send (&c, p) == FALSE,
"mongo_packet_send() fails if the FD is less than zero");
ok (errno == EBADF,
"mongo_packet_send() sets errno to EBADF is the FD is bad");
mongo_wire_packet_free (p);
p = mongo_wire_packet_new ();
h.id = 42;
h.resp_to = 0;
h.opcode = 1;
h.length = sizeof (mongo_packet_header);
mongo_wire_packet_set_header (p, &h);
c.fd = 1;
ok (mongo_packet_send (&c, p) == FALSE,
"mongo_packet_send() fails with an unfinished packet");
mongo_wire_packet_free (p);
begin_network_tests (2);
b = bson_new ();
bson_append_int32 (b, "getnonce", 1);
bson_finish (b);
p = mongo_wire_cmd_custom (42, config.db, 0, b);
bson_free (b);
conn = mongo_connect (config.primary_host, config.primary_port);
ok (mongo_packet_send (conn, p),
"mongo_packet_send() works");
close (conn->fd);
sleep (3);
ok (mongo_packet_send (conn, p) == FALSE,
"mongo_packet_send() fails on a closed socket");
mongo_wire_packet_free (p);
mongo_disconnect (conn);
end_network_tests ();
}
RUN_TEST (9, mongo_packet_send);
|
