| Цитата(borisbn @ 10.3.2011, 11:26) | чем скорость измеряешь ?
какой размер пакета, передаваемого за раз ?
попробуй увеличить его раз в 10-20... |
Про пакеты ничего не могу сказать, но буфера я менял в пределах от 1500 до 512000 и устанавливал их через setsockopt:
При отказе от ручного выставления размера буфера, он производит поиск оптимума сам, но на мою задачу это не влияет.
| Код |
if (setsockopt(lsock, SOL_SOCKET, SO_SNDBUF, (char*)&lenbuf, sizeof(lenbuf)) == SOCKET_ERROR) {return;}
if (setsockopt(lsock, SOL_SOCKET, SO_RCVBUF, (char*)&lenbuf, sizeof(lenbuf)) == SOCKET_ERROR){return;}
//if (setsockopt(lsock, IPPROTO_TCP, TCP_NODELAY, (char *) &boo, sizeof(boo)) == SOCKET_ERROR){return;}
if (setsockopt(lsock, SOL_SOCKET, SO_RCVTIMEO, (char *)&time, sizeof(time)) == SOCKET_ERROR){return;}
if (setsockopt(lsock, SOL_SOCKET, SO_SNDTIMEO, (char *)&time, sizeof(time)) == SOCKET_ERROR){return;}
//if (setsockopt(lsock, SOL_SOCKET, SO_KEEPALIVE, (char*)&keep, sizeof(keep)) == SOCKET_ERROR){return;}
|
При инициализации глобальные переменные имеют следующие значения:
count_send_data = 10;
count_all_data = 0;
count_loc_data = 0;
lab = 0;
| Код |
case 2:
{
if (!WSAEnumNetworkEvents(sock, (WSAEVENT)hEvents[2], &wsEvents))
{
if (wsEvents.lNetworkEvents & FD_READ)
{
if (wsEvents.iErrorCode[FD_READ_BIT])
{
ClientMessage = "FD_READ fail. Stopping..";
Synchronize(write_memo);
dwDone = 1;
break;
}
else
{
do{
//принимаем данные
nRet = recv (sock, (char*)buf, lenbuf, 0);
//обрабатываем принятые данные
if (nRet > 0)
{
buf[nRet-1] = '\0';
int len = strlen(buf);
for(int i = 0; i <= len; i ++)
{
sin_data += sin((int)buf[i]);
}
ClientMessage = buf;
//EnterCriticalSection(&cs); // Вход в критическую секцию cs
count_all_data += nRet;
count_loc_data += nRet;
//LeaveCriticalSection(&cs); // Выход из критической секции cs
//накапливаем 10 приёмов и подсчитываем скорость
if(count_send_data == 10)
{
Synchronize(timer_timer);
ClientMessage = "count_send_data: " + (AnsiString)count_send_data;
Synchronize(write_memo);
count_send_data = 0;
} else { count_send_data ++; }
ClientMessage = "DS: " + (AnsiString)count_all_data + ", Ch: " + (AnsiString)nRet + ", sin(x): " + (AnsiString)sin_data + " " + (AnsiString)sock;
Synchronize(write_memo);
}
}while (nRet > 0);
//Synchronize(TestTime);
}
}
if (wsEvents.lNetworkEvents & FD_CLOSE)
{
if (wsEvents.iErrorCode[FD_CLOSE_BIT])
{
ClientMessage = "FD_CLOSE fail with code " + (AnsiString)wsEvents.iErrorCode[FD_CLOSE_BIT];
Synchronize(write_memo);
if (wsEvents.iErrorCode[FD_CLOSE_BIT] == WSAENETDOWN)
{
ClientMessage = "Stopping..";
Synchronize(write_memo);
dwDone = 1;
break;
}
}
else
{
lab = 2;
Synchronize(timer_timer);
sin_data = 0;
ClientMessage = "Client disconnected.";
Synchronize(write_memo);
WSAEventSelect (sock, (WSAEVENT)hEvents[2], 0);
shutdown (sock, SD_BOTH);
closesocket (sock);
dwCount = 2;
}
}
}
else
{
ClientMessage = "WSAEnumNetworkEvent fail with code " + (AnsiString)WSAGetLastError();
Synchronize(write_memo);
ResetEvent (hEvents[2]);
}
} break;
void __fastcall TWinsockThread::timer_timer()
{
int t1buf;
double curtime, speed = 0;
switch(lab)
{
case 0:
{
t_begin = t_1 = clock();
ClientMessage = "0";
lab = 1;
} break;
case 1:
{
t1buf = clock();
curtime = t1buf - t_1;
speed = count_loc_data;//байты
//--------->
count_loc_data = 0;
t_1 = t1buf;
} break;
case 2:
{
curtime = (int)clock() - (int)t_begin;
speed = count_all_data;//байты
//--------->
ClientMessage = "count_all_data: " + (AnsiString)count_all_data + " byte";
write_memo();
count_all_data = 0;
lab = 0;
} break;
}
//--------->
if((speed)&&(curtime))
{
speed *= 8; //биты
speed /= 1024; //кбиты
speed /= 1024; //мбиты
speed /= (curtime*0.001); //мбиты / секунды
ClientMessage = "Speed: " + (AnsiString)speed + " mbit/sec";
write_memo();
}
//--------->
Application->ProcessMessages();
}
|
Добавлено через 3 минуты и 2 секунды
Но вот воспользовался советом и пустил клиента в 4 потока и сервера в 4, скорость при этом на локал хосте выросла с 176 до ~350 - 700 МБит/сек, но какая то она нестабильная, у меня складывается впечатление что я где то с потоками напортачил, а вернее с подсчётом времени из этих потоков!? Сейчас у меня заведена глобальная переменная в которую потоки плюсуют количество принятых данных, при приёме десяти порций происходит подсчёт результата.
Внимание вопрос, если я использую один сокет на сервере и один на клиенте, то могу ли я заполнить канал в 1 ГБит/сек, или же мне продолжать мутки с многопоточностью? |
)