or.h 23.5 KB
Newer Older
1
2
/* Copyright 2001,2002 Roger Dingledine, Matej Pfajfar. */
/* See LICENSE for licensing information */
Roger Dingledine's avatar
Roger Dingledine committed
3
4
5
6
7
/* $Id$ */

#ifndef __OR_H
#define __OR_H

Nick Mathewson's avatar
Nick Mathewson committed
8
9
#include "orconfig.h"

Roger Dingledine's avatar
Roger Dingledine committed
10
11
#include <stdio.h>
#include <stdlib.h>
Roger Dingledine's avatar
Roger Dingledine committed
12
#include <limits.h>
Roger Dingledine's avatar
Roger Dingledine committed
13
14
15
16
17
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <netdb.h>
#include <ctype.h>
18
19
20
#ifdef HAVE_STDINT_H
#include <stdint.h>
#endif
Nick Mathewson's avatar
Nick Mathewson committed
21
#ifdef HAVE_SYS_POLL_H
Roger Dingledine's avatar
Roger Dingledine committed
22
#include <sys/poll.h>
Nick Mathewson's avatar
Nick Mathewson committed
23
24
25
26
27
#elif HAVE_POLL_H
#include <poll.h>
#else
#include "../common/fakepoll.h"
#endif
Roger Dingledine's avatar
Roger Dingledine committed
28
29
30
31
32
#include <sys/types.h>
#include <sys/fcntl.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/time.h>
33
#include <sys/stat.h>
Roger Dingledine's avatar
Roger Dingledine committed
34
35
36
37
#include <netinet/in.h>
#include <arpa/inet.h>
#include <errno.h>
#include <assert.h>
38
#include <time.h>
Roger Dingledine's avatar
Roger Dingledine committed
39

40
#include "../common/crypto.h"
Roger Dingledine's avatar
Roger Dingledine committed
41
42
#include "../common/log.h"
#include "../common/ss.h"
43
#include "../common/version.h"
Roger Dingledine's avatar
Roger Dingledine committed
44
45

#define MAXCONNECTIONS 200 /* upper bound on max connections.
46
                              can be lowered by config file */
Roger Dingledine's avatar
Roger Dingledine committed
47

48
#define MAX_BUF_SIZE (640*1024)
49
#define DEFAULT_BANDWIDTH_OP 102400
Roger Dingledine's avatar
Roger Dingledine committed
50
51
52

#define ACI_TYPE_LOWER 0
#define ACI_TYPE_HIGHER 1
53
54
55
56
57
58
59
#define ACI_TYPE_BOTH 2

/* bitvector of the roles that we might want to play. You can or (|) them together */
#define ROLE_OR_LISTEN 1
#define ROLE_OR_CONNECT_ALL 2
#define ROLE_OP_LISTEN 4
#define ROLE_AP_LISTEN 8
60
61
#define ROLE_DIR_LISTEN 16
#define ROLE_DIR_SERVER 32
Roger Dingledine's avatar
Roger Dingledine committed
62

63
64
#define ROLE_IS_OR(role) ((role & ROLE_OR_LISTEN) || (role & ROLE_OR_CONNECT_ALL) || (role & ROLE_OP_LISTEN))

Roger Dingledine's avatar
Roger Dingledine committed
65
66
67
68
#define CONN_TYPE_OP_LISTENER 1
#define CONN_TYPE_OP 2
#define CONN_TYPE_OR_LISTENER 3
#define CONN_TYPE_OR 4
69
70
71
#define CONN_TYPE_EXIT 5
#define CONN_TYPE_AP_LISTENER 6
#define CONN_TYPE_AP 7
72
73
#define CONN_TYPE_DIR_LISTENER 8
#define CONN_TYPE_DIR 9
74
#define CONN_TYPE_DNSMASTER 10
Roger Dingledine's avatar
Roger Dingledine committed
75
76
77

#define LISTENER_STATE_READY 0

78
79
#define DNSMASTER_STATE_OPEN 0

Roger Dingledine's avatar
Roger Dingledine committed
80
81
82
83
84
85
86
#define OP_CONN_STATE_AWAITING_KEYS 0
#define OP_CONN_STATE_OPEN 1
#if 0
#define OP_CONN_STATE_CLOSE 2 /* flushing the buffer, then will close */
#define OP_CONN_STATE_CLOSE_WAIT 3 /* have sent a destroy, awaiting a confirmation */
#endif

