Lines Matching refs:tsctp_meta
73 struct tsctp_meta { struct
167 struct tsctp_meta *meta_listening, *meta_accepted; in handle_accept()
170 meta_listening = (struct tsctp_meta *) upcall_data; in handle_accept()
182 meta_accepted = malloc(sizeof(struct tsctp_meta)); in handle_accept()
188 memset(meta_accepted, 0, sizeof(struct tsctp_meta)); in handle_accept()
206 struct tsctp_meta* tsctp_meta = (struct tsctp_meta*) upcall_data; in handle_upcall() local
226 …while ((n = usrsctp_recvv(upcall_socket, tsctp_meta->buffer, BUFFERSIZE, (struct sockaddr *) &addr… in handle_upcall()
228 if (!tsctp_meta->stat_recv_calls) { in handle_upcall()
229 gettimeofday(&tsctp_meta->stat_start, NULL); in handle_upcall()
231 tsctp_meta->stat_recv_calls++; in handle_upcall()
234 tsctp_meta->stat_notifications++; in handle_upcall()
239 snp = (union sctp_notification *)tsctp_meta->buffer; in handle_upcall()
260 tsctp_meta->stat_fragment_sum += n; in handle_upcall()
262 tsctp_meta->stat_messages++; in handle_upcall()
263 if (tsctp_meta->stat_message_length == 0) { in handle_upcall()
264 tsctp_meta->stat_message_length = tsctp_meta->stat_fragment_sum; in handle_upcall()
279 timersub(&time_now, &tsctp_meta->stat_start, &time_diff); in handle_upcall()
282 if (tsctp_meta->par_stats_human) { in handle_upcall()
285 printf("\tmessage size : %" PRIu64 "\n", tsctp_meta->stat_message_length); in handle_upcall()
286 printf("\tmessages : %" PRIu64 "\n", tsctp_meta->stat_messages); in handle_upcall()
287 printf("\trecv() calls : %" PRIu64 "\n", tsctp_meta->stat_recv_calls); in handle_upcall()
288 printf("\tnotifications : %" PRIu64 "\n", tsctp_meta->stat_notifications); in handle_upcall()
289 …printf("\ttransferred : %sByte\n", bytes2human(tsctp_meta->stat_message_length * tsctp_meta->sta… in handle_upcall()
291 …tgoodput : %sBit/s\n", bytes2human((double) tsctp_meta->stat_message_length * (double) tsctp… in handle_upcall()
295 tsctp_meta->stat_message_length, in handle_upcall()
296 tsctp_meta->stat_messages, in handle_upcall()
297 tsctp_meta->stat_recv_calls, in handle_upcall()
298 tsctp_meta->stat_message_length * tsctp_meta->stat_messages, in handle_upcall()
300 (double) tsctp_meta->stat_message_length * (double) tsctp_meta->stat_messages / seconds, in handle_upcall()
301 tsctp_meta->stat_notifications); in handle_upcall()
306 free(tsctp_meta->buffer); in handle_upcall()
307 free(tsctp_meta); in handle_upcall()
312 if ((events & SCTP_EVENT_WRITE) && tsctp_meta->par_role == TSCTP_CLIENT && !done) { in handle_upcall()
315 if (tsctp_meta->par_ordered == 0) { in handle_upcall()
319 …while ((n = usrsctp_sendv(upcall_socket, tsctp_meta->buffer, tsctp_meta->par_message_length, NULL,… in handle_upcall()
320 if (tsctp_meta->stat_messages == 0) { in handle_upcall()
321 gettimeofday(&tsctp_meta->stat_start, NULL); in handle_upcall()
323 tsctp_meta->stat_messages++; in handle_upcall()
326 printf("Message #%" PRIu64 " sent\n", tsctp_meta->stat_messages); in handle_upcall()
329 if (tsctp_meta->par_messages && tsctp_meta->par_messages == tsctp_meta->stat_messages) { in handle_upcall()
338 free(tsctp_meta->buffer); in handle_upcall()
339 free(tsctp_meta); in handle_upcall()
344 timersub(&time_now, &tsctp_meta->stat_start, &time_diff); in handle_upcall()
347 if ((tsctp_meta->par_messages && tsctp_meta->par_messages == tsctp_meta->stat_messages) || in handle_upcall()
348 (tsctp_meta->par_runtime && tsctp_meta->par_runtime <= seconds)) { in handle_upcall()
356 free(tsctp_meta->buffer); in handle_upcall()
357 free(tsctp_meta); in handle_upcall()
384 struct tsctp_meta *meta; in main()
591 meta = malloc(sizeof(struct tsctp_meta)); in main()
597 memset(meta, 0, sizeof(struct tsctp_meta)); in main()