unbound/util/tube.c

237 	if(tube->res_write < sizeof(item->len)) {
238 		r = write(c->fd, ((uint8_t*)&item->len) + tube->res_write,
239 			sizeof(item->len) - tube->res_write);
252 		if(tube->res_write < sizeof(item->len))
255 	r = write(c->fd, item->buf + tube->res_write - sizeof(item->len),
256 		item->len - (tube->res_write - sizeof(item->len)));
269 	if(tube->res_write < sizeof(item->len) + item->len)
284 int tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len,
292 		r = write(fd, &len, sizeof(len));
304 	while(d != (ssize_t)sizeof(len)) {
305 		if((r=write(fd, ((char*)&len)+d, sizeof(len)-d)) == -1) {
313 	while(d != (ssize_t)len) {
314 		if((r=write(fd, buf+d, len-d)) == -1) {
326 int tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len,
333 	*len = 0;
335 		r = read(fd, len, sizeof(*len));
349 	while(d != (ssize_t)sizeof(*len)) {
350 		if((r=read(fd, ((char*)len)+d, sizeof(*len)-d)) == -1) {
361 	log_assert(*len < 65536*2);
362 	*buf = (uint8_t*)malloc(*len);
369 	while(d < (ssize_t)*len) {
370 		if((r=read(fd, (*buf)+d, (size_t)((ssize_t)*len)-d)) == -1) {
450 int tube_queue_item(struct tube* tube, uint8_t* msg, size_t len)
460 	item->len = len;
559 int tube_write_msg(struct tube* tube, uint8_t* buf, uint32_t len,
563 	verbose(VERB_ALGO, "tube write_msg len %d", (int)len);
564 	a = (uint8_t*)memdup(buf, len);
570 	return tube_queue_item(tube, a, len);
573 int tube_read_msg(struct tube* tube, uint8_t** buf, uint32_t* len,
605 	*len = item->len;
607 	verbose(VERB_ALGO, "tube read_msg len %d", (int)*len);
682 int tube_queue_item(struct tube* tube, uint8_t* msg, size_t len)
686 	verbose(VERB_ALGO, "tube queue_item len %d", (int)len);
693 	item->len = len;
714 	uint32_t len = 0;
717 		if(tube_read_msg(tube, &buf, &len, 1)) {
719 			(*tube->listen_cb)(tube, buf, len, NETEVENT_NOERROR,