Java Kompics类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中se.sics.kompics.Kompics类的典型用法代码示例。如果您正苦于以下问题：Java Kompics类的具体用法？Java Kompics怎么用？Java Kompics使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Kompics类属于se.sics.kompics包，在下文中一共展示了Kompics类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(StopCollectData event) {
    CroupierStats.stopCollectData();
    CroupierStats.report(VodConfig.SYSTEM_OVERLAY_ID);

    InterAsStats.stopCollectData();
    InterAsStats.report(InterAs.SYSTEM_INTER_AS_OVERLAY_ID);

    VideoStats.stopCollectData();
    VideoStats.report(Video.SYSTEM_VIDEO_OVERLAY_ID);

    // experiment finished
    if (LSConfig.hasMonitorUrlSet()) {
        Experiment e = monitoringClient.findExperiment(String.valueOf(LSConfig.getExperimentId()));
        e.setStatus(Experiment.Status.finished);
        monitoringClient.editExperiment(e);
    }

    Kompics.shutdown();
    System.exit(0);
}

开发者ID:jimdowling，项目名称:gvod，代码行数:22，代码来源:VideoSimulator.java

示例2: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(BootstrapTimeout event) {
    logger.debug(compName + " boostrap timeout: " + event.getTimeoutId());

    BootstrapRequest req = (BootstrapRequest) delegator.doGetContext(event.getTimeoutId());
    if (delegator.doCancelRetry(event.getTimeoutId())) {
        if (req != null) {
            BootstrapResponse response = new BootstrapResponse(
                    req, false,
                    req.getOverlay(),
                    new ArrayList<VodDescriptor>());
            delegator.doTrigger(response, bootstrap);
        } else {
            logger.error(compName + "Couldn't find BootstrapRequest object in BootstrapTimeout handler");
            Kompics.shutdown();
            System.exit(-1);
        }
    }
}

开发者ID:jimdowling，项目名称:gvod，代码行数:20，代码来源:BootstrapClient.java

示例3: main

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static void main(String[] args) {
//        if (args.length != 4) {
//            System.out.println("Usage: host numWorkerThreads numClients delay");
//            return;
//        }
//        server = args[0];
//        int numWorkers = Integer.parseInt(args[1]);
//        numClients = Integer.parseInt(args[2]);
//        delayBetweenBootstraps = Integer.parseInt(args[3]);
        server = "b00t.info";
        int numWorkers = 4;
        numClients = 4;
        delayBetweenBootstraps = 2000;
        System.setProperty("java.net.preferIPv4Stack", "true");
        Kompics.createAndStart(BootstrapClientStress.class, numWorkers);

    }

开发者ID:jimdowling，项目名称:gvod，代码行数:18，代码来源:BootstrapClientStress.java

示例4: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(BootPortBindResponse event) {
    if (event.getStatus() == BootPortBindResponse.Status.SUCCESS) {
        String webServerAddr = "http:/" + VodConfig.getIp().toString()
                + ":" + BootstrapConfig.getWebSearchPort();
        final JettyWebServerConfiguration webConfiguration =
                new JettyWebServerConfiguration(VodConfig.getIp(),
                BootstrapConfig.getWebSearchPort(),
                BootstrapConfig.DEFAULT_WEB_REQUEST_TIMEOUT_MS,
                BootstrapConfig.DEFAULT_WEB_THREADS,
                webServerAddr);
        trigger(new JettyWebServerInit(webConfiguration), web.getControl());
        logger.info("Webserver Started. Address={}", webServerAddr + "/1/1/search");
    } else {
        logger.error(event.getStatus()
                + " - problem binding to port for BootstrapServer: " + event.getPort());
        Kompics.shutdown();
        System.exit(-2);
    }
}

开发者ID:jimdowling，项目名称:gvod，代码行数:21，代码来源:BootstrapServerMain.java

示例5: App

import se.sics.kompics.Kompics; //导入依赖的package包/类
@org.junit.Ignore
public void App() {
    setTestObj(this);

    assert (true);

    Kompics.createAndStart(TestStClientComponent.class, 1);
    try {
        ProvaBootstrapServerInMemory.semaphore.acquire(EVENT_COUNT);
        System.out.println("Finished test.");
    } catch (InterruptedException e) {
        assert (false);
    } finally {
        Kompics.shutdown();
    }
    if (testStatus == false) {
        assertTrue(false);
    }

}

