Public Types
typedef std::map< int, shared_ptr< Param > >	ParamShard

Public Member Functions
	Server (int thread_id, int group_id, int server_id)

void	Setup (const UpdaterProto &proto, shared_ptr< ParamShard > shard)

void	Run ()

Protected Member Functions
virtual Msg *	HandleGet (shared_ptr< Param > param, Msg **msg)
	Process GET request. More...

virtual Msg *	HandleUpdate (shared_ptr< Param > param, Msg **msg)
	Process Update request. More...

virtual Msg *	HandlePut (shared_ptr< Param > param, Msg **msg)
	Process PUT request. More...

virtual Msg *	HandleSyncRequest (shared_ptr< Param > param, Msg **msg)
	TODO Process SYNC request.

virtual int	HandleSyncResponse (shared_ptr< Param > param, Msg **msg)
	TODO Process SYNC response.

virtual bool	SyncNow ()
	Scheduler for synchronizing server groups. More...

Member Function Documentation

virtual Msg* singa::Server::HandleGet	(	shared_ptr< Param >	param,
		Msg **	msg
	)

protectedvirtual

Process GET request.

virtual Msg* singa::Server::HandlePut	(	shared_ptr< Param >	param,
		Msg **	msg
	)

protectedvirtual

Process PUT request.

Returns: the original message or response message. If we don't want need to acknowledge the put request, then return nullptr.

virtual Msg* singa::Server::HandleUpdate	(	shared_ptr< Param >	param,
		Msg **	msg
	)

protectedvirtual

Process Update request.

virtual bool singa::Server::SyncNow ( )

protectedvirtual

Scheduler for synchronizing server groups.

TODO implement the Caffe's synchronization scheduler for data parallelism

The documentation for this class was generated from the following file:

Public Types