Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E4540200CD1 for ; Wed, 21 Jun 2017 02:57:34 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E3768160C03; Wed, 21 Jun 2017 00:57:34 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D3198160C01 for ; Wed, 21 Jun 2017 02:57:31 +0200 (CEST) Received: (qmail 45802 invoked by uid 500); 21 Jun 2017 00:57:30 -0000 Mailing-List: contact commits-help@mesos.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@mesos.apache.org Delivered-To: mailing list commits@mesos.apache.org Received: (qmail 45604 invoked by uid 99); 21 Jun 2017 00:57:30 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 21 Jun 2017 00:57:30 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 20A4AE38E1; Wed, 21 Jun 2017 00:57:30 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@mesos.apache.org Date: Wed, 21 Jun 2017 00:57:41 -0000 Message-Id: In-Reply-To: <30bc71aafe0d4b41b59d07dc0a60a631@git.apache.org> References: <30bc71aafe0d4b41b59d07dc0a60a631@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [13/51] [partial] mesos-site git commit: Updated the website built from mesos SHA: ae76475. archived-at: Wed, 21 Jun 2017 00:57:35 -0000 http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6b298f58/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Executor.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Executor.html b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Executor.html new file mode 100644 index 0000000..8a3acff --- /dev/null +++ b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Executor.html @@ -0,0 +1,680 @@ + + + + + + +Apache Mesos: mesos::internal::slave::Executor Class Reference + + + + + + +
+
+ + + + + + +
+
Apache Mesos +
+
+
+ + + + + +
+
+
+Public Types | +Public Member Functions | +Public Attributes | +List of all members
+
+
mesos::internal::slave::Executor Class Reference
+
+
+ +

#include <slave.hpp>

+ + + + +

+Public Types

enum  State { REGISTERING, +RUNNING, +TERMINATING, +TERMINATED + }
 
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

+Public Member Functions

 Executor (Slave *slave, const FrameworkID &frameworkId, const ExecutorInfo &info, const ContainerID &containerId, const std::string &directory, const Option< std::string > &user, bool checkpoint)
 
 ~Executor ()
 
Task * addTask (const TaskInfo &task)
 
void completeTask (const TaskID &taskId)
 
void checkpointExecutor ()
 
void checkpointTask (const TaskInfo &task)
 
void checkpointTask (const Task &task)
 
void recoverTask (const state::TaskState &state, bool recheckpointTask)
 
Try< Nothing > updateTaskState (const TaskStatus &status)
 
bool incompleteTasks ()
 
template<typename Message >
void send (const Message &message)
 
bool isCommandExecutor () const
 
void closeHttpConnection ()
 
Option< TaskGroupInfo > getQueuedTaskGroup (const TaskID &taskId)
 
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +

+Public Attributes

enum
+mesos::internal::slave::Executor::State 		state
 
Slave * slave
 
const ExecutorID id
 
const ExecutorInfo info
 
const FrameworkID frameworkId
 
const ContainerID containerId
 
const std::string directory
 
const Option< std::string > user
 
const bool checkpoint
 
Option< HttpConnection > http
 
Option< process::UPID > pid
 
Resources resources
 
LinkedHashMap< TaskID, TaskInfo > queuedTasks
 
std::list< TaskGroupInfo > queuedTaskGroups
 
LinkedHashMap< TaskID, Task * > launchedTasks
 
LinkedHashMap< TaskID, Task * > terminatedTasks
 
boost::circular_buffer
+< std::shared_ptr< Task > > 		completedTasks
 
Option
+< mesos::slave::ContainerTermination > 		pendingTermination
 
+

Member Enumeration Documentation

+ +
+
+ + + + +
enum mesos::internal::slave::Executor::State
+
+ + + + + +
Enumerator
REGISTERING  +
RUNNING  +
TERMINATING  +
TERMINATED  +
+ +
+
+

Constructor & Destructor Documentation

+ +
+
+ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + +
mesos::internal::slave::Executor::Executor (Slave * slave,
const FrameworkID & frameworkId,
const ExecutorInfo & info,
const ContainerID & containerId,
const std::string & directory,
const Option< std::string > & user,
bool checkpoint 
)
+
+ +
+
+ +
+
+ + + + + + + +
mesos::internal::slave::Executor::~Executor ()
+
+ +
+
+

Member Function Documentation

