Blame src/CharReader.cc

Packit Service a2489d
/*
Packit Service a2489d
 * lftp - file transfer program
Packit Service a2489d
 *
Packit Service a2489d
 * Copyright (c) 1996-2012 by Alexander V. Lukyanov (lav@yars.free.net)
Packit Service a2489d
 *
Packit Service a2489d
 * This program is free software; you can redistribute it and/or modify
Packit Service a2489d
 * it under the terms of the GNU General Public License as published by
Packit Service a2489d
 * the Free Software Foundation; either version 3 of the License, or
Packit Service a2489d
 * (at your option) any later version.
Packit Service a2489d
 *
Packit Service a2489d
 * This program is distributed in the hope that it will be useful,
Packit Service a2489d
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit Service a2489d
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
Packit Service a2489d
 * GNU General Public License for more details.
Packit Service a2489d
 *
Packit Service a2489d
 * You should have received a copy of the GNU General Public License
Packit Service a2489d
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
Packit Service a2489d
 */
Packit Service a2489d
Packit Service a2489d
#include <config.h>
Packit Service a2489d
Packit Service a2489d
#include <unistd.h>
Packit Service a2489d
#include <fcntl.h>
Packit Service a2489d
#include <errno.h>
Packit Service a2489d
#include "trio.h"
Packit Service a2489d
#include "CharReader.h"
Packit Service a2489d
Packit Service a2489d
int CharReader::Do()
Packit Service a2489d
{
Packit Service a2489d
   int m=STALL;
Packit Service a2489d
   if(ch!=NOCHAR)
Packit Service a2489d
      return m;
Packit Service a2489d
   if(!Ready(fd,POLLIN))
Packit Service a2489d
   {
Packit Service a2489d
      Block(fd,POLLIN);
Packit Service a2489d
      return m;
Packit Service a2489d
   }
Packit Service a2489d
Packit Service a2489d
   int oldfl=fcntl(fd,F_GETFL);
Packit Service a2489d
   if(!(oldfl&O_NONBLOCK))
Packit Service a2489d
      fcntl(fd,F_SETFL,oldfl|O_NONBLOCK);
Packit Service a2489d
Packit Service a2489d
   unsigned char c;
Packit Service a2489d
   int res=read(fd,&c,1);
Packit Service a2489d
   if(res==-1 && errno==EAGAIN)
Packit Service a2489d
      Block(fd,POLLIN);
Packit Service a2489d
   else if(res==-1 && errno==EINTR)
Packit Service a2489d
      m=MOVED;
Packit Service a2489d
   else if(res>0)
Packit Service a2489d
   {
Packit Service a2489d
      ch=c;
Packit Service a2489d
      m=MOVED;
Packit Service a2489d
   }
Packit Service a2489d
   else	 // eof or error.
Packit Service a2489d
   {
Packit Service a2489d
      ch=EOFCHAR;
Packit Service a2489d
      m=MOVED;
Packit Service a2489d
   }
Packit Service a2489d
Packit Service a2489d
   if(!(oldfl&O_NONBLOCK))
Packit Service a2489d
      fcntl(fd,F_SETFL,oldfl);
Packit Service a2489d
Packit Service a2489d
   if(res==-1 && ch==EOFCHAR)
Packit Service a2489d
      fprintf(stderr,"read(%d): %s\n",fd,strerror(errno));
Packit Service a2489d
Packit Service a2489d
   return m;
Packit Service a2489d
}