Package com.subgraph.orchid

Examples of com.subgraph.orchid.RelayCell

162
163
164
165
166
167
168
169
170
171
172
173
  /* Runs in the context of the connection cell reading thread */
  private void processRelayDataCell(RelayCell cell) {
    if(cell.getRelayCommand() == RelayCell.RELAY_DATA) {
      cell.getCircuitNode().decrementDeliverWindow();
      if(cell.getCircuitNode().considerSendingSendme()) {
        final RelayCell sendme = createRelayCell(RelayCell.RELAY_SENDME, 0, cell.getCircuitNode());
        sendRelayCellTo(sendme, sendme.getCircuitNode());
      }
    }

    synchronized(streamMap) {
      final StreamImpl stream = streamMap.get(cell.getStreamId());
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
    circuit.sendRelayCell(cell);
  }


  public RelayCell receiveRelayResponse(int expectedCommand, Router extendTarget) {
    final RelayCell cell = circuit.receiveRelayCell();
    if(cell == null) {
      throw new TorException("Timeout building circuit");
    }
    final int command = cell.getRelayCommand();
    if(command == RelayCell.RELAY_TRUNCATED) {
      final int code = cell.getByte() & 0xFF;
      final String msg = CellImpl.errorToDescription(code);
      final String source = nodeToName(cell.getCircuitNode());
      if(code == Cell.ERROR_PROTOCOL) {
        logProtocolViolation(source, extendTarget);
      }
      throw new TorException("Error from ("+ source +") while extending to ("+ extendTarget.getNickname() + "): "+ msg);
    } else if(command != expectedCommand) {
View Full Code Here
32
33
34
35
36
37
38
39
40
41
      return extendWithTunneledExtend(onion);
    }
  }
 
  private CircuitNode extendWithExtend2(byte[] onion) {
    final RelayCell cell = createExtend2Cell(onion);
    extender.sendRelayCell(cell);
    final RelayCell response = extender.receiveRelayResponse(RelayCell.RELAY_EXTENDED2, router);
    return processExtended2(response);
  }
View Full Code Here
39
40
41
42
43
44
45
46
47
48
    final RelayCell response = extender.receiveRelayResponse(RelayCell.RELAY_EXTENDED2, router);
    return processExtended2(response);
  }
 
  private CircuitNode extendWithTunneledExtend(byte[] onion) {
    final RelayCell cell = createExtendCell(onion, kex.getNtorCreateMagic());
    extender.sendRelayCell(cell);
    final RelayCell response = extender.receiveRelayResponse(RelayCell.RELAY_EXTENDED, router);
    return processExtended(response);
  }
View Full Code Here
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
  private boolean finalRouterSupportsExtend2() {
    return extender.getFinalRouter().getNTorOnionKey() != null;
  }
 
  private RelayCell createExtend2Cell(byte[] ntorOnionskin) {
    final RelayCell cell = extender.createRelayCell(RelayCell.RELAY_EXTEND2);

    cell.putByte(2);
     
    cell.putByte(0);
    cell.putByte(6);
    cell.putByteArray(router.getAddress().getAddressDataBytes());
    cell.putShort(router.getOnionPort());
     
    cell.putByte(2);
    cell.putByte(20);
    cell.putByteArray(router.getIdentityHash().getRawBytes());
     
    cell.putShort(0x0002);
    cell.putShort(ntorOnionskin.length);
    cell.putByteArray(ntorOnionskin);
    return cell;
  }
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
    cell.putByteArray(ntorOnionskin);
    return cell;
  }
 
  private RelayCell createExtendCell(byte[] ntorOnionskin, byte[] ntorMagic) {
    final RelayCell cell = extender.createRelayCell(RelayCell.RELAY_EXTEND);
    cell.putByteArray(router.getAddress().getAddressDataBytes());
    cell.putShort(router.getOnionPort());
    final int paddingLength = CircuitExtender.TAP_ONIONSKIN_LEN - (ntorOnionskin.length + ntorMagic.length);
    final byte[] padding = new byte[paddingLength];
    cell.putByteArray(ntorMagic);
    cell.putByteArray(ntorOnionskin);
    cell.putByteArray(padding);
    cell.putByteArray(router.getIdentityHash().getRawBytes());
    return cell;
  }
View Full Code Here
21
22
23
24
25
26
27
28
29
30
31
32
33
    this.kex = new TorTapKeyAgreement(router.getOnionKey());
  }

  public CircuitNode extendTo() {
    logger.fine("Extending to "+ router.getNickname() + " with TAP");
    final RelayCell cell = createRelayExtendCell();
    extender.sendRelayCell(cell);
    final RelayCell response = extender.receiveRelayResponse(RelayCell.RELAY_EXTENDED, router);
    if(response == null) {
      return null;
    }
    return processExtendResponse(response);
  }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
54
    }
    return extender.createNewNode(router, keyMaterial, verifyDigest);
  }

  private RelayCell createRelayExtendCell() {
    final RelayCell cell = extender.createRelayCell(RelayCell.RELAY_EXTEND);
    cell.putByteArray(router.getAddress().getAddressDataBytes());
    cell.putShort(router.getOnionPort());
    cell.putByteArray(kex.createOnionSkin());
    cell.putByteArray(router.getIdentityHash().getRawBytes());
    return cell;
  }
View Full Code Here
TOP

Related Classes of com.subgraph.orchid.RelayCell

  • com.subgraph.orchid.circuits.CircuitExtender
  • com.subgraph.orchid.circuits.CircuitIO
  • com.subgraph.orchid.circuits.hs.IntroductionProcessor
  • com.subgraph.orchid.circuits.hs.RendezvousProcessor
  • com.subgraph.orchid.circuits.NTorCircuitExtender
  • com.subgraph.orchid.circuits.StreamImpl
  • com.subgraph.orchid.circuits.TapCircuitExtender
  • com.subgraph.orchid.circuits.TorInputStreamTest
    • 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.