Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1063)

Side by Side Diff: media/midi/midi_manager_win.cc

Issue 2834423002: Web MIDI: rename DynamicallyInitializedMidiManagerWin (Closed)
Patch Set: Created 3 years, 8 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « media/midi/midi_manager_win.h ('k') | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
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
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
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
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
OLDNEW
« no previous file with comments | « media/midi/midi_manager_win.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698