2019-06-06 15:21:15 +03:00
|
|
|
/*******************************************************************************
|
|
|
|
* Copyright (c) 2015-2018 Skymind, Inc.
|
|
|
|
*
|
|
|
|
* This program and the accompanying materials are made available under the
|
|
|
|
* terms of the Apache License, Version 2.0 which is available at
|
|
|
|
* https://www.apache.org/licenses/LICENSE-2.0.
|
|
|
|
*
|
|
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
|
|
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
|
|
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
|
|
* License for the specific language governing permissions and limitations
|
|
|
|
* under the License.
|
|
|
|
*
|
|
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
|
|
******************************************************************************/
|
|
|
|
|
|
|
|
package org.deeplearning4j.perf.listener;
|
|
|
|
|
|
|
|
import org.apache.commons.io.FileUtils;
|
|
|
|
import org.junit.Ignore;
|
|
|
|
import org.junit.Rule;
|
|
|
|
import org.junit.Test;
|
|
|
|
import org.junit.rules.TemporaryFolder;
|
|
|
|
import org.nd4j.linalg.factory.Nd4j;
|
|
|
|
|
|
|
|
import java.io.File;
|
|
|
|
import java.util.Arrays;
|
|
|
|
|
|
|
|
import static org.junit.Assert.assertEquals;
|
|
|
|
import static org.junit.Assert.assertTrue;
|
|
|
|
|
|
|
|
@Ignore("AB 2019/05/24 - Failing on CI - \"Could not initialize class oshi.jna.platform.linux.Libc\" - Issue #7657")
|
2019-06-13 20:40:40 +10:00
|
|
|
public class SystemPollingTest extends BaseDL4JTest {
|
2019-06-06 15:21:15 +03:00
|
|
|
|
|
|
|
@Rule
|
|
|
|
public TemporaryFolder tempDir = new TemporaryFolder();
|
|
|
|
|
|
|
|
@Test
|
|
|
|
public void testPolling() throws Exception {
|
|
|
|
Nd4j.create(1);
|
|
|
|
File tmpDir = tempDir.newFolder();
|
|
|
|
|
|
|
|
SystemPolling systemPolling = new SystemPolling.Builder()
|
|
|
|
.outputDirectory(tmpDir).pollEveryMillis(1000)
|
|
|
|
.build();
|
|
|
|
systemPolling.run();
|
|
|
|
|
|
|
|
Thread.sleep(8000);
|
|
|
|
|
|
|
|
systemPolling.stopPolling();
|
|
|
|
|
|
|
|
File[] files = tmpDir.listFiles();
|
|
|
|
assertTrue(files != null && files.length > 0);
|
|
|
|
//System.out.println(Arrays.toString(files));
|
|
|
|
|
|
|
|
String yaml = FileUtils.readFileToString(files[0]);
|
|
|
|
HardwareMetric fromYaml = HardwareMetric.fromYaml(yaml);
|
|
|
|
System.out.println(fromYaml);
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|