1. tms-old
  2. beam
  3. libBeam
  4. BEvent.cpp
 RSS Git Download  Clone
Raw View History
Blames found: 29 Mode: text/x-c++src Binary: false


Hang on, we reloading big blames...
 6ae0d525
/*******************************************************************************
 57456599
* BEvent.cpp Event class * T.Barnaby, BEAM Ltd, 2005-07-08 * Copyright (c) 2005 All Right Reserved, Beam Ltd, http://www.beam.ltd.uk
 6ae0d525
******************************************************************************* */ #include <BEvent.h> #include <BPoll.h>
 57456599
#include <stdlib.h> #include <unistd.h> #include <sys/ioctl.h> BEvent::BEvent(BUInt32 type, BUInt32 arg) : otype(type), oarg(arg){
 6ae0d525
}
 57456599
BUInt32 BEvent::type(){
 6ae0d525
return otype; }
 57456599
BUInt32 BEvent::arg(){ return oarg;
 6ae0d525
} BEventPipe::BEventPipe(){ pipe(ofds); } BEventPipe::~BEventPipe(){ close(ofds[0]); close(ofds[1]); }
 57456599
void BEventPipe::clear(){ BEvent e;
 6ae0d525
 57456599
while(!read(e, 0));
 6ae0d525
}
 57456599
int BEventPipe::getFd(){
 6ae0d525
return ofds[0]; }
 57456599
BUInt BEventPipe::writeAvailable() const { return 1;
 6ae0d525
}
 57456599
BError BEventPipe::write(const BEvent& event, BTimeout timeout){
 6ae0d525
BError err;
 57456599
::write(ofds[1], &event, sizeof(event));
 6ae0d525
return err; }
 57456599
BUInt BEventPipe::readAvailable() const{ int nBytes = 0; ioctl(ofds[0], FIONREAD, &nBytes); return nBytes / sizeof(BEvent); } BError BEventPipe::read(BEvent& event, BTimeout timeout){
 6ae0d525
BError err; BPoll poll; int fd;
 57456599
if(timeout != BTimeoutForever){
 6ae0d525
poll.append(ofds[0]);
 57456599
if(err = poll.doPoll(fd, timeout))
 6ae0d525
return err; }
 57456599
::read(ofds[0], &event, sizeof(event));
 6ae0d525
return err; }