1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
/*
tcpcla.h: common definitions for TCP convergence layer
adapter modules.
Author: Scott Burleigh, JPL
Modification History:
Date Who What
Copyright (c) 2003, California Institute of Technology.
ALL RIGHTS RESERVED. U.S. Government Sponsorship
acknowledged.
*/
#ifndef _TCPCLA_H_
#define _TCPCLA_H_
#include "bpP.h"
#include <pthread.h>
#include "ipnfw.h"
#include "dtn2fw.h"
#ifdef __cplusplus
extern "C" {
#endif
#if !defined(MIN)
#define MIN(x, y) ((x) < (y) ? (x) : (y))
#endif
#if 0
#define TCPCLA_BUFSZ (1024 * 1024)
#endif
#define TCPCLA_BUFSZ (64 * 1024)
#define BpTcpDefaultPortNbr 4556
#define DEFAULT_TCP_RATE -1
/* TCP has congestion control, so rate control not needed. */
#define TCPCLA_MAGIC "dtn!"
#define TCPCLA_MAGIC_SIZE 4
#define TCPCLA_ID_VERSION 0x03
#define TCPCLA_FLAGS 0x00
#define TCPCLA_TYPE_DATA 0x01
#define TCPCLA_TYPE_ACK 0x02
#define TCPCLA_TYPE_REF_BUN 0x03
#define TCPCLA_TYPE_KEEP_AL 0x04
#define TCPCLA_TYPE_SHUT_DN 0x05
#define SHUT_DN_BUFSZ 32
#define SHUT_DN_DELAY_FLAG 0x01
#define SHUT_DN_REASON_FLAG 0x02
#define SHUT_DN_NO 0
#define SHUT_DN_IDLE 1
#define SHUT_DN_IDLE_HEX 0x00
#define SHUT_DN_VER 2
#define SHUT_DN_VER_HEX 0x01
#define SHUT_DN_BUSY 3
#define SHUT_DN_BUSY_HEX 0x02
#define BACKOFF_TIMER_START 30
#define BACKOFF_TIMER_LIMIT 3600
#ifndef KEEPALIVE_PERIOD
#define KEEPALIVE_PERIOD (15)
#endif
extern int tcpDelayEnabled;
extern int tcpDelayNsecPerByte;
extern int tcpDesiredKeepAlivePeriod;
extern int _tcpOutductId(struct sockaddr *sn, char *protocolName,
char *ductName);
extern void handleConnectionLoss();
extern int connectToCLI(struct sockaddr *sn, int *sock);
extern int sendBytesByTCP(int *bundleSocket, char *from, int length,
struct sockaddr *sn);
extern int sendBundleByTCP(struct sockaddr *socketName,
int *bundleSocket, unsigned int bundleLength,
Object bundleZco, unsigned char *buffer);
extern int sendBundleByTCPCL(struct sockaddr *socketName,
int *bundleSocket, unsigned int bundleLength,
Object bundleZco, unsigned char *buffer,
int *keepalivePeriod);
extern int receiveBytesByTCP(int bundleSocket, char *into, int length);
extern int receiveBundleByTcp(int bundleSocket, AcqWorkArea *work,
char *buffer);
extern int receiveBundleByTcpCL(int bundleSocket, AcqWorkArea *work, char *buffer);
extern int receiveSegmentByTcpCL(int bundleSocket,AcqWorkArea *work,char *buffer, uvast *segmentLength,int *flags);
extern int sendContactHeader(int *bundleSocket, unsigned char *buffer,
struct sockaddr *socketName);
extern int receiveContactHeader(int *bundleSocket, unsigned char *buffer,
int *keepalivePeriod);
extern void findVInduct(VInduct **vduct, char *protocolName);
extern int sendShutDownMessage(int *bundleSocket, int reason, int delay,
struct sockaddr *socketName);
#ifdef __cplusplus
}
#endif
#endif /* _TCPCLA_H */
|
