/src/libyaml/src/writer.c

Source

#include "yaml_private.h"

/*
 * Declarations.
 */

static int
yaml_emitter_set_writer_error(yaml_emitter_t *emitter, const char *problem);

YAML_DECLARE(int)
yaml_emitter_flush(yaml_emitter_t *emitter);

/*
 * Set the writer error and return 0.
 */

static int
yaml_emitter_set_writer_error(yaml_emitter_t *emitter, const char *problem)
{
    emitter->error = YAML_WRITER_ERROR;
    emitter->problem = problem;

    return 0;
}

/*
 * Flush the output buffer.
 */

YAML_DECLARE(int)
yaml_emitter_flush(yaml_emitter_t *emitter)
{
    int low, high;

    assert(emitter);    /* Non-NULL emitter object is expected. */
    assert(emitter->write_handler); /* Write handler must be set. */
    assert(emitter->encoding);  /* Output encoding must be set. */

    emitter->buffer.last = emitter->buffer.pointer;
    emitter->buffer.pointer = emitter->buffer.start;

    /* Check if the buffer is empty. */

    if (emitter->buffer.start == emitter->buffer.last) {
        return 1;
    }

    /* If the output encoding is UTF-8, we don't need to recode the buffer. */

    if (emitter->encoding == YAML_UTF8_ENCODING)
    {
        if (emitter->write_handler(emitter->write_handler_data,
                    emitter->buffer.start,
                    emitter->buffer.last - emitter->buffer.start)) {
            emitter->buffer.last = emitter->buffer.start;
            emitter->buffer.pointer = emitter->buffer.start;
            return 1;
        }
        else {
            return yaml_emitter_set_writer_error(emitter, "write error");
        }
    }

    /* Recode the buffer into the raw buffer. */

    low = (emitter->encoding == YAML_UTF16LE_ENCODING ? 0 : 1);
    high = (emitter->encoding == YAML_UTF16LE_ENCODING ? 1 : 0);

    while (emitter->buffer.pointer != emitter->buffer.last)
    {
        unsigned char octet;
        unsigned int width;
        unsigned int value;
        size_t k;

        /*
         * See the "reader.c" code for more details on UTF-8 encoding.  Note
         * that we assume that the buffer contains a valid UTF-8 sequence.
         */

        /* Read the next UTF-8 character. */

        octet = emitter->buffer.pointer[0];

        width = (octet & 0x80) == 0x00 ? 1 :
                (octet & 0xE0) == 0xC0 ? 2 :
                (octet & 0xF0) == 0xE0 ? 3 :
                (octet & 0xF8) == 0xF0 ? 4 : 0;

        value = (octet & 0x80) == 0x00 ? octet & 0x7F :
                (octet & 0xE0) == 0xC0 ? octet & 0x1F :
                (octet & 0xF0) == 0xE0 ? octet & 0x0F :
                (octet & 0xF8) == 0xF0 ? octet & 0x07 : 0;

        for (k = 1; k < width; k ++) {
            octet = emitter->buffer.pointer[k];
            value = (value << 6) + (octet & 0x3F);
        }

        emitter->buffer.pointer += width;

        /* Write the character. */

        if (value < 0x10000)
        {
            emitter->raw_buffer.last[high] = value >> 8;
            emitter->raw_buffer.last[low] = value & 0xFF;

            emitter->raw_buffer.last += 2;
        }
        else
        {
            /* Write the character using a surrogate pair (check "reader.c"). */

            value -= 0x10000;
            emitter->raw_buffer.last[high] = 0xD8 + (value >> 18);
            emitter->raw_buffer.last[low] = (value >> 10) & 0xFF;
            emitter->raw_buffer.last[high+2] = 0xDC + ((value >> 8) & 0xFF);
            emitter->raw_buffer.last[low+2] = value & 0xFF;

            emitter->raw_buffer.last += 4;
        }
    }

    /* Write the raw buffer. */

    if (emitter->write_handler(emitter->write_handler_data,
                emitter->raw_buffer.start,
                emitter->raw_buffer.last - emitter->raw_buffer.start)) {
        emitter->buffer.last = emitter->buffer.start;
        emitter->buffer.pointer = emitter->buffer.start;
        emitter->raw_buffer.last = emitter->raw_buffer.start;
        emitter->raw_buffer.pointer = emitter->raw_buffer.start;
        return 1;
    }
    else {
        return yaml_emitter_set_writer_error(emitter, "write error");
    }
}