87
88
89
90
/* how to read these states:
 * foo_CONN_STATE_bar_baz:
 * "I am acting as a bar, currently in stage baz of talking with a foo."
 */
91
#define OR_CONN_STATE_OP_CONNECTING 0 /* an application proxy wants me to connect to this OR */
92
#define OR_CONN_STATE_OP_SENDING_KEYS 1
93
#define OR_CONN_STATE_CLIENT_CONNECTING 2 /* I'm connecting to this OR as an OR */
94
95
96
97
98
99
100
101
#define OR_CONN_STATE_CLIENT_SENDING_AUTH 3 /* sending address and info */
#define OR_CONN_STATE_CLIENT_AUTH_WAIT 4 /* have sent address and info, waiting */
#define OR_CONN_STATE_CLIENT_SENDING_NONCE 5 /* sending nonce, last piece of handshake */
#define OR_CONN_STATE_SERVER_AUTH_WAIT 6 /* waiting for address and info */
#define OR_CONN_STATE_SERVER_SENDING_AUTH 7 /* writing auth and nonce */
#define OR_CONN_STATE_SERVER_NONCE_WAIT 8 /* waiting for confirmation of nonce */
#define OR_CONN_STATE_OPEN 9 /* ready to send/receive cells. */

102
103
#define EXIT_CONN_STATE_RESOLVING 0 /* waiting for response from dnsmaster */
#define EXIT_CONN_STATE_CONNECTING 1 /* waiting for connect() to finish */
104
#define EXIT_CONN_STATE_OPEN 2
Roger Dingledine's avatar
Roger Dingledine committed
105
#if 0
106
107
#define EXIT_CONN_STATE_CLOSE 3 /* flushing the buffer, then will close */
#define EXIT_CONN_STATE_CLOSE_WAIT 4 /* have sent a destroy, awaiting a confirmation */
Roger Dingledine's avatar
Roger Dingledine committed
108
109
#endif

110
#define AP_CONN_STATE_SOCKS_WAIT 0
111
112
113
#define AP_CONN_STATE_OR_WAIT 1
#define AP_CONN_STATE_OPEN 2

114
115
116
117
118
119
#define DIR_CONN_STATE_CONNECTING 0
#define DIR_CONN_STATE_SENDING_COMMAND 1
#define DIR_CONN_STATE_READING 2
#define DIR_CONN_STATE_COMMAND_WAIT 3
#define DIR_CONN_STATE_WRITING 4

120
121
122
123
124
125
126
#define CIRCUIT_STATE_ONION_WAIT 0 /* receiving the onion */
#define CIRCUIT_STATE_ONION_PENDING 1 /* waiting to process the onion */
#define CIRCUIT_STATE_OR_WAIT 2 /* I'm at the beginning of the path, my firsthop is still connecting */
#define CIRCUIT_STATE_OPEN 3 /* onion processed, ready to send data along the connection */
//#define CIRCUIT_STATE_CLOSE_WAIT1 4 /* sent two "destroy" signals, waiting for acks */
//#define CIRCUIT_STATE_CLOSE_WAIT2 5 /* received one ack, waiting for one more 
//                                       (or if just one was sent, waiting for that one */
Roger Dingledine's avatar
Roger Dingledine committed
127
128
//#define CIRCUIT_STATE_CLOSE 4 /* both acks received, connection is dead */ /* NOT USED */

129
130
131
132
133
134
135
136
137
138
#define TOPIC_COMMAND_BEGIN 1
#define TOPIC_COMMAND_DATA 2
#define TOPIC_COMMAND_END 3
#define TOPIC_COMMAND_CONNECTED 4
#define TOPIC_COMMAND_SENDME 5

#define TOPIC_HEADER_SIZE 4

#define TOPIC_STATE_RESOLVING

139
140
141
142
143
144
145
146
/* available cipher functions */
#define ONION_CIPHER_IDENTITY 0
#define ONION_CIPHER_DES 1
#define ONION_CIPHER_RC4 2

/* default cipher function */
#define ONION_DEFAULT_CIPHER ONION_CIPHER_DES

147
148
149
150
151
152
153
154
155
156
#define CELL_DIRECTION_IN 1
#define CELL_DIRECTION_OUT 2
#define EDGE_EXIT 3 /* make direction and edge values not overlap, to help catch bugs */
#define EDGE_AP 4

