Revision b71dda24

View differences:

util/queueManagement.c
105 105
	else return NULL;	
106 106
}
107 107

  
108

  
108
#ifdef RTX
109 109
void addPacketRTXqueue(PacketContainer *packet) {
110 110
	//removing old packets - because of maxTimeToHold
111 111
	struct timeval now, age;
......
156 156
	}
157 157
	return 1;	
158 158
}
159
#endif
159 160

  
160 161
void setQueuesParams (int TXsize, int RTXsize, double maxTTHold) {
161 162
	TXmaxSize = TXsize * 1024;
......
176 177
	return 0;
177 178
}
178 179

  
180
#ifdef RTX
179 181
PacketContainer* searchPacketInRTX(int connID, int msgSeqNum, int offset) {
180 182
	
181 183
	connID = ntohl(connID);
......
227 229
        }
228 230
        return 0;
229 231
}
230

  
232
#endif
util/queueManagement.h
48 48

  
49 49
PacketContainer* takePacketToSend();
50 50

  
51
void addPacketRTXqueue(PacketContainer *packet);
52

  
53 51
int removeOldestPacket() ;
54 52

  
55 53
void setQueueSizes (int TXsize, int RTXsize);
......
60 58

  
61 59
void setQueuesParams (int TXsize, int RTXsize, double maxTimeToHold);
62 60

  
61
#ifdef RTX
62
void addPacketRTXqueue(PacketContainer *packet);
63

  
63 64
int rtxPacketsFromTo(int connID, int msgSeqNum, int offsetFrom, int offsetTo);
65
#endif
util/rateLimiter.c
54 54
   		gettimeofday(&now, NULL);
55 55
		bib_then = now;
56 56

  
57
#ifdef RTX
57 58
		if (!(packet->priority & NO_RTX)) addPacketRTXqueue(packet);
59
#endif
58 60

  
59 61
		sendPacket(packet->udpSocket, packet->iov, 4, packet->socketaddr);
60 62
	}
......
96 98
			return addPacketTXqueue(newPacket);
97 99
		}
98 100
	}
101
#ifdef RTX
99 102
	if (!(priority & NO_RTX)) addPacketRTXqueue(newPacket);
100
	
103
#endif
104

  
101 105
	return sendPacket(udpSocket, iov, 4, socketaddr);
102 106
}
103 107

  

Also available in: Unified diff