4 char packet_buffer
[LARGE_PACKET_MAX
];
5 static const char *packet_trace_prefix
= "git";
6 static const char trace_key
[] = "GIT_TRACE_PACKET";
8 void packet_trace_identity(const char *prog
)
10 packet_trace_prefix
= xstrdup(prog
);
13 static void packet_trace(const char *buf
, unsigned int len
, int write
)
18 if (!trace_want(trace_key
))
21 /* +32 is just a guess for header + quoting */
22 strbuf_init(&out
, len
+32);
24 strbuf_addf(&out
, "packet: %12s%c ",
25 packet_trace_prefix
, write
? '>' : '<');
27 if ((len
>= 4 && !prefixcmp(buf
, "PACK")) ||
28 (len
>= 5 && !prefixcmp(buf
+1, "PACK"))) {
29 strbuf_addstr(&out
, "PACK ...");
33 /* XXX we should really handle printable utf8 */
34 for (i
= 0; i
< len
; i
++) {
35 /* suppress newlines */
38 if (buf
[i
] >= 0x20 && buf
[i
] <= 0x7e)
39 strbuf_addch(&out
, buf
[i
]);
41 strbuf_addf(&out
, "\\%o", buf
[i
]);
45 strbuf_addch(&out
, '\n');
46 trace_strbuf(trace_key
, &out
);
51 * If we buffered things up above (we don't, but we should),
54 void packet_flush(int fd
)
56 packet_trace("0000", 4, 1);
57 write_or_die(fd
, "0000", 4);
60 void packet_buf_flush(struct strbuf
*buf
)
62 packet_trace("0000", 4, 1);
63 strbuf_add(buf
, "0000", 4);
66 #define hex(a) (hexchar[(a) & 15])
67 static char buffer
[1000];
68 static unsigned format_packet(const char *fmt
, va_list args
)
70 static char hexchar
[] = "0123456789abcdef";
73 n
= vsnprintf(buffer
+ 4, sizeof(buffer
) - 4, fmt
, args
);
74 if (n
>= sizeof(buffer
)-4)
75 die("protocol error: impossibly long line");
77 buffer
[0] = hex(n
>> 12);
78 buffer
[1] = hex(n
>> 8);
79 buffer
[2] = hex(n
>> 4);
81 packet_trace(buffer
+4, n
-4, 1);
85 void packet_write(int fd
, const char *fmt
, ...)
91 n
= format_packet(fmt
, args
);
93 write_or_die(fd
, buffer
, n
);
96 void packet_buf_write(struct strbuf
*buf
, const char *fmt
, ...)
102 n
= format_packet(fmt
, args
);
104 strbuf_add(buf
, buffer
, n
);
107 static int safe_read(int fd
, void *buffer
, unsigned size
, int options
)
109 ssize_t ret
= read_in_full(fd
, buffer
, size
);
111 die_errno("read error");
112 else if (ret
< size
) {
113 if (options
& PACKET_READ_GENTLE_ON_EOF
)
116 die("The remote end hung up unexpectedly");
122 static int packet_length(const char *linelen
)
127 for (n
= 0; n
< 4; n
++) {
128 unsigned char c
= linelen
[n
];
130 if (c
>= '0' && c
<= '9') {
134 if (c
>= 'a' && c
<= 'f') {
138 if (c
>= 'A' && c
<= 'F') {
147 int packet_read(int fd
, char *buffer
, unsigned size
, int options
)
152 ret
= safe_read(fd
, linelen
, 4, options
);
155 len
= packet_length(linelen
);
157 die("protocol error: bad line length character: %.4s", linelen
);
159 packet_trace("0000", 4, 0);
164 die("protocol error: bad line length %d", len
);
165 ret
= safe_read(fd
, buffer
, len
, options
);
169 if ((options
& PACKET_READ_CHOMP_NEWLINE
) &&
170 len
&& buffer
[len
-1] == '\n')
174 packet_trace(buffer
, len
, 0);
178 char *packet_read_line(int fd
, int *len_p
)
180 int len
= packet_read(fd
, packet_buffer
, sizeof(packet_buffer
),
181 PACKET_READ_CHOMP_NEWLINE
);
184 return len
? packet_buffer
: NULL
;
187 int packet_get_line(struct strbuf
*out
,
188 char **src_buf
, size_t *src_len
)
194 len
= packet_length(*src_buf
);
200 packet_trace("0000", 4, 0);
210 strbuf_add(out
, *src_buf
, len
);
213 packet_trace(out
->buf
, out
->len
, 0);