comparison src/mpg123/http.c @ 220:1e2d575fd2e7 trunk

[svn] - allow seeking in http streams that define a content length.

219:469078516127

static gsize rd_index, wr_index, buffer_length, prebuffer_length;
static guint64 buffer_read = 0;
static gchar *buffer;
static GThread *thread;
static GtkWidget *error_dialog = NULL;

static VFSFile *output_file = NULL;

#define BASE64_LENGTH(len) (4 * (((len) + 2) / 3))

static gpointer
http_buffer_loop(gpointer arg)
{
    gchar line[1024], *user, *pass, *host, *filename,
        *status, *url, *temp, *file;
    gchar *chost;
    gint cnt, written, error, port, cport;
    guint err_len;
    gboolean redirect;
    gint udp_sock = 0;

                                                        "Proxy-Authorization");
                    }
                }
                else
                    file = g_strconcat("/", filename, NULL);
                temp = g_strdup_printf("GET %s HTTP/1.0\r\n"
                                       "Host: %s\r\n"
                                       "User-Agent: %s/%s\r\n"
                                       "%s%s%s%s\r\n",
                                       file, host, PACKAGE_NAME, PACKAGE_VERSION,
                                       proxy_auth ? proxy_auth : "",
                                       auth ? auth : "",
                                       "Icy-MetaData:1\r\n",
                                       mpgdec_cfg.
                                       use_udp_channel ? udpspace : "");

                g_free(file);
                if (proxy_auth)
                    g_free(proxy_auth);
                if (auth)

                                fprintf(stderr,
                                        "Server wants udp messages on port %d\n",
                                        atoi(line + 20));
#endif
/*  								udp_serverport = atoi (line + 20); */
                            }

                        }
                        else {
                            eof = TRUE;
                            mpgdec_ip.set_info_text(NULL);
                            break;

    return NULL;
}

int
mpgdec_http_open(gchar * _url)
{
    gchar *url;

    url = g_strdup(_url);

    prebuffering = TRUE;
    mpgdec_ip.set_status_buffering(TRUE);
    going = TRUE;
    eof = FALSE;
    buffer = g_malloc(buffer_length);

    thread = g_thread_create(http_buffer_loop, url, TRUE, NULL);

    return 0;
}

220:1e2d575fd2e7

static gsize rd_index, wr_index, buffer_length, prebuffer_length;
static guint64 buffer_read = 0;
static gchar *buffer;
static GThread *thread;
static GtkWidget *error_dialog = NULL;
static unsigned long range;

static VFSFile *output_file = NULL;

#define BASE64_LENGTH(len) (4 * (((len) + 2) / 3))

static gpointer
http_buffer_loop(gpointer arg)
{
    gchar line[1024], *user, *pass, *host, *filename,
        *status, *url, *temp, *temp2, *file;
    gchar *chost;
    gint cnt, written, error, port, cport;
    guint err_len;
    gboolean redirect;
    gint udp_sock = 0;

                                                        "Proxy-Authorization");
                    }
                }
                else
                    file = g_strconcat("/", filename, NULL);
                if (range)
                {
                    temp2 = g_strdup_printf("Range: bytes=%lu-\r\n", range);
                } else
                    temp2 = NULL;
                temp = g_strdup_printf("GET %s HTTP/1.1\r\n"
                                       "Host: %s\r\n"
                                       "User-Agent: %s/%s\r\n"
                                       "%s%s%s%s%s\r\n",
                                       file, host, PACKAGE_NAME, PACKAGE_VERSION,
                                       proxy_auth ? proxy_auth : "",
                                       auth ? auth : "",
                                       "Icy-MetaData:1\r\n",
                                       mpgdec_cfg.
                                       use_udp_channel ? udpspace : "",
				       temp2 != NULL ? temp2 : "");

                g_free(file);
                if (proxy_auth)
                    g_free(proxy_auth);
                if (auth)

                                fprintf(stderr,
                                        "Server wants udp messages on port %d\n",
                                        atoi(line + 20));
#endif
/*  								udp_serverport = atoi (line + 20); */

                            }

                            if (!strncasecmp(line, "content-length:", 15)) {
                                mpgdec_info->filesize = atoi(line + 15);
                            }
                        }
                        else {
                            eof = TRUE;
                            mpgdec_ip.set_info_text(NULL);
                            break;

    return NULL;
}

int
mpgdec_http_open(gchar * _url, unsigned long rng)
{
    gchar *url;

    url = g_strdup(_url);

    prebuffering = TRUE;
    mpgdec_ip.set_status_buffering(TRUE);
    going = TRUE;
    eof = FALSE;
    buffer = g_malloc(buffer_length);
    range = rng;

    thread = g_thread_create(http_buffer_loop, url, TRUE, NULL);

    return 0;
}