| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "media/midi/dynamically_initialized_midi_manager_win.h" | 5 #include "media/midi/midi_manager_win.h" |
| 6 | 6 |
| 7 #include <windows.h> | 7 #include <windows.h> |
| 8 | 8 |
| 9 #include <ks.h> | 9 #include <ks.h> |
| 10 #include <ksmedia.h> | 10 #include <ksmedia.h> |
| 11 #include <mmreg.h> | 11 #include <mmreg.h> |
| 12 #include <mmsystem.h> | 12 #include <mmsystem.h> |
| 13 | 13 |
| 14 #include <algorithm> | 14 #include <algorithm> |
| 15 #include <string> | 15 #include <string> |
| (...skipping 11 matching lines...) Expand all Loading... |
| 27 #include "media/midi/message_util.h" | 27 #include "media/midi/message_util.h" |
| 28 #include "media/midi/midi_manager_winrt.h" | 28 #include "media/midi/midi_manager_winrt.h" |
| 29 #include "media/midi/midi_port_info.h" | 29 #include "media/midi/midi_port_info.h" |
| 30 #include "media/midi/midi_service.h" | 30 #include "media/midi/midi_service.h" |
| 31 #include "media/midi/midi_switches.h" | 31 #include "media/midi/midi_switches.h" |
| 32 | 32 |
| 33 namespace midi { | 33 namespace midi { |
| 34 | 34 |
| 35 // Forward declaration of PortManager for anonymous functions and internal | 35 // Forward declaration of PortManager for anonymous functions and internal |
| 36 // classes to use it. | 36 // classes to use it. |
| 37 class DynamicallyInitializedMidiManagerWin::PortManager { | 37 class MidiManagerWin::PortManager { |
| 38 public: | 38 public: |
| 39 // Calculates event time from elapsed time that system provides. | 39 // Calculates event time from elapsed time that system provides. |
| 40 base::TimeTicks CalculateInEventTime(size_t index, uint32_t elapsed_ms) const; | 40 base::TimeTicks CalculateInEventTime(size_t index, uint32_t elapsed_ms) const; |
| 41 | 41 |
| 42 // Registers HMIDIIN handle to resolve port index. | 42 // Registers HMIDIIN handle to resolve port index. |
| 43 void RegisterInHandle(HMIDIIN handle, size_t index); | 43 void RegisterInHandle(HMIDIIN handle, size_t index); |
| 44 | 44 |
| 45 // Unregisters HMIDIIN handle. | 45 // Unregisters HMIDIIN handle. |
| 46 void UnregisterInHandle(HMIDIIN handle); | 46 void UnregisterInHandle(HMIDIIN handle); |
| 47 | 47 |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 97 // TODO(toyoshim): Consider to use linked small buffers so that midiOutReset() | 97 // TODO(toyoshim): Consider to use linked small buffers so that midiOutReset() |
| 98 // can abort sending unhandled following buffers. | 98 // can abort sending unhandled following buffers. |
| 99 constexpr size_t kSysExSizeLimit = 256 * 1024; | 99 constexpr size_t kSysExSizeLimit = 256 * 1024; |
| 100 | 100 |
| 101 // Defines input buffer size. | 101 // Defines input buffer size. |
| 102 constexpr size_t kBufferLength = 32 * 1024; | 102 constexpr size_t kBufferLength = 32 * 1024; |
| 103 | 103 |
| 104 // Global variables to identify MidiManager instance. | 104 // Global variables to identify MidiManager instance. |
| 105 constexpr int kInvalidInstanceId = -1; | 105 constexpr int kInvalidInstanceId = -1; |
| 106 int g_active_instance_id = kInvalidInstanceId; | 106 int g_active_instance_id = kInvalidInstanceId; |
| 107 DynamicallyInitializedMidiManagerWin* g_manager_instance = nullptr; | 107 MidiManagerWin* g_manager_instance = nullptr; |
| 108 | 108 |
| 109 // Obtains base::Lock instance pointer to lock instance_id. | 109 // Obtains base::Lock instance pointer to lock instance_id. |
| 110 base::Lock* GetInstanceIdLock() { | 110 base::Lock* GetInstanceIdLock() { |
| 111 static base::Lock* lock = new base::Lock; | 111 static base::Lock* lock = new base::Lock; |
| 112 return lock; | 112 return lock; |
| 113 } | 113 } |
| 114 | 114 |
| 115 // Issues unique MidiManager instance ID. | 115 // Issues unique MidiManager instance ID. |
| 116 int IssueNextInstanceId() { | 116 int IssueNextInstanceId() { |
| 117 static int id = kInvalidInstanceId; | 117 static int id = kInvalidInstanceId; |
| (...skipping 171 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 289 uint32_t device_id_; | 289 uint32_t device_id_; |
| 290 const uint16_t manufacturer_id_; | 290 const uint16_t manufacturer_id_; |
| 291 const uint16_t product_id_; | 291 const uint16_t product_id_; |
| 292 const uint32_t driver_version_; | 292 const uint32_t driver_version_; |
| 293 const std::string product_name_; | 293 const std::string product_name_; |
| 294 MidiPortInfo info_; | 294 MidiPortInfo info_; |
| 295 }; // class Port | 295 }; // class Port |
| 296 | 296 |
| 297 } // namespace | 297 } // namespace |
| 298 | 298 |
| 299 class DynamicallyInitializedMidiManagerWin::InPort final : public Port { | 299 class MidiManagerWin::InPort final : public Port { |
| 300 public: | 300 public: |
| 301 InPort(DynamicallyInitializedMidiManagerWin* manager, | 301 InPort(MidiManagerWin* manager, |
| 302 int instance_id, | 302 int instance_id, |
| 303 UINT device_id, | 303 UINT device_id, |
| 304 const MIDIINCAPS2W& caps) | 304 const MIDIINCAPS2W& caps) |
| 305 : Port("input", | 305 : Port("input", |
| 306 device_id, | 306 device_id, |
| 307 caps.wMid, | 307 caps.wMid, |
| 308 caps.wPid, | 308 caps.wPid, |
| 309 caps.vDriverVersion, | 309 caps.vDriverVersion, |
| 310 base::WideToUTF8( | 310 base::WideToUTF8( |
| 311 base::string16(caps.szPname, wcslen(caps.szPname))), | 311 base::string16(caps.szPname, wcslen(caps.szPname))), |
| 312 caps.ManufacturerGuid), | 312 caps.ManufacturerGuid), |
| 313 manager_(manager), | 313 manager_(manager), |
| 314 in_handle_(kInvalidInHandle), | 314 in_handle_(kInvalidInHandle), |
| 315 instance_id_(instance_id) {} | 315 instance_id_(instance_id) {} |
| 316 | 316 |
| 317 static std::vector<std::unique_ptr<InPort>> EnumerateActivePorts( | 317 static std::vector<std::unique_ptr<InPort>> EnumerateActivePorts( |
| 318 DynamicallyInitializedMidiManagerWin* manager, | 318 MidiManagerWin* manager, |
| 319 int instance_id) { | 319 int instance_id) { |
| 320 std::vector<std::unique_ptr<InPort>> ports; | 320 std::vector<std::unique_ptr<InPort>> ports; |
| 321 const UINT num_devices = midiInGetNumDevs(); | 321 const UINT num_devices = midiInGetNumDevs(); |
| 322 for (UINT device_id = 0; device_id < num_devices; ++device_id) { | 322 for (UINT device_id = 0; device_id < num_devices; ++device_id) { |
| 323 MIDIINCAPS2W caps; | 323 MIDIINCAPS2W caps; |
| 324 MMRESULT result = midiInGetDevCaps( | 324 MMRESULT result = midiInGetDevCaps( |
| 325 device_id, reinterpret_cast<LPMIDIINCAPSW>(&caps), sizeof(caps)); | 325 device_id, reinterpret_cast<LPMIDIINCAPSW>(&caps), sizeof(caps)); |
| 326 if (result != MMSYSERR_NOERROR) { | 326 if (result != MMSYSERR_NOERROR) { |
| 327 LOG(ERROR) << "midiInGetDevCaps fails on device " << device_id; | 327 LOG(ERROR) << "midiInGetDevCaps fails on device " << device_id; |
| 328 continue; | 328 continue; |
| 329 } | 329 } |
| 330 ports.push_back( | 330 ports.push_back( |
| 331 base::MakeUnique<InPort>(manager, instance_id, device_id, caps)); | 331 base::MakeUnique<InPort>(manager, instance_id, device_id, caps)); |
| 332 } | 332 } |
| 333 return ports; | 333 return ports; |
| 334 } | 334 } |
| 335 | 335 |
| 336 void Finalize(scoped_refptr<base::SingleThreadTaskRunner> runner) { | 336 void Finalize(scoped_refptr<base::SingleThreadTaskRunner> runner) { |
| 337 if (in_handle_ != kInvalidInHandle) { | 337 if (in_handle_ != kInvalidInHandle) { |
| 338 runner->PostTask( | 338 runner->PostTask(FROM_HERE, base::Bind(&FinalizeInPort, in_handle_, |
| 339 FROM_HERE, | 339 base::Passed(&hdr_))); |
| 340 base::Bind(&FinalizeInPort, in_handle_, base::Passed(&hdr_))); | |
| 341 manager_->port_manager()->UnregisterInHandle(in_handle_); | 340 manager_->port_manager()->UnregisterInHandle(in_handle_); |
| 342 in_handle_ = kInvalidInHandle; | 341 in_handle_ = kInvalidInHandle; |
| 343 } | 342 } |
| 344 } | 343 } |
| 345 | 344 |
| 346 base::TimeTicks CalculateInEventTime(uint32_t elapsed_ms) const { | 345 base::TimeTicks CalculateInEventTime(uint32_t elapsed_ms) const { |
| 347 return start_time_ + base::TimeDelta::FromMilliseconds(elapsed_ms); | 346 return start_time_ + base::TimeDelta::FromMilliseconds(elapsed_ms); |
| 348 } | 347 } |
| 349 | 348 |
| 350 void RestoreBuffer() { | 349 void RestoreBuffer() { |
| 351 if (in_handle_ == kInvalidInHandle || !hdr_) | 350 if (in_handle_ == kInvalidInHandle || !hdr_) |
| 352 return; | 351 return; |
| 353 midiInAddBuffer(in_handle_, hdr_.get(), sizeof(*hdr_)); | 352 midiInAddBuffer(in_handle_, hdr_.get(), sizeof(*hdr_)); |
| 354 } | 353 } |
| 355 | 354 |
| 356 void NotifyPortStateSet(DynamicallyInitializedMidiManagerWin* manager) { | 355 void NotifyPortStateSet(MidiManagerWin* manager) { |
| 357 manager->PostReplyTask( | 356 manager->PostReplyTask(base::Bind(&MidiManagerWin::SetInputPortState, |
| 358 base::Bind(&DynamicallyInitializedMidiManagerWin::SetInputPortState, | 357 base::Unretained(manager), index_, |
| 359 base::Unretained(manager), index_, info_.state)); | 358 info_.state)); |
| 360 } | 359 } |
| 361 | 360 |
| 362 void NotifyPortAdded(DynamicallyInitializedMidiManagerWin* manager) { | 361 void NotifyPortAdded(MidiManagerWin* manager) { |
| 363 manager->PostReplyTask( | 362 manager->PostReplyTask(base::Bind(&MidiManagerWin::AddInputPort, |
| 364 base::Bind(&DynamicallyInitializedMidiManagerWin::AddInputPort, | 363 base::Unretained(manager), info_)); |
| 365 base::Unretained(manager), info_)); | |
| 366 } | 364 } |
| 367 | 365 |
| 368 // Port overrides: | 366 // Port overrides: |
| 369 bool Disconnect() override { | 367 bool Disconnect() override { |
| 370 if (in_handle_ != kInvalidInHandle) { | 368 if (in_handle_ != kInvalidInHandle) { |
| 371 // Following API call may fail because device was already disconnected. | 369 // Following API call may fail because device was already disconnected. |
| 372 // But just in case. | 370 // But just in case. |
| 373 midiInClose(in_handle_); | 371 midiInClose(in_handle_); |
| 374 manager_->port_manager()->UnregisterInHandle(in_handle_); | 372 manager_->port_manager()->UnregisterInHandle(in_handle_); |
| 375 in_handle_ = kInvalidInHandle; | 373 in_handle_ = kInvalidInHandle; |
| (...skipping 25 matching lines...) Expand all Loading... |
| 401 midiInUnprepareHeader(in_handle_, hdr_.get(), sizeof(*hdr_)); | 399 midiInUnprepareHeader(in_handle_, hdr_.get(), sizeof(*hdr_)); |
| 402 hdr_.reset(); | 400 hdr_.reset(); |
| 403 midiInClose(in_handle_); | 401 midiInClose(in_handle_); |
| 404 in_handle_ = kInvalidInHandle; | 402 in_handle_ = kInvalidInHandle; |
| 405 } | 403 } |
| 406 Disconnect(); | 404 Disconnect(); |
| 407 } | 405 } |
| 408 } | 406 } |
| 409 | 407 |
| 410 private: | 408 private: |
| 411 DynamicallyInitializedMidiManagerWin* manager_; | 409 MidiManagerWin* manager_; |
| 412 HMIDIIN in_handle_; | 410 HMIDIIN in_handle_; |
| 413 ScopedMIDIHDR hdr_; | 411 ScopedMIDIHDR hdr_; |
| 414 base::TimeTicks start_time_; | 412 base::TimeTicks start_time_; |
| 415 const int instance_id_; | 413 const int instance_id_; |
| 416 }; | 414 }; |
| 417 | 415 |
| 418 class DynamicallyInitializedMidiManagerWin::OutPort final : public Port { | 416 class MidiManagerWin::OutPort final : public Port { |
| 419 public: | 417 public: |
| 420 OutPort(UINT device_id, const MIDIOUTCAPS2W& caps) | 418 OutPort(UINT device_id, const MIDIOUTCAPS2W& caps) |
| 421 : Port("output", | 419 : Port("output", |
| 422 device_id, | 420 device_id, |
| 423 caps.wMid, | 421 caps.wMid, |
| 424 caps.wPid, | 422 caps.wPid, |
| 425 caps.vDriverVersion, | 423 caps.vDriverVersion, |
| 426 base::WideToUTF8( | 424 base::WideToUTF8( |
| 427 base::string16(caps.szPname, wcslen(caps.szPname))), | 425 base::string16(caps.szPname, wcslen(caps.szPname))), |
| 428 caps.ManufacturerGuid), | 426 caps.ManufacturerGuid), |
| (...skipping 16 matching lines...) Expand all Loading... |
| 445 return ports; | 443 return ports; |
| 446 } | 444 } |
| 447 | 445 |
| 448 void Finalize(scoped_refptr<base::SingleThreadTaskRunner> runner) { | 446 void Finalize(scoped_refptr<base::SingleThreadTaskRunner> runner) { |
| 449 if (out_handle_ != kInvalidOutHandle) { | 447 if (out_handle_ != kInvalidOutHandle) { |
| 450 runner->PostTask(FROM_HERE, base::Bind(&FinalizeOutPort, out_handle_)); | 448 runner->PostTask(FROM_HERE, base::Bind(&FinalizeOutPort, out_handle_)); |
| 451 out_handle_ = kInvalidOutHandle; | 449 out_handle_ = kInvalidOutHandle; |
| 452 } | 450 } |
| 453 } | 451 } |
| 454 | 452 |
| 455 void NotifyPortStateSet(DynamicallyInitializedMidiManagerWin* manager) { | 453 void NotifyPortStateSet(MidiManagerWin* manager) { |
| 456 manager->PostReplyTask( | 454 manager->PostReplyTask(base::Bind(&MidiManagerWin::SetOutputPortState, |
| 457 base::Bind(&DynamicallyInitializedMidiManagerWin::SetOutputPortState, | 455 base::Unretained(manager), index_, |
| 458 base::Unretained(manager), index_, info_.state)); | 456 info_.state)); |
| 459 } | 457 } |
| 460 | 458 |
| 461 void NotifyPortAdded(DynamicallyInitializedMidiManagerWin* manager) { | 459 void NotifyPortAdded(MidiManagerWin* manager) { |
| 462 manager->PostReplyTask( | 460 manager->PostReplyTask(base::Bind(&MidiManagerWin::AddOutputPort, |
| 463 base::Bind(&DynamicallyInitializedMidiManagerWin::AddOutputPort, | 461 base::Unretained(manager), info_)); |
| 464 base::Unretained(manager), info_)); | |
| 465 } | 462 } |
| 466 | 463 |
| 467 void Send(const std::vector<uint8_t>& data) { | 464 void Send(const std::vector<uint8_t>& data) { |
| 468 if (out_handle_ == kInvalidOutHandle) | 465 if (out_handle_ == kInvalidOutHandle) |
| 469 return; | 466 return; |
| 470 | 467 |
| 471 if (data.size() <= 3) { | 468 if (data.size() <= 3) { |
| 472 uint32_t message = 0; | 469 uint32_t message = 0; |
| 473 for (size_t i = 0; i < data.size(); ++i) | 470 for (size_t i = 0; i < data.size(); ++i) |
| 474 message |= (static_cast<uint32_t>(data[i]) << (i * 8)); | 471 message |= (static_cast<uint32_t>(data[i]) << (i * 8)); |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 527 } else { | 524 } else { |
| 528 out_handle_ = kInvalidOutHandle; | 525 out_handle_ = kInvalidOutHandle; |
| 529 Disconnect(); | 526 Disconnect(); |
| 530 } | 527 } |
| 531 } | 528 } |
| 532 | 529 |
| 533 const bool software_; | 530 const bool software_; |
| 534 HMIDIOUT out_handle_; | 531 HMIDIOUT out_handle_; |
| 535 }; | 532 }; |
| 536 | 533 |
| 537 base::TimeTicks | 534 base::TimeTicks MidiManagerWin::PortManager::CalculateInEventTime( |
| 538 DynamicallyInitializedMidiManagerWin::PortManager::CalculateInEventTime( | |
| 539 size_t index, | 535 size_t index, |
| 540 uint32_t elapsed_ms) const { | 536 uint32_t elapsed_ms) const { |
| 541 GetTaskLock()->AssertAcquired(); | 537 GetTaskLock()->AssertAcquired(); |
| 542 CHECK_GT(input_ports_.size(), index); | 538 CHECK_GT(input_ports_.size(), index); |
| 543 return input_ports_[index]->CalculateInEventTime(elapsed_ms); | 539 return input_ports_[index]->CalculateInEventTime(elapsed_ms); |
| 544 } | 540 } |
| 545 | 541 |
| 546 void DynamicallyInitializedMidiManagerWin::PortManager::RegisterInHandle( | 542 void MidiManagerWin::PortManager::RegisterInHandle(HMIDIIN handle, |
| 547 HMIDIIN handle, | 543 size_t index) { |
| 548 size_t index) { | |
| 549 GetTaskLock()->AssertAcquired(); | 544 GetTaskLock()->AssertAcquired(); |
| 550 hmidiin_to_index_map_[handle] = index; | 545 hmidiin_to_index_map_[handle] = index; |
| 551 } | 546 } |
| 552 | 547 |
| 553 void DynamicallyInitializedMidiManagerWin::PortManager::UnregisterInHandle( | 548 void MidiManagerWin::PortManager::UnregisterInHandle(HMIDIIN handle) { |
| 554 HMIDIIN handle) { | |
| 555 GetTaskLock()->AssertAcquired(); | 549 GetTaskLock()->AssertAcquired(); |
| 556 hmidiin_to_index_map_.erase(handle); | 550 hmidiin_to_index_map_.erase(handle); |
| 557 } | 551 } |
| 558 | 552 |
| 559 bool DynamicallyInitializedMidiManagerWin::PortManager::FindInHandle( | 553 bool MidiManagerWin::PortManager::FindInHandle(HMIDIIN hmi, size_t* out_index) { |
| 560 HMIDIIN hmi, | |
| 561 size_t* out_index) { | |
| 562 GetTaskLock()->AssertAcquired(); | 554 GetTaskLock()->AssertAcquired(); |
| 563 auto found = hmidiin_to_index_map_.find(hmi); | 555 auto found = hmidiin_to_index_map_.find(hmi); |
| 564 if (found == hmidiin_to_index_map_.end()) | 556 if (found == hmidiin_to_index_map_.end()) |
| 565 return false; | 557 return false; |
| 566 *out_index = found->second; | 558 *out_index = found->second; |
| 567 return true; | 559 return true; |
| 568 } | 560 } |
| 569 | 561 |
| 570 void DynamicallyInitializedMidiManagerWin::PortManager::RestoreInBuffer( | 562 void MidiManagerWin::PortManager::RestoreInBuffer(size_t index) { |
| 571 size_t index) { | |
| 572 GetTaskLock()->AssertAcquired(); | 563 GetTaskLock()->AssertAcquired(); |
| 573 CHECK_GT(input_ports_.size(), index); | 564 CHECK_GT(input_ports_.size(), index); |
| 574 input_ports_[index]->RestoreBuffer(); | 565 input_ports_[index]->RestoreBuffer(); |
| 575 } | 566 } |
| 576 | 567 |
| 577 void CALLBACK | 568 void CALLBACK |
| 578 DynamicallyInitializedMidiManagerWin::PortManager::HandleMidiInCallback( | 569 MidiManagerWin::PortManager::HandleMidiInCallback(HMIDIIN hmi, |
| 579 HMIDIIN hmi, | 570 UINT msg, |
| 580 UINT msg, | 571 DWORD_PTR instance, |
| 581 DWORD_PTR instance, | 572 DWORD_PTR param1, |
| 582 DWORD_PTR param1, | 573 DWORD_PTR param2) { |
| 583 DWORD_PTR param2) { | |
| 584 if (msg != MIM_DATA && msg != MIM_LONGDATA) | 574 if (msg != MIM_DATA && msg != MIM_LONGDATA) |
| 585 return; | 575 return; |
| 586 int instance_id = static_cast<int>(instance); | 576 int instance_id = static_cast<int>(instance); |
| 587 DynamicallyInitializedMidiManagerWin* manager = nullptr; | 577 MidiManagerWin* manager = nullptr; |
| 588 | 578 |
| 589 // Use |g_task_lock| so to ensure the instance can keep alive while running, | 579 // Use |g_task_lock| so to ensure the instance can keep alive while running, |
| 590 // and to access member variables that are used on TaskRunner. | 580 // and to access member variables that are used on TaskRunner. |
| 591 base::AutoLock task_lock(*GetTaskLock()); | 581 base::AutoLock task_lock(*GetTaskLock()); |
| 592 { | 582 { |
| 593 base::AutoLock lock(*GetInstanceIdLock()); | 583 base::AutoLock lock(*GetInstanceIdLock()); |
| 594 if (instance_id != g_active_instance_id) | 584 if (instance_id != g_active_instance_id) |
| 595 return; | 585 return; |
| 596 manager = g_manager_instance; | 586 manager = g_manager_instance; |
| 597 } | 587 } |
| 598 | 588 |
| 599 size_t index; | 589 size_t index; |
| 600 if (!manager->port_manager()->FindInHandle(hmi, &index)) | 590 if (!manager->port_manager()->FindInHandle(hmi, &index)) |
| 601 return; | 591 return; |
| 602 | 592 |
| 603 DCHECK(msg == MIM_DATA || msg == MIM_LONGDATA); | 593 DCHECK(msg == MIM_DATA || msg == MIM_LONGDATA); |
| 604 if (msg == MIM_DATA) { | 594 if (msg == MIM_DATA) { |
| 605 const uint8_t status_byte = static_cast<uint8_t>(param1 & 0xff); | 595 const uint8_t status_byte = static_cast<uint8_t>(param1 & 0xff); |
| 606 const uint8_t first_data_byte = static_cast<uint8_t>((param1 >> 8) & 0xff); | 596 const uint8_t first_data_byte = static_cast<uint8_t>((param1 >> 8) & 0xff); |
| 607 const uint8_t second_data_byte = | 597 const uint8_t second_data_byte = |
| 608 static_cast<uint8_t>((param1 >> 16) & 0xff); | 598 static_cast<uint8_t>((param1 >> 16) & 0xff); |
| 609 const uint8_t kData[] = {status_byte, first_data_byte, second_data_byte}; | 599 const uint8_t kData[] = {status_byte, first_data_byte, second_data_byte}; |
| 610 const size_t len = GetMessageLength(status_byte); | 600 const size_t len = GetMessageLength(status_byte); |
| 611 DCHECK_LE(len, arraysize(kData)); | 601 DCHECK_LE(len, arraysize(kData)); |
| 612 std::vector<uint8_t> data; | 602 std::vector<uint8_t> data; |
| 613 data.assign(kData, kData + len); | 603 data.assign(kData, kData + len); |
| 614 manager->PostReplyTask(base::Bind( | 604 manager->PostReplyTask(base::Bind( |
| 615 &DynamicallyInitializedMidiManagerWin::ReceiveMidiData, | 605 &MidiManagerWin::ReceiveMidiData, base::Unretained(manager), index, |
| 616 base::Unretained(manager), index, data, | 606 data, manager->port_manager()->CalculateInEventTime(index, param2))); |
| 617 manager->port_manager()->CalculateInEventTime(index, param2))); | |
| 618 } else { | 607 } else { |
| 619 DCHECK_EQ(static_cast<UINT>(MIM_LONGDATA), msg); | 608 DCHECK_EQ(static_cast<UINT>(MIM_LONGDATA), msg); |
| 620 LPMIDIHDR hdr = reinterpret_cast<LPMIDIHDR>(param1); | 609 LPMIDIHDR hdr = reinterpret_cast<LPMIDIHDR>(param1); |
| 621 if (hdr->dwBytesRecorded > 0) { | 610 if (hdr->dwBytesRecorded > 0) { |
| 622 const uint8_t* src = reinterpret_cast<const uint8_t*>(hdr->lpData); | 611 const uint8_t* src = reinterpret_cast<const uint8_t*>(hdr->lpData); |
| 623 std::vector<uint8_t> data; | 612 std::vector<uint8_t> data; |
| 624 data.assign(src, src + hdr->dwBytesRecorded); | 613 data.assign(src, src + hdr->dwBytesRecorded); |
| 625 manager->PostReplyTask(base::Bind( | 614 manager->PostReplyTask(base::Bind( |
| 626 &DynamicallyInitializedMidiManagerWin::ReceiveMidiData, | 615 &MidiManagerWin::ReceiveMidiData, base::Unretained(manager), index, |
| 627 base::Unretained(manager), index, data, | 616 data, manager->port_manager()->CalculateInEventTime(index, param2))); |
| 628 manager->port_manager()->CalculateInEventTime(index, param2))); | |
| 629 } | 617 } |
| 630 manager->PostTask(base::Bind( | 618 manager->PostTask(base::Bind(&MidiManagerWin::PortManager::RestoreInBuffer, |
| 631 &DynamicallyInitializedMidiManagerWin::PortManager::RestoreInBuffer, | 619 base::Unretained(manager->port_manager()), |
| 632 base::Unretained(manager->port_manager()), index)); | 620 index)); |
| 633 } | 621 } |
| 634 } | 622 } |
| 635 | 623 |
| 636 void CALLBACK | 624 void CALLBACK |
| 637 DynamicallyInitializedMidiManagerWin::PortManager::HandleMidiOutCallback( | 625 MidiManagerWin::PortManager::HandleMidiOutCallback(HMIDIOUT hmo, |
| 638 HMIDIOUT hmo, | 626 UINT msg, |
| 639 UINT msg, | 627 DWORD_PTR instance, |
| 640 DWORD_PTR instance, | 628 DWORD_PTR param1, |
| 641 DWORD_PTR param1, | 629 DWORD_PTR param2) { |
| 642 DWORD_PTR param2) { | |
| 643 if (msg == MOM_DONE) { | 630 if (msg == MOM_DONE) { |
| 644 ScopedMIDIHDR hdr(reinterpret_cast<LPMIDIHDR>(param1)); | 631 ScopedMIDIHDR hdr(reinterpret_cast<LPMIDIHDR>(param1)); |
| 645 if (!hdr) | 632 if (!hdr) |
| 646 return; | 633 return; |
| 647 // TODO(toyoshim): Call midiOutUnprepareHeader outside the callback. | 634 // TODO(toyoshim): Call midiOutUnprepareHeader outside the callback. |
| 648 // Since this callback may be invoked after the manager is destructed, | 635 // Since this callback may be invoked after the manager is destructed, |
| 649 // and can not send a task to the TaskRunner in such case, we need to | 636 // and can not send a task to the TaskRunner in such case, we need to |
| 650 // consider to track MIDIHDR per port, and clean it in port finalization | 637 // consider to track MIDIHDR per port, and clean it in port finalization |
| 651 // steps, too. | 638 // steps, too. |
| 652 midiOutUnprepareHeader(hmo, hdr.get(), sizeof(*hdr)); | 639 midiOutUnprepareHeader(hmo, hdr.get(), sizeof(*hdr)); |
| 653 } | 640 } |
| 654 } | 641 } |
| 655 | 642 |
| 656 DynamicallyInitializedMidiManagerWin::DynamicallyInitializedMidiManagerWin( | 643 MidiManagerWin::MidiManagerWin(MidiService* service) |
| 657 MidiService* service) | |
| 658 : MidiManager(service), | 644 : MidiManager(service), |
| 659 instance_id_(IssueNextInstanceId()), | 645 instance_id_(IssueNextInstanceId()), |
| 660 port_manager_(base::MakeUnique<PortManager>()) { | 646 port_manager_(base::MakeUnique<PortManager>()) { |
| 661 base::AutoLock lock(*GetInstanceIdLock()); | 647 base::AutoLock lock(*GetInstanceIdLock()); |
| 662 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); | 648 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); |
| 663 | 649 |
| 664 // Obtains the task runner for the current thread that hosts this instnace. | 650 // Obtains the task runner for the current thread that hosts this instnace. |
| 665 thread_runner_ = base::ThreadTaskRunnerHandle::Get(); | 651 thread_runner_ = base::ThreadTaskRunnerHandle::Get(); |
| 666 } | 652 } |
| 667 | 653 |
| 668 DynamicallyInitializedMidiManagerWin::~DynamicallyInitializedMidiManagerWin() { | 654 MidiManagerWin::~MidiManagerWin() { |
| 669 base::AutoLock lock(*GetInstanceIdLock()); | 655 base::AutoLock lock(*GetInstanceIdLock()); |
| 670 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); | 656 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); |
| 671 CHECK(thread_runner_->BelongsToCurrentThread()); | 657 CHECK(thread_runner_->BelongsToCurrentThread()); |
| 672 } | 658 } |
| 673 | 659 |
| 674 void DynamicallyInitializedMidiManagerWin::StartInitialization() { | 660 void MidiManagerWin::StartInitialization() { |
| 675 { | 661 { |
| 676 base::AutoLock lock(*GetInstanceIdLock()); | 662 base::AutoLock lock(*GetInstanceIdLock()); |
| 677 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); | 663 CHECK_EQ(kInvalidInstanceId, g_active_instance_id); |
| 678 g_active_instance_id = instance_id_; | 664 g_active_instance_id = instance_id_; |
| 679 CHECK_EQ(nullptr, g_manager_instance); | 665 CHECK_EQ(nullptr, g_manager_instance); |
| 680 g_manager_instance = this; | 666 g_manager_instance = this; |
| 681 } | 667 } |
| 682 // Registers on the I/O thread to be notified on the I/O thread. | 668 // Registers on the I/O thread to be notified on the I/O thread. |
| 683 CHECK(thread_runner_->BelongsToCurrentThread()); | 669 CHECK(thread_runner_->BelongsToCurrentThread()); |
| 684 base::SystemMonitor::Get()->AddDevicesChangedObserver(this); | 670 base::SystemMonitor::Get()->AddDevicesChangedObserver(this); |
| 685 | 671 |
| 686 // Starts asynchronous initialization on TaskRunner. | 672 // Starts asynchronous initialization on TaskRunner. |
| 687 PostTask( | 673 PostTask(base::Bind(&MidiManagerWin::InitializeOnTaskRunner, |
| 688 base::Bind(&DynamicallyInitializedMidiManagerWin::InitializeOnTaskRunner, | 674 base::Unretained(this))); |
| 689 base::Unretained(this))); | |
| 690 } | 675 } |
| 691 | 676 |
| 692 void DynamicallyInitializedMidiManagerWin::Finalize() { | 677 void MidiManagerWin::Finalize() { |
| 693 // Unregisters on the I/O thread. OnDevicesChanged() won't be called any more. | 678 // Unregisters on the I/O thread. OnDevicesChanged() won't be called any more. |
| 694 CHECK(thread_runner_->BelongsToCurrentThread()); | 679 CHECK(thread_runner_->BelongsToCurrentThread()); |
| 695 base::SystemMonitor::Get()->RemoveDevicesChangedObserver(this); | 680 base::SystemMonitor::Get()->RemoveDevicesChangedObserver(this); |
| 696 { | 681 { |
| 697 base::AutoLock lock(*GetInstanceIdLock()); | 682 base::AutoLock lock(*GetInstanceIdLock()); |
| 698 CHECK_EQ(instance_id_, g_active_instance_id); | 683 CHECK_EQ(instance_id_, g_active_instance_id); |
| 699 g_active_instance_id = kInvalidInstanceId; | 684 g_active_instance_id = kInvalidInstanceId; |
| 700 CHECK_EQ(this, g_manager_instance); | 685 CHECK_EQ(this, g_manager_instance); |
| 701 g_manager_instance = nullptr; | 686 g_manager_instance = nullptr; |
| 702 } | 687 } |
| 703 | 688 |
| 704 // Ensures that no task runs on TaskRunner so to destruct the instance safely. | 689 // Ensures that no task runs on TaskRunner so to destruct the instance safely. |
| 705 // Tasks that did not started yet will do nothing after invalidate the | 690 // Tasks that did not started yet will do nothing after invalidate the |
| 706 // instance ID above. | 691 // instance ID above. |
| 707 // Behind the lock below, we can safely access all members for finalization | 692 // Behind the lock below, we can safely access all members for finalization |
| 708 // even on the I/O thread. | 693 // even on the I/O thread. |
| 709 base::AutoLock lock(*GetTaskLock()); | 694 base::AutoLock lock(*GetTaskLock()); |
| 710 | 695 |
| 711 // Posts tasks that finalize each device port without MidiManager instance | 696 // Posts tasks that finalize each device port without MidiManager instance |
| 712 // on TaskRunner. If another MidiManager instance is created, its | 697 // on TaskRunner. If another MidiManager instance is created, its |
| 713 // initialization runs on the same task runner after all tasks posted here | 698 // initialization runs on the same task runner after all tasks posted here |
| 714 // finish. | 699 // finish. |
| 715 for (const auto& port : *port_manager_->inputs()) | 700 for (const auto& port : *port_manager_->inputs()) |
| 716 port->Finalize(service()->GetTaskRunner(kTaskRunner)); | 701 port->Finalize(service()->GetTaskRunner(kTaskRunner)); |
| 717 for (const auto& port : *port_manager_->outputs()) | 702 for (const auto& port : *port_manager_->outputs()) |
| 718 port->Finalize(service()->GetTaskRunner(kTaskRunner)); | 703 port->Finalize(service()->GetTaskRunner(kTaskRunner)); |
| 719 } | 704 } |
| 720 | 705 |
| 721 void DynamicallyInitializedMidiManagerWin::DispatchSendMidiData( | 706 void MidiManagerWin::DispatchSendMidiData(MidiManagerClient* client, |
| 722 MidiManagerClient* client, | 707 uint32_t port_index, |
| 723 uint32_t port_index, | 708 const std::vector<uint8_t>& data, |
| 724 const std::vector<uint8_t>& data, | 709 double timestamp) { |
| 725 double timestamp) { | |
| 726 if (timestamp != 0.0) { | 710 if (timestamp != 0.0) { |
| 727 base::TimeTicks time = base::TimeTicks() + | 711 base::TimeTicks time = |
| 728 base::TimeDelta::FromMicroseconds( | 712 base::TimeTicks() + base::TimeDelta::FromMicroseconds( |
| 729 timestamp * base::Time::kMicrosecondsPerSecond); | 713 timestamp * base::Time::kMicrosecondsPerSecond); |
| 730 base::TimeTicks now = base::TimeTicks::Now(); | 714 base::TimeTicks now = base::TimeTicks::Now(); |
| 731 if (now < time) { | 715 if (now < time) { |
| 732 PostDelayedTask( | 716 PostDelayedTask( |
| 733 base::Bind(&DynamicallyInitializedMidiManagerWin::SendOnTaskRunner, | 717 base::Bind(&MidiManagerWin::SendOnTaskRunner, base::Unretained(this), |
| 734 base::Unretained(this), client, port_index, data), | 718 client, port_index, data), |
| 735 time - now); | 719 time - now); |
| 736 return; | 720 return; |
| 737 } | 721 } |
| 738 } | 722 } |
| 739 PostTask(base::Bind(&DynamicallyInitializedMidiManagerWin::SendOnTaskRunner, | 723 PostTask(base::Bind(&MidiManagerWin::SendOnTaskRunner, base::Unretained(this), |
| 740 base::Unretained(this), client, port_index, data)); | 724 client, port_index, data)); |
| 741 } | 725 } |
| 742 | 726 |
| 743 void DynamicallyInitializedMidiManagerWin::OnDevicesChanged( | 727 void MidiManagerWin::OnDevicesChanged( |
| 744 base::SystemMonitor::DeviceType device_type) { | 728 base::SystemMonitor::DeviceType device_type) { |
| 745 // Notified on the I/O thread. | 729 // Notified on the I/O thread. |
| 746 CHECK(thread_runner_->BelongsToCurrentThread()); | 730 CHECK(thread_runner_->BelongsToCurrentThread()); |
| 747 | 731 |
| 748 switch (device_type) { | 732 switch (device_type) { |
| 749 case base::SystemMonitor::DEVTYPE_AUDIO: | 733 case base::SystemMonitor::DEVTYPE_AUDIO: |
| 750 case base::SystemMonitor::DEVTYPE_VIDEO_CAPTURE: | 734 case base::SystemMonitor::DEVTYPE_VIDEO_CAPTURE: |
| 751 // Add case of other unrelated device types here. | 735 // Add case of other unrelated device types here. |
| 752 return; | 736 return; |
| 753 case base::SystemMonitor::DEVTYPE_UNKNOWN: { | 737 case base::SystemMonitor::DEVTYPE_UNKNOWN: { |
| 754 PostTask(base::Bind( | 738 PostTask(base::Bind(&MidiManagerWin::UpdateDeviceListOnTaskRunner, |
| 755 &DynamicallyInitializedMidiManagerWin::UpdateDeviceListOnTaskRunner, | 739 base::Unretained(this))); |
| 756 base::Unretained(this))); | |
| 757 break; | 740 break; |
| 758 } | 741 } |
| 759 } | 742 } |
| 760 } | 743 } |
| 761 | 744 |
| 762 void DynamicallyInitializedMidiManagerWin::ReceiveMidiData( | 745 void MidiManagerWin::ReceiveMidiData(uint32_t index, |
| 763 uint32_t index, | 746 const std::vector<uint8_t>& data, |
| 764 const std::vector<uint8_t>& data, | 747 base::TimeTicks time) { |
| 765 base::TimeTicks time) { | |
| 766 MidiManager::ReceiveMidiData(index, data.data(), data.size(), time); | 748 MidiManager::ReceiveMidiData(index, data.data(), data.size(), time); |
| 767 } | 749 } |
| 768 | 750 |
| 769 void DynamicallyInitializedMidiManagerWin::PostTask(const base::Closure& task) { | 751 void MidiManagerWin::PostTask(const base::Closure& task) { |
| 770 service() | 752 service() |
| 771 ->GetTaskRunner(kTaskRunner) | 753 ->GetTaskRunner(kTaskRunner) |
| 772 ->PostTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task)); | 754 ->PostTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task)); |
| 773 } | 755 } |
| 774 | 756 |
| 775 void DynamicallyInitializedMidiManagerWin::PostDelayedTask( | 757 void MidiManagerWin::PostDelayedTask(const base::Closure& task, |
| 776 const base::Closure& task, | 758 base::TimeDelta delay) { |
| 777 base::TimeDelta delay) { | |
| 778 service() | 759 service() |
| 779 ->GetTaskRunner(kTaskRunner) | 760 ->GetTaskRunner(kTaskRunner) |
| 780 ->PostDelayedTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task), | 761 ->PostDelayedTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task), |
| 781 delay); | 762 delay); |
| 782 } | 763 } |
| 783 | 764 |
| 784 void DynamicallyInitializedMidiManagerWin::PostReplyTask( | 765 void MidiManagerWin::PostReplyTask(const base::Closure& task) { |
| 785 const base::Closure& task) { | |
| 786 thread_runner_->PostTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task)); | 766 thread_runner_->PostTask(FROM_HERE, base::Bind(&RunTask, instance_id_, task)); |
| 787 } | 767 } |
| 788 | 768 |
| 789 void DynamicallyInitializedMidiManagerWin::InitializeOnTaskRunner() { | 769 void MidiManagerWin::InitializeOnTaskRunner() { |
| 790 UpdateDeviceListOnTaskRunner(); | 770 UpdateDeviceListOnTaskRunner(); |
| 791 PostReplyTask( | 771 PostReplyTask(base::Bind(&MidiManagerWin::CompleteInitialization, |
| 792 base::Bind(&DynamicallyInitializedMidiManagerWin::CompleteInitialization, | 772 base::Unretained(this), mojom::Result::OK)); |
| 793 base::Unretained(this), mojom::Result::OK)); | |
| 794 } | 773 } |
| 795 | 774 |
| 796 void DynamicallyInitializedMidiManagerWin::UpdateDeviceListOnTaskRunner() { | 775 void MidiManagerWin::UpdateDeviceListOnTaskRunner() { |
| 797 std::vector<std::unique_ptr<InPort>> active_input_ports = | 776 std::vector<std::unique_ptr<InPort>> active_input_ports = |
| 798 InPort::EnumerateActivePorts(this, instance_id_); | 777 InPort::EnumerateActivePorts(this, instance_id_); |
| 799 ReflectActiveDeviceList(this, port_manager_->inputs(), &active_input_ports); | 778 ReflectActiveDeviceList(this, port_manager_->inputs(), &active_input_ports); |
| 800 | 779 |
| 801 std::vector<std::unique_ptr<OutPort>> active_output_ports = | 780 std::vector<std::unique_ptr<OutPort>> active_output_ports = |
| 802 OutPort::EnumerateActivePorts(); | 781 OutPort::EnumerateActivePorts(); |
| 803 ReflectActiveDeviceList(this, port_manager_->outputs(), &active_output_ports); | 782 ReflectActiveDeviceList(this, port_manager_->outputs(), &active_output_ports); |
| 804 | 783 |
| 805 // TODO(toyoshim): This method may run before internal MIDI device lists that | 784 // TODO(toyoshim): This method may run before internal MIDI device lists that |
| 806 // Windows manages were updated. This may be because MIDI driver may be loaded | 785 // Windows manages were updated. This may be because MIDI driver may be loaded |
| 807 // after the raw device list was updated. To avoid this problem, we may want | 786 // after the raw device list was updated. To avoid this problem, we may want |
| 808 // to retry device check later if no changes are detected here. | 787 // to retry device check later if no changes are detected here. |
| 809 } | 788 } |
| 810 | 789 |
| 811 template <typename T> | 790 template <typename T> |
| 812 void DynamicallyInitializedMidiManagerWin::ReflectActiveDeviceList( | 791 void MidiManagerWin::ReflectActiveDeviceList(MidiManagerWin* manager, |
| 813 DynamicallyInitializedMidiManagerWin* manager, | 792 std::vector<T>* known_ports, |
| 814 std::vector<T>* known_ports, | 793 std::vector<T>* active_ports) { |
| 815 std::vector<T>* active_ports) { | |
| 816 // Update existing port states. | 794 // Update existing port states. |
| 817 for (const auto& port : *known_ports) { | 795 for (const auto& port : *known_ports) { |
| 818 const auto& it = std::find_if( | 796 const auto& it = std::find_if( |
| 819 active_ports->begin(), active_ports->end(), | 797 active_ports->begin(), active_ports->end(), |
| 820 [&port](const auto& candidate) { return *candidate == *port; }); | 798 [&port](const auto& candidate) { return *candidate == *port; }); |
| 821 if (it == active_ports->end()) { | 799 if (it == active_ports->end()) { |
| 822 if (port->Disconnect()) | 800 if (port->Disconnect()) |
| 823 port->NotifyPortStateSet(this); | 801 port->NotifyPortStateSet(this); |
| 824 } else { | 802 } else { |
| 825 port->set_device_id((*it)->device_id()); | 803 port->set_device_id((*it)->device_id()); |
| (...skipping 10 matching lines...) Expand all Loading... |
| 836 }) == known_ports->end()) { | 814 }) == known_ports->end()) { |
| 837 size_t index = known_ports->size(); | 815 size_t index = known_ports->size(); |
| 838 port->set_index(index); | 816 port->set_index(index); |
| 839 known_ports->push_back(std::move(port)); | 817 known_ports->push_back(std::move(port)); |
| 840 (*known_ports)[index]->Connect(); | 818 (*known_ports)[index]->Connect(); |
| 841 (*known_ports)[index]->NotifyPortAdded(this); | 819 (*known_ports)[index]->NotifyPortAdded(this); |
| 842 } | 820 } |
| 843 } | 821 } |
| 844 } | 822 } |
| 845 | 823 |
| 846 void DynamicallyInitializedMidiManagerWin::SendOnTaskRunner( | 824 void MidiManagerWin::SendOnTaskRunner(MidiManagerClient* client, |
| 847 MidiManagerClient* client, | 825 uint32_t port_index, |
| 848 uint32_t port_index, | 826 const std::vector<uint8_t>& data) { |
| 849 const std::vector<uint8_t>& data) { | |
| 850 CHECK_GT(port_manager_->outputs()->size(), port_index); | 827 CHECK_GT(port_manager_->outputs()->size(), port_index); |
| 851 (*port_manager_->outputs())[port_index]->Send(data); | 828 (*port_manager_->outputs())[port_index]->Send(data); |
| 852 // |client| will be checked inside MidiManager::AccumulateMidiBytesSent. | 829 // |client| will be checked inside MidiManager::AccumulateMidiBytesSent. |
| 853 PostReplyTask( | 830 PostReplyTask(base::Bind(&MidiManagerWin::AccumulateMidiBytesSent, |
| 854 base::Bind(&DynamicallyInitializedMidiManagerWin::AccumulateMidiBytesSent, | 831 base::Unretained(this), client, data.size())); |
| 855 base::Unretained(this), client, data.size())); | |
| 856 } | 832 } |
| 857 | 833 |
| 858 MidiManager* MidiManager::Create(MidiService* service) { | 834 MidiManager* MidiManager::Create(MidiService* service) { |
| 859 if (base::FeatureList::IsEnabled(features::kMidiManagerWinrt) && | 835 if (base::FeatureList::IsEnabled(features::kMidiManagerWinrt) && |
| 860 base::win::GetVersion() >= base::win::VERSION_WIN10) | 836 base::win::GetVersion() >= base::win::VERSION_WIN10) { |
| 861 return new MidiManagerWinrt(service); | 837 return new MidiManagerWinrt(service); |
| 862 return new DynamicallyInitializedMidiManagerWin(service); | 838 } |
| 839 return new MidiManagerWin(service); |
| 863 } | 840 } |
| 864 | 841 |
| 865 } // namespace midi | 842 } // namespace midi |
| OLD | NEW |