#define CIRCWINDOW_START 1000
#define CIRCWINDOW_INCREMENT 100

#define TOPICWINDOW_START 500
#define TOPICWINDOW_INCREMENT 50
157

Roger Dingledine's avatar
Roger Dingledine committed
158
159
160
161
162
163
164
165
166
167
/* cell commands */
#define CELL_PADDING 0
#define CELL_CREATE 1
#define CELL_DATA 2
#define CELL_DESTROY 3
#define CELL_ACK 4
#define CELL_NACK 5
#define CELL_SENDME 6

#define CELL_PAYLOAD_SIZE 120
168
#define CELL_NETWORK_SIZE 128
Roger Dingledine's avatar
Roger Dingledine committed
169

170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
/* enumeration of types which option values can take */
#define CONFIG_TYPE_STRING  0
#define CONFIG_TYPE_CHAR    1
#define CONFIG_TYPE_INT     2
#define CONFIG_TYPE_LONG    3
#define CONFIG_TYPE_DOUBLE  4

#define CONFIG_LINE_MAXLEN 1024

/* legal characters in a filename */
#define CONFIG_LEGAL_FILENAME_CHARACTERS "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789.-_/"

struct config_line {
  char *key;
  char *value;
  struct config_line *next;
};

Roger Dingledine's avatar
Roger Dingledine committed
188
189
typedef uint16_t aci_t;

Roger Dingledine's avatar
Roger Dingledine committed
190
/* cell definition */
191
typedef struct { 
Roger Dingledine's avatar
Roger Dingledine committed
192
193
194
195
196
197
198
  aci_t aci; /* Anonymous Connection Identifier */
  unsigned char command;
  unsigned char length; /* of payload if data cell, else value of sendme */
  uint32_t seq; /* sequence number */
  unsigned char payload[120];
} cell_t;

199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
#define SOCKS4_REQUEST_GRANTED          90
#define SOCKS4_REQUEST_REJECT           91
#define SOCKS4_REQUEST_IDENT_FAILED     92
#define SOCKS4_REQUEST_IDENT_CONFLICT   93

/* structure of a socks client operation */
typedef struct {
   unsigned char version;     /* socks version number */
   unsigned char command;     /* command code */
   unsigned char destport[2]; /* destination port, network order */
   unsigned char destip[4];   /* destination address */
   /* userid follows, terminated by a NULL */
   /* dest host follows, terminated by a NULL */
} socks4_t;

214
struct connection_t { 
Roger Dingledine's avatar
Roger Dingledine committed
215
216
217
218
219
220
221
222
223
224

/* Used by all types: */

  unsigned char type;
  int state;
  int s; /* our socket */
  int poll_index;
  int marked_for_close;

  char *inbuf;
225
226
  int inbuflen;
  int inbuf_datalen;
Roger Dingledine's avatar
Roger Dingledine committed
227
  int inbuf_reached_eof;
228
  long timestamp_lastread;
Roger Dingledine's avatar
Roger Dingledine committed
229
230

  char *outbuf;
231
232
233
  int outbuflen; /* how many bytes are allocated for the outbuf? */
  int outbuf_flushlen; /* how much data should we try to flush from the outbuf? */
  int outbuf_datalen; /* how much data is there total on the outbuf? */
234
235
236
  long timestamp_lastwritten;

  long timestamp_created;
Roger Dingledine's avatar
Roger Dingledine committed
237

238
239
  int onions_handled_this_second;

240
//  uint16_t aci; /* anonymous connection identifier */
Roger Dingledine's avatar
Roger Dingledine committed
241
242
243
244

/* used by OR and OP: */

  uint32_t bandwidth; /* connection bandwidth */
245
  int receiver_bucket; /* when this hits 0, stop receiving. Every second we
246
247
                        * add 'bandwidth' to this, capping it at 10*bandwidth.
                        */
248
  struct timeval send_timeval; /* for determining when to send the next cell */
Roger Dingledine's avatar
Roger Dingledine committed
249
250

  /* link encryption */
251
252
  crypto_cipher_env_t *f_crypto;
  crypto_cipher_env_t *b_crypto;
Roger Dingledine's avatar
Roger Dingledine committed
253
254
255
256

//  struct timeval lastsend; /* time of last transmission to the client */
//  struct timeval interval; /* transmission interval */

257
  uint32_t addr; /* these two uniquely identify a router. Both in host order. */
Roger Dingledine's avatar
Roger Dingledine committed
258
259
  uint16_t port;

260
/* used by exit and ap: */
Roger Dingledine's avatar
Roger Dingledine committed
261

262
  uint16_t topic_id;
263
264
265
  struct connection_t *next_topic;
  int n_receive_topicwindow;
  int p_receive_topicwindow;
266
267
268

