ChoirSession.h

Go to the documentation of this file.

#ifndef ChoirSession_h
#define ChoirSession_h

#include "zg/ZGDatabasePeerSession.h"
#include "MusicData.h"

namespace choir {

class MusicSheet;
class PlaybackState;
class NoteAssignmentsMap;

class ChoirSession : public ZGDatabasePeerSession
{
public:
   ChoirSession(const ZGPeerSettings & peerSettings);

   // PulseNode interface
   virtual uint64 GetPulseTime(const PulseArgs & args);
   virtual void Pulse(const PulseArgs & args);

   void SendMessageToGUI(const ConstMessageRef & msg, bool allowReviewTrigger, bool force = false);

   void SetReviewResults(uint64 allNotesAtLastReview);

protected:
   // ZGDatabasePeerSession interface
   IDatabaseObjectRef CreateDatabaseObject(uint32 whichDatabase);

   // ZGPeerSession interface
   virtual void PeerHasComeOnline(const ZGPeerID & peerID, const ConstMessageRef & peerInfo);
   virtual void PeerHasGoneOffline(const ZGPeerID & peerID, const ConstMessageRef & peerInfo);
   virtual void SeniorPeerChanged(const ZGPeerID & oldSeniorPeerID, const ZGPeerID & newSeniorPeerID);

   virtual void MessageReceivedFromSession(AbstractReflectSession & from, const MessageRef & msg, void * userData);

private:
   bool IsStrategyReviewMaybeNecessary() const;
   status_t SendPeerOnlineOfflineMessageToGUI(uint32 whatCode, const ZGPeerID & id, const ConstMessageRef & optPeerInfo);
   ConstMessageRef GenerateLatenciesMessage() const;

   MusicSheet & GetMusicSheet();
   PlaybackState & GetPlaybackState();
   NoteAssignmentsMap & GetNoteAssignmentsMap();

   const MusicSheet & GetMusicSheet() const;
   const PlaybackState & GetPlaybackState() const;
   const NoteAssignmentsMap & GetNoteAssignmentsMap() const;

   bool _requestAssignmentStrategyReviewPending;
   uint64 _allNotesAtLastReview;
   Hashtable<ZGPeerID, ConstMessageRef> _peersAtLastReview;

   uint64 _nextSendLatenciesTime;
};
DECLARE_REFTYPES(ChoirSession);

}; // end namespace choir

#endif