1*3398c5b8SAndrew Rist /************************************************************** 2cdf0e10cSrcweir * 3*3398c5b8SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one 4*3398c5b8SAndrew Rist * or more contributor license agreements. See the NOTICE file 5*3398c5b8SAndrew Rist * distributed with this work for additional information 6*3398c5b8SAndrew Rist * regarding copyright ownership. The ASF licenses this file 7*3398c5b8SAndrew Rist * to you under the Apache License, Version 2.0 (the 8*3398c5b8SAndrew Rist * "License"); you may not use this file except in compliance 9*3398c5b8SAndrew Rist * with the License. You may obtain a copy of the License at 10*3398c5b8SAndrew Rist * 11*3398c5b8SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0 12*3398c5b8SAndrew Rist * 13*3398c5b8SAndrew Rist * Unless required by applicable law or agreed to in writing, 14*3398c5b8SAndrew Rist * software distributed under the License is distributed on an 15*3398c5b8SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*3398c5b8SAndrew Rist * KIND, either express or implied. See the License for the 17*3398c5b8SAndrew Rist * specific language governing permissions and limitations 18*3398c5b8SAndrew Rist * under the License. 19*3398c5b8SAndrew Rist * 20*3398c5b8SAndrew Rist *************************************************************/ 21*3398c5b8SAndrew Rist 22*3398c5b8SAndrew Rist 23cdf0e10cSrcweir 24cdf0e10cSrcweir #ifndef TCPIO_HXX 25cdf0e10cSrcweir #define TCPIO_HXX 26cdf0e10cSrcweir 27cdf0e10cSrcweir #include <vos/socket.hxx> 28cdf0e10cSrcweir #include <vos/mutex.hxx> 29cdf0e10cSrcweir 30cdf0e10cSrcweir #include "communiio.hxx" 31cdf0e10cSrcweir 32cdf0e10cSrcweir class TCPIO : public ITransmiter, public IReceiver 33cdf0e10cSrcweir { 34cdf0e10cSrcweir private: 35cdf0e10cSrcweir vos::OStreamSocket *pStreamSocket; 36cdf0e10cSrcweir vos::OMutex aMSocketReadAccess; 37cdf0e10cSrcweir vos::OMutex aMSocketWriteAccess; 38cdf0e10cSrcweir 39cdf0e10cSrcweir public: 40cdf0e10cSrcweir 41cdf0e10cSrcweir /// TCPIO(vos::OStreamSocket * pSocket)42cdf0e10cSrcweir TCPIO( vos::OStreamSocket *pSocket ):pStreamSocket( pSocket ){} ~TCPIO()43cdf0e10cSrcweir virtual ~TCPIO(){} 44cdf0e10cSrcweir 45cdf0e10cSrcweir 46cdf0e10cSrcweir /// implement ITransmiter 47cdf0e10cSrcweir virtual comm_USHORT TransferBytes( const void* pBuffer, comm_UINT32 nLen ); 48cdf0e10cSrcweir 49cdf0e10cSrcweir /// implement IReceiver 50cdf0e10cSrcweir virtual comm_USHORT ReceiveBytes( void* pBuffer, comm_UINT32 nLen ); 51cdf0e10cSrcweir 52cdf0e10cSrcweir // helper 53cdf0e10cSrcweir void SetStreamSocket( vos::OStreamSocket *pSocket ); 54cdf0e10cSrcweir 55cdf0e10cSrcweir }; 56cdf0e10cSrcweir 57cdf0e10cSrcweir #endif 58