5 static void pack_line(const char *line
)
7 if (!strcmp(line
, "0000") || !strcmp(line
, "0000\n"))
9 else if (!strcmp(line
, "0001") || !strcmp(line
, "0001\n"))
12 packet_write_fmt(1, "%s", line
);
15 static void pack(int argc
, const char **argv
)
17 if (argc
) { /* read from argv */
19 for (i
= 0; i
< argc
; i
++)
21 } else { /* read from stdin */
22 char line
[LARGE_PACKET_MAX
];
23 while (fgets(line
, sizeof(line
), stdin
)) {
29 static void unpack(void)
31 struct packet_reader reader
;
32 packet_reader_init(&reader
, 0, NULL
, 0,
33 PACKET_READ_GENTLE_ON_EOF
|
34 PACKET_READ_CHOMP_NEWLINE
);
36 while (packet_reader_read(&reader
) != PACKET_READ_EOF
) {
37 switch (reader
.status
) {
40 case PACKET_READ_NORMAL
:
41 printf("%s\n", reader
.line
);
43 case PACKET_READ_FLUSH
:
46 case PACKET_READ_DELIM
:
49 case PACKET_READ_RESPONSE_END
:
56 static void unpack_sideband(void)
58 struct packet_reader reader
;
59 packet_reader_init(&reader
, 0, NULL
, 0,
60 PACKET_READ_GENTLE_ON_EOF
|
61 PACKET_READ_CHOMP_NEWLINE
);
63 while (packet_reader_read(&reader
) != PACKET_READ_EOF
) {
67 switch (reader
.status
) {
70 case PACKET_READ_NORMAL
:
71 band
= reader
.line
[0] & 0xff;
72 if (band
< 1 || band
> 2)
73 continue; /* skip non-sideband packets */
76 write_or_die(fd
, reader
.line
+ 1, reader
.pktlen
- 1);
78 case PACKET_READ_FLUSH
:
80 case PACKET_READ_DELIM
:
81 case PACKET_READ_RESPONSE_END
:
87 static int send_split_sideband(void)
89 const char *part1
= "Hello,";
90 const char *primary
= "\001primary: regular output\n";
91 const char *part2
= " world!\n";
93 send_sideband(1, 2, part1
, strlen(part1
), LARGE_PACKET_MAX
);
94 packet_write(1, primary
, strlen(primary
));
95 send_sideband(1, 2, part2
, strlen(part2
), LARGE_PACKET_MAX
);
96 packet_response_end(1);
101 static int receive_sideband(void)
103 return recv_sideband("sideband", 0, 1);
106 int cmd__pkt_line(int argc
, const char **argv
)
109 die("too few arguments");
111 if (!strcmp(argv
[1], "pack"))
112 pack(argc
- 2, argv
+ 2);
113 else if (!strcmp(argv
[1], "unpack"))
115 else if (!strcmp(argv
[1], "unpack-sideband"))
117 else if (!strcmp(argv
[1], "send-split-sideband"))
118 send_split_sideband();
119 else if (!strcmp(argv
[1], "receive-sideband"))
122 die("invalid argument '%s'", argv
[1]);