  char socks_version; 
  char read_username;
269

270
  char *dest_addr;
271
  uint16_t dest_port; /* host order */
272
273
274

  char dest_tmp[512];
  int dest_tmplen;
Roger Dingledine's avatar
Roger Dingledine committed
275
  
276
  char *address; /* strdup into this, because free_connection frees it */
277
  crypto_pk_env_t *pkey; /* public RSA key for the other side */
Roger Dingledine's avatar
Roger Dingledine committed
278
279
280

  char nonce[8];
 
281
282
283
};

typedef struct connection_t connection_t;
Roger Dingledine's avatar
Roger Dingledine committed
284
285

/* config stuff we know about the other ORs in the network */
286
typedef struct {
Roger Dingledine's avatar
Roger Dingledine committed
287
288
  char *address;
 
289
  uint32_t addr; /* all host order */
290
291
292
  uint16_t or_port;
  uint16_t op_port;
  uint16_t ap_port;
293
  uint16_t dir_port;
Roger Dingledine's avatar
Roger Dingledine committed
294
 
295
  crypto_pk_env_t *pkey; /* public RSA key */
Roger Dingledine's avatar
Roger Dingledine committed
296
297
 
  /* link info */
298
299
  uint32_t bandwidth;

Roger Dingledine's avatar
Roger Dingledine committed
300
301
302
303
304
305
306
307
308
309
310
//  struct timeval  min_interval;
 
  /* time when last data was sent to that router */
//  struct timeval lastsend;
 
  /* socket */
//  int s;

  void *next;
} routerinfo_t;

311
typedef struct { 
312
313
314
315
316
  unsigned int forwf;
  unsigned int backf;
  char digest2[20]; /* second SHA output for onion_layer_t.keyseed */
  char digest3[20]; /* third SHA output for onion_layer_t.keyseed */

317
318
319
  /* crypto environments */
  crypto_cipher_env_t *f_crypto;
  crypto_cipher_env_t *b_crypto;
320
321
322
  
} crypt_path_t;

323
324
325
326
327
struct data_queue_t {
  cell_t *cell;
  struct data_queue_t *next;
};

Roger Dingledine's avatar
Roger Dingledine committed
328
/* per-anonymous-connection struct */
329
typedef struct {
Roger Dingledine's avatar
Roger Dingledine committed
330
331
332
333
  uint32_t n_addr;
  uint16_t n_port;
  connection_t *p_conn;
  connection_t *n_conn;
334
335
  int n_receive_circwindow;
  int p_receive_circwindow;
Roger Dingledine's avatar
Roger Dingledine committed
336
337
338
339

  aci_t p_aci; /* connection identifiers */
  aci_t n_aci;

340
341
  struct data_queue_t *data_queue; /* for queueing cells at the edges */

Roger Dingledine's avatar
Roger Dingledine committed
342
343
344
  unsigned char p_f; /* crypto functions */
  unsigned char n_f;

345
346
  crypto_cipher_env_t *p_crypto; /* crypto environments */
  crypto_cipher_env_t *n_crypto;
Roger Dingledine's avatar
Roger Dingledine committed
347

348
  crypt_path_t **cpath;
349
  int cpathlen; 
350

Roger Dingledine's avatar
Roger Dingledine committed
351
352
353
354
355
356
357
358
359
360
361
  uint32_t expire; /* expiration time for the corresponding onion */

  int state;

  unsigned char *onion; /* stores the onion when state is CONN_STATE_OPEN_WAIT */
  uint32_t onionlen; /* total onion length */
  uint32_t recvlen; /* length of the onion so far */

  void *next;
} circuit_t;

362
363
364
365
366
367
struct onion_queue_t {
  circuit_t *circ;
  struct data_queue_t *data_cells;
  struct onion_queue_t *next;
};

368
#if 0
369
370
371
372
373
374
375
376
typedef struct
{ 
  int zero:1;
  int version:7;
  int backf:4;
  int forwf:4;
  uint16_t port;
  uint32_t addr;
377
  uint32_t expire;
378
379
  unsigned char keyseed[16];
} onion_layer_t;
380
#endif
381

