|
|
@ -15,7 +15,9 @@ limitations under the License. */
|
|
|
|
#include "PaddleAPI.h"
|
|
|
|
#include "PaddleAPI.h"
|
|
|
|
|
|
|
|
|
|
|
|
#include "PaddleAPIPrivate.h"
|
|
|
|
#include "PaddleAPIPrivate.h"
|
|
|
|
|
|
|
|
#ifndef PADDLE_WITHOUT_GOLANG
|
|
|
|
#include "paddle/trainer/NewRemoteParameterUpdater.h"
|
|
|
|
#include "paddle/trainer/NewRemoteParameterUpdater.h"
|
|
|
|
|
|
|
|
#endif
|
|
|
|
#include "paddle/trainer/RemoteParameterUpdater.h"
|
|
|
|
#include "paddle/trainer/RemoteParameterUpdater.h"
|
|
|
|
#include "paddle/trainer/ThreadParameterUpdater.h"
|
|
|
|
#include "paddle/trainer/ThreadParameterUpdater.h"
|
|
|
|
|
|
|
|
|
|
|
@ -30,11 +32,16 @@ ParameterUpdater *ParameterUpdater::createLocalUpdater(
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ParameterUpdater *ParameterUpdater::createNewRemoteUpdater(
|
|
|
|
ParameterUpdater *ParameterUpdater::createNewRemoteUpdater(
|
|
|
|
OptimizationConfig *config, const std::string pserverSpec) {
|
|
|
|
OptimizationConfig *config,
|
|
|
|
|
|
|
|
const std::string pserverSpec) throw(UnsupportError) {
|
|
|
|
|
|
|
|
#ifndef PADDLE_WITHOUT_GOLANG
|
|
|
|
auto updater = new ParameterUpdater();
|
|
|
|
auto updater = new ParameterUpdater();
|
|
|
|
updater->m->updater.reset(new paddle::NewRemoteParameterUpdater(
|
|
|
|
updater->m->updater.reset(new paddle::NewRemoteParameterUpdater(
|
|
|
|
config->m->getConfig(), pserverSpec));
|
|
|
|
config->m->getConfig(), pserverSpec));
|
|
|
|
return updater;
|
|
|
|
return updater;
|
|
|
|
|
|
|
|
#else
|
|
|
|
|
|
|
|
throw UnsupportError();
|
|
|
|
|
|
|
|
#endif
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
ParameterUpdater *ParameterUpdater::createRemoteUpdater(
|
|
|
|
ParameterUpdater *ParameterUpdater::createRemoteUpdater(
|
|
|
|