src/kits/media/experimental/MediaConnection.cpp

   1 /*
   2  * Copyright 2015, Dario Casalinuovo. All rights reserved.
   3  * Distributed under the terms of the MIT License.
   4  */
   5
   6 #include <MediaConnection.h>
   7
   8 #include "MediaClientNode.h"
   9
  10 #include "debug.h"
  11
  12
  13 BMediaConnection::BMediaConnection(media_connection_kinds kinds)
  14         :
  15         fOwner(NULL),
  16         fBind(NULL),
  17         fBufferGroup(NULL),
  18         fMinLatency(0),
  19         fMaxLatency(0)
  20 {
  21         CALLED();
  22
  23         fConnection.kinds = kinds;
  24         fConnection.id = -1;
  25         //fConnection.client = media_client::null;
  26 }
  27
  28
  29 BMediaConnection::~BMediaConnection()
  30 {
  31         CALLED();
  32
  33 }
  34
  35
  36 const media_connection&
  37 BMediaConnection::Connection() const
  38 {
  39         return fConnection;
  40 }
  41
  42
  43 BMediaClient*
  44 BMediaConnection::Client() const
  45 {
  46         return fOwner;
  47 }
  48
  49
  50 bool
  51 BMediaConnection::HasBinding() const
  52 {
  53         CALLED();
  54
  55         return fBind != NULL;
  56 }
  57
  58
  59 BMediaConnection*
  60 BMediaConnection::Binding() const
  61 {
  62         CALLED();
  63
  64         return fBind;
  65 }
  66
  67
  68 void
  69 BMediaConnection::SetAcceptedFormat(const media_format& format)
  70 {
  71         CALLED();
  72
  73         fConnection.format = format;
  74 }
  75
  76
  77 const media_format&
  78 BMediaConnection::AcceptedFormat() const
  79 {
  80         CALLED();
  81
  82         return fConnection.format;
  83 }
  84
  85
  86 bool
  87 BMediaConnection::IsConnected() const
  88 {
  89         CALLED();
  90
  91         return fConnected;
  92 }
  93
  94
  95 status_t
  96 BMediaConnection::Disconnect()
  97 {
  98         CALLED();
  99
 100         status_t ret = fOwner->_DisconnectConnection(this);
 101         if (ret != B_OK)
 102                 return ret;
 103
 104         delete fBufferGroup;
 105         fBufferGroup = NULL;
 106
 107         return ret;
 108 }
 109
 110
 111 status_t
 112 BMediaConnection::Release()
 113 {
 114         CALLED();
 115
 116         status_t ret = fOwner->_ReleaseConnection(this);
 117         if (ret != B_OK)
 118                 return ret;
 119
 120         delete this;
 121         return ret;
 122 }
 123
 124
 125 size_t
 126 BMediaConnection::BufferSize() const
 127 {
 128         CALLED();
 129
 130         switch (fConnection.format.type) {
 131                 case B_MEDIA_RAW_AUDIO:
 132                         return fConnection.format.u.raw_audio.buffer_size;
 133
 134                 case B_MEDIA_RAW_VIDEO:
 135                         return fConnection.format.u.raw_video.display.bytes_per_row *
 136                                 fConnection.format.u.raw_video.display.line_count;
 137
 138                 default:
 139                         return 0;
 140         }
 141 }
 142
 143
 144 void
 145 BMediaConnection::Connected(const media_format& format)
 146 {
 147         fConnected = true;
 148 }
 149
 150
 151 void
 152 BMediaConnection::Disconnected()
 153 {
 154         fConnected = false;
 155 }
 156
 157
 158 void
 159 BMediaConnection::GetLatencyRange(bigtime_t* min, bigtime_t* max) const
 160 {
 161         CALLED();
 162
 163         *min = fMinLatency;
 164         *max = fMaxLatency;
 165 }
 166
 167
 168 void
 169 BMediaConnection::SetLatencyRange(bigtime_t min, bigtime_t max)
 170 {
 171         CALLED();
 172
 173         fMinLatency = min;
 174         fMaxLatency = max;
 175 }
 176
 177
 178 void
 179 BMediaConnection::_ConnectionRegistered(BMediaClient* owner,
 180         media_connection_id id)
 181 {
 182         fOwner = owner;
 183         fConnection.id = id;
 184         fConnection.client = fOwner->Client();
 185
 186         if (fConnection.IsOutput()) {
 187                 fConnection.source.port = fOwner->fNode->ControlPort();
 188                 fConnection.source.id = fConnection.id;
 189
 190                 fConnection.destination = media_destination::null;
 191         } else {
 192                 fConnection.destination.port = fOwner->fNode->ControlPort();
 193                 fConnection.destination.id = fConnection.id;
 194
 195                 fConnection.source = media_source::null;
 196         }
 197 }
 198
 199
 200 const media_source&
 201 BMediaConnection::_Source() const
 202 {
 203         return fConnection._Source();
 204 }
 205
 206
 207 const media_destination&
 208 BMediaConnection::_Destination() const
 209 {
 210         return fConnection._Destination();
 211 }
 212
 213
 214 void BMediaConnection::_ReservedMediaConnection0() {}
 215 void BMediaConnection::_ReservedMediaConnection1() {}
 216 void BMediaConnection::_ReservedMediaConnection2() {}
 217 void BMediaConnection::_ReservedMediaConnection3() {}
 218 void BMediaConnection::_ReservedMediaConnection4() {}
 219 void BMediaConnection::_ReservedMediaConnection5() {}
 220 void BMediaConnection::_ReservedMediaConnection6() {}
 221 void BMediaConnection::_ReservedMediaConnection7() {}
 222 void BMediaConnection::_ReservedMediaConnection8() {}
 223 void BMediaConnection::_ReservedMediaConnection9() {}
 224 void BMediaConnection::_ReservedMediaConnection10() {}
 225
 226
 227 BMediaInput::BMediaInput()
 228         :
 229         BMediaConnection(B_MEDIA_INPUT)
 230 {
 231 }
 232
 233
 234 BMediaInput::~BMediaInput()
 235 {
 236         CALLED();
 237 }
 238
 239
 240 status_t
 241 BMediaInput::FormatChanged(const media_format& format)
 242 {
 243         if (!format_is_compatible(format, AcceptedFormat()))
 244                 return B_MEDIA_BAD_FORMAT;
 245
 246         SetAcceptedFormat(format);
 247
 248         return B_OK;
 249 }
 250
 251
 252 void
 253 BMediaInput::HandleBuffer(BBuffer* buffer)
 254 {
 255         CALLED();
 256
 257 }
 258
 259
 260 media_input
 261 BMediaInput::_MediaInput() const
 262 {
 263         return Connection()._MediaInput();
 264 }
 265
 266
 267 void BMediaInput::_ReservedMediaInput0() {}
 268 void BMediaInput::_ReservedMediaInput1() {}
 269 void BMediaInput::_ReservedMediaInput2() {}
 270 void BMediaInput::_ReservedMediaInput3() {}
 271 void BMediaInput::_ReservedMediaInput4() {}
 272 void BMediaInput::_ReservedMediaInput5() {}
 273 void BMediaInput::_ReservedMediaInput6() {}
 274 void BMediaInput::_ReservedMediaInput7() {}
 275 void BMediaInput::_ReservedMediaInput8() {}
 276 void BMediaInput::_ReservedMediaInput9() {}
 277 void BMediaInput::_ReservedMediaInput10() {}
 278
 279
 280 BMediaOutput::BMediaOutput()
 281         :
 282         BMediaConnection(B_MEDIA_OUTPUT)
 283 {
 284 }
 285
 286
 287 BMediaOutput::~BMediaOutput()
 288 {
 289         CALLED();
 290 }
 291
 292
 293 bool
 294 BMediaOutput::IsEnabled() const
 295 {
 296         CALLED();
 297
 298         return fEnabled;
 299 }
 300
 301
 302 void
 303 BMediaOutput::SetEnabled(bool enabled)
 304 {
 305         fEnabled = enabled;
 306 }
 307
 308
 309 status_t
 310 BMediaOutput::PrepareToConnect(media_format* format)
 311 {
 312         if (!format_is_compatible(AcceptedFormat(), *format))
 313                 return B_ERROR;
 314
 315         SetAcceptedFormat(*format);
 316
 317         return B_OK;
 318 }
 319
 320
 321 status_t
 322 BMediaOutput::FormatProposal(media_format* format)
 323 {
 324         *format = AcceptedFormat();
 325         return B_OK;
 326 }
 327
 328
 329 status_t
 330 BMediaOutput::FormatChangeRequested(media_format* format)
 331 {
 332         return B_ERROR;
 333 }
 334
 335
 336 status_t
 337 BMediaOutput::SendBuffer(BBuffer* buffer)
 338 {
 339         CALLED();
 340
 341         if (!IsConnected())
 342                 return B_ERROR;
 343
 344         return fOwner->fNode->SendBuffer(buffer, this);
 345 }
 346
 347
 348 media_output
 349 BMediaOutput::_MediaOutput() const
 350 {
 351         return Connection()._MediaOutput();
 352 }
 353
 354
 355 void BMediaOutput::_ReservedMediaOutput0() {}
 356 void BMediaOutput::_ReservedMediaOutput1() {}
 357 void BMediaOutput::_ReservedMediaOutput2() {}
 358 void BMediaOutput::_ReservedMediaOutput3() {}
 359 void BMediaOutput::_ReservedMediaOutput4() {}
 360 void BMediaOutput::_ReservedMediaOutput5() {}
 361 void BMediaOutput::_ReservedMediaOutput6() {}
 362 void BMediaOutput::_ReservedMediaOutput7() {}
 363 void BMediaOutput::_ReservedMediaOutput8() {}
 364 void BMediaOutput::_ReservedMediaOutput9() {}
 365 void BMediaOutput::_ReservedMediaOutput10() {}