Package net.tomp2p.connection

Examples of net.tomp2p.connection.ChannelClientConfiguration

723
724
725
726
727
728
729
730
731
732
733
734
    // create custom RSA factories
    SignatureFactory factory = new H2HSignatureFactory();
    SignatureCodec codec = new H2HSignatureCodec();

    // replace default signature factories
    ChannelClientConfiguration clientConfig = PeerMaker.createDefaultChannelClientConfiguration();
    clientConfig.signatureFactory(factory);
    ChannelServerConficuration serverConfig = PeerMaker.createDefaultChannelServerConfiguration();
    serverConfig.signatureFactory(factory);

    KeyPair keyPairPeer1 = gen.generateKeyPair();
    Peer p1 = new PeerMaker(Number160.createHash(1)).ports(4834).keyPair(keyPairPeer1)
View Full Code Here
803
804
805
806
807
808
809
810
811
812
813
814
    // create custom RSA factories
    SignatureFactory factory = new H2HSignatureFactory();
    SignatureCodec codec = new H2HSignatureCodec();

    // replace default signature factories
    ChannelClientConfiguration clientConfig = PeerMaker.createDefaultChannelClientConfiguration();
    clientConfig.signatureFactory(factory);
    ChannelServerConficuration serverConfig = PeerMaker.createDefaultChannelServerConfiguration();
    serverConfig.signatureFactory(factory);

    KeyPair keyPairPeer1 = gen.generateKeyPair();
    Peer p1 = new PeerMaker(Number160.createHash(1)).ports(4834).keyPair(keyPairPeer1)
View Full Code Here
1010
1011
1012
1013
1014
1015
1016
1017
1018
1019
1020
1021
    // create custom RSA factories
    SignatureFactory factory = new H2HSignatureFactory();

    // replace default signature factories
    ChannelClientConfiguration clientConfig = PeerMaker.createDefaultChannelClientConfiguration();
    clientConfig.signatureFactory(factory);
    ChannelServerConficuration serverConfig = PeerMaker.createDefaultChannelServerConfiguration();
    serverConfig.signatureFactory(factory);

    KeyPair keyPairPeer1 = gen.generateKeyPair();
    Peer p1 = new PeerMaker(Number160.createHash(1)).ports(4834).keyPair(keyPairPeer1)
View Full Code Here
1107
1108
1109
1110
1111
1112
1113
1114
1115
1116
1117
1118
    // create custom RSA factories
    SignatureFactory factory = new H2HSignatureFactory();
    SignatureCodec codec = new H2HSignatureCodec();

    // replace default signature factories
    ChannelClientConfiguration clientConfig = PeerMaker.createDefaultChannelClientConfiguration();
    clientConfig.signatureFactory(factory);
    ChannelServerConficuration serverConfig = PeerMaker.createDefaultChannelServerConfiguration();
    serverConfig.signatureFactory(factory);

    KeyPair keyPairPeer1 = gen.generateKeyPair();
    Peer p1 = new PeerMaker(Number160.createHash(1)).ports(4834).keyPair(keyPairPeer1)
View Full Code Here
156
157
158
159
160
161
162
163
164
165
166
167
168
    logger.debug("Found free port {}.", port);

    // configure the thread handling internally, callback can be blocking
    eventExecutorGroup = new DefaultEventExecutorGroup(H2HConstants.NUM_OF_NETWORK_THREADS);

    ChannelClientConfiguration clientConfig = PeerMaker.createDefaultChannelClientConfiguration();
    clientConfig.signatureFactory(new H2HSignatureFactory());
    clientConfig.pipelineFilter(new PeerMaker.EventExecutorGroupFilter(eventExecutorGroup));

    ChannelServerConficuration serverConfig = PeerMaker.createDefaultChannelServerConfiguration();
    serverConfig.signatureFactory(new H2HSignatureFactory());
    serverConfig.pipelineFilter(new PeerMaker.EventExecutorGroupFilter(eventExecutorGroup));