+ +
+
+ + + + + + + + +
Task* mesos::internal::slave::Executor::addTask (const TaskInfo & task)
+
+ +
+
+ +
+
+ + + + + + + +
void mesos::internal::slave::Executor::checkpointExecutor ()
+
+ +
+
+ +
+
+ + + + + + + + +
void mesos::internal::slave::Executor::checkpointTask (const TaskInfo & task)
+
+ +
+
+ +
+
+ + + + + + + + +
void mesos::internal::slave::Executor::checkpointTask (const Task & task)
+
+ +
+
+ +
+
+ + + + + + + +
void mesos::internal::slave::Executor::closeHttpConnection ()
+
+ +
+
+ +
+
+ + + + + + + + +
void mesos::internal::slave::Executor::completeTask (const TaskID & taskId)
+
+ +
+
+ +
+
+ + + + + + + + +
Option<TaskGroupInfo> mesos::internal::slave::Executor::getQueuedTaskGroup (const TaskID & taskId)
+
+ +
+
+ +
+
+ + + + + + + +
bool mesos::internal::slave::Executor::incompleteTasks ()
+
+ +
+
+ +
+
+ + + + + + + +
bool mesos::internal::slave::Executor::isCommandExecutor () const
+
+ +
+
+ +
+
+ + + + + + + + + + + + + + + + + + +
void mesos::internal::slave::Executor::recoverTask (const state::TaskState & state,
bool recheckpointTask 
)
+
+ +
+
+ +
+
+
+template<typename Message >
+ + + + + +
+ + + + + + + + +
void mesos::internal::slave::Executor::send (const Message & message)
+ 		+inline
+
+ +
+
+ +
+
+ + + + + + + + +
Try<Nothing> mesos::internal::slave::Executor::updateTaskState (const TaskStatus & status)
+
+ +
+
+

Member Data Documentation

+ +
+
+ + + + +
const bool mesos::internal::slave::Executor::checkpoint
+
+ +
+
+ +
+
+ + + + +
boost::circular_buffer<std::shared_ptr<Task> > mesos::internal::slave::Executor::completedTasks
+
+ +
+
+ +
+
+ + + + +
const ContainerID mesos::internal::slave::Executor::containerId
+
+ +
+
+ +
+
+ + + + +
const std::string mesos::internal::slave::Executor::directory
+
+ +
+
+ +
+
+ + + + +
const FrameworkID mesos::internal::slave::Executor::frameworkId
+
+ +
+
+ +
+
+ + + + +
Option<HttpConnection> mesos::internal::slave::Executor::http
+
+ +
+
+ +
+
+ + + + +
const ExecutorID mesos::internal::slave::Executor::id
+
+ +
+
+ +
+
+ + + + +
const ExecutorInfo mesos::internal::slave::Executor::info
+
+ +
+
+ +
+
+ + + + +
LinkedHashMap<TaskID, Task*> mesos::internal::slave::Executor::launchedTasks
+
+ +
+
+ +
+
+ + + + +
Option<mesos::slave::ContainerTermination> mesos::internal::slave::Executor::pendingTermination
+
+ +
+
+ +
+
+ + + + +
Option<process::UPID> mesos::internal::slave::Executor::pid
+
+ +
+
+ +
+
+ + + + +
std::list<TaskGroupInfo> mesos::internal::slave::Executor::queuedTaskGroups
+
+ +
+
+ +
+
+ + + + +
LinkedHashMap<TaskID, TaskInfo> mesos::internal::slave::Executor::queuedTasks
+
+ +
+
+ +
+
+ + + + +
Resources mesos::internal::slave::Executor::resources
+
+ +
+
+ +
+
+ + + + +
Slave* mesos::internal::slave::Executor::slave
+
+ +
+
+ +
+
+ + + + +
enum mesos::internal::slave::Executor::State mesos::internal::slave::Executor::state
+
+ +
+
+ +
+
+ + + + +
LinkedHashMap<TaskID, Task*> mesos::internal::slave::Executor::terminatedTasks
+
+ +
+
+ +
+
+ + + + +
const Option<std::string> mesos::internal::slave::Executor::user
+
+ +
+
+
The documentation for this class was generated from the following file: +
+ +
+Generated by   +doxygen + 1.8.5 +
+ + http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6b298f58/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher-members.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher-members.html b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher-members.html index 6d62d8f..75f63a5 100644 --- a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher-members.html +++ b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher-members.html @@ -58,16 +58,15 @@

This is the complete list of members for mesos::internal::slave::Fetcher, including all inherited members.

