Merge pull request #1551 from erwincoumans/master

C-API/PyBullet: fix issue with plugin manager
This commit is contained in:
erwincoumans
2018-02-06 10:48:19 -08:00
committed by GitHub
13 changed files with 96 additions and 50 deletions

View File

@@ -78,7 +78,7 @@ typedef b3PoolBodyHandle<b3Plugin> b3PluginHandle;
struct b3PluginManagerInternalData struct b3PluginManagerInternalData
{ {
b3ResizablePool<b3PluginHandle> m_plugins; b3ResizablePool<b3PluginHandle> m_plugins;
b3HashMap<b3HashString, b3PluginHandle*> m_pluginMap; b3HashMap<b3HashString, int> m_pluginMap;
PhysicsDirect* m_physicsDirect; PhysicsDirect* m_physicsDirect;
b3AlignedObjectArray<b3KeyboardEvent> m_keyEvents; b3AlignedObjectArray<b3KeyboardEvent> m_keyEvents;
b3AlignedObjectArray<b3VRControllerEvent> m_vrEvents; b3AlignedObjectArray<b3VRControllerEvent> m_vrEvents;
@@ -102,8 +102,12 @@ b3PluginManager::~b3PluginManager()
{ {
while (m_data->m_pluginMap.size()) while (m_data->m_pluginMap.size())
{ {
b3PluginHandle** plugin = m_data->m_pluginMap.getAtIndex(0); int* pluginUidPtr = m_data->m_pluginMap.getAtIndex(0);
unloadPlugin((*plugin)->m_pluginUniqueId); if (pluginUidPtr)
{
int pluginUid = *pluginUidPtr;
unloadPlugin(*pluginUidPtr);
}
} }
delete m_data->m_physicsDirect; delete m_data->m_physicsDirect;
m_data->m_pluginMap.clear(); m_data->m_pluginMap.clear();
@@ -140,11 +144,11 @@ int b3PluginManager::loadPlugin(const char* pluginPath, const char* postFixStr)
{ {
int pluginUniqueId = -1; int pluginUniqueId = -1;
b3PluginHandle** pluginOrgPtr = m_data->m_pluginMap.find(pluginPath); int* pluginUidPtr = m_data->m_pluginMap.find(pluginPath);
if (pluginOrgPtr) if (pluginUidPtr)
{ {
//already loaded //already loaded
pluginUniqueId = (*pluginOrgPtr)->m_pluginUniqueId; pluginUniqueId = *pluginUidPtr;
} }
else else
{ {
@@ -185,7 +189,7 @@ int b3PluginManager::loadPlugin(const char* pluginPath, const char* postFixStr)
plugin->m_ownsPluginHandle = true; plugin->m_ownsPluginHandle = true;
plugin->m_pluginHandle = pluginHandle; plugin->m_pluginHandle = pluginHandle;
plugin->m_pluginPath = pluginPath; plugin->m_pluginPath = pluginPath;
m_data->m_pluginMap.insert(pluginPath, plugin); m_data->m_pluginMap.insert(pluginPath, pluginUniqueId);
} }
else else
{ {
@@ -246,16 +250,19 @@ void b3PluginManager::tickPlugins(double timeStep, bool isPreTick)
{ {
for (int i=0;i<m_data->m_pluginMap.size();i++) for (int i=0;i<m_data->m_pluginMap.size();i++)
{ {
b3PluginHandle** pluginPtr = m_data->m_pluginMap.getAtIndex(i); int* pluginUidPtr = m_data->m_pluginMap.getAtIndex(i);
b3PluginHandle* plugin = 0; b3PluginHandle* plugin = 0;
if (pluginPtr && *pluginPtr)
if (pluginUidPtr)
{ {
plugin = *pluginPtr; int pluginUid = *pluginUidPtr;
plugin = m_data->m_plugins.getHandle(pluginUid);
} }
else else
{ {
continue; continue;
} }
PFN_TICK tick = isPreTick? plugin->m_preTickFunc : plugin->m_postTickFunc; PFN_TICK tick = isPreTick? plugin->m_preTickFunc : plugin->m_postTickFunc;
if (tick) if (tick)
{ {
@@ -319,7 +326,7 @@ int b3PluginManager::registerStaticLinkedPlugin(const char* pluginPath, PFN_INIT
pluginHandle->m_userPointer = 0; pluginHandle->m_userPointer = 0;
m_data->m_pluginMap.insert(pluginPath, pluginHandle); m_data->m_pluginMap.insert(pluginPath, pluginUniqueId);
{ {
b3PluginContext context; b3PluginContext context;

View File

@@ -47,7 +47,7 @@ def main():
print(obs) print(obs)
episode_rew = 0 episode_rew = 0
while not done: while not done:
env.render() env.render(mode='human')
act = policy.sample_action(obs, .1) act = policy.sample_action(obs, .1)
print("Action") print("Action")
print(act) print(act)

View File

@@ -17,7 +17,7 @@ import time
import subprocess import subprocess
import pybullet as p import pybullet as p
import pybullet_data import pybullet_data
from pkg_resources import parse_version
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@@ -100,7 +100,8 @@ class CartPoleBulletEnv(gym.Env):
def _render(self, mode='human', close=False): def _render(self, mode='human', close=False):
return return
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -14,6 +14,8 @@ import pybullet as p
from . import kuka from . import kuka
import random import random
import pybullet_data import pybullet_data
from pkg_resources import parse_version
maxSteps = 1000 maxSteps = 1000
RENDER_HEIGHT = 720 RENDER_HEIGHT = 720
@@ -254,7 +256,8 @@ class KukaCamGymEnv(gym.Env):
#print(reward) #print(reward)
return reward return reward
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -13,6 +13,7 @@ import pybullet as p
from . import kuka from . import kuka
import random import random
import pybullet_data import pybullet_data
from pkg_resources import parse_version
largeValObservation = 100 largeValObservation = 100
@@ -185,6 +186,7 @@ class KukaGymEnv(gym.Env):
def _render(self, mode="rgb_array", close=False): def _render(self, mode="rgb_array", close=False):
if mode != "rgb_array": if mode != "rgb_array":
return np.array([]) return np.array([])
base_pos,orn = self._p.getBasePositionAndOrientation(self._kuka.kukaUid) base_pos,orn = self._p.getBasePositionAndOrientation(self._kuka.kukaUid)
view_matrix = self._p.computeViewMatrixFromYawPitchRoll( view_matrix = self._p.computeViewMatrixFromYawPitchRoll(
cameraTargetPosition=base_pos, cameraTargetPosition=base_pos,
@@ -199,7 +201,12 @@ class KukaGymEnv(gym.Env):
(_, _, px, _, _) = self._p.getCameraImage( (_, _, px, _, _) = self._p.getCameraImage(
width=RENDER_WIDTH, height=RENDER_HEIGHT, viewMatrix=view_matrix, width=RENDER_WIDTH, height=RENDER_HEIGHT, viewMatrix=view_matrix,
projectionMatrix=proj_matrix, renderer=self._p.ER_BULLET_HARDWARE_OPENGL) projectionMatrix=proj_matrix, renderer=self._p.ER_BULLET_HARDWARE_OPENGL)
rgb_array = np.array(px) #renderer=self._p.ER_TINY_RENDERER)
rgb_array = np.array(px, dtype=np.uint8)
rgb_array = np.reshape(rgb_array, (RENDER_WIDTH, RENDER_HEIGHT, 4))
rgb_array = rgb_array[:, :, :3] rgb_array = rgb_array[:, :, :3]
return rgb_array return rgb_array
@@ -276,7 +283,8 @@ class KukaGymEnv(gym.Env):
#print(reward) #print(reward)
return reward return reward
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -10,7 +10,8 @@ import pybullet_data
import pdb import pdb
import distutils.dir_util import distutils.dir_util
import glob import glob
from pkg_resources import parse_version
import gym
class KukaDiverseObjectEnv(KukaGymEnv): class KukaDiverseObjectEnv(KukaGymEnv):
"""Class for Kuka environment with diverse objects. """Class for Kuka environment with diverse objects.
@@ -323,4 +324,10 @@ class KukaDiverseObjectEnv(KukaGymEnv):
selected_objects_filenames = [] selected_objects_filenames = []
for object_index in selected_objects: for object_index in selected_objects:
selected_objects_filenames += [found_object_directories[object_index]] selected_objects_filenames += [found_object_directories[object_index]]
return selected_objects_filenames return selected_objects_filenames
if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset
step = _step

View File

@@ -20,6 +20,7 @@ from . import minitaur
import os import os
import pybullet_data import pybullet_data
from . import minitaur_env_randomizer from . import minitaur_env_randomizer
from pkg_resources import parse_version
NUM_SUBSTEPS = 5 NUM_SUBSTEPS = 5
NUM_MOTORS = 8 NUM_MOTORS = 8
@@ -377,7 +378,8 @@ class MinitaurBulletEnv(gym.Env):
self.minitaur.GetObservationUpperBound()) self.minitaur.GetObservationUpperBound())
return observation return observation
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -14,6 +14,7 @@ from . import racecar
import random import random
from . import bullet_client from . import bullet_client
import pybullet_data import pybullet_data
from pkg_resources import parse_version
RENDER_HEIGHT = 720 RENDER_HEIGHT = 720
RENDER_WIDTH = 960 RENDER_WIDTH = 960
@@ -175,7 +176,8 @@ class RacecarGymEnv(gym.Env):
#print(reward) #print(reward)
return reward return reward
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -14,6 +14,7 @@ from . import bullet_client
from . import racecar from . import racecar
import random import random
import pybullet_data import pybullet_data
from pkg_resources import parse_version
RENDER_HEIGHT = 720 RENDER_HEIGHT = 720
RENDER_WIDTH = 960 RENDER_WIDTH = 960
@@ -190,7 +191,8 @@ class RacecarZEDGymEnv(gym.Env):
#print(reward) #print(reward)
return reward return reward
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -12,7 +12,7 @@ import time
import pybullet as p import pybullet as p
from . import simpleHumanoid from . import simpleHumanoid
import random import random
from pkg_resources import parse_version
import pybullet_data import pybullet_data
@@ -110,7 +110,8 @@ class SimpleHumanoidGymEnv(gym.Env):
print(reward) print(reward)
return reward return reward
render = _render if parse_version(gym.__version__)>=parse_version('0.9.6'):
reset = _reset render = _render
seed = _seed reset = _reset
step = _step seed = _seed
step = _step

View File

@@ -1,7 +1,7 @@
import gym, gym.spaces, gym.utils, gym.utils.seeding import gym, gym.spaces, gym.utils, gym.utils.seeding
import numpy as np import numpy as np
import pybullet as p import pybullet as p
from pkg_resources import parse_version
class MJCFBaseBulletEnv(gym.Env): class MJCFBaseBulletEnv(gym.Env):
""" """
@@ -115,10 +115,11 @@ class MJCFBaseBulletEnv(gym.Env):
def step(self, *args, **kwargs): def step(self, *args, **kwargs):
return self._step(*args, **kwargs) return self._step(*args, **kwargs)
close = _close if parse_version(gym.__version__)>=parse_version('0.9.6'):
render = _render close = _close
reset = _reset render = _render
seed = _seed reset = _reset
seed = _seed
class Camera: class Camera:

View File

@@ -1,6 +1,12 @@
r"""An example to run of the minitaur gym environment with sine gaits. r"""An example to run of the minitaur gym environment with sine gaits.
""" """
import os
import inspect
currentdir = os.path.dirname(os.path.abspath(inspect.getfile(inspect.currentframe())))
parentdir = os.path.dirname(os.path.dirname(currentdir))
os.sys.path.insert(0,parentdir)
import math import math
import numpy as np import numpy as np
from pybullet_envs.bullet import minitaur_gym_env from pybullet_envs.bullet import minitaur_gym_env

View File

@@ -1,3 +1,9 @@
import os
import inspect
currentdir = os.path.dirname(os.path.abspath(inspect.getfile(inspect.currentframe())))
parentdir = os.path.dirname(os.path.dirname(currentdir))
os.sys.path.insert(0,parentdir)
import pybullet as p import pybullet as p
import math import math
import time import time