View Full Code Here
403
404
405
406
407
408
409
410
411
412
413
414
415
        Peer peer = null;
        try {
          Number160 peerId = Number160.createHash(clientId);
          PeerMapConfiguration pmc = new PeerMapConfiguration(peerId).peerNoVerification();
          PeerMap pm = new PeerMap(pmc);
          ChannelClientConfiguration cc = PeerBuilder.createDefaultChannelClientConfiguration();
          cc.maxPermitsTCP(100);
          cc.maxPermitsUDP(100);
            peer = new PeerBuilder(peerId).channelClientConfiguration(cc).ports(clientPort).peerMap(pm).start();
            PeerAddress masterNodeAddress = new PeerAddress(Number160.createHash(seedNodeId), seedNodeIP, seedNodePort,
                                                            seedNodePort);
            FutureDiscover futureDiscover = peer.discover().peerAddress(masterNodeAddress).start();
            futureDiscover.awaitUninterruptibly();
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
            final int port1 = 4001;
            final int port2 = 4002;
            final int timeout = 20;
           
            ChannelServerConfiguration csc = PeerBuilder.createDefaultChannelServerConfiguration();
        ChannelClientConfiguration ccc = PeerBuilder.createDefaultChannelClientConfiguration();
        csc.pipelineFilter(createFilter());
        ccc.pipelineFilter(createFilter());
           
            peer1 = new PeerBuilder(new Number160(RND)).ports(port1).channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            peer2 = new PeerBuilder(new Number160(RND)).ports(port2).start();
            //
            peer2.objectDataReply(new ObjectDataReply() {
View Full Code Here
270
271
272
273
274
275
276
277
278
279
280
281
282
          retVal.putAll(channelHandlers);
          return retVal;
        }
      };
      ChannelServerConfiguration csc = PeerBuilder.createDefaultChannelServerConfiguration();
      ChannelClientConfiguration ccc = PeerBuilder.createDefaultChannelClientConfiguration();
      csc.pipelineFilter(pf);
      ccc.pipelineFilter(pf);
            sender = new PeerBuilder(new Number160("0x50")).p2pId(55).enableMaintenance(false).ports(2424).channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            recv1 = new PeerBuilder(new Number160("0x20")).p2pId(55).enableMaintenance(false).ports(8088).channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            recv1.objectDataReply(new ObjectDataReply() {
                @Override
                public Object reply(PeerAddress sender, Object request) throws Exception {
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
341
342
          retVal.putAll(channelHandlers);
          return retVal;
        }
      };
      ChannelServerConfiguration csc = PeerBuilder.createDefaultChannelServerConfiguration();
      ChannelClientConfiguration ccc = PeerBuilder.createDefaultChannelClientConfiguration();
      csc.pipelineFilter(pf);
      ccc.pipelineFilter(pf);
            sender = new PeerBuilder(new Number160("0x50")).p2pId(55).ports(2424).enableMaintenance(false)
                    .channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            recv1 = new PeerBuilder(new Number160("0x20")).p2pId(55).ports(8088).enableMaintenance(false)
                .channelClientConfiguration(ccc).channelServerConfiguration(csc).start();
            recv1.objectDataReply(new ObjectDataReply() {
View Full Code Here
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
    channelServerConfiguration.signatureFactory(new DSASignatureFactory());
    return channelServerConfiguration;
  }

  public static ChannelClientConfiguration createDefaultChannelClientConfiguration() {
    ChannelClientConfiguration channelClientConfiguration = new ChannelClientConfiguration();
    channelClientConfiguration.bindings(new Bindings());
    channelClientConfiguration.maxPermitsPermanentTCP(MAX_PERMITS_PERMANENT_TCP);
    channelClientConfiguration.maxPermitsTCP(MAX_PERMITS_TCP);
    channelClientConfiguration.maxPermitsUDP(MAX_PERMITS_UDP);
    channelClientConfiguration.pipelineFilter(new DefaultPipelineFilter());
    channelClientConfiguration.signatureFactory(new DSASignatureFactory());
    channelClientConfiguration.senderTCP(new InetSocketAddress(0).getAddress());
    channelClientConfiguration.senderUDP(new InetSocketAddress(0).getAddress());
    return channelClientConfiguration;
  }
View Full Code Here
TOP

Related Classes of net.tomp2p.connection.ChannelClientConfiguration

  • net.tomp2p.dht.TestDHT
  • net.tomp2p.examples.ExamplePersistentConnection
  • net.tomp2p.examples.TomP2PTests
  • net.tomp2p.p2p.PeerBuilder
  • net.tomp2p.rpc.TestDirect
  • org.hive2hive.core.network.Connection
  • org.hive2hive.core.tomp2p.SecurityTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.