Changeset 501

Show
Ignore:
Timestamp:
08/15/07 02:23:09 (1 year ago)
Author:
blackhedd
Message:

refactored pipes to avoid opening a useless I/O stream.

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • version_0/ext/ed.h

    r454 r501  
    269269{ 
    270270        public: 
    271                 PipeDescriptor (FILE*, pid_t, EventMachine_t*); 
     271                PipeDescriptor (int, pid_t, EventMachine_t*); 
    272272                virtual ~PipeDescriptor(); 
    273273 
     
    297297                time_t LastIo; 
    298298                int InactivityTimeout; 
    299                 //FILE *MyStream; 
    300299 
    301300                deque<OutboundPage> OutboundPages; 
  • version_0/ext/em.cpp

    r393 r501  
    13761376        if (f > 0) { 
    13771377                close (sv[1]); 
    1378                 PipeDescriptor *pd = new PipeDescriptor (fdopen(sv[0], "r+"), f, this); 
     1378                PipeDescriptor *pd = new PipeDescriptor (sv[0], f, this); 
    13791379                if (!pd) 
    13801380                        throw std::runtime_error ("unable to allocate pipe"); 
  • version_0/ext/pipe.cpp

    r408 r501  
    2828******************************/ 
    2929 
    30 PipeDescriptor::PipeDescriptor (FILE *fp, pid_t subpid, EventMachine_t *parent_em): 
    31         EventableDescriptor (fileno (fp), parent_em), 
     30PipeDescriptor::PipeDescriptor (int fd, pid_t subpid, EventMachine_t *parent_em): 
     31        EventableDescriptor (fd, parent_em), 
    3232        bReadAttemptedAfterClose (false), 
    3333        LastIo (gCurrentLoopTime), 
    3434        InactivityTimeout (0), 
    35         //MyStream (fp), 
    3635        OutboundDataSize (0), 
    3736        SubprocessPid (subpid)