Line	Count	Source
1
2		#include "yaml_private.h"
3
4		/*
5		* Declarations.
6		*/
7
8		static int
9		yaml_emitter_set_writer_error(yaml_emitter_t emitter, const char problem);
10
11		YAML_DECLARE(int)
12		yaml_emitter_flush(yaml_emitter_t *emitter);
13
14		/*
15		* Set the writer error and return 0.
16		*/
17
18		static int
19		yaml_emitter_set_writer_error(yaml_emitter_t emitter, const char problem)
20	20.9k	{
21	20.9k	emitter->error = YAML_WRITER_ERROR;
22	20.9k	emitter->problem = problem;
23
24	20.9k	return 0;
25	20.9k	}
26
27		/*
28		* Flush the output buffer.
29		*/
30
31		YAML_DECLARE(int)
32		yaml_emitter_flush(yaml_emitter_t *emitter)
33	991k	{
34	991k	int low, high;
35
36	991k	assert(emitter); /* Non-NULL emitter object is expected. */
37	991k	assert(emitter->write_handler); /* Write handler must be set. */
38	991k	assert(emitter->encoding); /* Output encoding must be set. */
39
40	991k	emitter->buffer.last = emitter->buffer.pointer;
41	991k	emitter->buffer.pointer = emitter->buffer.start;
42
43		/* Check if the buffer is empty. */
44
45	991k	if (emitter->buffer.start == emitter->buffer.last) {
46	26.7k	return 1;
47	26.7k	}
48
49		/* If the output encoding is UTF-8, we don't need to recode the buffer. */
50
51	964k	if (emitter->encoding == YAML_UTF8_ENCODING)
52	957k	{
53	957k	if (emitter->write_handler(emitter->write_handler_data,
54	957k	emitter->buffer.start,
55	957k	emitter->buffer.last - emitter->buffer.start)) {
56	936k	emitter->buffer.last = emitter->buffer.start;
57	936k	emitter->buffer.pointer = emitter->buffer.start;
58	936k	return 1;
59	936k	}
60	20.2k	else {
61	20.2k	return yaml_emitter_set_writer_error(emitter, "write error");
62	20.2k	}
63	957k	}
64
65		/* Recode the buffer into the raw buffer. */
66
67	7.50k	low = (emitter->encoding == YAML_UTF16LE_ENCODING ? 0 : 1);
68	7.50k	high = (emitter->encoding == YAML_UTF16LE_ENCODING ? 1 : 0);
69
70	86.5M	while (emitter->buffer.pointer != emitter->buffer.last)
71	86.5M	{
72	86.5M	unsigned char octet;
73	86.5M	unsigned int width;
74	86.5M	unsigned int value;
75	86.5M	size_t k;
76
77		/*
78		* See the "reader.c" code for more details on UTF-8 encoding. Note
79		* that we assume that the buffer contains a valid UTF-8 sequence.
80		*/
81
82		/* Read the next UTF-8 character. */
83
84	86.5M	octet = emitter->buffer.pointer[0];
85
86	86.5M	width = (octet & 0x80) == 0x00 ? 1 :
87	86.5M	(octet & 0xE0) == 0xC0 ? 2 :
88	7.51M	(octet & 0xF0) == 0xE0 ? 3 :
89	7.51M	(octet & 0xF8) == 0xF0 ? 4 : 0;
90
91	86.5M	value = (octet & 0x80) == 0x00 ? octet & 0x7F :
92	86.5M	(octet & 0xE0) == 0xC0 ? octet & 0x1F :
93	7.51M	(octet & 0xF0) == 0xE0 ? octet & 0x0F :
94	7.51M	(octet & 0xF8) == 0xF0 ? octet & 0x07 : 0;
95
96	101M	for (k = 1; k < width; k ++) {
97	15.0M	octet = emitter->buffer.pointer[k];
98	15.0M	value = (value << 6) + (octet & 0x3F);
99	15.0M	}
100
101	86.5M	emitter->buffer.pointer += width;
102
103		/* Write the character. */
104
105	86.5M	if (value < 0x10000)
106	86.5M	{
107	86.5M	emitter->raw_buffer.last[high] = value >> 8;
108	86.5M	emitter->raw_buffer.last[low] = value & 0xFF;
109
110	86.5M	emitter->raw_buffer.last += 2;
111	86.5M	}
112	0	else
113	0	{
114		/* Write the character using a surrogate pair (check "reader.c"). */
115
116	0	value -= 0x10000;
117	0	emitter->raw_buffer.last[high] = 0xD8 + (value >> 18);
118	0	emitter->raw_buffer.last[low] = (value >> 10) & 0xFF;
119	0	emitter->raw_buffer.last[high+2] = 0xDC + ((value >> 8) & 0xFF);
120	0	emitter->raw_buffer.last[low+2] = value & 0xFF;
121
122	0	emitter->raw_buffer.last += 4;
123	0	}
124	86.5M	}
125
126		/* Write the raw buffer. */
127
128	7.50k	if (emitter->write_handler(emitter->write_handler_data,
129	7.50k	emitter->raw_buffer.start,
130	7.50k	emitter->raw_buffer.last - emitter->raw_buffer.start)) {
131	6.86k	emitter->buffer.last = emitter->buffer.start;
132	6.86k	emitter->buffer.pointer = emitter->buffer.start;
133	6.86k	emitter->raw_buffer.last = emitter->raw_buffer.start;
134	6.86k	emitter->raw_buffer.pointer = emitter->raw_buffer.start;
135	6.86k	return 1;
136	6.86k	}
137	645	else {
138	645	return yaml_emitter_set_writer_error(emitter, "write error");
139	645	}
140	7.50k	}
141

Coverage Report

Created: 2026-07-16 06:23