BSession is no longer a parent class

Removal of deprecated reply functions
Global protocol change - reply port is at the end of data, not the beginning
PortLink still uses the BSession messaging style


git-svn-id: file:///srv/svn/repos/haiku/trunk/current@4933 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
DarkWyrm
2003-10-03 22:20:28 +00:00
parent 041e26d578
commit 7b6beb9bde
+30 -41
View File
@@ -1,58 +1,47 @@
#ifndef _PORTLINK_H #ifndef _PORTLINK_H
#define _PORTLINK_H #define _PORTLINK_H
#include <BeBuild.h> #include <BeBuild.h>
#include <OS.h> #include <OS.h>
#include "Session.h"
class PortMessage; class PortMessage;
class PortLink : public BSession{ class PortLink
{
public: public:
class ReplyData PortLink(port_id port);
{ PortLink(const PortLink &link);
public: virtual ~PortLink(void) { }
ReplyData(void) { code=0; buffersize=0; buffer=NULL; }
~ReplyData(void) { if(buffer) delete buffer; }
int32 code;
ssize_t buffersize;
int8 *buffer;
};
PortLink( port_id port );
PortLink( const PortLink &link );
virtual ~PortLink() { }
void SetOpCode( int32 code ); void SetOpCode(int32 code);
void SetPort( port_id port );
port_id GetPort(); void SetPort(port_id port);
status_t Flush( bigtime_t timeout = B_INFINITE_TIMEOUT ); port_id GetPort();
int8* FlushWithReply( int32 *code, status_t *status, ssize_t *buffersize,
bigtime_t timeout=B_INFINITE_TIMEOUT ); status_t Flush(bigtime_t timeout = B_INFINITE_TIMEOUT);
status_t FlushWithReply( PortLink::ReplyData *data,bigtime_t timeout=B_INFINITE_TIMEOUT ); status_t FlushWithReply(PortMessage *msg,bigtime_t timeout=B_INFINITE_TIMEOUT);
status_t FlushWithReply( PortMessage *msg,bigtime_t timeout=B_INFINITE_TIMEOUT );
status_t Attach(const void *data, size_t size); void MakeEmpty();
void MakeEmpty(); status_t Attach(const void *data, size_t size);
template <class Type> status_t Attach(Type data) template <class Type> status_t Attach(Type data)
{ {
int32 size = sizeof(Type); int32 size = sizeof(Type);
if (4096 - fSendPosition > size){ if (4096 - fSendPosition > size){
memcpy(fSendBuffer + fSendPosition, &data, size); memcpy(fSendBuffer + fSendPosition, &data, size);
fSendPosition += size; fSendPosition += size;
return B_OK; return B_OK;
}
return B_NO_MEMORY;
} }
return B_NO_MEMORY;
}
private: private:
bool port_ok; bool port_ok;
port_id fSendPort;
port_id fReceivePort;
char *fSendBuffer;
int32 fSendPosition;
int32 fSendCode;
}; };
//extern _IMPEXP_BE _PortLink_ *main_session;
#endif #endif