Package streamer.debug

Examples of streamer.debug.MockSource

675
676
677
678
679
680
681
682
683
684
685
        (byte)0x04, (byte)0xc0, (byte)0x0c, (byte)0x00, (byte)0x0d, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x02, (byte)0xc0, (byte)0x0c, (byte)0x00,
        (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00, (byte)0x00,
    };
    /* @formatter:on */

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));
        Element todo = new ClientMCSConnectInitial("ClientMCSConnectInitial");
        Element x224 = new ClientX224DataPDU("x224");
        Element tpkt = new ClientTpkt("tpkt");

        Element sink = new MockSink("sink", ByteBuffer.convertByteArraysToByteBuffers(packet));
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
                (byte)0x00, // RT successfull (0000...., 0x0)
                // Initiator: 1001+3 = 1004
                (byte)0x00, (byte)0x03,};

        RdpState rdpState = new RdpState();
        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(packet, new byte[] {1, 2, 3}));
        Element atachUserConfirm = new ServerMCSAttachUserConfirmPDU("attach_user_confirm", rdpState);
        Element sink = new MockSink("sink");
        Element mainSink = new MockSink("mainSink", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));

        Pipeline pipeline = new PipelineImpl("test");
View Full Code Here
1117
1118
1119
1120
1121
1122
1123
1124
1125
1126
1127
        ScreenDescription screenDescription = new ScreenDescription();
        screenDescription.setFramebufferSize(1024, 768);

        rdpState.serverShareId = 0x000103ea;

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {}));
        Element confirm_active = new ClientConfirmActivePDU("confirm_active", screenDescription, rdpState);
        Element sink = new MockSink("sink", ByteBuffer.convertByteArraysToByteBuffers(packet));

        Pipeline pipeline = new PipelineImpl("test");
        pipeline.add(source, confirm_active, sink);
View Full Code Here
114
115
116
117
118
119
120
121
122
123
124
                (byte)0x01, (byte)0x00, // Length if source descriptor: 1 (LE)
                (byte)0x00, // Source descriptor (should be set to 0): 0
        };

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(packet));
        Element mcs = new ServerMCSPDU("mcs") {
            {
                verbose = true;
            }
        };
View Full Code Here
217
218
219
220
221
222
223
224
225
226
227
                (byte)0x08, (byte)0x00, // RDP_NEG_RSP::length (8 bytes)
                (byte)0x05, (byte)0x00, (byte)0x00, (byte)0x00, // Code:  HYBRID_REQUIRED_BY_SERVER

        };

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(packet));
        Element cc = new ServerX224ConnectionConfirmPDU("cc");
        Element tpkt = new ServerTpkt("tpkt");
        Element sink = new MockSink("sink", new ByteBuffer[] {});
        Element mainSink = new MockSink("mainSink", new ByteBuffer[] {});
View Full Code Here
437
438
439
440
441
442
443
444
445
446
447
        // cbAutoReconnectCookie: 0 bytes (LE)
        (byte) 0x00, (byte) 0x00,
    };
    /* @formatter:on */

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));
        Element client_info = new ClientInfoPDU("client_info", "vlisivka");
        Element x224 = new ClientX224DataPDU("x224");
        Element tpkt = new ClientTpkt("tpkt");
        Element sink = new MockSink("sink", ByteBuffer.convertByteArraysToByteBuffers(packet));
        Element mainSink = new MockSink("mainSink", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));
View Full Code Here
568
569
570
571
572
573
574
575
576
577
578
          (byte)0x01, (byte)0x00, (byte)0x01,
    };
    /* @formatter:on */

        NtlmState ntlmState = new NtlmState();
        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(serverChallengePacket, new byte[] {1, 2, 3}));
        Element ntlmssp_negotiate = new ClientNtlmsspNegotiate("ntlmssp_negotiate", ntlmState);
        Element ntlmssp_challenge = new ServerNtlmsspChallenge("ntlmssp_challenge", ntlmState);
        Element ntlmssp_auth = new ClientNtlmsspPubKeyAuth("ntlmssp_auth", ntlmState, sslState, "192.168.0.101", "workgroup", "apollo3", "Administrator",
                "R2Preview!");
        Element sink = new MockSink("sink", ByteBuffer.convertByteArraysToByteBuffers(clientNegotiatePacket, clientAuthPacket), (Dumper)ntlmssp_auth);
View Full Code Here
497
498
499
500
501
502
503
504
505
506
507
                (byte)0x01, (byte)0x00, // Length if source descriptor: 1 (LE)
                (byte)0x00, // Source descriptor (should be set to 0): 0
        };

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(packet));
        RdpState rdpState = new RdpState() {
            {
                serverShareId = 66538;
            }
        };
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
        // 0 - padding

    };
    /* @formatter:on */

        MockSource source = new MockSource("source", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));
        Element todo = new ClientMCSAttachUserRequest("TODO");
        Element x224 = new ClientX224DataPDU("x224");
        Element tpkt = new ClientTpkt("tpkt");
        Element sink = new MockSink("sink", ByteBuffer.convertByteArraysToByteBuffers(packet));
        Element mainSink = new MockSink("mainSink", ByteBuffer.convertByteArraysToByteBuffers(new byte[] {1, 2, 3}));
View Full Code Here
331
332
333
334
335
336
337
338
339
340
341
        // System.setProperty("streamer.Link.debug", "true");
        System.setProperty("streamer.Element.debug", "true");
        // System.setProperty("streamer.Pipeline.debug", "true");

        Element source = new MockSource("source") {
            {
                // Split messages at random boundaries to check "pushback" logic
                bufs = ByteBuffer.convertByteArraysToByteBuffers(new byte[] {
                        // Message type: server bell
                        RfbConstants.SERVER_BELL,
View Full Code Here
TOP

Related Classes of streamer.debug.MockSource

  • rdpclient.clip.ServerClipboardCapabilitiesPDU
  • rdpclient.clip.ServerFormatDataResponsePDU
  • rdpclient.clip.ServerFormatListPDU
  • rdpclient.clip.ServerMonitorReadyPDU
  • rdpclient.hyperv.ClientPreConnectionBlob
  • rdpclient.ntlmssp.ClientNtlmsspNegotiate
  • rdpclient.ntlmssp.ClientNtlmsspPubKeyAuth
  • rdpclient.ntlmssp.ServerNtlmsspChallenge
  • rdpclient.rdp.ClientConfirmActivePDU
  • rdpclient.rdp.ClientInfoPDU
    • 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.