开发者ID:jimdowling，项目名称:gvod，代码行数:21，代码来源:ProvaBootstrapServerInMemory.java

示例6: App

import se.sics.kompics.Kompics; //导入依赖的package包/类
@org.junit.Ignore
public void App() {
    setTestObj(this);

    assert (true);

    Kompics.createAndStart(TestStClientComponent.class, 1);
    try {
        ProvaBootstrapServer.semaphore.acquire(EVENT_COUNT);
        System.out.println("Finished test.");
    } catch (InterruptedException e) {
        assert (false);
    } finally {
        Kompics.shutdown();
    }
    if (testStatus == false) {
        assertTrue(false);
    }

}

开发者ID:jimdowling，项目名称:gvod，代码行数:21，代码来源:ProvaBootstrapServer.java

示例7: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(Fault event) {
    for (StackTraceElement ste : event.getFault().getStackTrace()) {
        logger.error(ste.toString());
    }
    Throwable t = event.getFault();
    if (t != null) {
        if (t.getCause() != null) {
            logger.error(t.getCause().toString());
            exitErrorDialog("Network fault: " + t.getCause().toString());
        }
    }
    // for whatever reason, didn't call exitErrorDialog
    Kompics.shutdown();
    System.exit(-1);
}

开发者ID:jimdowling，项目名称:gvod，代码行数:17，代码来源:SwingMain.java

示例8: newClient

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static BlockingClient newClient() {
    if (INSTANCE == null) { // Not the nicest singleton solution but fine for this
        synchronized (ClientManager.class) {
            if (INSTANCE == null) {
                try {
                    //MessageRegistrator.register();
                    Kompics.createAndStart(ClientManager.class, Runtime.getRuntime().availableProcessors());
                    startedQ.take();
                } catch (InterruptedException ex) {
                    throw new RuntimeException(ex);
                }
            }
        }
    }
    return INSTANCE.addClient();
}

开发者ID:CaracalDB，项目名称:CaracalDB，代码行数:17，代码来源:ClientManager.java

示例9: createManager

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static Manager createManager() throws InterruptedException, ExecutionException {
    MessageRegistrator.register();
    SettableFuture<Manager> managerFuture = SettableFuture.create();

    ConfigUpdate up = confB.finalise();
    Config.Impl configI = (se.sics.kompics.config.Config.Impl) conf.copy(false);
    configI.apply(up, ValueMerger.NONE);
    conf = configI;
    System.out.println("Address: " + conf.getValue("experiment.self.address", Address.class));
    Kompics.setConfig(conf);
    Kompics.createAndStart(Manager.class, new Manager.Init(managerFuture));
    LOG.debug("Waiting for Manager to start...");
    Manager m = managerFuture.get();
    LOG.info("Manager started!");
    return m;
}

开发者ID:CaracalDB，项目名称:CaracalDB，代码行数:17，代码来源:Main.java

示例10: testApp

import se.sics.kompics.Kompics; //导入依赖的package包/类
public void testApp() {

        setTestObj(this);

        Kompics.createAndStart(TestResolveIpComponent.class, 1);
        long startTime = System.currentTimeMillis();
        try {
            GetIpTest.semaphore.acquire(EVENT_COUNT);
        } catch (InterruptedException e) {
            assert (false);
        } finally {
            long endTime = System.currentTimeMillis();
            System.out.println("Time taken: " + (endTime - startTime) + "ms");
            System.out.println("Exiting unit test....");
            Kompics.shutdown();
        }

        if (status == false) {
            assertTrue(false);
        } else {
            assertTrue(true);
        }
    }

开发者ID:jimdowling，项目名称:nat-traverser，代码行数:24，代码来源:GetIpTest.java

示例11: testApp

import se.sics.kompics.Kompics; //导入依赖的package包/类
public void testApp() {

        setTestObj(this);

        Kompics.createAndStart(TestUpnpComponent.class, 1);
        try {
            UpnpTest.semaphore.acquire(EVENT_COUNT);
            System.out.println("Exiting unit test....");
        } catch (InterruptedException e) {
            assert (false);
        } finally {
            Kompics.shutdown();
        }

        if (status == false) {
            assertTrue(false);
        } else {
            assertTrue(true);
        }
    }

开发者ID:jimdowling，项目名称:nat-traverser，代码行数:21，代码来源:UpnpTest.java

示例12: runInstance

