| 1055 | |
| 1056 | |
| 1057 | int RemotePluginBase::sendMessage( const message & _m ) |
| 1058 | { |
| 1059 | #ifdef SYNC_WITH_SHM_FIFO |
| 1060 | m_out->lock(); |
| 1061 | m_out->writeInt( _m.id ); |
| 1062 | m_out->writeInt( _m.data.size() ); |
| 1063 | int j = 8; |
| 1064 | for( unsigned int i = 0; i < _m.data.size(); ++i ) |
| 1065 | { |
| 1066 | m_out->writeString( _m.data[i] ); |
| 1067 | j += 4 + _m.data[i].size(); |
| 1068 | } |
| 1069 | m_out->unlock(); |
| 1070 | m_out->messageSent(); |
| 1071 | #else |
| 1072 | pthread_mutex_lock( &m_sendMutex ); |
| 1073 | writeInt( _m.id ); |
| 1074 | writeInt( _m.data.size() ); |
| 1075 | int j = 8; |
| 1076 | for( unsigned int i = 0; i < _m.data.size(); ++i ) |
| 1077 | { |
| 1078 | writeString( _m.data[i] ); |
| 1079 | j += 4 + _m.data[i].size(); |
| 1080 | } |
| 1081 | pthread_mutex_unlock( &m_sendMutex ); |
| 1082 | #endif |
| 1083 | |
| 1084 | return j; |
| 1085 | } |
| 1086 | |
| 1087 | |
| 1088 |
no test coverage detected