- - + + - - - - - + + + +
basename(const std::string &uri)mesos::internal::slave::Fetcherstatic
fetch(const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user, const SlaveID &slaveId, const Flags &flags)mesos::internal::slave::Fetcher
Fetcher()mesos::internal::slave::Fetcher
fetch(const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user)mesos::internal::slave::Fetcher
Fetcher(const Flags &flags)mesos::internal::slave::Fetcher
Fetcher(const process::Owned< FetcherProcess > &process)mesos::internal::slave::Fetcher
isNetUri(const std::string &uri)mesos::internal::slave::Fetcherstatic
kill(const ContainerID &containerId)mesos::internal::slave::Fetcher
recover(const SlaveID &slaveId, const Flags &flags)mesos::internal::slave::Fetcherstatic
uriToLocalPath(const std::string &uri, const Option< std::string > &frameworksHome)mesos::internal::slave::Fetcherstatic
validateOutputFile(const std::string &path)mesos::internal::slave::Fetcherstatic
validateUri(const std::string &uri)mesos::internal::slave::Fetcherstatic
~Fetcher()mesos::internal::slave::Fetchervirtual
uriToLocalPath(const std::string &uri, const Option< std::string > &frameworksHome)mesos::internal::slave::Fetcherstatic
validateOutputFile(const std::string &path)mesos::internal::slave::Fetcherstatic
validateUri(const std::string &uri)mesos::internal::slave::Fetcherstatic
~Fetcher()mesos::internal::slave::Fetchervirtual
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6b298f58/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher.html b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher.html index 0c3502e..afe0e6d 100644 --- a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher.html +++ b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1Fetcher.html @@ -63,14 +63,14 @@ - - + + - - + +

Public Member Functions

 Fetcher ()
 
 Fetcher (const Flags &flags)
 
 Fetcher (const process::Owned< FetcherProcess > &process)
 
virtual ~Fetcher ()
 
process::Future< Nothing > fetch (const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user, const SlaveID &slaveId, const Flags &flags)
 
process::Future< Nothing > fetch (const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user)
 
void kill (const ContainerID &containerId)
 
@@ -86,18 +86,17 @@ Static Public Member Functions - -
 
static bool isNetUri (const std::string &uri)
 
static Try< Nothing > recover (const SlaveID &slaveId, const Flags &flags)
 

Constructor & Destructor Documentation

- +
- + +
mesos::internal::slave::Fetcher::Fetcher ()const Flags & flags)
@@ -169,7 +168,7 @@ Static Public Member Functions
- +
@@ -195,19 +194,7 @@ Static Public Member Functions - - - - - - - - - - - - - + @@ -259,40 +246,6 @@ Static Public Member Functions - -
-
-
const Option< std::string > & user,
const SlaveID & slaveId,
const Flags & flags user 
- - - - -
- - - - - - - - - - - - - - - - - - -
static Try<Nothing> mesos::internal::slave::Fetcher::recover (const SlaveID & slaveId,
const Flags & flags 
)
- 		-static
-
- -
-
http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6b298f58/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess-members.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess-members.html b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess-members.html index 33da42a..43a8643 100644 --- a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess-members.html +++ b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess-members.html @@ -57,16 +57,16 @@

This is the complete list of members for mesos::internal::slave::FetcherProcess, including all inherited members.