import se.sics.kompics.Kompics; //导入依赖的package包/类
private void runInstance() {
    Kompics.createAndStart(StunClientComponentTester.class, 1);
    try {
        StunClientTest.semaphore.acquire(1);
        if (!res) {
            Assert.fail();
        }
    } catch (Throwable e) {
        logger.error(e.getMessage());
        e.printStackTrace();
        StunClientTest.semaphore.release();
        Assert.fail(e.getMessage());
    } finally {
        Kompics.shutdown();
    }
}

开发者ID:jimdowling，项目名称:nat-traverser，代码行数:17，代码来源:StunClientTest.java

示例13: runAtLeastTests

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static synchronized void runAtLeastTests(NetworkGenerator nGen, int numNodes, Transport[] protos) {
    LOG.info("\n******************** Running AT LEAST Test ********************\n");
    NetworkTest.nGen = nGen;
    NetworkTest.numNodes = numNodes;
    NetworkTest.protos = protos;
    WAIT_FOR.set(1);

    msgId.set(0);
    messageStatus.clear();
    TestUtil.reset("Datagram test (" + Arrays.toString(NetworkTest.protos) + ") Nodes #" + numNodes, 10000); //10 sec timeout for all the connections to be dropped properly

    Kompics.createAndStart(LauncherComponent.class, 8, 50);

    for (int i = 0; i < numNodes; i++) {
        LOG.info("Waiting for {}/{} STOPPED.", i + 1, numNodes);
        TestUtil.waitFor(STOPPED);
        LOG.info("Got {}/{} STOPPED.", i + 1, numNodes);
    }

    LOG.info("\n******************** Shutting Down Kompics ********************\n");
    Kompics.shutdown();

    assertTrue(numNodes <= messageStatus.size());
    LOG.info("\n******************** AT LEAST Test Done ********************\n");
}

开发者ID:kompics，项目名称:kompics，代码行数:26，代码来源:NetworkTest.java

示例14: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(Data event) {
    if (first) {
        startTS = System.currentTimeMillis();
        first = false;
    }
    System.arraycopy(event.data, 0, data, event.pos, DataMessage.MESSAGE_SIZE);
    tracker.add(event.pos);
    System.out.println("Received message #"+event.pos);
    if (tracker.size() == event.total) {
        long endTS = System.currentTimeMillis();
        double diff = ((double) endTS - startTS)/1000.0;
        double throughput = ((double)data.length)/(diff*1024.0);
        System.out.println("Transfer complete! Data received in " + diff + "s with " + throughput + "kb/s");
        Kompics.asyncShutdown();
    }
}

开发者ID:kompics，项目名称:kompics，代码行数:18，代码来源:Receiver.java

示例15: kolaTest

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Test
    public void kolaTest() {
        try {
            //System.out.println(new java.io.File( "." ).getCanonicalPath());
            TestUtil.reset("Kola Test");
            Main.main(new String[]{"-p", "-m", "-s", targetPath, "src/test/resources/se/sics/kola/KolaTests.kola", "src/test/resources/se/sics/kola/TestPort.kola"});
            compile(targetPath);
            ClassLoader cl = new URLClassLoader(new URL[]{(new File(targetPath)).toURI().toURL()});
            Class testClass = cl.loadClass("se.sics.kola.KolaTestC");
            Kompics.createAndStart(testClass, 1);
            TestUtil.waitFor("InitStringA");
            TestUtil.waitFor("InitStringB");
            TestUtil.waitFor("STARTED");
            TestUtil.waitFor("RECEIVED");
            TestUtil.waitFor("SingletonEvent");
            TestUtil.waitFor("REPLIED");
            Kompics.shutdown();
            
            
//            Object o = testClass.newInstance();
//            Method m = testClass.getMethod("test");
//            Object ret = m.invoke(o);
//            boolean res = ((Boolean) ret);
//            Assert.assertTrue(res);
        } catch (IOException |
                InterruptedException |
                ClassNotFoundException |
                SecurityException |
                IllegalArgumentException ex) {
            ex.printStackTrace(System.err);
            Assert.fail(ex.getMessage());
        }
    }

开发者ID:kompics，项目名称:kola，代码行数:34，代码来源:GenerationTest.java

示例16: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(GenerateReport event) {
    CroupierStats.report(VodConfig.SYSTEM_OVERLAY_ID);
    GradientStats.summaryReport(VodConfig.SYSTEM_OVERLAY_ID);
    if (System.currentTimeMillis() > EXPERIMENT_TIME) {
        Kompics.shutdown();
        System.exit(0);
    }
}

