{
readq_T *node;
readq_T *head = &channel->ch_head;
+ char_u *p;
+ int i;
node = (readq_T *)alloc(sizeof(readq_T));
if (node == NULL)
vim_free(node);
return FAIL; /* out of memory */
}
- mch_memmove(node->rq_buffer, buf, (size_t)len);
- node->rq_buffer[len] = NUL;
+
+ /* TODO: don't strip CR when channel is in raw mode */
+ p = node->rq_buffer;
+ for (i = 0; i < len; ++i)
+ if (buf[i] != CAR || i + 1 >= len || buf[i + 1] != NL)
+ *p++ = buf[i];
+ *p = NUL;
/* append node to the tail of the queue */
node->rq_next = NULL;
ga_concat(gap, (char_u *)": ");
}
+/*
+ * Append "str" to "gap", escaping unprintable characters.
+ * Changes NL to \n, CR to \r, etc.
+ */
+ static void
+ga_concat_esc(garray_T *gap, char_u *str)
+{
+ char_u *p;
+ char_u buf[NUMBUFLEN];
+
+ for (p = str; *p != NUL; ++p)
+ switch (*p)
+ {
+ case BS: ga_concat(gap, (char_u *)"\\b"); break;
+ case ESC: ga_concat(gap, (char_u *)"\\e"); break;
+ case FF: ga_concat(gap, (char_u *)"\\f"); break;
+ case NL: ga_concat(gap, (char_u *)"\\n"); break;
+ case TAB: ga_concat(gap, (char_u *)"\\t"); break;
+ case CAR: ga_concat(gap, (char_u *)"\\r"); break;
+ case '\\': ga_concat(gap, (char_u *)"\\\\"); break;
+ default:
+ if (*p < ' ')
+ {
+ vim_snprintf((char *)buf, NUMBUFLEN, "\\x%02x", *p);
+ ga_concat(gap, buf);
+ }
+ else
+ ga_append(gap, *p);
+ break;
+ }
+}
+
/*
* Fill "gap" with information about an assert error.
*/
ga_concat(gap, (char_u *)"Expected ");
if (exp_str == NULL)
{
- ga_concat(gap, tv2string(exp_tv, &tofree, numbuf, 0));
+ ga_concat_esc(gap, tv2string(exp_tv, &tofree, numbuf, 0));
vim_free(tofree);
}
else
- ga_concat(gap, exp_str);
+ ga_concat_esc(gap, exp_str);
ga_concat(gap, (char_u *)" but got ");
- ga_concat(gap, tv2string(got_tv, &tofree, numbuf, 0));
+ ga_concat_esc(gap, tv2string(got_tv, &tofree, numbuf, 0));
vim_free(tofree);
}
}