Channel Class Reference

#include <spawn.hpp>

Collaboration diagram for Channel:

Public Types
enum	Direction { CHOUT = 0 , CHIN = 1 }

Public Member Functions
	Channel (int s=2048)
void	Init (int fd, Direction d)
void	Init (Direction d)
void	redirect ()
int	getPipe () const
void	read (std::string *str)
int	write (void *data, int lenght)
void	close ()
void	closeUnused ()
void	wait ()
	~Channel ()

Public Attributes
const int	sz

Private Member Functions
enum Direction	otherDirection (Direction t)
void	restore ()

Private Attributes
int	toBeClosed
int	origin
int	saved
int	fd
std::string *	str
uintptr_t	tid

Friends
unsigned int	bkgread (void *)

Detailed Description

Definition at line 21 of file spawn.hpp.

Member Enumeration Documentation

Direction

enum Channel::Direction

Enumerator
CHOUT
CHIN

Definition at line 24 of file spawn.hpp.

{ CHOUT= 0, CHIN= 1 };

Constructor & Destructor Documentation

Channel()

Channel::Channel

(

int

s = 2048

)

Definition at line 17 of file spawn.cpp.

                       : sz (s) {
  origin    = -1;
  saved     = -1;
  fd        = -1;
  toBeClosed= -1;
  str       = NULL;
  tid       = 0;
}

~Channel()

Channel::~Channel

(

)

Definition at line 100 of file spawn.cpp.

                   {
  closeUnused ();
  close ();
  if (tid) {
    TerminateThread ((HANDLE) tid, -99);
    CloseHandle ((HANDLE) tid);
  }
}

Member Function Documentation

Init() [1/2]

void Channel::Init	(	int	fd,
		Direction	d )

Definition at line 44 of file spawn.cpp.

                                   {
  int pp[2];
  origin= _fd;
  if (_pipe (pp, sz, O_NOINHERIT | _O_BINARY) == 0) {
    fd        = pp[d];
    toBeClosed= pp[otherDirection (d)];
  }
  else origin= -1;
}

Init() [2/2]

void Channel::Init

(

Direction

d

)

Definition at line 27 of file spawn.cpp.

                          {
  int pp[2];
  if (_pipe (pp, sz, O_NOINHERIT | _O_BINARY) == 0) {
    int pr[2];
    if (_pipe (pr, sz, _O_BINARY) == 0) {
      _close (pr[d]);
      _dup2 (pp[otherDirection (d)], pr[otherDirection (d)]);
      _close (pp[otherDirection (d)]);
      fd        = pp[d];
      toBeClosed= pr[otherDirection (d)];
    }
    else _close (pp[d]);
    _close (pp[otherDirection (d)]);
  }
}

redirect()

void Channel::redirect

(

)

Definition at line 55 of file spawn.cpp.

                   {
  if (origin < 0) return;
  saved= _dup (origin);
  _dup2 (toBeClosed, origin);
}

getPipe()

int Channel::getPipe ( ) const

inline

Definition at line 29 of file spawn.hpp.

{ return (toBeClosed); }

read()

void Channel::read

(

std::string *

str

)

Definition at line 62 of file spawn.cpp.

                              {
  str= _str;
  tid= _beginthreadex (NULL, 0, bkgread, this, 0, NULL);
}

write()

int Channel::write ( void * data, int lenght )

inline

Definition at line 31 of file spawn.hpp.

                                            {
    return (_write (fd, data, lenght));
  }

close()

void Channel::close

(

)

Definition at line 68 of file spawn.cpp.

                {
  if (fd >= 0) {
    _close (fd);
    fd= -1;
  }
}

closeUnused()

void Channel::closeUnused

(

)

Definition at line 76 of file spawn.cpp.

                      {
  if (toBeClosed >= 0) {
    _close (toBeClosed);
    toBeClosed= -1;
  }
  restore ();
}

wait()

void Channel::wait

(

)

Definition at line 85 of file spawn.cpp.

               {
  if (tid && WaitForSingleObject ((HANDLE) tid, 5000) == 0 &&
      CloseHandle ((HANDLE) tid))
    tid= 0;
}

otherDirection()

enum Direction Channel::otherDirection ( Direction t )

inlineprivate

Definition at line 41 of file spawn.hpp.

                                                     {
    return (t == CHOUT ? CHIN : CHOUT);
  }

restore()

void Channel::restore ( )

private

Definition at line 92 of file spawn.cpp.

                  {
  if (saved >= 0) {
    _dup2 (saved, origin);
    _close (saved);
    saved= -1;
  }
}

Friends And Related Symbol Documentation

bkgread

unsigned int bkgread ( void * )

friend

Definition at line 110 of file spawn.cpp.

                      {
  char     buf[1024];
  int      cnt;
  Channel* that= (Channel*) thatv;
  do {
    cnt= _read (that->fd, buf, sizeof (buf));
    if (cnt > 0) *(that->str)+= std::basic_string<char> (buf, cnt);
    else if (cnt == 0) that->close ();
  } while (cnt > 0);
  return (cnt);
}

Member Data Documentation

sz

const int Channel::sz

Definition at line 38 of file spawn.hpp.

toBeClosed

int Channel::toBeClosed

private

Definition at line 44 of file spawn.hpp.

origin

int Channel::origin

private

Definition at line 45 of file spawn.hpp.

saved

int Channel::saved

private

Definition at line 46 of file spawn.hpp.

fd

int Channel::fd

private

Definition at line 47 of file spawn.hpp.

str

std::string* Channel::str

private

Definition at line 48 of file spawn.hpp.

tid

uintptr_t Channel::tid

private

Definition at line 49 of file spawn.hpp.

---

The documentation for this class was generated from the following files:

• spawn.hpp
• spawn.cpp