开发者ID:jimdowling，项目名称:gvod，代码行数:10，代码来源:GradientSimulator.java

示例17: handle

import se.sics.kompics.Kompics; //导入依赖的package包/类
@Override
public void handle(GenerateReport event) {
    CroupierStats.report(VodConfig.SYSTEM_OVERLAY_ID);
    InterAsStats.report(InterAs.SYSTEM_INTER_AS_OVERLAY_ID);
    if (System.currentTimeMillis() > EXPERIMENT_TIME) {
        Kompics.shutdown();
        System.exit(0);
    }
}

开发者ID:jimdowling，项目名称:gvod，代码行数:10，代码来源:LsSimulator.java

示例18: main

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static void main(String[] args) {
    try {
        LSConfig.init(args);
    } catch (IOException ex) {
        System.err.println("Exiting after parsing command line args");
        java.util.logging.Logger.getLogger(VideoMain.class.getName()).log(Level.SEVERE, null, ex);
        Kompics.shutdown();
        System.exit(-1);
    }
    System.setProperty("java.net.preferIPv4Stack", "true");
    Kompics.createAndStart(VideoMain.class, 2);

}

开发者ID:jimdowling，项目名称:gvod，代码行数:14，代码来源:VideoMain.java

示例19: main

import se.sics.kompics.Kompics; //导入依赖的package包/类
public static void main(String[] args) {
    System.setProperty("java.net.preferIPv4Stack", "true");
    Runtime.getRuntime().addShutdownHook(new Thread() {
        @Override
        public void run() {
            logger.info("Shutting down BootstrapServer...");
            //Get the jvm heap size.
            long heapSize = Runtime.getRuntime().totalMemory();
            //Print the jvm heap size.
            logger.debug("Heap Size = " + heapSize);
            try {
                if (Kompics.getScheduler() != null) {
                    Kompics.shutdown();
                }
            } catch (Exception e) {
                logger.warn("Error shutting down: " + e.getMessage());
            }
        }
    });

    try {
        BootstrapConfig.init(args);
        Kompics.createAndStart(BootstrapServerMain.class, BootstrapConfig.getNumWorkers());
    } catch (IOException ex) {
        java.util.logging.Logger.getLogger(BootstrapServerMain.class.getName()).log(Level.SEVERE, null, ex);
    }
}

开发者ID:jimdowling，项目名称:gvod，代码行数:28，代码来源:BootstrapServerMain.java

示例20: startGui

import se.sics.kompics.Kompics; //导入依赖的package包/类
private void startGui() {

        try {
            JwHttpServer.startOrUpdate(
                    new InetSocketAddress(VodConfig.getMediaPort()),
                    "/", new BrowserGuiHandler(main));
            logger.info("Media server listening at: "
                    + VodConfig.LOCALHOST + ":"
                    + VodConfig.getMediaPort()
                    + "/");
        } catch (IOException ex) {
            logger.warn("Couldn't bind to BrowserGuiHandler port");
            logger.error(ex.getMessage());
            Kompics.shutdown();
            System.exit(-1);
        }

        if (VodConfig.GUI) {
            logger.info("Starting Swing GUI..");
            userInterface = create(SwingComponent.class);
            connect(userInterface.getNegative(BootstrapPort.class), bootstrap.getPositive(BootstrapPort.class));
            trigger(new UserInterfaceInit(this), userInterface.getControl());

            subscribe(handleStartInBackground, userInterface.getNegative(AppMainPort.class));
            subscribe(handleDownloadSpeed, userInterface.getNegative(AppMainPort.class));
        }

    }

开发者ID:jimdowling，项目名称:gvod，代码行数:29，代码来源:SwingMain.java

注：本文中的se.sics.kompics.Kompics类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Type类代码示例发布时间：2022-05-22

Java JobEntryZipFile类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18273|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9677|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8179|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8549|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8457|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9393|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8430|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7865|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8415|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Kompics类代码示例

示例1: handle

示例2: handle

示例3: main

示例4: handle

示例5: App

示例6: App

示例7: handle

示例8: newClient

示例9: createManager

示例10: testApp

示例11: testApp

示例12: runInstance

示例13: runAtLeastTests

示例14: handle

示例15: kolaTest

示例16: handle

示例17: handle

示例18: main

示例19: main

示例20: startGui

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

Matlab如何循环读取文件

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053