1 files changed, 99 insertions, 0 deletions
diff --git a/src/filesystem/MythSession.h b/src/filesystem/MythSession.h
new file mode 100644
index 0000000000..6cc96eda36
--- /dev/null
+++ b/src/filesystem/MythSession.h
@@ -0,0 +1,99 @@
+#pragma once
+/*
+ *      Copyright (C) 2005-2013 Team XBMC
+ *      http://xbmc.org
+ *
+ *  This Program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2, or (at your option)
+ *  any later version.
+ *
+ *  This Program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ *  GNU General Public License for more details.
+ *
+ *  You should have received a copy of the GNU General Public License
+ *  along with XBMC; see the file COPYING.  If not, see
+ *  <http://www.gnu.org/licenses/>.
+ *
+ */
+
+#include <string>
+#include "threads/CriticalSection.h"
+#include "threads/Thread.h"
+
+typedef struct cmyth_ringbuf   *cmyth_ringbuf_t;
+typedef struct cmyth_conn      *cmyth_conn_t;
+typedef struct cmyth_recorder  *cmyth_recorder_t;
+typedef struct cmyth_proginfo  *cmyth_proginfo_t;
+typedef struct cmyth_proglist  *cmyth_proglist_t;
+typedef struct cmyth_file      *cmyth_file_t;
+typedef struct cmyth_database  *cmyth_database_t;
+typedef struct cmyth_timestamp *cmyth_timestamp_t;
+
+class DllLibCMyth;
+class CDateTime;
+class CFileItem;
+class CURL;
+
+namespace XFILE
+{
+
+class CMythSession
+  : private CThread
+{
+public:
+  static CMythSession*  AquireSession(const CURL& url);
+  static void           ReleaseSession(CMythSession*);
+  static void           CheckIdle();
+  static void           LogCMyth(int level, char *msg);
+
+  class IEventListener
+  {
+  public:
+    virtual ~IEventListener() {};
+    virtual void OnEvent(int event, const std::string& data)=0;
+  };
+
+  bool             SetListener(IEventListener *listener);
+  cmyth_conn_t     GetControl();
+  cmyth_database_t GetDatabase();
+  DllLibCMyth*     GetLibrary();
+  cmyth_proglist_t GetAllRecordedPrograms();
+  void             ResetAllRecordedPrograms();
+
+  void             SetFileItemMetaData(CFileItem &item, cmyth_proginfo_t program);
+
+  CDateTime        GetValue(cmyth_timestamp_t t);
+  std::string      GetValue(char* str);
+
+private:
+  CMythSession(const CURL& url);
+  ~CMythSession();
+
+  virtual void Process();
+
+  bool             CanSupport(const CURL& url);
+  void             Disconnect();
+
+  void             SetSeasonAndEpisode(const cmyth_proginfo_t &program, int *season, int *epsiode);
+
+  IEventListener*  m_listener;
+  cmyth_conn_t     m_control;
+  cmyth_conn_t     m_event;
+  cmyth_database_t m_database;
+  std::string      m_hostname;
+  std::string      m_username;
+  std::string      m_password;
+  int              m_port;
+  DllLibCMyth*     m_dll;
+  CCriticalSection m_section;
+  unsigned int     m_timestamp;
+  cmyth_proglist_t m_all_recorded; // Cache of all_recorded programs.
+
+  static CCriticalSection            m_section_session;
+  static std::vector<CMythSession*>  m_sessions;
+};
+
+}