Function __parse_csv_record

lib/csv.c:76–220

}

csv_record *__parse_csv_record(const str *_in, enum csv_flags parse_flags,
                               unsigned char sep)
{
	str_list *record = NULL, **last = &record;
	str in = *_in, field;
	char *ch, *p, *c, finished, *lim, *field_start;

	if (parse_flags & CSV_SHM) {
		malloc_f = osips_shm_malloc;
		free_f = osips_shm_free;
	} else {
		malloc_f = osips_pkg_malloc;
		free_f = osips_pkg_free;
	}

	if (parse_flags & CSV_RFC_4180)
		goto rfc_4180_parsing;

	trim(&in);

	for (finished = 0; !finished; ) {
		ch = memchr(in.s, sep, in.len);
		if (!ch) {
			ch = in.s + in.len;
			finished = 1;
		}

		field.s = in.s;
		field.len = ch - in.s;
		in.s += field.len + 1;
		in.len -= field.len + 1;
		trim(&field);

		if (!push_csv_field(&field, last, parse_flags))
			goto oom;

		last = &(*last)->next;
	}

	return record;

rfc_4180_parsing:
	parse_flags |= CSV_DUP_FIELDS;

	if (in.len >= 2 && in.s[in.len - 2] == '\r' && in.s[in.len - 1] == '\n')
		in.len -= 2;

	field_start = NULL;
	for (ch = in.s, lim = in.s + in.len; ch < lim; ch++) {
		if (*ch < 0x20 || *ch > 0x7E)
			goto bad_csv_str;

		switch (*ch) {
		case ',':
			if (field_start)
				field.s = field_start;
			else
				field.s = in.s;