382
383
384
385
#define ONION_LAYER_SIZE 28
#define ONION_PADDING_SIZE (128-ONION_LAYER_SIZE)

typedef struct {
386
387
388
   char *LogLevel;
   char *RouterFile;
   char *PrivateKeyFile;
389
   double CoinWeight;
390
391
392
   int ORPort;
   int OPPort;
   int APPort;
393
   int DirPort;
394
395
   int MaxConn;
   int TrafficShaping;
396
   int LinkPadding;
397
398
   int DirRebuildPeriod;
   int DirFetchPeriod;
399
   int KeepalivePeriod;
400
   int MaxOnionsPending;
401
   int Role;
402
   int loglevel;
403
} or_options_t;
Roger Dingledine's avatar
Roger Dingledine committed
404
405
406
407
408
409


    /* all the function prototypes go here */

/********************************* buffers.c ***************************/

410
int buf_new(char **buf, int *buflen, int *buf_datalen);
Roger Dingledine's avatar
Roger Dingledine committed
411

412
void buf_free(char *buf);
Roger Dingledine's avatar
Roger Dingledine committed
413

414
int read_to_buf(int s, int at_most, char **buf, int *buflen, int *buf_datalen, int *reached_eof);
Roger Dingledine's avatar
Roger Dingledine committed
415
416
  /* grab from s, put onto buf, return how many bytes read */

417
int flush_buf(int s, char **buf, int *buflen, int *buf_flushlen, int *buf_datalen);
Roger Dingledine's avatar
Roger Dingledine committed
418
419
420
421
  /* push from buf onto s
   * then memmove to front of buf
   * return -1 or how many bytes remain on the buf */

422
423
int write_to_buf(char *string, int string_len,
                 char **buf, int *buflen, int *buf_datalen);
Roger Dingledine's avatar
Roger Dingledine committed
424
425
426
427
  /* append string to buf (growing as needed, return -1 if "too big")
   * return total number of bytes on the buf
   */

428
int fetch_from_buf(char *string, int string_len,
429
                   char **buf, int *buflen, int *buf_datalen);
430
431
432
433
434
435
436
437
438
439
  /* if there is string_len bytes in buf, write them onto string,
   * then memmove buf back (that is, remove them from buf)
   */

int find_on_inbuf(char *string, int string_len,
                  char *buf, int buf_datalen);
  /* find first instance of needle 'string' on haystack 'buf'. return how
   * many bytes from the beginning of buf to the end of string.
   * If it's not there, return -1.
   */
Roger Dingledine's avatar
Roger Dingledine committed
440
441
442

/********************************* cell.c ***************************/

Roger Dingledine's avatar
Roger Dingledine committed
443
int pack_create(uint16_t aci, unsigned char *onion, uint32_t onionlen, unsigned char **cellbuf, unsigned int *cellbuflen);
Roger Dingledine's avatar
Roger Dingledine committed
444
445
446
447
448
449
450
451
452
453
454
455
456

/********************************* circuit.c ***************************/

void circuit_add(circuit_t *circ);
void circuit_remove(circuit_t *circ);

circuit_t *circuit_new(aci_t p_aci, connection_t *p_conn);

/* internal */
aci_t get_unique_aci_by_addr_port(uint32_t addr, uint16_t port, int aci_type);

circuit_t *circuit_get_by_aci_conn(aci_t aci, connection_t *conn);
circuit_t *circuit_get_by_conn(connection_t *conn);
457
circuit_t *circuit_get_by_edge_type(char edge_type);
458
circuit_t *circuit_enumerate_by_naddr_nport(circuit_t *start, uint32_t naddr, uint16_t nport);
Roger Dingledine's avatar
Roger Dingledine committed
459

460
461
int circuit_deliver_data_cell_from_edge(cell_t *cell, circuit_t *circ, char edge_type);
int circuit_deliver_data_cell(cell_t *cell, circuit_t *circ, int crypt_type);
462
int circuit_crypt(circuit_t *circ, char *in, int inlen, char crypt_type);
Roger Dingledine's avatar
Roger Dingledine committed
463

464
465
466
467
void circuit_resume_edge_reading(circuit_t *circ, int edge_type);
int circuit_consider_stop_edge_reading(circuit_t *circ, int edge_type);
int circuit_consider_sending_sendme(circuit_t *circ, int edge_type);

