Line | Source | Count |
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 | #include "includes.h" | - |
27 | | - |
28 | #include <sys/types.h> | - |
29 | #include <sys/uio.h> | - |
30 | | - |
31 | #include <errno.h> | - |
32 | #include <stdio.h> | - |
33 | #include <string.h> | - |
34 | #include <unistd.h> | - |
35 | #include <stdarg.h> | - |
36 | | - |
37 | #include "sshbuf.h" | - |
38 | #include "ssherr.h" | - |
39 | #include "log.h" | - |
40 | #include "atomicio.h" | - |
41 | #include "msg.h" | - |
42 | #include "misc.h" | - |
43 | | - |
44 | int | - |
45 | ssh_msg_send(int fd, u_char type, struct sshbuf *m) | - |
46 | { | - |
47 | u_char buf[5]; | - |
48 | u_int mlen = sshbuf_len(m); | - |
49 | | - |
50 | debug3("ssh_msg_send: type %u", (unsigned int)type & 0xff); | - |
51 | | - |
52 | put_u32(buf, mlen + 1); | - |
53 | buf[4] = type; | - |
54 | if (atomicio(vwrite, fd, buf, sizeof(buf)) != sizeof(buf)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
55 | error("ssh_msg_send: write"); | - |
56 | return (-1); never executed: return (-1); | 0 |
57 | } | - |
58 | if (atomicio(vwrite, fd, sshbuf_mutable_ptr(m), mlen) != mlen) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
59 | error("ssh_msg_send: write"); | - |
60 | return (-1); never executed: return (-1); | 0 |
61 | } | - |
62 | return (0); never executed: return (0); | 0 |
63 | } | - |
64 | | - |
65 | int | - |
66 | ssh_msg_recv(int fd, struct sshbuf *m) | - |
67 | { | - |
68 | u_char buf[4], *p; | - |
69 | u_int msg_len; | - |
70 | int r; | - |
71 | | - |
72 | debug3("ssh_msg_recv entering"); | - |
73 | | - |
74 | if (atomicio(read, fd, buf, sizeof(buf)) != sizeof(buf)) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
75 | if (errno != EPIPE)TRUE | never evaluated | FALSE | never evaluated |
| 0 |
76 | error("ssh_msg_recv: read: header"); never executed: error("ssh_msg_recv: read: header"); | 0 |
77 | return (-1); never executed: return (-1); | 0 |
78 | } | - |
79 | msg_len = get_u32(buf); | - |
80 | if (msg_len > 256 * 1024) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
81 | error("ssh_msg_recv: read: bad msg_len %u", msg_len); | - |
82 | return (-1); never executed: return (-1); | 0 |
83 | } | - |
84 | sshbuf_reset(m); | - |
85 | if ((r = sshbuf_reserve(m, msg_len, &p)) != 0) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
86 | error("%s: buffer error: %s", __func__, ssh_err(r)); | - |
87 | return -1; never executed: return -1; | 0 |
88 | } | - |
89 | if (atomicio(read, fd, p, msg_len) != msg_len) {TRUE | never evaluated | FALSE | never evaluated |
| 0 |
90 | error("ssh_msg_recv: read: %s", strerror(errno)); | - |
91 | return (-1); never executed: return (-1); | 0 |
92 | } | - |
93 | return (0); never executed: return (0); | 0 |
94 | } | - |
| | |