154e6dadea
This makes Engines (task execution strategies: serial, thread, fork) pluggable just like most of the rest of ok. It removes the thread and process limits, as I find myself rarely caring about what they are exactly. Instead of limiting to num-cores, we just allow any number of concurrent threads, and any number of concurrent child processes subject to OS limitations. Change-Id: Icef49d86818fe9a4b7380efb60e73e40bc2e6b73 Reviewed-on: https://skia-review.googlesource.com/27140 Reviewed-by: Mike Klein <mtklein@chromium.org> Commit-Queue: Mike Klein <mtklein@chromium.org>
70 lines
1.8 KiB
C++
70 lines
1.8 KiB
C++
/*
|
|
* Copyright 2017 Google Inc.
|
|
*
|
|
* Use of this source code is governed by a BSD-style license that can be
|
|
* found in the LICENSE file.
|
|
*/
|
|
|
|
#ifndef ok_DEFINED
|
|
#define ok_DEFINED
|
|
|
|
#include "SkCanvas.h"
|
|
#include <functional>
|
|
#include <future>
|
|
#include <map>
|
|
#include <memory>
|
|
#include <string>
|
|
|
|
// Not really ok-specific, but just kind of generally handy.
|
|
template <typename T>
|
|
static std::unique_ptr<T> move_unique(T& v) {
|
|
return std::unique_ptr<T>{new T{std::move(v)}};
|
|
}
|
|
|
|
void ok_log(const char*);
|
|
|
|
enum class Status { OK, Failed, Crashed, Skipped, None };
|
|
|
|
struct Engine {
|
|
virtual ~Engine() {}
|
|
virtual bool crashproof() = 0;
|
|
virtual std::future<Status> spawn(std::function<Status(void)>) = 0;
|
|
};
|
|
|
|
struct Src {
|
|
virtual ~Src() {}
|
|
virtual std::string name() = 0;
|
|
virtual SkISize size() = 0;
|
|
virtual Status draw(SkCanvas*) = 0;
|
|
};
|
|
|
|
struct Stream {
|
|
virtual ~Stream() {}
|
|
virtual std::unique_ptr<Src> next() = 0;
|
|
};
|
|
|
|
struct Dst {
|
|
virtual ~Dst() {}
|
|
virtual Status draw(Src*) = 0;
|
|
virtual sk_sp<SkImage> image() = 0;
|
|
};
|
|
|
|
class Options {
|
|
std::map<std::string, std::string> kv;
|
|
public:
|
|
explicit Options(std::string = "");
|
|
std::string& operator[](std::string k);
|
|
std::string operator()(std::string k, std::string fallback = "") const;
|
|
};
|
|
|
|
// Create globals to register your new type of Stream or Dst.
|
|
struct Register {
|
|
Register(const char* name, const char* help, std::unique_ptr<Engine> (*factory)(Options));
|
|
Register(const char* name, const char* help, std::unique_ptr<Stream> (*factory)(Options));
|
|
Register(const char* name, const char* help, std::unique_ptr<Dst> (*factory)(Options));
|
|
Register(const char* name, const char* help,
|
|
std::unique_ptr<Dst>(*factory)(Options, std::unique_ptr<Dst>));
|
|
};
|
|
|
|
#endif//ok_DEFINED
|