czmq-4.1.1/src/zgossip_msg.c

40     byte *needle;                       //  Read/write pointer for serialization  member
52     memcpy (self->needle, (host), size); \
53     self->needle += size; \
58     if (self->needle + size > self->ceiling) { \
62     memcpy ((host), self->needle, size); \
63     self->needle += size; \
68     *(byte *) self->needle = (byte) (host); \
69     self->needle++; \
74     self->needle [0] = (byte) (((host) >> 8)  & 255); \
75     self->needle [1] = (byte) (((host))       & 255); \
76     self->needle += 2; \
81     self->needle [0] = (byte) (((host) >> 24) & 255); \
82     self->needle [1] = (byte) (((host) >> 16) & 255); \
83     self->needle [2] = (byte) (((host) >> 8)  & 255); \
84     self->needle [3] = (byte) (((host))       & 255); \
85     self->needle += 4; \
90     self->needle [0] = (byte) (((host) >> 56) & 255); \
91     self->needle [1] = (byte) (((host) >> 48) & 255); \
92     self->needle [2] = (byte) (((host) >> 40) & 255); \
93     self->needle [3] = (byte) (((host) >> 32) & 255); \
94     self->needle [4] = (byte) (((host) >> 24) & 255); \
95     self->needle [5] = (byte) (((host) >> 16) & 255); \
96     self->needle [6] = (byte) (((host) >> 8)  & 255); \
97     self->needle [7] = (byte) (((host))       & 255); \
98     self->needle += 8; \
103     if (self->needle + 1 > self->ceiling) { \
107     (host) = *(byte *) self->needle; \
108     self->needle++; \
113     if (self->needle + 2 > self->ceiling) { \
117     (host) = ((uint16_t) (self->needle [0]) << 8) \
118            +  (uint16_t) (self->needle [1]); \
119     self->needle += 2; \
124     if (self->needle + 4 > self->ceiling) { \
128     (host) = ((uint32_t) (self->needle [0]) << 24) \
129            + ((uint32_t) (self->needle [1]) << 16) \
130            + ((uint32_t) (self->needle [2]) << 8) \
131            +  (uint32_t) (self->needle [3]); \
132     self->needle += 4; \
137     if (self->needle + 8 > self->ceiling) { \
141     (host) = ((uint64_t) (self->needle [0]) << 56) \
142            + ((uint64_t) (self->needle [1]) << 48) \
143            + ((uint64_t) (self->needle [2]) << 40) \
144            + ((uint64_t) (self->needle [3]) << 32) \
145            + ((uint64_t) (self->needle [4]) << 24) \
146            + ((uint64_t) (self->needle [5]) << 16) \
147            + ((uint64_t) (self->needle [6]) << 8) \
148            +  (uint64_t) (self->needle [7]); \
149     self->needle += 8; \
156     memcpy (self->needle, (host), string_size); \
157     self->needle += string_size; \
164     if (self->needle + string_size > (self->ceiling)) { \
168     memcpy ((host), self->needle, string_size); \
170     self->needle += string_size; \
177     memcpy (self->needle, (host), string_size); \
178     self->needle += string_size; \
185     if (self->needle + string_size > (self->ceiling)) { \
191     memcpy ((host), self->needle, string_size); \
193     self->needle += string_size; \
254     self->needle = (byte *) zmq_msg_data (&frame);  in zgossip_msg_recv()
255     self->ceiling = self->needle + zmq_msg_size (&frame);  in zgossip_msg_recv()
382     self->needle = (byte *) zmq_msg_data (&frame);  in zgossip_msg_send()