s444341/Projekt_SIK
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

poprawki2

Browse Source
This commit is contained in:
Jakub Adamski 2019-11-27 12:13:10 +01:00
parent 28d0f2a2c5
commit 4a77c74ce7
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
klient/src/main/java/Projekt/App.java
View File

@ -111,11 +111,11 @@ public class App {
fDos = new DataOutputStream(fSocket.getOutputStream()); //polaczenie dla pliku fDos = new DataOutputStream(fSocket.getOutputStream()); //polaczenie dla pliku
int wyslano = 0; int wyslano = 0;
while (wyslano < sendFile.length()){ //wysylamy po 1024 while (wyslano < sendFile.length()){ //wysylamy po 1024
byte[] bufor = new byte[1024];
int tobyte = 1024; //standardowa ilosc bajtow int tobyte = 1024; //standardowa ilosc bajtow
if (wyslano + tobyte > fileContent.length){ if (wyslano + tobyte > fileContent.length){
tobyte = fileContent.length - wyslano; tobyte = fileContent.length - wyslano;
} }
byte[] bufor = new byte[tobyte];
System.arraycopy(fileContent, wyslano, bufor, 0, tobyte); System.arraycopy(fileContent, wyslano, bufor, 0, tobyte);
fDos.write(bufor); //uwaga dodac sprawdzanie czy na pewno wyslalismy dobra liczbe bajtow fDos.write(bufor); //uwaga dodac sprawdzanie czy na pewno wyslalismy dobra liczbe bajtow
wyslano += 1024; wyslano += 1024;

9
server/server.c
View File

@ -37,8 +37,9 @@ int main(void) {
int socket_recv; int socket_recv;
int accept_recv; int accept_recv;
int accept_temp; int accept_temp;
char msg[1025] = "Puste"; unsigned char buff[1024];
char msg_copy[1025]; char msg[1024] = "Puste";
char msg_copy[1024];
struct client_socket client[7]; //Tablica Klientów struct client_socket client[7]; //Tablica Klientów
fd_set Socket; //Zbiór jednego deskryptora - głównego socketa fd_set Socket; //Zbiór jednego deskryptora - głównego socketa
fd_set Recv; fd_set Recv;
@ -248,13 +249,13 @@ int main(void) {
plik = fopen(token3, "rb"); plik = fopen(token3, "rb");
razem = 0; razem = 0;
while(razem < wielkosc) { while(razem < wielkosc) {
memset(msg, 0, 1024);
read_plik = fread(msg, 1, 1024, plik); read_plik = fread(msg, 1, 1024, plik);
send_plik = send(pliki_accept, msg, read_plik, 0); send_plik = send(pliki_accept, msg, read_plik, 0);
if (read_plik != send_plik) { if (read_plik != send_plik) {
break; break;
} }
razem += send_plik; razem += send_plik;
memset(msg, 0, 1024);
} }
fclose(plik); fclose(plik);
@ -289,12 +290,12 @@ int main(void) {
razem = 0; razem = 0;
plik = fopen(token3, "wb"); plik = fopen(token3, "wb");
while(razem < wielkosc) { while(razem < wielkosc) {
memset(msg, 0, 1024);
read_plik = recv(pliki_accept, msg, 1024, 0); //read_plik = recv(pliki_socket, msg, 1024, 0); KUBA read_plik = recv(pliki_accept, msg, 1024, 0); //read_plik = recv(pliki_socket, msg, 1024, 0); KUBA
if(read_plik < 0) { if(read_plik < 0) {
break; break;
} }
fwrite(msg, 1, 1024, plik); fwrite(msg, 1, 1024, plik);
memset(msg, 0, 1024);
razem += read_plik; razem += read_plik;
} }
fclose(plik); fclose(plik);