- + - + - - + + @@ -87,7 +87,7 @@ - + http://git-wip-us.apache.org/repos/asf/mesos-site/blob/6b298f58/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess.html ---------------------------------------------------------------------- diff --git a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess.html b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess.html index 517accd..035d18e 100644 --- a/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess.html +++ b/content/api/latest/c++/classmesos_1_1internal_1_1slave_1_1FetcherProcess.html @@ -80,20 +80,20 @@ Classes
_fetch(const hashmap< CommandInfo::URI, Option< process::Future< std::shared_ptr< Cache::Entry >>>> &entries, const ContainerID &containerId, const std::string &sandboxDirectory, const std::string &cacheDirectory, const Option< std::string > &user, const Flags &flags)mesos::internal::slave::FetcherProcessvirtual
_fetch(const hashmap< CommandInfo::URI, Option< process::Future< std::shared_ptr< Cache::Entry >>>> &entries, const ContainerID &containerId, const std::string &sandboxDirectory, const std::string &cacheDirectory, const Option< std::string > &user)mesos::internal::slave::FetcherProcessvirtual
AuthenticatedHttpRequestHandler typedefprocess::ProcessBaseprotected
availableCacheSpace()mesos::internal::slave::FetcherProcess
cacheFiles(const SlaveID &slaveId, const Flags &flags)mesos::internal::slave::FetcherProcess
cacheFiles()mesos::internal::slave::FetcherProcess
cacheSize()mesos::internal::slave::FetcherProcess
delegate(const std::string &name, const UPID &pid)process::ProcessBaseinlineprotected
eventCount()process::ProcessBaseinlineprotected
exited(const UPID &)process::ProcessBaseinlineprotectedvirtual
fetch(const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user, const SlaveID &slaveId, const Flags &flags)mesos::internal::slave::FetcherProcess
FetcherProcess()mesos::internal::slave::FetcherProcessinline
fetch(const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user)mesos::internal::slave::FetcherProcess
FetcherProcess(const Flags &_flags)mesos::internal::slave::FetcherProcessinline
finalize()process::ProcessBaseinlineprotectedvirtual
httpprocess::ProcessBase
HttpRequestHandler typedefprocess::ProcessBaseprotected
route(const std::string &name, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &), const RouteOptions &options=RouteOptions())process::ProcessBaseinlineprotected
route(const std::string &name, const std::string &realm, const Option< std::string > &help, const AuthenticatedHttpRequestHandler &handler, const RouteOptions &options=RouteOptions())process::ProcessBaseprotected
route(const std::string &name, const std::string &realm, const Option< std::string > &help, Future< http::Response >(T::*method)(const http::Request &, const Option< http::authentication::Principal > &), const RouteOptions &options=RouteOptions())process::ProcessBaseinlineprotected
run(const ContainerID &containerId, const std::string &sandboxDirectory, const Option< std::string > &user, const mesos::fetcher::FetcherInfo &info, const Flags &flags)mesos::internal::slave::FetcherProcessvirtual
run(const ContainerID &containerId, const std::string &sandboxDirectory, const Option< std::string > &user, const mesos::fetcher::FetcherInfo &info)mesos::internal::slave::FetcherProcessvirtual
Self typedefprocess::Process< FetcherProcess >protected
self() constprocess::Process< FetcherProcess >inline
send(const UPID &to, const std::string &name, const char *data=nullptr, size_t length=0)process::ProcessBaseprotected
- - + + - - - - + + + + - - - - + + + + @@ -211,7 +211,7 @@ const http::Request

Public Member Functions

 FetcherProcess ()
 
 FetcherProcess (const Flags &_flags)
 
virtual ~FetcherProcess ()
 
process::Future< Nothing > fetch (const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user, const SlaveID &slaveId, const Flags &flags)
 
virtual process::Future< Nothing > run (const ContainerID &containerId, const std::string &sandboxDirectory, const Option< std::string > &user, const mesos::fetcher::FetcherInfo &info, const Flags &flags)
 
process::Future< Nothing > fetch (const ContainerID &containerId, const CommandInfo &commandInfo, const std::string &sandboxDirectory, const Option< std::string > &user)
 
virtual process::Future< Nothing > run (const ContainerID &containerId, const std::string &sandboxDirectory, const Option< std::string > &user, const mesos::fetcher::FetcherInfo &info)
 
void kill (const ContainerID &containerId)
 
virtual process::Future< Nothing > _fetch (const hashmap< CommandInfo::URI, Option< process::Future< std::shared_ptr< Cache::Entry >>>> &entries, const ContainerID &containerId, const std::string &sandboxDirectory, const std::string &cacheDirectory, const Option< std::string > &user, const Flags &flags)
 
Try< std::list< Path > > cacheFiles (const SlaveID &slaveId, const Flags &flags)
 
virtual process::Future< Nothing > _fetch (const hashmap< CommandInfo::URI, Option< process::Future< std::shared_ptr< Cache::Entry >>>> &entries, const ContainerID &containerId, const std::string &sandboxDirectory, const std::string &cacheDirectory, const Option< std::string > &user)
 
Try< std::list< Path > > cacheFiles ()
 
size_t cacheSize ()
 
Bytes availableCacheSpace ()
 

Constructor & Destructor Documentation

- +
@@ -221,7 +221,8 @@ const http::Request - + +
mesos::internal::slave::FetcherProcess::FetcherProcess ()const Flags & _flags)
@@ -258,7 +259,7 @@ const http::Request

Member Function Documentation

- +
@@ -293,13 +294,7 @@ const http::Request - - - - - - - + @@ -331,26 +326,15 @@ const http::Request - +
const Option< std::string > & user,
const Flags & flags user 
- - - - - + - - - - - - -
Try<std::list<Path> > mesos::internal::slave::FetcherProcess::cacheFiles (const SlaveID & slaveId,
) const Flags & flags 
)
@@ -372,7 +356,7 @@ const http::Request
- +
@@ -398,19 +382,7 @@ const http::Request - - - - - - - - - - - - - + @@ -438,7 +410,7 @@ const http::Request - +
const Option< std::string > & user,
const SlaveID & slaveId,
const Flags & flags user 
@@ -467,13 +439,7 @@ const http::Request - - - - - - - +
const mesos::fetcher::FetcherInfo & info,
const Flags & flags info