/* * Copyright (C) 2000-2004 Damien Douxchamps  <ddouxchamps@users.sf.net> * * 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. */#include "coriander.h"gintFtpStartThread(camera_t* cam){  chain_t* ftp_service=NULL;  ftpthread_info_t *info=NULL;  gchar *tmp;  ftp_service=GetService(camera,SERVICE_FTP);  if (ftp_service==NULL) { // if no FTP service running...    ftp_service=(chain_t*)malloc(sizeof(chain_t));    ftp_service->current_buffer=NULL;    ftp_service->next_buffer=NULL;    ftp_service->data=(void*)malloc(sizeof(ftpthread_info_t));    info=(ftpthread_info_t*)ftp_service->data;    pthread_mutex_init(&ftp_service->mutex_data, NULL);    pthread_mutex_init(&ftp_service->mutex_struct, NULL);    pthread_mutex_init(&info->mutex_cancel, NULL);        /* if you want a clean-interrupt thread:*/    pthread_mutex_lock(&info->mutex_cancel);    info->cancel_req=0;    pthread_mutex_unlock(&info->mutex_cancel);        /* setup ftp_thread: handles, ...*/    pthread_mutex_lock(&ftp_service->mutex_data);    info->period=cam->prefs.ftp_period;    info->datenum=cam->prefs.ftp_datenum;    info->counter=0;    strcpy(info->address, cam->prefs.ftp_address);    strcpy(info->user, cam->prefs.ftp_user);    strcpy(info->password, cam->prefs.ftp_password);    strcpy(info->path, cam->prefs.ftp_path);    strcpy(info->filename, cam->prefs.ftp_filename);    tmp = strrchr(info->filename, '.');        if (tmp==NULL) {      MainError("You should supply an extension");      pthread_mutex_unlock(&ftp_service->mutex_data);      FreeChain(ftp_service);      return(-1);    }        tmp[0] = '\0';// cut filename before point    strcpy(info->filename_ext, strrchr(cam->prefs.ftp_filename, '.'));        CommonChainSetup(cam,ftp_service,SERVICE_FTP);        info->buffer=NULL;    info->imlib_buffer_size=0;        info->scratch=cam->prefs.ftp_scratch;    #ifdef HAVE_FTPLIB    if (!OpenFtpConnection(info)) {      MainError("Failed to open FTP connection");      pthread_mutex_unlock(&ftp_service->mutex_data);      FreeChain(ftp_service);      return(-1);    }#else    MainError("You don't have FTPLIB");    pthread_mutex_unlock(&ftp_service->mutex_data);    FreeChain(ftp_service);    return(-1);#endif        /* Insert chain and start service*/    pthread_mutex_lock(&ftp_service->mutex_struct);    InsertChain(cam, ftp_service);    if (pthread_create(&ftp_service->thread, NULL, FtpThread,(void*) ftp_service)) {      /* error starting thread. You should cleanup here	 (free, unset global vars,...):*/            /* Mendatory cleanups:*/      RemoveChain(cam, ftp_service);      pthread_mutex_unlock(&ftp_service->mutex_struct);      pthread_mutex_unlock(&ftp_service->mutex_data);      free(info->buffer);      FreeChain(ftp_service);      return(-1);    }    pthread_mutex_unlock(&ftp_service->mutex_struct);    pthread_mutex_unlock(&ftp_service->mutex_data);      }    return (1);}void*FtpCleanupThread(void* arg) {  chain_t* ftp_service;  ftpthread_info_t *info;  ftp_service=(chain_t*)arg;  info=(ftpthread_info_t*)ftp_service->data;  /* Specific cleanups: */  /* Mendatory cleanups: */  pthread_mutex_unlock(&ftp_service->mutex_data);  FtpStopThread(camera); // we do this in case of auto-kill from the thread.  return(NULL);}void*FtpThread(void* arg){  static gchar filename_out[STRING_SIZE];  chain_t* ftp_service=NULL;  ftpthread_info_t *info=NULL;  GdkImlibImage *im=NULL;  long int skip_counter;  float tmp;  ftp_service=(chain_t*)arg;  pthread_mutex_lock(&ftp_service->mutex_data);  info=(ftpthread_info_t*)ftp_service->data;  skip_counter=(info->period-1); /* send immediately, then start skipping */  /* These settings depend on the thread. For 100% safe deferred-cancel   threads, I advise you use a custom thread cancel flag. See display thread.*/  pthread_setcancelstate(PTHREAD_CANCEL_DISABLE,NULL);  pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED,NULL);  pthread_mutex_unlock(&ftp_service->mutex_data);   // time inits:  ftp_service->prev_time = times(&ftp_service->tms_buf);  ftp_service->fps_frames=0;  ftp_service->processed_frames=0;  while (1) {     /* Clean cancel handlers */    pthread_mutex_lock(&info->mutex_cancel);    if (info->cancel_req>0) {      break;    }    else {      pthread_mutex_unlock(&info->mutex_cancel);      pthread_mutex_lock(&ftp_service->mutex_data);      if(RollBuffers(ftp_service)) { // have buffers been rolled?	FtpThreadCheckParams(ftp_service);	if (ftp_service->current_buffer->width!=-1) {	  if (skip_counter>=(info->period-1)) {	    skip_counter=0;	    convert_to_rgb(ftp_service->current_buffer, info->buffer);	    switch (info->scratch) {	    case FTP_SCRATCH_OVERWRITE:	      sprintf(filename_out, "%s%s", info->filename,info->filename_ext);	      break;	    case FTP_SCRATCH_SEQUENTIAL:	      switch (info->datenum) {	      case FTP_TAG_DATE:		sprintf(filename_out, "%s-%s%s", info->filename, ftp_service->current_buffer->captime_string, info->filename_ext);		break;	      case FTP_TAG_NUMBER:		sprintf(filename_out,"%s-%10.10li%s", info->filename, info->counter++, info->filename_ext);		break;	      }	      break;	    default:	      break;	    }		    	    im=gdk_imlib_create_image_from_data(info->buffer, NULL, ftp_service->current_buffer->width, ftp_service->current_buffer->height);#ifdef HAVE_FTPLIB	    if (!CheckFtpConnection(info)) {	      MainError("Ftp connection lost for good");	      // AUTO CANCEL THREAD	      pthread_mutex_lock(&info->mutex_cancel);	      info->cancel_req=1;	      pthread_mutex_unlock(&info->mutex_cancel);	    }	    else {	      FtpPutFrame(filename_out, im, info);	    }#endif	    ftp_service->fps_frames++;	    ftp_service->processed_frames++;	    if (im != NULL)	      gdk_imlib_kill_image(im);	  }	  else	    skip_counter++;	  	  // FPS display:	  ftp_service->current_time=times(&ftp_service->tms_buf);	  tmp=(float)(ftp_service->current_time-ftp_service->prev_time)/sysconf(_SC_CLK_TCK);	  if (tmp==0)	    ftp_service->fps=fabs(0.0);	  else	    ftp_service->fps=fabs((float)ftp_service->fps_frames/tmp);	}	pthread_mutex_unlock(&ftp_service->mutex_data);      }      else {	pthread_mutex_unlock(&ftp_service->mutex_data);      }    }    usleep(0);  }  pthread_mutex_unlock(&info->mutex_cancel);  return ((void*)1);}gintFtpStopThread(camera_t* cam){  ftpthread_info_t *info;  chain_t *ftp_service;  ftp_service=GetService(cam,SERVICE_FTP);  if (ftp_service!=NULL) { // if FTP service running...    info=(ftpthread_info_t*)ftp_service->data;    /* Clean cancel handler: */    pthread_mutex_lock(&info->mutex_cancel);    info->cancel_req=1;    pthread_mutex_unlock(&info->mutex_cancel);        /* common handlers...*/    pthread_join(ftp_service->thread, NULL);        pthread_mutex_lock(&ftp_service->mutex_data);    pthread_mutex_lock(&ftp_service->mutex_struct);    RemoveChain(cam,ftp_service);        /* Do custom cleanups here...*/    if (info->buffer!=NULL) {      free(info->buffer);      info->buffer=NULL;    }#ifdef HAVE_FTPLIB    CloseFtpConnection(info->ftp_handle);#endif    /* Mendatory cleanups: */    pthread_mutex_unlock(&ftp_service->mutex_struct);    pthread_mutex_unlock(&ftp_service->mutex_data);    FreeChain(ftp_service);      }  return (1);}voidFtpThreadCheckParams(chain_t *ftp_service){  ftpthread_info_t *info;  int buffer_size_change=0;  info=(ftpthread_info_t*)ftp_service->data;  // copy harmless parameters anyway:  ftp_service->local_param_copy.bpp=ftp_service->current_buffer->bpp;  ftp_service->local_param_copy.bayer_pattern=ftp_service->current_buffer->bayer_pattern;  // if some parameters changed, we need to re-allocate the local buffers and restart the ftp  if ((ftp_service->current_buffer->width!=ftp_service->local_param_copy.width)||      (ftp_service->current_buffer->height!=ftp_service->local_param_copy.height)||      (ftp_service->current_buffer->bytes_per_frame!=ftp_service->local_param_copy.bytes_per_frame)||      (ftp_service->current_buffer->mode!=ftp_service->local_param_copy.mode)||      (ftp_service->current_buffer->format!=ftp_service->local_param_copy.format)||      // check F7 color mode change      ((ftp_service->current_buffer->format==FORMAT_SCALABLE_IMAGE_SIZE)&&       (ftp_service->current_buffer->format7_color_mode!=ftp_service->local_param_copy.format7_color_mode)       ) ||      // check bayer and stereo decoding      (ftp_service->current_buffer->stereo_decoding!=ftp_service->local_param_copy.stereo_decoding)||      (ftp_service->current_buffer->bayer!=ftp_service->local_param_copy.bayer)      ) {    if (ftp_service->current_buffer->width*ftp_service->current_buffer->height!=	ftp_service->local_param_copy.width*ftp_service->local_param_copy.height) {      buffer_size_change=1;    }    else {      buffer_size_change=0;    }        // copy all new parameters:    ftp_service->local_param_copy.width=ftp_service->current_buffer->width;    ftp_service->local_param_copy.height=ftp_service->current_buffer->height;    ftp_service->local_param_copy.bytes_per_frame=ftp_service->current_buffer->bytes_per_frame;    ftp_service->local_param_copy.mode=ftp_service->current_buffer->mode;    ftp_service->local_param_copy.format=ftp_service->current_buffer->format;    ftp_service->local_param_copy.format7_color_mode=ftp_service->current_buffer->format7_color_mode;    ftp_service->local_param_copy.stereo_decoding=ftp_service->current_buffer->stereo_decoding;    ftp_service->local_param_copy.bayer=ftp_service->current_buffer->bayer;    ftp_service->local_param_copy.buffer_image_bytes=ftp_service->current_buffer->buffer_image_bytes;        // DO SOMETHING    if (buffer_size_change!=0) {            if (info->buffer!=NULL) {	free(info->buffer);	info->buffer=NULL;      }      info->imlib_buffer_size=ftp_service->current_buffer->width*ftp_service->current_buffer->height*3;      info->buffer=(unsigned char*)malloc(info->imlib_buffer_size*sizeof(unsigned char));    }  }}#ifdef HAVE_FTPLIBgboolean OpenFtpConnection(ftpthread_info_t* info){  char  tmp[STRING_SIZE];  FtpInit();  //MainStatus("Ftp: starting...\n");  if (!FtpConnect(info->address, &info->ftp_handle)) {    MainError("Ftp: connection to server failed");    return FALSE;  }    if (FtpLogin(info->user, info->password, info->ftp_handle) != 1) {    MainError("Ftp: login failed.");    return FALSE;  }    sprintf(tmp, "Ftp: logged in as %s", info->user);  MainStatus(tmp);    if (info->path != NULL && strcmp(info->path,"")) {    if (!FtpChdir(info->path, info->ftp_handle)) {      MainError("Ftp: chdir failed");      return FALSE;    }    sprintf(tmp, "Ftp: chdir %s", info->path);    MainStatus(tmp);  }    MainStatus("Ftp: ready to send");  return TRUE;}voidCloseFtpConnection(netbuf *ftp_handle){  FtpQuit(ftp_handle);}gbooleanCheckFtpConnection(ftpthread_info_t* info){   if (!FtpChdir(".", info->ftp_handle))    // we can't access the current directory! Connection is probably lost. Reconnect:     if (!OpenFtpConnection(info)) {      MainError("Ftp: Can't restore lost connection");      return FALSE;    }  return TRUE;}gbooleanFtpPutFrame(char *filename, GdkImlibImage *im, ftpthread_info_t* info){  //netbuf **file_handle=NULL;  char *tmp;  tmp=(char*)malloc(STRING_SIZE*sizeof(char));  // we have to write to a local tmp file to convert...    sprintf(tmp,"/tmp/coriander_ftp_image%s",info->filename_ext);  gdk_imlib_save_image(im, tmp, NULL);  if (!FtpPut(tmp, filename, FTPLIB_IMAGE, info->ftp_handle)) {    free(tmp);    MainError("Ftp failed to put file.");    return FALSE;  }  free(tmp);  return TRUE;}#endif // HAVE_FTPLIB