1
0
Fork 0
mirror of https://github.com/git/git.git synced 2024-05-03 22:28:09 +02:00

Merge branch 'ab/pkt-line-cleanup' into next

Code clean-up.

* ab/pkt-line-cleanup:
  pkt-line.[ch]: remove unused packet_read_line_buf()
  pkt-line.[ch]: remove unused packet_buf_write_len()
This commit is contained in:
Junio C Hamano 2021-10-18 16:00:29 -07:00
commit 79b07663da
6 changed files with 13 additions and 53 deletions

View File

@ -82,8 +82,8 @@ static void worker_loop(struct checkout *state)
size_t i, nr = 0, alloc = 0; size_t i, nr = 0, alloc = 0;
while (1) { while (1) {
int len = packet_read(0, NULL, NULL, packet_buffer, int len = packet_read(0, packet_buffer, sizeof(packet_buffer),
sizeof(packet_buffer), 0); 0);
if (len < 0) if (len < 0)
BUG("packet_read() returned negative value"); BUG("packet_read() returned negative value");

View File

@ -765,7 +765,7 @@ static int execute(void)
set_keep_alive(0); set_keep_alive(0);
alarm(init_timeout ? init_timeout : timeout); alarm(init_timeout ? init_timeout : timeout);
pktlen = packet_read(0, NULL, NULL, packet_buffer, sizeof(packet_buffer), 0); pktlen = packet_read(0, packet_buffer, sizeof(packet_buffer), 0);
alarm(0); alarm(0);
len = strlen(line); len = strlen(line);

View File

@ -603,8 +603,7 @@ static void gather_results_from_workers(struct pc_worker *workers,
continue; continue;
if (pfd->revents & POLLIN) { if (pfd->revents & POLLIN) {
int len = packet_read(pfd->fd, NULL, NULL, int len = packet_read(pfd->fd, packet_buffer,
packet_buffer,
sizeof(packet_buffer), 0); sizeof(packet_buffer), 0);
if (len < 0) { if (len < 0) {

View File

@ -289,22 +289,6 @@ void packet_buf_write(struct strbuf *buf, const char *fmt, ...)
va_end(args); va_end(args);
} }
void packet_buf_write_len(struct strbuf *buf, const char *data, size_t len)
{
size_t orig_len, n;
orig_len = buf->len;
strbuf_addstr(buf, "0000");
strbuf_add(buf, data, len);
n = buf->len - orig_len;
if (n > LARGE_PACKET_MAX)
die(_("protocol error: impossibly long line"));
set_packet_header(&buf->buf[orig_len], n);
packet_trace(data, len, 1);
}
int write_packetized_from_fd_no_flush(int fd_in, int fd_out) int write_packetized_from_fd_no_flush(int fd_in, int fd_out)
{ {
char *buf = xmalloc(LARGE_PACKET_DATA_MAX); char *buf = xmalloc(LARGE_PACKET_DATA_MAX);
@ -453,38 +437,28 @@ enum packet_read_status packet_read_with_status(int fd, char **src_buffer,
return PACKET_READ_NORMAL; return PACKET_READ_NORMAL;
} }
int packet_read(int fd, char **src_buffer, size_t *src_len, int packet_read(int fd, char *buffer, unsigned size, int options)
char *buffer, unsigned size, int options)
{ {
int pktlen = -1; int pktlen = -1;
packet_read_with_status(fd, src_buffer, src_len, buffer, size, packet_read_with_status(fd, NULL, NULL, buffer, size, &pktlen,
&pktlen, options); options);
return pktlen; return pktlen;
} }
static char *packet_read_line_generic(int fd, char *packet_read_line(int fd, int *dst_len)
char **src, size_t *src_len,
int *dst_len)
{ {
int len = packet_read(fd, src, src_len, int len = packet_read(fd, packet_buffer, sizeof(packet_buffer),
packet_buffer, sizeof(packet_buffer),
PACKET_READ_CHOMP_NEWLINE); PACKET_READ_CHOMP_NEWLINE);
if (dst_len) if (dst_len)
*dst_len = len; *dst_len = len;
return (len > 0) ? packet_buffer : NULL; return (len > 0) ? packet_buffer : NULL;
} }
char *packet_read_line(int fd, int *len_p)
{
return packet_read_line_generic(fd, NULL, NULL, len_p);
}
int packet_read_line_gently(int fd, int *dst_len, char **dst_line) int packet_read_line_gently(int fd, int *dst_len, char **dst_line)
{ {
int len = packet_read(fd, NULL, NULL, int len = packet_read(fd, packet_buffer, sizeof(packet_buffer),
packet_buffer, sizeof(packet_buffer),
PACKET_READ_CHOMP_NEWLINE|PACKET_READ_GENTLE_ON_EOF); PACKET_READ_CHOMP_NEWLINE|PACKET_READ_GENTLE_ON_EOF);
if (dst_len) if (dst_len)
*dst_len = len; *dst_len = len;
@ -493,11 +467,6 @@ int packet_read_line_gently(int fd, int *dst_len, char **dst_line)
return len; return len;
} }
char *packet_read_line_buf(char **src, size_t *src_len, int *dst_len)
{
return packet_read_line_generic(-1, src, src_len, dst_len);
}
ssize_t read_packetized_to_strbuf(int fd_in, struct strbuf *sb_out, int options) ssize_t read_packetized_to_strbuf(int fd_in, struct strbuf *sb_out, int options)
{ {
int packet_len; int packet_len;
@ -507,7 +476,7 @@ ssize_t read_packetized_to_strbuf(int fd_in, struct strbuf *sb_out, int options)
for (;;) { for (;;) {
strbuf_grow(sb_out, LARGE_PACKET_DATA_MAX); strbuf_grow(sb_out, LARGE_PACKET_DATA_MAX);
packet_len = packet_read(fd_in, NULL, NULL, packet_len = packet_read(fd_in,
/* strbuf_grow() above always allocates one extra byte to /* strbuf_grow() above always allocates one extra byte to
* store a '\0' at the end of the string. packet_read() * store a '\0' at the end of the string. packet_read()
* writes a '\0' extra byte at the end, too. Let it know * writes a '\0' extra byte at the end, too. Let it know

View File

@ -29,7 +29,6 @@ void packet_buf_delim(struct strbuf *buf);
void set_packet_header(char *buf, int size); void set_packet_header(char *buf, int size);
void packet_write(int fd_out, const char *buf, size_t size); void packet_write(int fd_out, const char *buf, size_t size);
void packet_buf_write(struct strbuf *buf, const char *fmt, ...) __attribute__((format (printf, 2, 3))); void packet_buf_write(struct strbuf *buf, const char *fmt, ...) __attribute__((format (printf, 2, 3)));
void packet_buf_write_len(struct strbuf *buf, const char *data, size_t len);
int packet_flush_gently(int fd); int packet_flush_gently(int fd);
int packet_write_fmt_gently(int fd, const char *fmt, ...) __attribute__((format (printf, 2, 3))); int packet_write_fmt_gently(int fd, const char *fmt, ...) __attribute__((format (printf, 2, 3)));
int write_packetized_from_fd_no_flush(int fd_in, int fd_out); int write_packetized_from_fd_no_flush(int fd_in, int fd_out);
@ -88,8 +87,7 @@ void packet_fflush(FILE *f);
#define PACKET_READ_CHOMP_NEWLINE (1u<<1) #define PACKET_READ_CHOMP_NEWLINE (1u<<1)
#define PACKET_READ_DIE_ON_ERR_PACKET (1u<<2) #define PACKET_READ_DIE_ON_ERR_PACKET (1u<<2)
#define PACKET_READ_GENTLE_ON_READ_ERROR (1u<<3) #define PACKET_READ_GENTLE_ON_READ_ERROR (1u<<3)
int packet_read(int fd, char **src_buffer, size_t *src_len, char int packet_read(int fd, char *buffer, unsigned size, int options);
*buffer, unsigned size, int options);
/* /*
* Convert a four hex digit packet line length header into its numeric * Convert a four hex digit packet line length header into its numeric
@ -138,12 +136,6 @@ char *packet_read_line(int fd, int *size);
*/ */
int packet_read_line_gently(int fd, int *size, char **dst_line); int packet_read_line_gently(int fd, int *size, char **dst_line);
/*
* Same as packet_read_line, but read from a buf rather than a descriptor;
* see packet_read for details on how src_* is used.
*/
char *packet_read_line_buf(char **src_buf, size_t *src_len, int *size);
/* /*
* Reads a stream of variable sized packets until a flush packet is detected. * Reads a stream of variable sized packets until a flush packet is detected.
*/ */

View File

@ -1088,7 +1088,7 @@ static int rpc_service(struct rpc_state *rpc, struct discovery *heads,
rpc->protocol_header = NULL; rpc->protocol_header = NULL;
while (!err) { while (!err) {
int n = packet_read(rpc->out, NULL, NULL, rpc->buf, rpc->alloc, 0); int n = packet_read(rpc->out, rpc->buf, rpc->alloc, 0);
if (!n) if (!n)
break; break;
rpc->pos = 0; rpc->pos = 0;