|
|
@@ -13,6 +13,7 @@ |
|
|
# limitations under the License. |
|
|
# limitations under the License. |
|
|
# ============================================================================== |
|
|
# ============================================================================== |
|
|
|
|
|
|
|
|
|
|
|
import os |
|
|
import random |
|
|
import random |
|
|
import time |
|
|
import time |
|
|
from multiprocessing import Process |
|
|
from multiprocessing import Process |
|
|
@@ -81,6 +82,11 @@ def test_graphdata_distributed(): |
|
|
""" |
|
|
""" |
|
|
Test distributed |
|
|
Test distributed |
|
|
""" |
|
|
""" |
|
|
|
|
|
ASAN = os.environ.get('ASAN_OPTIONS') |
|
|
|
|
|
if ASAN: |
|
|
|
|
|
logger.info("skip the graphdata distributed when asan mode") |
|
|
|
|
|
return |
|
|
|
|
|
|
|
|
logger.info('test distributed.\n') |
|
|
logger.info('test distributed.\n') |
|
|
|
|
|
|
|
|
server_port = random.randint(10000, 60000) |
|
|
server_port = random.randint(10000, 60000) |
|
|
|