Copyright 1999, Be Incorporated. All Rights Reserved.
This file may be used under the terms of the Be Sample Code License.
*/
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <Debug.h>
#include <FindDirectory.h>
#include <InterfaceDefs.h>
#include <Message.h>
#include <OS.h>
#include <add-ons/input_server/InputServerDevice.h>
#include <SupportDefs.h>
extern "C" _EXPORT BInputServerDevice* instantiate_input_device();
class ViewInputDevice;
class ViewInputDevice : public BInputServerDevice {
public:
ViewInputDevice();
virtual ~ViewInputDevice();
virtual status_t Start(const char *device, void *cookie);
virtual status_t Stop(const char *device, void *cookie);
private:
thread_id _Thread;
static int32 _StartWatchPort(void *arg);
void _WatchPort();
port_id _Port;
};
BInputServerDevice* instantiate_input_device()
{
return (new ViewInputDevice());
}
ViewInputDevice::ViewInputDevice()
: BInputServerDevice()
{
input_device_ref *device[2];
input_device_ref mover = {"ViewInputDevice", B_POINTING_DEVICE, NULL};
device[0] = &mover;
device[1] = NULL;
_Port = -1;
RegisterDevices(device);
}
ViewInputDevice::~ViewInputDevice()
{
}
status_t ViewInputDevice::Start(const char *device, void *cookie)
{
_Port = find_port("ViewInputDevice");
if(_Port < 0) {
_sPrintf("ViewInputDevice: find_port error: (0x%x) %s\n",_Port,strerror(_Port));
return(_Port);
}
_Thread = spawn_thread(_StartWatchPort, device, B_REAL_TIME_DISPLAY_PRIORITY+4, this);
resume_thread(_Thread);
return (B_NO_ERROR);
}
status_t ViewInputDevice::Stop(const char *device, void *cookie)
{
kill_thread(_Thread);
_Port = -1;
return (B_NO_ERROR);
}
int32 ViewInputDevice::_StartWatchPort(void *arg)
{
ViewInputDevice *self = (ViewInputDevice*)arg;
self->_WatchPort();
return (B_NO_ERROR);
}
void ViewInputDevice::_WatchPort()
{
int32 code;
ssize_t length;
char *buffer;
BMessage *event;
status_t err;
while (true) {
length = port_buffer_size(_Port);
buffer = (char*)malloc(length);
event = NULL;
event = new BMessage();
err = read_port(_Port, &code, buffer, length);
if(err != length) {
if(err >= 0) {
_sPrintf("ViewInputDevice: failed to read full packet (read %u of %u)\n",err,length);
} else {
_sPrintf("ViewInputDevice: read_port error: (0x%x) %s\n",err,strerror(err));
}
} else if ((err = event->Unflatten(buffer)) < 0) {
_sPrintf("ViewInputDevice: (0x%x) %s\n",err,strerror(err));
} else {
EnqueueMessage(event);
event = NULL;
}
free( buffer);
if(event!=NULL) {
delete(event);
event = NULL;
}
}
}
