Function run

lib_acl/samples/udp/client/main.cpp:114–154

}

static void run(const char *local_addr, const char *peer_addr,
	int count, int dlen, int inter, int need_read, int mio_on, int quit)
{
	int       i;
	double    spent;
	char      data[4096];
	struct    timeval begin, end;
	SOCK_UDP *sock = udp_client_open(local_addr, peer_addr);

	(void) quit;

	if (sock == NULL) {
		printf("open_sock error!\r\n");
		return;
	}

	if (dlen > (int) sizeof(data) - 1)
		dlen = (int) sizeof(data) - 1;
	for (i = 0; i < dlen; i++)
		data[i] = 'X';
	data[dlen] = 0;

	gettimeofday(&begin, NULL);

	if (mio_on)
		i = mio(sock, peer_addr, dlen, count, inter, need_read);
	else
		i = sio(sock, data, dlen, count, inter, need_read);

	gettimeofday(&end, NULL);
	spent = stamp_sub(&end, &begin);

	printf("thread: %lu, total: %d, curr: %d, spent: %.2f, speed: %.2f\r\n",
		(unsigned long) acl_pthread_self(), count, i, spent,
		(i * 1000) / (spent > 1 ? spent : 1));

	printf("thread: %lu, peer addr: %s\r\n",
		(unsigned long) acl_pthread_self(), peer_addr);

	udp_close(sock);
}

typedef struct {
	char  local[64];