Lines Matching refs:ret
64 int ret, server_msg;
150 ret = amqp_socket_open_noblock(s->socket, hostname, port, &tval);
152 if (ret) {
154 amqp_error_string2(ret));
237 int ret;
244 ret = ff_network_wait_fd_timeout(fd, 1, h->rw_timeout, &h->interrupt_callback);
245 if (ret)
246 return ret;
252 ret = amqp_basic_publish(s->conn, DEFAULT_CHANNEL, amqp_cstring_bytes(s->exchange),
256 if (ret) {
257 av_log(h, AV_LOG_ERROR, "Error publish: %s\n", amqp_error_string2(ret));
268 int ret;
273 ret = ff_network_wait_fd_timeout(fd, 0, h->rw_timeout, &h->interrupt_callback);
274 if (ret)
275 return ret;