goto send_reply;
}
- fprintf(stderr, "name: %s\n", session_name);
session = session_create(session_name, hostname, live_timer,
snapshot, conn->major, conn->minor);
if (!session) {
if (stream->prev_seq < stream->rotate_at_seq_num) {
DBG("Stream %" PRIu64 " no yet ready for rotation",
stream->stream_handle);
- fprintf(stderr, "Stream %" PRIu64 " no yet ready for rotation\n",
- stream->stream_handle);
ret = 0;
goto end;
} else if (stream->prev_seq > stream->rotate_at_seq_num) {
/* TODO */
} else {
DBG("Stream %" PRIu64 " ready for rotation", stream->stream_handle);
- fprintf(stderr, "Stream %" PRIu64 " ready for rotation\n", stream->stream_handle);
}
ret = do_rotate_stream(stream);
goto end;
}
- fprintf(stderr, "Renaming %s to %s/\n", stream_info.current_path,
- stream_info.new_path);
-
old = create_output_path(stream_info.current_path);
if (!old) {
ERR("Failed to create current output path");
uint32_t rotate_pending;
DBG("Rotate pending command received");
- fprintf(stderr, "Rotate pending command received\n");
if (!session || conn->version_check_done == 0) {
ERR("Trying to check for data before version check");
rcu_read_unlock();
send_reply:
- fprintf(stderr, "Rotate pending done: %d\n", rotate_pending);
memset(&reply, 0, sizeof(reply));
reply.ret_code = htobe32(rotate_pending);
ret = conn->sock->ops->sendmsg(conn->sock, &reply, sizeof(reply), 0);