CodecScheduler.h

Go to the documentation of this file.

/*
 *    Copyright (C) 2016-2026 Grok Image Compression Inc.
 *
 *    This source code is free software: you can redistribute it and/or  modify
 *    it under the terms of the GNU Affero General Public License, version 3,
 *    as published by the Free Software Foundation.
 *
 *    This source code 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 Affero General Public License for more details.
 *
 *    You should have received a copy of the GNU Affero General Public License
 *    along with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 */
 
#pragma once
 
#include "grk_taskflow.h"
 
namespace grk
{
 
struct ITileProcessor;
struct TileComponent;
class ResolutionChecker
{
public:
  ResolutionChecker(uint16_t numComponents, TileComponent* comps, bool cacheAll);
 
  // Check if a specific component contains a given resolution
  bool contains(uint16_t compno, uint8_t resolution) const;
 
  std::pair<uint8_t, uint8_t> getResBounds(uint16_t compno);
 
private:
  // Pair of <resBegin, resUpperBound> for each component
  std::vector<std::pair<uint8_t, uint8_t>> componentResolutions_;
};

struct DifferentialInfo
{
  DifferentialInfo(void) : layersDecompressed_(0) {}

  uint16_t layersDecompressed_;
};

class CodecScheduler : public FlowComponent
{
public:
  explicit CodecScheduler(uint16_t numComps);

  virtual ~CodecScheduler();

  virtual bool scheduleT1(ITileProcessor* proc) = 0;

  void run(void);

  bool wait(void);

  virtual void release(void) = 0;
 
protected:
  void releaseCoders(void);

  std::atomic_bool success_;

  uint16_t numcomps_;

  std::vector<t1::ICoder*> coders_;

  tf::Future<void> runFuture_;
};
 
} // namespace grk