equal
deleted
inserted
replaced
24 #include "tmsproxy.h" |
24 #include "tmsproxy.h" |
25 |
25 |
26 using namespace TMS; |
26 using namespace TMS; |
27 |
27 |
28 // CONSTANTS |
28 // CONSTANTS |
29 const TUint KServerConnectRetries = 2; |
29 const TUint KTMSServerConnectRetries = 2; |
30 const TUint KSessionMessageSlots = 10; |
30 const TUint KSessionMessageSlots = 10; |
31 |
31 |
32 // ----------------------------------------------------------------------------- |
32 // ----------------------------------------------------------------------------- |
33 // StartServer |
33 // StartServer |
34 // Static function to start the server process thread. |
34 // Static function to start the server process thread. |
74 // TMSProxy::TMSProxy |
74 // TMSProxy::TMSProxy |
75 // ----------------------------------------------------------------------------- |
75 // ----------------------------------------------------------------------------- |
76 // |
76 // |
77 EXPORT_C TMSProxy::TMSProxy() |
77 EXPORT_C TMSProxy::TMSProxy() |
78 { |
78 { |
79 iEffectsObsrvrList.Reset(); |
79 ResetObjectLists(); |
80 iEffectsParentList.Reset(); |
|
81 iRoutingObsrvrList.Reset(); |
|
82 iRoutingParentList.Reset(); |
|
83 iMsgQHandler = NULL; |
80 iMsgQHandler = NULL; |
84 } |
81 } |
85 |
82 |
86 // ----------------------------------------------------------------------------- |
83 // ----------------------------------------------------------------------------- |
87 // TMSProxy::~TMSProxy |
84 // TMSProxy::~TMSProxy |
88 // ----------------------------------------------------------------------------- |
85 // ----------------------------------------------------------------------------- |
89 // |
86 // |
90 EXPORT_C TMSProxy::~TMSProxy() |
87 EXPORT_C TMSProxy::~TMSProxy() |
91 { |
88 { |
92 iEffectsObsrvrList.Reset(); |
89 ResetObjectLists(); |
93 iEffectsParentList.Reset(); |
|
94 iRoutingObsrvrList.Reset(); |
|
95 iRoutingParentList.Reset(); |
|
96 |
90 |
97 if (iMsgQHandler) |
91 if (iMsgQHandler) |
98 { |
92 { |
99 iMsgQHandler->Cancel(); |
93 iMsgQHandler->Cancel(); |
100 } |
94 } |
116 // |
110 // |
117 EXPORT_C gint TMSProxy::Connect() |
111 EXPORT_C gint TMSProxy::Connect() |
118 { |
112 { |
119 TRACE_PRN_FN_ENT; |
113 TRACE_PRN_FN_ENT; |
120 |
114 |
121 gint retry = KServerConnectRetries; |
115 gint retry = KTMSServerConnectRetries; |
122 gint err(TMS_RESULT_GENERAL_ERROR); |
116 gint err(TMS_RESULT_GENERAL_ERROR); |
123 gint numMessageSlots = KSessionMessageSlots; |
117 gint numMessageSlots = KSessionMessageSlots; |
124 |
118 |
125 for (;;) |
119 for (;;) |
126 { |
120 { |
469 case EMsgQueueGlobalVolumeType: |
463 case EMsgQueueGlobalVolumeType: |
470 case EMsgQueueGlobalGainType: |
464 case EMsgQueueGlobalGainType: |
471 status = RemoveGlobalEffectObserver((*(TMSEffectObserver*) obsrv)); |
465 status = RemoveGlobalEffectObserver((*(TMSEffectObserver*) obsrv)); |
472 break; |
466 break; |
473 case EMsgQueueGlobalRoutingType: |
467 case EMsgQueueGlobalRoutingType: |
474 status = RemoveRoutingObserver((*(TMSGlobalRoutingObserver*) obsrv)); |
468 status = RemoveRoutingObserver((*(TMSGlobalRoutingObserver*) |
|
469 obsrv)); |
475 break; |
470 break; |
476 default: |
471 default: |
477 status = TMS_RESULT_INVALID_ARGUMENT; |
472 status = TMS_RESULT_INVALID_ARGUMENT; |
478 break; |
473 break; |
479 } |
474 } |
510 gint status = iEffectsObsrvrList.Find(&obsrv); |
505 gint status = iEffectsObsrvrList.Find(&obsrv); |
511 if (status == KErrNotFound) |
506 if (status == KErrNotFound) |
512 { |
507 { |
513 status = iEffectsObsrvrList.Append(&obsrv); |
508 status = iEffectsObsrvrList.Append(&obsrv); |
514 status = iEffectsParentList.Append(&parent); |
509 status = iEffectsParentList.Append(&parent); |
515 //status = iClientList.Append(clientid); |
|
516 } |
510 } |
517 else |
511 else |
518 { |
512 { |
519 status = TMS_RESULT_ALREADY_EXIST; |
513 status = TMS_RESULT_ALREADY_EXIST; |
520 } |
514 } |
527 gint index = iEffectsObsrvrList.Find(&obsrv); |
521 gint index = iEffectsObsrvrList.Find(&obsrv); |
528 if (index >= 0) |
522 if (index >= 0) |
529 { |
523 { |
530 iEffectsObsrvrList.Remove(index); |
524 iEffectsObsrvrList.Remove(index); |
531 iEffectsParentList.Remove(index); |
525 iEffectsParentList.Remove(index); |
532 //iClientList.Remove(index); |
|
533 } |
526 } |
534 else |
527 else |
535 { |
528 { |
536 status = TMS_RESULT_DOES_NOT_EXIST; |
529 status = TMS_RESULT_DOES_NOT_EXIST; |
537 } |
530 } |
544 gint status = iRoutingObsrvrList.Find(&obsrv); |
537 gint status = iRoutingObsrvrList.Find(&obsrv); |
545 if (status == KErrNotFound) |
538 if (status == KErrNotFound) |
546 { |
539 { |
547 status = iRoutingObsrvrList.Append(&obsrv); |
540 status = iRoutingObsrvrList.Append(&obsrv); |
548 status = iRoutingParentList.Append(&parent); |
541 status = iRoutingParentList.Append(&parent); |
549 //status = iClientList.Append(clientid); |
|
550 } |
542 } |
551 else |
543 else |
552 { |
544 { |
553 status = TMS_RESULT_ALREADY_EXIST; |
545 status = TMS_RESULT_ALREADY_EXIST; |
554 } |
546 } |
561 gint index = iRoutingObsrvrList.Find(&obsrv); |
553 gint index = iRoutingObsrvrList.Find(&obsrv); |
562 if (index >= 0) |
554 if (index >= 0) |
563 { |
555 { |
564 iRoutingObsrvrList.Remove(index); |
556 iRoutingObsrvrList.Remove(index); |
565 iRoutingParentList.Remove(index); |
557 iRoutingParentList.Remove(index); |
566 //iClientList.Remove(index); |
|
567 } |
558 } |
568 else |
559 else |
569 { |
560 { |
570 status = TMS_RESULT_DOES_NOT_EXIST; |
561 status = TMS_RESULT_DOES_NOT_EXIST; |
571 } |
562 } |
661 default: |
652 default: |
662 break; |
653 break; |
663 } |
654 } |
664 } |
655 } |
665 |
656 |
|
657 // --------------------------------------------------------------------------- |
|
658 // TMSProxy::ResetObjectLists |
|
659 // --------------------------------------------------------------------------- |
|
660 // |
|
661 void TMSProxy::ResetObjectLists() |
|
662 { |
|
663 iEffectsObsrvrList.Reset(); |
|
664 iRoutingObsrvrList.Reset(); |
|
665 |
|
666 iEffectsParentList.Reset(); |
|
667 iRoutingParentList.Reset(); |
|
668 } |
|
669 |
666 // End of file |
670 // End of file |