Roger Dingledine's avatar
Roger Dingledine committed
468
469
int circuit_init(circuit_t *circ, int aci_type);
void circuit_free(circuit_t *circ);
470
void circuit_free_cpath(crypt_path_t **cpath, int cpathlen);
Roger Dingledine's avatar
Roger Dingledine committed
471

472
473


Roger Dingledine's avatar
Roger Dingledine committed
474
475
476
477
478
void circuit_close(circuit_t *circ);

void circuit_about_to_close_connection(connection_t *conn);
  /* flush and send destroys for all circuits using conn */

479
480
void circuit_dump_by_conn(connection_t *conn);

Roger Dingledine's avatar
Roger Dingledine committed
481
482
483
484
485
/********************************* command.c ***************************/

void command_process_cell(cell_t *cell, connection_t *conn);

void command_process_create_cell(cell_t *cell, connection_t *conn);
486
void command_process_sendme_cell(cell_t *cell, connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
487
488
void command_process_data_cell(cell_t *cell, connection_t *conn);
void command_process_destroy_cell(cell_t *cell, connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
489
void command_process_connected_cell(cell_t *cell, connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
490
491
492

/********************************* config.c ***************************/

493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
const char *basename(const char *filename);

/* open configuration file for reading */
FILE *config_open(const unsigned char *filename);

/* close configuration file */
int config_close(FILE *f);

struct config_line *config_get_commandlines(int argc, char **argv);

/* parse the config file and strdup into key/value strings. Return list.
 *  *  * Warn and ignore mangled lines. */
struct config_line *config_get_lines(FILE *f);

void config_free_lines(struct config_line *front);

int config_compare(struct config_line *c, char *key, int type, void *arg);

void config_assign(or_options_t *options, struct config_line *list);
Roger Dingledine's avatar
Roger Dingledine committed
512

513
514
/* return 0 if success, <0 if failure. */
int getconfig(int argc, char **argv, or_options_t *options);
515

Roger Dingledine's avatar
Roger Dingledine committed
516
517
/********************************* connection.c ***************************/

518
519
int tv_cmp(struct timeval *a, struct timeval *b);

Roger Dingledine's avatar
Roger Dingledine committed
520
521
522
523
connection_t *connection_new(int type);

void connection_free(connection_t *conn);

524
int connection_create_listener(struct sockaddr_in *bindaddr, int type);
Roger Dingledine's avatar
Roger Dingledine committed
525
526
527
528

int connection_handle_listener_read(connection_t *conn, int new_type, int new_state);

/* start all connections that should be up but aren't */
Roger Dingledine's avatar
cleanup    
Roger Dingledine committed
529
int retry_all_connections(int role, uint16_t or_listenport, 
530
  uint16_t op_listenport, uint16_t ap_listenport, uint16_t dir_listenport);
Roger Dingledine's avatar
Roger Dingledine committed
531
532
533
534
535

int connection_read_to_buf(connection_t *conn);

int connection_fetch_from_buf(char *string, int len, connection_t *conn);

536
int connection_outbuf_too_full(connection_t *conn);
537
int connection_find_on_inbuf(char *string, int len, connection_t *conn);
538
int connection_wants_to_flush(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
539
540
541
int connection_flush_buf(connection_t *conn);

int connection_write_to_buf(char *string, int len, connection_t *conn);
542
543
544
545
546
547
548
549
void connection_send_cell(connection_t *conn);

int connection_receiver_bucket_should_increase(connection_t *conn);
void connection_increment_receiver_bucket (connection_t *conn);

void connection_increment_send_timeval(connection_t *conn);
void connection_init_timeval(connection_t *conn);

550
int connection_speaks_cells(connection_t *conn);
551
int connection_is_listener(connection_t *conn);
552
553
int connection_state_is_open(connection_t *conn);

Roger Dingledine's avatar
Roger Dingledine committed
554
int connection_send_destroy(aci_t aci, connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
555
int connection_send_connected(aci_t aci, connection_t *conn);
556
int connection_encrypt_cell(char *cellp, connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
557
558
559
int connection_write_cell_to_buf(cell_t *cellp, connection_t *conn);

int connection_process_inbuf(connection_t *conn);
560
int connection_package_raw_inbuf(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
561
562
int connection_process_cell_from_inbuf(connection_t *conn);

563
int connection_consider_sending_sendme(connection_t *conn, int edge_type);
Roger Dingledine's avatar
Roger Dingledine committed
564
565
int connection_finished_flushing(connection_t *conn);

566
/********************************* connection_ap.c ****************************/
Roger Dingledine's avatar
Roger Dingledine committed
567

568
int connection_ap_process_inbuf(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
569

570
int ap_handshake_process_socks(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
571

572
int ap_handshake_create_onion(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
573

574
int ap_handshake_establish_circuit(connection_t *conn, unsigned int *route, int routelen, char *onion,
575
                                   int onionlen, crypt_path_t **cpath);
Roger Dingledine's avatar
Roger Dingledine committed
576

577
void ap_handshake_n_conn_open(connection_t *or_conn);
578
579

int ap_handshake_send_onion(connection_t *ap_conn, connection_t *or_conn, circuit_t *circ);
580
int ap_handshake_send_begin(connection_t *ap_conn, circuit_t *circ);
581

582
int ap_handshake_socks_reply(connection_t *conn, char result);
Roger Dingledine's avatar
Roger Dingledine committed
583
int connection_ap_send_connected(connection_t *conn);
584
int connection_ap_process_data_cell(cell_t *cell, circuit_t *circ);
585
586
587

int connection_ap_finished_flushing(connection_t *conn);

588
int connection_ap_create_listener(struct sockaddr_in *bindaddr);
589
590
591
592
593
594
595

int connection_ap_handle_listener_read(connection_t *conn);

/********************************* connection_exit.c ***************************/

int connection_exit_process_inbuf(connection_t *conn);
int connection_exit_package_inbuf(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
596
int connection_exit_send_connected(connection_t *conn);
597
int connection_exit_process_data_cell(cell_t *cell, circuit_t *circ);
598
599

int connection_exit_finished_flushing(connection_t *conn);
600
int connection_exit_connect(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
601
602
603
604
605
606
607
608
609

/********************************* connection_op.c ***************************/

int op_handshake_process_keys(connection_t *conn);

int connection_op_process_inbuf(connection_t *conn);

int connection_op_finished_flushing(connection_t *conn);

610
int connection_op_create_listener(struct sockaddr_in *bindaddr);
Roger Dingledine's avatar
Roger Dingledine committed
611
612
613

int connection_op_handle_listener_read(connection_t *conn);

614
/********************************* connection_or.c ***************************/
Roger Dingledine's avatar
Roger Dingledine committed
615

616
617
int connection_or_process_inbuf(connection_t *conn);
int connection_or_finished_flushing(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
618

619
620
621
622
623
624
625
626
627
628
629
void conn_or_init_crypto(connection_t *conn);

int or_handshake_op_send_keys(connection_t *conn);
int or_handshake_op_finished_sending_keys(connection_t *conn);

int or_handshake_client_process_auth(connection_t *conn);
int or_handshake_client_send_auth(connection_t *conn);

int or_handshake_server_process_auth(connection_t *conn);
int or_handshake_server_process_nonce(connection_t *conn);

630
631
632
connection_t *connect_to_router_as_or(routerinfo_t *router);
connection_t *connection_or_connect_as_or(routerinfo_t *router);
connection_t *connection_or_connect_as_op(routerinfo_t *router);
633

634
int connection_or_create_listener(struct sockaddr_in *bindaddr);
635
int connection_or_handle_listener_read(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
636

637
638
639
640
641
642
643
644
645
/********************************* directory.c ***************************/

void directory_initiate_fetch(routerinfo_t *router);
int directory_send_command(connection_t *conn);
void directory_rebuild(void);
int connection_dir_process_inbuf(connection_t *conn);
int directory_handle_command(connection_t *conn);
int directory_handle_reading(connection_t *conn);
int connection_dir_finished_flushing(connection_t *conn);
646
int connection_dir_create_listener(struct sockaddr_in *bindaddr);
647
648
int connection_dir_handle_listener_read(connection_t *conn);

649
650
651
652
/********************************* dns.c ***************************/

int connection_dns_finished_flushing(connection_t *conn);
int connection_dns_process_inbuf(connection_t *conn);
653
int dns_resolve(connection_t *exitconn);
654
655
int dns_master_start(void);

Roger Dingledine's avatar
Roger Dingledine committed
656
657
/********************************* main.c ***************************/

Roger Dingledine's avatar
cleanup    
Roger Dingledine committed
658
659
void setprivatekey(crypto_pk_env_t *k);
crypto_pk_env_t *getprivatekey(void);
Roger Dingledine's avatar
Roger Dingledine committed
660
661
662
663
int connection_add(connection_t *conn);
int connection_remove(connection_t *conn);
void connection_set_poll_socket(connection_t *conn);

664
665
connection_t *connection_twin_get_by_addr_port(uint32_t addr, uint16_t port);
connection_t *connection_exact_get_by_addr_port(uint32_t addr, uint16_t port);
Roger Dingledine's avatar
Roger Dingledine committed
666
667
668
669

connection_t *connection_get_by_type(int type);

void connection_watch_events(connection_t *conn, short events);
670
671
void connection_stop_reading(connection_t *conn);
void connection_start_reading(connection_t *conn);
672
673
void connection_stop_writing(connection_t *conn);
void connection_start_writing(connection_t *conn);
Roger Dingledine's avatar
Roger Dingledine committed
674
675
676
677
678

void check_conn_read(int i);
void check_conn_marked(int i);
void check_conn_write(int i);

679
int prepare_for_poll(int *timeout);
Roger Dingledine's avatar
Roger Dingledine committed
680
681
682

int do_main_loop(void);

683
void dumpstats(void);
684
void dump_directory_to_string(char *s, int maxlen);
685

Roger Dingledine's avatar
Roger Dingledine committed
686
687
688
689
690
691
692
int main(int argc, char *argv[]);

/********************************* onion.c ***************************/

int decide_aci_type(uint32_t local_addr, uint16_t local_port,
                    uint32_t remote_addr, uint16_t remote_port);

693
694
695
696
int onion_pending_add(circuit_t *circ);
int onion_pending_check(void);
void onion_pending_process_one(void);
void onion_pending_remove(circuit_t *circ);
697
struct data_queue_t *data_queue_add(struct data_queue_t *list, cell_t *cell);
698
void onion_pending_data_add(circuit_t *circ, cell_t *cell);
Roger Dingledine's avatar
Roger Dingledine committed
699

700
701
702
703
704
705
706
/* uses a weighted coin with weight cw to choose a route length */
int chooselen(double cw);

/* returns an array of pointers to routent that define a new route through the OR network
 * int cw is the coin weight to use when choosing the route 
 * order of routers is from last to first
 */
707
unsigned int *new_route(double cw, routerinfo_t **rarray, int rarray_len, int *routelen);
708

709
710
711
/* create a cipher by onion cipher type. */
crypto_cipher_env_t *create_onion_cipher(int cipher_type, char *key, char *iv, int encrypt_mode);

712
/* creates a new onion from route, stores it and its length into bufp and lenp respectively */
713
unsigned char *create_onion(routerinfo_t **rarray, int rarray_len, unsigned int *route, int routelen, int *len, crypt_path_t **cpath);
714
715
716

/* encrypts 128 bytes of the onion with the specified public key, the rest with 
 * DES OFB with the key as defined in the outter layer */
717
int encrypt_onion(unsigned char *onion, uint32_t onionlen, crypto_pk_env_t *pkey);
718
719

/* decrypts the first 128 bytes using RSA and prkey, decrypts the rest with DES OFB with key1 */
720
int decrypt_onion(unsigned char *onion, uint32_t onionlen, crypto_pk_env_t *prkey);
721
722

/* delete first n bytes of the onion and pads the end with n bytes of random data */
723
void pad_onion(unsigned char *onion, uint32_t onionlen, int n);
724

725
void init_tracked_tree(void);
726

Roger Dingledine's avatar
Roger Dingledine committed
727
728
/********************************* routers.c ***************************/

729
730
int learn_my_address(struct sockaddr_in *me);
void router_retry_connections(void);
731
732
733
734
routerinfo_t *router_pick_directory_server(void);
routerinfo_t *router_get_by_addr_port(uint32_t addr, uint16_t port);
unsigned int *router_new_route(int *routelen);
unsigned char *router_create_onion(unsigned int *route, int routelen, int *len, crypt_path_t **cpath);
735
int router_is_me(uint32_t addr, uint16_t port);
736
routerinfo_t *router_get_first_in_route(unsigned int *route, int routelen);
737
void router_forget_router(uint32_t addr, uint16_t port);
738
739
int router_get_list_from_file(char *routerfile);
int router_get_list_from_string(char *s);
Roger Dingledine's avatar
Roger Dingledine committed
740
741

#endif