+ outpktno++;
+
+ if(outpktno >= dropfrom && outpktno < dropto) {
+ if(drand48() < dropout) {
+ debug("Dropped outgoing packet\n");
+ return len;
+ }
+
+ if(!reorder_data && drand48() < reorder) {
+ reorder_data = malloc(len);
+
+ if(!reorder_data) {
+ debug("Out of memory\n");
+ return len;
+ }
+
+ reorder_len = len;
+ memcpy(reorder_data, data, len);
+ reorder_countdown = 1 + drand48() * reorder_dist;
+ return len;
+ }
+ }
+
+ if(reorder_data) {
+ if(--reorder_countdown < 0) {
+ total_out += reorder_len;
+ send(s, reorder_data, reorder_len, MSG_DONTWAIT);
+ free(reorder_data);
+ reorder_data = NULL;
+ }
+ }
+
+ total_out += len;
+ ssize_t result = send(s, data, len, MSG_DONTWAIT);
+
+ if(result <= 0) {
+ debug("Error sending UDP packet: %s\n", strerror(errno));
+ }
+
+ return result;
+}
+
+static void set_mtu(struct utcp *u, int s) {
+ if(!mtu) {
+ socklen_t optlen = sizeof(mtu);
+ getsockopt(s, IPPROTO_IP, IP_MTU, &mtu, &optlen);
+ }
+
+ if(!mtu || mtu == 65535) {
+ mtu = 1500;
+ }
+
+ fprintf(stderr, "Using MTU %lu\n", mtu);
+
+ utcp_set_mtu(u, mtu ? mtu - 48 : 1300);