Lines Matching refs:d1
239 if (s->d1->mtu < dtls1_min_mtu() && !(SSL_get_options(s) & SSL_OP_NO_QUERY_MTU))
241 s->d1->mtu =
246 if (s->d1->mtu < dtls1_min_mtu())
248 s->d1->mtu = 0;
249 s->d1->mtu = dtls1_guess_mtu(s->d1->mtu);
251 s->d1->mtu, NULL);
255 mtu = s->d1->mtu;
273 mtu = s->d1->mtu - (DTLS1_HM_HEADER_LENGTH + DTLS1_RT_HEADER_LENGTH);
277 assert(s->d1->mtu >= dtls1_min_mtu()); /* should have something reasonable now */
281 (int)s->d1->w_msg_hdr.msg_len + DTLS1_HM_HEADER_LENGTH);
302 curr_mtu = s->d1->mtu - BIO_wpending(SSL_get_wbio(s)) -
311 curr_mtu = s->d1->mtu - DTLS1_RT_HEADER_LENGTH -
356 s->d1->mtu = BIO_ctrl(SSL_get_wbio(s),
368 if (type == SSL3_RT_HANDSHAKE && ! s->d1->retransmitting)
373 const struct hm_header_st *msg_hdr = &s->d1->w_msg_hdr;
451 msg_hdr = &s->d1->r_msg_hdr;
486 if (!s->d1->listen)
487 s->d1->handshake_read_seq++;
519 if ( s->d1->r_msg_hdr.frag_off == 0) /* first fragment */
530 s->d1->r_msg_hdr.msg_len = msg_len;
532 s->d1->r_msg_hdr.type = msg_hdr->type;
533 s->d1->r_msg_hdr.seq = msg_hdr->seq;
535 else if (msg_len != s->d1->r_msg_hdr.msg_len)
560 item = pqueue_peek(s->d1->buffered_messages);
570 if ( s->d1->handshake_read_seq == frag->msg_header.seq)
573 pqueue_pop(s->d1->buffered_messages);
633 item = pqueue_find(s->d1->buffered_messages, seq64be);
703 item = pqueue_insert(s->d1->buffered_messages, item);
736 item = pqueue_find(s->d1->buffered_messages, seq64be);
749 if (msg_hdr->seq <= s->d1->handshake_read_seq ||
750 msg_hdr->seq > s->d1->handshake_read_seq + 10 || item != NULL ||
751 (s->d1->handshake_read_seq == 0 && msg_hdr->type == SSL3_MT_FINISHED))
793 item = pqueue_insert(s->d1->buffered_messages, item);
855 if (msg_hdr.seq != s->d1->handshake_read_seq && !(s->d1->listen && msg_hdr.seq == 1))
865 if (!s->server && s->d1->r_msg_hdr.frag_off == 0 &&
955 s->d1->handshake_write_seq = s->d1->next_handshake_write_seq;
961 s->d1->handshake_write_seq, 0, 0);
1029 pqueue sent = s->d1->sent_messages;
1071 assert(s->d1->w_msg_hdr.msg_len +
1076 assert(s->d1->w_msg_hdr.msg_len +
1080 frag->msg_header.msg_len = s->d1->w_msg_hdr.msg_len;
1081 frag->msg_header.seq = s->d1->w_msg_hdr.seq;
1082 frag->msg_header.type = s->d1->w_msg_hdr.type;
1084 frag->msg_header.frag_len = s->d1->w_msg_hdr.msg_len;
1091 frag->msg_header.saved_retransmit_state.epoch = s->d1->w_epoch;
1112 pqueue_insert(s->d1->sent_messages, item);
1139 item = pqueue_find(s->d1->sent_messages, seq64be);
1167 saved_state.epoch = s->d1->w_epoch;
1169 s->d1->retransmitting = 1;
1175 s->d1->w_epoch = frag->msg_header.saved_retransmit_state.epoch;
1180 memcpy(s->s3->write_sequence, s->d1->last_write_sequence, sizeof(s->s3->write_sequence));
1190 s->d1->w_epoch = saved_state.epoch;
1194 memcpy(s->d1->last_write_sequence, s->s3->write_sequence, sizeof(s->s3->write_sequence));
1198 s->d1->retransmitting = 0;
1210 for(item = pqueue_pop(s->d1->sent_messages);
1211 item != NULL; item = pqueue_pop(s->d1->sent_messages))
1224 if (frag_off == 0 && !s->d1->listen)
1226 s->d1->handshake_write_seq = s->d1->next_handshake_write_seq;
1227 s->d1->next_handshake_write_seq++;
1230 dtls1_set_message_header_int(s, mt, len, s->d1->handshake_write_seq,
1243 struct hm_header_st *msg_hdr = &s->d1->w_msg_hdr;
1256 struct hm_header_st *msg_hdr = &s->d1->w_msg_hdr;
1265 struct hm_header_st *msg_hdr = &s->d1->w_msg_hdr;
