---

panda/src/downloader/downloadDb.h

Go to the documentation of this file.

// Filename: downloadDb.h
// Created by:  shochet (06Sep00)
//
////////////////////////////////////////////////////////////////////
//
// PANDA 3D SOFTWARE
// Copyright (c) 2001, Disney Enterprises, Inc.  All rights reserved
//
// All use of this software is subject to the terms of the Panda 3d
// Software license.  You should have received a copy of this license
// along with this source code; you will also find a current copy of
// the license at http://www.panda3d.org/license.txt .
//
// To contact the maintainers of this program write to
// panda3d@yahoogroups.com .
//
////////////////////////////////////////////////////////////////////
#ifndef DOWNLOADDB_H
#define DOWNLOADDB_H

#include "pandabase.h"
#include "notify.h"
#include "filename.h"
#include "multifile.h"
#include "datagram.h"
#include "datagramIterator.h"

#include "pvector.h"
#include "pointerTo.h"
#include "pmap.h"

#include "hashVal.h"
#include "buffer.h"

/*
//////////////////////////////////////////////////
//  Database Format
//////////////////////////////////////////////////
magic_number
number_of_multifiles
header_length multifile_name phase version size status num_files
  header_length file_name version hash
  header_length file_name version hash
header_length multifile_name phase version size status num_files
  header_length file_name version hash
  header_length file_name version hash
  ...
...


A Db is a Vector<MultifileRecord>
MultifileRecord is a Vector<FileRecord>
*/

typedef float Phase;

////////////////////////////////////////////////////////////////////
//       Class : DownloadDb
// Description : A listing of files within multifiles for management
//               of client-side synchronization with a server-provided
//               set of files.
//
//               This class manages one copy of the database for the
//               client, representing the files on the client system,
//               and another copy for the server, representing the
//               files the server has available.
////////////////////////////////////////////////////////////////////
class EXPCL_PANDAEXPRESS DownloadDb {
PUBLISHED:
  // Status of a multifile is stored in this enum
  // Note these values are in increasing order of "doneness"
  // So if you are decompressed, you are complete
  // If you are extracted, you are decompressed and complete
  enum Status {
    Status_incomplete = 0,
    Status_complete = 1,
    Status_decompressed = 2,
    Status_extracted = 3
  };

  DownloadDb(void);
  DownloadDb(Ramfile &server_file, Filename &client_file);
  DownloadDb(Filename &server_file, Filename &client_file);
  ~DownloadDb(void);

  void output(ostream &out) const;
  void write(ostream &out) const;
  void write_version_map(ostream &out) const;

  // Write a database file
  bool write_client_db(Filename &file);
  bool write_server_db(Filename &file);

  INLINE int get_client_num_multifiles(void) const;
  INLINE int get_server_num_multifiles(void) const;

  INLINE string get_client_multifile_name(int index) const;
  INLINE string get_server_multifile_name(int index) const;

  INLINE int get_client_multifile_size(string mfname) const;
  INLINE void set_client_multifile_size(string mfname, int size);
  INLINE int set_client_multifile_delta_size(string mfname, int size);
  INLINE int get_server_multifile_size(string mfname) const;
  INLINE void set_server_multifile_size(string mfname, int size);

  INLINE Phase get_client_multifile_phase(string mfname) const;
  INLINE Phase get_server_multifile_phase(string mfname) const;

  INLINE void set_client_multifile_incomplete(string mfname);
  INLINE void set_client_multifile_complete(string mfname);
  INLINE void set_client_multifile_decompressed(string mfname);
  INLINE void set_client_multifile_extracted(string mfname);

  INLINE int get_server_num_files(string mfname) const;
  INLINE string get_server_file_name(string mfname, int index) const;

  // Queries from the Launcher
  bool client_multifile_exists(string mfname) const;
  bool client_multifile_complete(string mfname) const;
  bool client_multifile_decompressed(string mfname) const;
  bool client_multifile_extracted(string mfname) const;

