channel.cpp

linux下实现视频播放的播放器

/*
 *  Copyright (C) 2005-2007  gulikoza
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 */

/* $Id$ */

#include "main.h"

#define USES_BASECLASS
#include "video.h"

#include "wxgui/Channel_List.h"

#include <time.h>

//#define DEBUG
#include "log.h"

#define MODULE "Channel"

int Channel::Open(CStr& file)
{
    char line[80];
    FILE *list;

    if(file.empty())
	return 0;

    list = fopen(file.c_str(), "r");
    if(!list) {
	ERROR_MSG("Cannot open file %s", file.c_str());
	return 0;
    }

    // First line shoule be #EXTM3U
    // EXTM3U should be optional
/*
    if(!fgets(line, 80, list)) {
	ERROR_MSG("Emtpy file %s", file);
	return 0;
    }

    if(strcmp(line, "#EXTM3U")) {
	ERROR_MSG("Not an extended m3u playlist");
	return 0;
    }
*/
    // Read until EOF
    int i = 0, j;

    while(fgets(line, 80, list)) {
	i++;
	j = strlen(line) - 1;

	// Delete all control characters at the end
	while((j >= 0) && iscntrl(line[j])) {
	    line[j] = '\0';
	    j--;
	}

	if((strlen(line) < 1) || (!strcmp(line, "#EXTM3U"))) {
	    DEBUG_MSG("Skipping empty line %d", i);
	    continue;
	}

	channels[num].type = 0;

	// Extended info
	char *c;

	if(!strncmp(line, "#EXTINF", 7)) {
	    c = strrchr(line, ',');
	    if(c) {
		c++;
		channels[num].name = c;
		DEBUG_MSG("Found Channel name %s", c);
	    }
	    // Next line should be channel info
	    if(!fgets(line, 80, list)) {
		ERROR_MSG("Truncated file at line %d", i);
		fclose(list);
		return 0;
	    }

	    j = strlen(line) - 1;
	    while((j >= 0) && iscntrl(line[j])) {
		line[j] = '\0';
		j--;
	    }
	    if((c = strchr(c, ';'))) {
		*c = '\0';
	    }

	    if((strlen(line) > 6) && !strncmp(line, "udp://", 6)) {
		channels[num].type = 1;
		c = line + 6;
		if(*c == '@') c++;
	    } else {
		c = line;
	    }
	} else {
	    c = line;
	}

	channels[num].location = c;
	DEBUG_MSG("Found Channel location %s", c);
	num++;
	if(num == MAX_CHANNELS) {
	    ERROR_MSG("Max number for channel list is %d", MAX_CHANNELS);
	    break;
	}
    }

    ERROR_MSG("Found %d channels", num);
    fclose(list);
    return num;
}

bool Channel::Close()
{
    // Check for recording in progress
    if((current) && (sdl.recording)) {
#if (C_HAVE_WXGUI)
	if(wxMessageBox(wxT("Recording is in progress and changing the channel will stop it.\nDo you want to continue?"),
	    wxT("Recording in progress"), wxICON_QUESTION | wxYES_NO) == wxNO)
	    return false;
#endif
	sdl.recording = false;
    }
    sdl_bar.SetRec(sdl.recording);

    if(source) {
	SAFE_DELETE(source);
	SDL_PauseAudio(1);
	close_audio();

	SDL_Event event;

	// Wait for quit events (also process any pending events)
	while((sdl.count) || (events->Peek())) {
	    events->Wait(&event);
	    sdl.decoder = (Decoder *)event.user.data1;
	    // Decoders might be late, sending the event when we are already
	    // closing the channel, they should quit sooner or later :-)
	    if(sdl.decoder)
		sdl.count++;
	    else
		sdl.count--;
	    LOG_MSG("Received decoder address event: 0x%p, remaining: %d", sdl.decoder, sdl.count);
	}

	ERROR_MSG("Channel closed.");
    }
    if(current) {
	last = current;
	current = 0;
    }
    source = NULL;
    return true;
}

bool Channel::SetChannel(unsigned int n)
{
    // 0 is an invalid channel
    if((n == 0) || (n > num))
	return false;

    if(!Close()) return false;
    // because we decrement n by 1 :-)
    n--;

    // Just for the fun of it
    SDL_Delay(50);
    if(sdl.recording == false) sdl.filename.clear();

    try {

	switch (channels[n].type) {
	    case 0:
		source = new fileSource;
		break;
	    case 1:
		source = new udpSource(sdl.iface, sdl.filename);
		break;
	    default:
		ERROR_MSG("Invalid channel type");
		break;
	}
    } catch(const char *c) {
	fprintf(stderr, "[%d] EXCEPTION: %s\n", SDL_GetTicks(), c);
	return false;
    }

    current = n + 1;
    sdl_bar.SetChannel(current, channels[n].name);
    ERROR_MSG("Set channel to %d:%s", current, channels[n].name.c_str());
    bool result = source->Open(channels[n].location);

#if (C_HAVE_WXGUI)
    if((result) && (gui.wxChannelList != NULL) && (gui.wxChannelList->IsVisible())) {
	gui.wxChannelList->FocusChanel(sdl.channel->GetNum());
    }
#endif

    return result;
}

bool Channel::OpenFile(CStr& filename)
{
    if(filename.empty()) return false;
    if(!Close()) return false;
    SDL_Delay(50);

    try {
	source = new fileSource;
    } catch(const char *c) {
	fprintf(stderr, "[%d] EXCEPTION: %s\n", SDL_GetTicks(), c);
	return false;
    }

    sdl_bar.SetChannel(0, filename);
    ERROR_MSG("Open file: %s", filename.c_str());
    return source->Open(filename);
}

void Channel::ToggleRecord()
{
    if(source) {

	source->TerminateThread();
	if(sdl.recording) {
	    source->configure(NULL);
	    sdl.recording = false;
	} else {

	    struct tm *now;
	    time_t t;

	    time(&t);
	    now = localtime(&t);

	    if((*sdl.recordingDir.last() != '\\') && (*sdl.recordingDir.last() != '/')) {
		sdl.recordingDir += '/';
	    }

	    sdl.filename.Format("%s%d%02d%02d %02d%02d%02d - %d %s.ts", sdl.recordingDir.c_str(), now->tm_year + 1900, now->tm_mon + 1, now->tm_mday,
		now->tm_hour, now->tm_min, now->tm_sec, GetNum(), GetName().c_str());

	    source->configure(sdl.filename.c_str());
	    sdl.recording = true;
	}
	source->ThreadCreate();
    }
}