BaseChannelRequester

2011-02-18 17:37:09 +01:00
parent fa23f39967
commit 5af10bb7b6
2 changed files with 237 additions and 0 deletions
@@ -0,0 +1,151 @@
+/*
+ * baseChannelRequester.cpp
+ */
+
+#include "baseChannelRequester.h"
+
+using namespace epics::pvData;
+
+namespace epics { namespace pvAccess {
+
+const Status BaseChannelRequester::okStatus = Status();
+const Status BaseChannelRequester::badCIDStatus = Status(Status::STATUSTYPE_ERROR, "bad channel id");
+const Status BaseChannelRequester::badIOIDStatus = Status(Status::STATUSTYPE_ERROR, "bad request id");
+const Status BaseChannelRequester::noReadACLStatus = Status(Status::STATUSTYPE_ERROR, "no read access");
+const Status BaseChannelRequester::noWriteACLStatus = Status(Status::STATUSTYPE_ERROR, "no write access");
+const Status BaseChannelRequester::noProcessACLStatus = Status(Status::STATUSTYPE_ERROR, "no process access");
+const Status BaseChannelRequester::otherRequestPendingStatus = Status(Status::STATUSTYPE_ERROR, "other request pending");
+
+const int32 BaseChannelRequester::NULL_REQUEST = -1;
+
+BaseChannelRequester::BaseChannelRequester(ServerContextImpl* context, ServerChannelImpl* channel,const pvAccessID ioid, Transport* transport) :
+		_ioid(ioid),
+		_transport(transport),
+		_channel(channel),
+		_context(context),
+		_pendingRequest(BaseChannelRequester::NULL_REQUEST)
+{
+
+}
+
+boolean BaseChannelRequester::startRequest(int32 qos)
+{
+	Lock guard(_mutex);
+	if (_pendingRequest != NULL_REQUEST)
+	{
+		return false;
+	}
+
+	_pendingRequest = qos;
+	return true;
+}
+
+void BaseChannelRequester::stopRequest()
+{
+	Lock guard(_mutex);
+	_pendingRequest = NULL_REQUEST;
+}
+
+int32 BaseChannelRequester::getPendingRequest()
+{
+	Lock guard(_mutex);
+	return _pendingRequest;
+}
+
+String BaseChannelRequester::getRequesterName()
+{
+	stringstream name;
+	name << typeid(*_transport).name() << "/" << _ioid;
+	return name.str();
+}
+
+void BaseChannelRequester::message(const String& message, const epics::pvData::MessageType messageType)
+{
+	BaseChannelRequester::message(_transport, _ioid, message, messageType);
+}
+
+void BaseChannelRequester::message(Transport* transport, const pvAccessID ioid, const String& message, const MessageType messageType)
+{
+	transport->enqueueSendRequest( new BaseChannelRequesterMessageTransportSender(ioid, message, messageType));
+}
+
+void BaseChannelRequester::sendFailureMessage(const int8 command, Transport* transport, const pvAccessID ioid, const int8 qos, const Status status)
+{
+	transport->enqueueSendRequest( new BaseChannelRequesterFailureMessageTransportSender(command, transport, ioid, qos, status));
+}
+
+BaseChannelRequesterMessageTransportSender::BaseChannelRequesterMessageTransportSender(const pvAccessID ioid, const String message,const epics::pvData::MessageType messageType):
+		_ioid(ioid),
+		_message(message),
+		_messageType(messageType)
+{
+}
+
+void BaseChannelRequesterMessageTransportSender::send(ByteBuffer* buffer, TransportSendControl* control)
+{
+	control->startMessage((int8)18, sizeof(int32)/sizeof(int8) + 1);
+	buffer->putInt(_ioid);
+	buffer->putByte((int8)_messageType);
+	epics::pvData::SerializeHelper::serializeString(_message, buffer, control);
+}
+
+void BaseChannelRequesterMessageTransportSender::lock()
+{
+	// noop
+}
+
+void BaseChannelRequesterMessageTransportSender::unlock()
+{
+	// noop
+}
+
+void BaseChannelRequesterMessageTransportSender::release()
+{
+	delete this;
+}
+
+void BaseChannelRequesterMessageTransportSender::acquire()
+{
+	// noop
+}
+
+BaseChannelRequesterFailureMessageTransportSender::BaseChannelRequesterFailureMessageTransportSender(const int8 command,
+		Transport* transport, const pvAccessID ioid, const int8 qos, const Status status) :
+	_command(command),
+	_ioid(ioid),
+	_qos(qos),
+	_status(status),
+	_transport(transport)
+{
+}
+
+void BaseChannelRequesterFailureMessageTransportSender::send(ByteBuffer* buffer, TransportSendControl* control)
+{
+	control->startMessage(_command, sizeof(int32)/sizeof(int8) + 1);
+	buffer->putInt(_ioid);
+	buffer->put(_qos);
+	_transport->getIntrospectionRegistry()->serializeStatus(buffer, control, _status);
+}
+
+void BaseChannelRequesterFailureMessageTransportSender::lock()
+{
+	// noop
+}
+
+void BaseChannelRequesterFailureMessageTransportSender::unlock()
+{
+	// noop
+}
+
+void BaseChannelRequesterFailureMessageTransportSender::release()
+{
+	delete this;
+}
+
+void BaseChannelRequesterFailureMessageTransportSender::acquire()
+{
+	// noop
+}
+
+}
+}