  // Ask what version (told with the hash) this multifile is
  HashVal get_client_multifile_hash(string mfname) const;
  void set_client_multifile_hash(string mfname, HashVal val);
  HashVal get_server_multifile_hash(string mfname) const;
  void set_server_multifile_hash(string mfname, HashVal val);

  // Operations on multifiles
  void delete_client_multifile(string mfname);
  void add_client_multifile(string server_mfname);
  void expand_client_multifile(string mfname);

  // Server side operations to create multifile records
  void create_new_server_db();
  void server_add_multifile(string mfname, Phase phase, int size, int status);
  void server_add_file(string mfname, string fname);

public:

  class EXPCL_PANDAEXPRESS FileRecord : public ReferenceCount {
  public:
    FileRecord(void);
    FileRecord(string name);
    void write(ostream &out) const;
    string _name;
  };

  typedef pvector< PT(FileRecord) > FileRecords;

  class EXPCL_PANDAEXPRESS MultifileRecord : public ReferenceCount {
  public:
    MultifileRecord(void);
    MultifileRecord(string name, Phase phase, int size, int status);
    void write(ostream &out) const;
    int get_num_files(void) const;
    string get_file_name(int index) const;
    bool file_exists(string fname) const;
    PT(FileRecord) get_file_record_named(string fname) const;
    void add_file_record(PT(FileRecord) fr);
    string _name;
    Phase _phase;
    int _size;
    int _status;
    HashVal _hash;
    PN_int32 _num_files;
    FileRecords _file_records;
  };

  typedef pvector< PT(MultifileRecord) > MultifileRecords;

  class EXPCL_PANDAEXPRESS Db {
  public:
    Db(void);
    void write(ostream &out) const;
    int get_num_multifiles(void) const;
    string get_multifile_name(int index) const;
    bool multifile_exists(string mfname) const;
    PT(MultifileRecord) get_multifile_record_named(string mfname) const;
    void add_multifile_record(PT(MultifileRecord) mfr);
    int parse_header(uchar *start, int size);
    int parse_record_header(uchar *start, int size);
    PT(MultifileRecord) parse_mfr(uchar *start, int size);
    PT(FileRecord) parse_fr(uchar *start, int size);
    bool read(istream &read_stream, bool want_server_info);
    bool write(ofstream &write_stream, bool want_server_info);
    Filename _filename;
    MultifileRecords _mfile_records;
    bool write_header(ofstream &write_stream);
    bool write_bogus_header(ofstream &write_stream);
  private:
    PN_int32 _header_length;

    // Datagram used for reading and writing to disk
    Datagram _datagram;

  };

PUBLISHED:
  Db read_db(Filename &file, bool want_server_info);
  Db read_db(Ramfile &file, bool want_server_info);
  bool write_db(Filename &file, Db db, bool want_server_info);

public:
  // The download db stores two databases, one that represents the
  // client's state and one that represents the server state.
  Db _client_db;
  Db _server_db;

  // Magic number for knowing this is a download Db
  static PN_uint32 _magic_number;
  static PN_uint32 _bogus_magic_number;
  typedef pvector<HashVal> VectorHash;
  typedef pmap<Filename, VectorHash> VersionMap;

PUBLISHED:
  void add_version(const Filename &name, const HashVal &hash, int version);
  void insert_new_version(const Filename &name, const HashVal &hash);
  bool has_version(const Filename &name) const;
  int get_num_versions(const Filename &name) const;
  void set_num_versions(const Filename &name, int num_versions);

  int get_version(const Filename &name, const HashVal &hash) const;
  const HashVal &get_hash(const Filename &name, int version) const;

protected:
  void write_version_map(ofstream &write_stream);
  bool read_version_map(istream &read_stream);
  VersionMap _versions;
  Datagram _master_datagram;
};

INLINE ostream &operator << (ostream &out, const DownloadDb &dldb) {
  dldb.output(out);
  return out;
}


#include "downloadDb.I"

#endif

---