Add forgotten server example files
[libisds.git] / client / common.c
bloba43c1d685869553b25e9234ed2df0e660311f6d0
1 #define _XOPEN_SOURCE 700
2 #include <stdlib.h>
3 #include <stdio.h>
4 /*#include <locale.h>*/
5 #include <time.h>
6 #include <string.h>
7 #include <stdint.h>
8 #include <inttypes.h>
9 #include <errno.h>
10 #include <sys/types.h>
11 #include <sys/stat.h>
12 #include <fcntl.h>
13 #include <unistd.h>
14 #include <sys/mman.h>
15 #include <isds.h>
17 char credentials_file[] = "../test_credentials";
19 static int read_config(char **line, int order) {
20 FILE *file;
21 size_t length = 0;
22 char *eol;
24 if (!line) return -1;
25 free(*line);
26 *line = NULL;
28 file = fopen(credentials_file, "r");
29 if (!file) {
30 fprintf(stderr, "Could open %s\n", credentials_file);
31 return -1;
34 for (int i = 0; i < order; i++) {
35 if (-1 == getline(line, &length, file)) {
36 fprintf(stderr, "Could not read line #%d from %s: ",
37 i + 1, credentials_file);
38 if (ferror(file))
39 fprintf(stderr, "error occured\n");
40 else if (feof(file))
41 fprintf(stderr, "end of file reached\n");
42 else
43 fprintf(stderr, "I don't know why\n");
44 fclose(file);
45 free(*line);
46 *line = NULL;
47 return -1;
51 fclose(file);
53 eol = strpbrk(*line, "\r\n");
54 if (eol) *eol = '\0';
56 return 0;
59 const char *username(void) {
60 static char *username;
62 if (!username) {
63 username = getenv("ISDS_USERNAME");
64 if (!username)
65 read_config(&username, 1);
67 return username;
70 const char *password(void) {
71 static char *password;
73 if (!password) {
74 password = getenv("ISDS_PASSWORD");
75 if (!password)
76 read_config(&password, 2);
78 return password;
81 void print_DbState(const long int state) {
82 switch(state) {
83 case DBSTATE_ACCESSIBLE: printf("ACCESSIBLE\n"); break;
84 case DBSTATE_TEMP_UNACCESSIBLE: printf("TEMP_UNACCESSIBLE\n"); break;
85 case DBSTATE_NOT_YET_ACCESSIBLE: printf("NOT_YET_ACCESSIBLE\n"); break;
86 case DBSTATE_PERM_UNACCESSIBLE: printf("PERM_UNACCESSIBLE\n"); break;
87 case DBSTATE_REMOVED: printf("REMOVED\n"); break;
88 default: printf("<unknown state %ld>\n", state);
92 void print_DbType(const long int *type) {
93 if (!type) printf("NULL\n");
94 else
95 switch(*type) {
96 case DBTYPE_SYSTEM: printf("SYSTEM\n"); break;
97 case DBTYPE_FO: printf("FO\n"); break;
98 case DBTYPE_PFO: printf("PFO\n"); break;
99 case DBTYPE_PFO_ADVOK: printf("PFO_ADVOK\n"); break;
100 case DBTYPE_PFO_DANPOR: printf("PFO_DAPOR\n"); break;
101 case DBTYPE_PFO_INSSPR: printf("PFO_INSSPR\n"); break;
102 case DBTYPE_PO: printf("PO\n"); break;
103 case DBTYPE_PO_ZAK: printf("PO_ZAK\n"); break;
104 case DBTYPE_PO_REQ: printf("PO_REQ\n"); break;
105 case DBTYPE_OVM: printf("OVM\n"); break;
106 case DBTYPE_OVM_NOTAR: printf("OVM_NOTAR\n"); break;
107 case DBTYPE_OVM_EXEKUT: printf("OVM_EXEKUT\n"); break;
108 case DBTYPE_OVM_REQ: printf("OVM_REQ\n"); break;
109 default: printf("<unknown type %ld>\n", *type);
114 void print_UserType(const long int *type) {
115 if (!type) printf("NULL\n");
116 else
117 switch(*type) {
118 case USERTYPE_PRIMARY: printf("PRIMARY\n"); break;
119 case USERTYPE_ENTRUSTED: printf("ENTRUSTED\n"); break;
120 case USERTYPE_ADMINISTRATOR: printf("ADMINISTRATOR\n"); break;
121 case USERTYPE_OFFICIAL: printf("OFFICIAL\n"); break;
122 default: printf("<unknown type %ld>\n", *type);
127 void print_sender_type(const isds_sender_type *type) {
128 if (!type) printf("NULL\n");
129 else
130 switch(*type) {
131 case SENDERTYPE_PRIMARY: printf("PRIMARY\n"); break;
132 case SENDERTYPE_ENTRUSTED: printf("ENTRUSTED\n"); break;
133 case SENDERTYPE_ADMINISTRATOR: printf("ADMINISTRATOR\n"); break;
134 case SENDERTYPE_OFFICIAL: printf("OFFICIAL\n"); break;
135 case SENDERTYPE_VIRTUAL: printf("VIRTUAL\n"); break;
136 default: printf("<unknown type %u>\n", *type);
141 void print_UserPrivils(const long int *privils) {
143 const char *priviledges[] = {
144 "READ_NON_PERSONAL",
145 "READ_ALL",
146 "CREATE_DM",
147 "VIEW_INFO",
148 "SEARCH_DB",
149 "OWNER_ADM",
150 "READ_VAULT",
151 "ERASE_VAULT"
153 const int priviledges_count = sizeof(priviledges)/sizeof(priviledges[0]);
155 if (!privils) printf("NULL\n");
156 else {
157 printf("%ld (", *privils);
159 for (int i = 0; i < priviledges_count; i++) {
160 if (*privils & (1<<i)) {
161 printf(
162 ((i + 1) == priviledges_count) ? "%s" : "%s|",
163 priviledges[i]);
167 printf(")\n");
172 void print_hash(const struct isds_hash *hash) {
173 if (!hash) {
174 printf("NULL\n");
175 return;
178 switch(hash->algorithm) {
179 case HASH_ALGORITHM_MD5: printf("MD5 "); break;
180 case HASH_ALGORITHM_SHA_1: printf("SHA-1 "); break;
181 case HASH_ALGORITHM_SHA_256: printf("SHA-256 "); break;
182 case HASH_ALGORITHM_SHA_512: printf("SHA-512 "); break;
183 default: printf("<Unknown hash algorithm %d> ", hash->algorithm);
184 break;
187 if (!hash->value) printf("<NULL>");
188 else
189 for (size_t i = 0; i < hash->length; i++) {
190 if (i > 0) printf(":");
191 printf("%02x", ((uint8_t *)(hash->value))[i]);
194 printf("\n");
198 void print_raw_type(const isds_raw_type type) {
199 switch(type) {
200 case RAWTYPE_INCOMING_MESSAGE:
201 printf("INCOMING_MESSAGE\n"); break;
202 case RAWTYPE_PLAIN_SIGNED_INCOMING_MESSAGE:
203 printf("PLAIN_SIGNED_INCOMING_MESSAGE\n"); break;
204 case RAWTYPE_CMS_SIGNED_INCOMING_MESSAGE:
205 printf("CMS_SIGNED_INCOMING_MESSAGE\n"); break;
206 case RAWTYPE_PLAIN_SIGNED_OUTGOING_MESSAGE:
207 printf("PLAIN_SIGNED_OUTGOING_MESSAGE\n"); break;
208 case RAWTYPE_CMS_SIGNED_OUTGOING_MESSAGE:
209 printf("CMS_SIGNED_OUTGOING_MESSAGE\n"); break;
210 case RAWTYPE_DELIVERYINFO:
211 printf("DELIVERYINFO\n"); break;
212 case RAWTYPE_PLAIN_SIGNED_DELIVERYINFO:
213 printf("PLAIN_SIGNED_DELIVERYINFO\n"); break;
214 case RAWTYPE_CMS_SIGNED_DELIVERYINFO:
215 printf("CMS_SIGNED_DELIVERYINFO\n"); break;
216 default:
217 printf("<Unknown raw type %d> ", type);
218 break;
222 static void print_dmMessageStatus(const isds_message_status *status) {
223 if (!status) printf("NULL\n");
224 else
225 switch(*status) {
226 case MESSAGESTATE_SENT: printf("SENT\n"); break;
227 case MESSAGESTATE_STAMPED: printf("STAMPED\n"); break;
228 case MESSAGESTATE_INFECTED: printf("INFECTED\n"); break;
229 case MESSAGESTATE_DELIVERED: printf("DELIVERED\n"); break;
230 case MESSAGESTATE_SUBSTITUTED: printf("SUBSTITUTED\n"); break;
231 case MESSAGESTATE_RECEIVED: printf("RECEIVED\n"); break;
232 case MESSAGESTATE_READ: printf("READ\n"); break;
233 case MESSAGESTATE_UNDELIVERABLE: printf("UNDELIVERABLE\n"); break;
234 case MESSAGESTATE_REMOVED: printf("REMOVED\n"); break;
235 case MESSAGESTATE_IN_SAFE: printf("IN_SAFE\n"); break;
236 default: printf("<unknown type %d>\n", *status);
240 void print_bool(const _Bool *boolean) {
241 printf("%s\n", (!boolean) ? "NULL" : ((*boolean)? "true" : "false") );
245 void print_longint(const long int *number) {
246 if (!number) printf("NULL\n");
247 else printf("%ld\n", *number);
251 void print_PersonName(const struct isds_PersonName *personName) {
252 printf("\tpersonName = ");
253 if (!personName) printf("NULL\n");
254 else {
255 printf("{\n");
256 printf("\t\tpnFirstName = %s\n", personName->pnFirstName);
257 printf("\t\tpnMiddleName = %s\n", personName->pnMiddleName);
258 printf("\t\tpnLastName = %s\n", personName->pnLastName);
259 printf("\t\tpnLastNameAtBirth = %s\n", personName->pnLastNameAtBirth);
260 printf("\t}\n");
265 void print_Address(const struct isds_Address *address) {
266 printf("\taddress = ");
267 if (!address) printf("NULL\n");
268 else {
269 printf("{\n");
271 printf("\t\tadCode = ");
272 print_longint(address->adCode);
274 printf("\t\tadCity = %s\n", address->adCity);
275 printf("\t\tadDistrict = %s\n", address->adDistrict);
276 printf("\t\tadStreet = %s\n", address->adStreet);
277 printf("\t\tadNumberInStreet = %s\n", address->adNumberInStreet);
278 printf("\t\tadNumberInMunicipality = %s\n",
279 address->adNumberInMunicipality);
280 printf("\t\tadZipCode = %s\n", address->adZipCode);
281 printf("\t\tadState = %s\n", address->adState);
282 printf("\t}\n");
287 void print_date(const struct tm *date) {
288 if (!date) printf("NULL\n");
289 else printf("%s", asctime(date));
293 void print_DbOwnerInfo(const struct isds_DbOwnerInfo *info) {
294 printf("dbOwnerInfo = ");
296 if (!info) {
297 printf("NULL\n");
298 return;
301 printf("{\n");
302 printf("\tdbID = %s\n", info->dbID);
304 printf("\tdbType = ");
305 print_DbType((long int *) (info->dbType));
306 printf("\tic = %s\n", info->ic);
308 print_PersonName(info->personName);
310 printf("\tfirmName = %s\n", info->firmName);
312 printf("\tbirthInfo = ");
313 if (!info->birthInfo) printf("NULL\n");
314 else {
315 printf("{\n");
317 printf("\t\tbiDate = ");
318 print_date(info->birthInfo->biDate);
320 printf("\t\tbiCity = %s\n", info->birthInfo->biCity);
321 printf("\t\tbiCounty = %s\n", info->birthInfo->biCounty);
322 printf("\t\tbiState = %s\n", info->birthInfo->biState);
323 printf("\t}\n");
326 print_Address(info->address);
328 printf("\tnationality = %s\n", info->nationality);
329 printf("\temail = %s\n", info->email);
330 printf("\ttelNumber = %s\n", info->telNumber);
331 printf("\tidentifier = %s\n", info->identifier);
333 printf("\taifoIsds = ");
334 print_bool(info->aifoIsds);
336 printf("\tregistryCode = %s\n", info->registryCode);
338 printf("\tdbState = ");
339 if (!info->dbState) printf("NULL\n");
340 else print_DbState(*(info->dbState));
342 printf("\tdbEffectiveOVM = ");
343 print_bool(info->dbEffectiveOVM);
345 printf("\tdbOpenAddressing = ");
346 print_bool(info->dbOpenAddressing);
348 printf("}\n");
353 void print_DbUserInfo(const struct isds_DbUserInfo *info) {
354 printf("dbUserInfo = ");
356 if (!info) {
357 printf("NULL\n");
358 return;
361 printf("{\n");
362 printf("\tuserID = %s\n", info->userID);
364 printf("\tuserType = ");
365 print_UserType((long int *) (info->userType));
367 printf("\tuserPrivils = ");
368 print_UserPrivils(info->userPrivils);
370 print_PersonName(info->personName);
371 print_Address(info->address);
373 printf("\tbiDate = ");
374 print_date(info->biDate);
376 printf("\tic = %s\n", info->ic);
377 printf("\tfirmName = %s\n", info->firmName);
379 printf("\tcaStreet = %s\n", info->caStreet);
380 printf("\tcaCity = %s\n", info->caCity);
381 printf("\tcaZipCode = %s\n", info->caZipCode);
382 printf("\tcaState = %s\n", info->caState);
383 printf("\taifo_ticket = %s\n", info->aifo_ticket);
385 printf("}\n");
389 void print_timeval(const struct timeval *time) {
390 struct tm broken;
391 char buffer[128];
392 time_t seconds_as_time_t;
394 if (!time) {
395 printf("NULL\n");
396 return;
399 /* MinGW32 GCC 4.8+ uses 64-bit time_t but time->tv_sec is defined as
400 * 32-bit long in Microsoft API. Convert value to the type expected by
401 * gmtime_r(). */
402 seconds_as_time_t = time->tv_sec;
403 if (!localtime_r(&seconds_as_time_t, &broken)) goto error;
404 if (!strftime(buffer, sizeof(buffer)/sizeof(char), "%c", &broken))
405 goto error;
406 printf("%s, %" PRIdMAX " us\n", buffer, (intmax_t)time->tv_usec);
407 return;
409 error:
410 printf("<Error while formating>\n>");
411 return;
415 void print_event_type(const isds_event_type *type) {
416 if (!type) {
417 printf("NULL");
418 return;
420 switch (*type) {
421 case EVENT_UKNOWN: printf("UNKNOWN\n"); break;
422 case EVENT_ENTERED_SYSTEM: printf("ENTERED_SYSTEM\n"); break;
423 case EVENT_ACCEPTED_BY_RECIPIENT:
424 printf("ACCEPTED_BY_RECIPIENT\n"); break;
425 case EVENT_ACCEPTED_BY_FICTION:
426 printf("DELIVERED_BY_FICTION\n"); break;
427 case EVENT_UNDELIVERABLE:
428 printf("UNDELIVERABLE\n"); break;
429 case EVENT_COMMERCIAL_ACCEPTED:
430 printf("COMMERCIAL_ACCEPTED\n"); break;
431 case EVENT_DELIVERED:
432 printf("DELIVERED\n"); break;
433 case EVENT_PRIMARY_LOGIN:
434 printf("PRIMARY_LOGIN\n"); break;
435 case EVENT_ENTRUSTED_LOGIN:
436 printf("ENTRUSTED_LOGIN\n"); break;
437 case EVENT_SYSCERT_LOGIN:
438 printf("SYSCERT_LOGIN\n"); break;
439 default: printf("<unknown type %d>\n", *type);
444 void print_events(const struct isds_list *events) {
445 const struct isds_list *item;
446 const struct isds_event *event;
448 if (!events) {
449 printf("NULL\n");
450 return;
453 printf("{\n");
455 for (item = events; item; item = item->next) {
456 event = (struct isds_event *) item->data;
457 printf("\t\t\tevent = ");
458 if (!event) printf("NULL");
459 else {
460 printf("{\n");
462 printf("\t\t\t\ttype = ");
463 print_event_type(event->type);
465 printf("\t\t\t\tdescription = %s\n", event->description);
467 printf("\t\t\t\ttime = ");
468 print_timeval(event->time);
470 printf("\t\t\t}\n");
474 printf("\t\t}\n");
478 void print_envelope(const struct isds_envelope *envelope) {
479 printf("\tenvelope = ");
481 if (!envelope) {
482 printf("NULL\n");
483 return;
485 printf("{\n");
487 printf("\t\tdmID = %s\n", envelope->dmID);
488 printf("\t\tdbIDSender = %s\n", envelope->dbIDSender);
489 printf("\t\tdmSender = %s\n", envelope->dmSender);
490 printf("\t\tdmSenderAddress = %s\n", envelope->dmSenderAddress);
491 printf("\t\tdmSenderType = ");
492 print_DbType(envelope->dmSenderType);
493 printf("\t\tdmRecipient = %s\n", envelope->dmRecipient);
494 printf("\t\tdmRecipientAddress = %s\n", envelope->dmRecipientAddress);
495 printf("\t\tdmAmbiguousRecipient = ");
496 print_bool(envelope->dmAmbiguousRecipient);
497 printf("\t\tdmType = %s\n", envelope->dmType);
499 printf("\t\tdmSenderOrgUnit = %s\n", envelope->dmSenderOrgUnit);
500 printf("\t\tdmSenderOrgUnitNum = ");
501 print_longint(envelope->dmSenderOrgUnitNum);
502 printf("\t\tdbIDRecipient = %s\n", envelope->dbIDRecipient);
503 printf("\t\tdmRecipientOrgUnit = %s\n", envelope->dmRecipientOrgUnit);
504 printf("\t\tdmRecipientOrgUnitNum = ");
505 print_longint(envelope->dmRecipientOrgUnitNum);
506 printf("\t\tdmToHands = %s\n", envelope->dmToHands);
507 printf("\t\tdmAnnotation = %s\n", envelope->dmAnnotation);
508 printf("\t\tdmRecipientRefNumber = %s\n", envelope->dmRecipientRefNumber);
509 printf("\t\tdmSenderRefNumber = %s\n", envelope->dmSenderRefNumber);
510 printf("\t\tdmRecipientIdent = %s\n", envelope->dmRecipientIdent);
511 printf("\t\tdmSenderIdent = %s\n", envelope->dmSenderIdent);
513 printf("\t\tdmLegalTitleLaw = ");
514 print_longint(envelope->dmLegalTitleLaw);
515 printf("\t\tdmLegalTitleYear = ");
516 print_longint(envelope->dmLegalTitleYear);
517 printf("\t\tdmLegalTitleSect = %s\n", envelope->dmLegalTitleSect);
518 printf("\t\tdmLegalTitlePar = %s\n", envelope->dmLegalTitlePar);
519 printf("\t\tdmLegalTitlePoint = %s\n", envelope->dmLegalTitlePoint);
521 printf("\t\tdmPersonalDelivery = ");
522 print_bool(envelope->dmPersonalDelivery);
523 printf("\t\tdmAllowSubstDelivery = ");
524 print_bool(envelope->dmAllowSubstDelivery);
525 printf("\t\tdmOVM = ");
526 print_bool(envelope->dmOVM);
527 printf("\t\tdmPublishOwnID = ");
528 print_bool(envelope->dmPublishOwnID);
530 printf("\t\tdmOrdinal = ");
531 if (!envelope->dmOrdinal) printf("NULL\n");
532 else printf("%lu\n", *(envelope->dmOrdinal));
534 printf("\t\tdmMessageStatus = ");
535 print_dmMessageStatus(envelope->dmMessageStatus);
537 printf("\t\tdmAttachmentSize = ");
538 if (!envelope->dmAttachmentSize) printf("NULL\n");
539 else printf("%lu kB\n", *(envelope->dmAttachmentSize));
541 printf("\t\tdmDeliveryTime = ");
542 print_timeval(envelope->dmDeliveryTime);
544 printf("\t\tdmAcceptanceTime = ");
545 print_timeval(envelope->dmAcceptanceTime);
547 printf("\t\thash = ");
548 print_hash(envelope->hash);
550 printf("\t\ttimestamp = %p\n", envelope->timestamp);
551 printf("\t\ttimestamp_length = %zu\n", envelope->timestamp_length);
553 printf("\t\tevents = ");
554 print_events(envelope->events);
556 printf("\t}\n");
560 void print_document(const struct isds_document *document) {
561 printf("\t\tdocument = ");
563 if (!document) {
564 printf("NULL\n");
565 return;
567 printf("\{\n");
569 printf("\t\t\tis_xml = %u\n", !!document->is_xml);
570 printf("\t\t\txml_node_list = %p\n", document->xml_node_list);
572 printf("\t\t\tdata = %p\n", document->data);
573 printf("\t\t\tdata_length = %zu\n", document->data_length);
574 printf("\t\t\tdmMimeType = %s\n", document->dmMimeType);
576 printf("\t\t\tdmFileMetaType = ");
577 switch(document->dmFileMetaType) {
578 case FILEMETATYPE_MAIN: printf("MAIN\n"); break;
579 case FILEMETATYPE_ENCLOSURE: printf("ENCLOSURE\n"); break;
580 case FILEMETATYPE_SIGNATURE: printf("SIGNATURE\n"); break;
581 case FILEMETATYPE_META: printf("META\n"); break;
582 default: printf("<unknown type %d>\n", document->dmFileMetaType);
585 printf("\t\t\tdmFileGuid = %s\n", document->dmFileGuid);
586 printf("\t\t\tdmUpFileGuid = %s\n", document->dmUpFileGuid);
587 printf("\t\t\tdmFileDescr = %s\n", document->dmFileDescr);
588 printf("\t\t\tdmFormat = %s\n", document->dmFormat);
589 printf("\t\t}\n");
593 void print_documents(const struct isds_list *documents) {
594 const struct isds_list *item;
596 printf("\tdocuments = ");
598 if (!documents) {
599 printf("NULL\n");
600 return;
602 printf("{\n");
604 for (item = documents; item; item = item->next) {
605 print_document((struct isds_document *) (item->data));
608 printf("\t}\n");
612 void print_message(const struct isds_message *message) {
613 printf("message = ");
615 if (!message) {
616 printf("NULL\n");
617 return;
620 printf("{\n");
622 printf("\traw = %p\n", message->raw);
623 printf("\traw_length = %zu\n", message->raw_length);
624 printf("\traw_type = ");
625 print_raw_type(message->raw_type);
626 printf("\txml = %p\n", message->xml);
627 print_envelope(message->envelope);
628 print_documents(message->documents);
630 printf("}\n");
633 void print_copies(const struct isds_list *copies) {
634 const struct isds_list *item;
635 struct isds_message_copy *copy;
637 printf("Copies = ");
638 if (!copies) {
639 printf("<NULL>\n");
640 return;
643 printf("{\n");
644 for (item = copies; item; item = item->next) {
645 copy = (struct isds_message_copy *) item->data;
646 printf("\tCopy = ");
648 if (!copy)
649 printf("<NULL>\n");
650 else {
651 printf("{\n");
652 printf("\t\tdbIDRecipient = %s\n", copy->dbIDRecipient);
653 printf("\t\tdmRecipientOrgUnit = %s\n", copy->dmRecipientOrgUnit);
655 printf("\t\tdmRecipientOrgUnitNum = ");
656 if (copy->dmRecipientOrgUnitNum)
657 printf("%ld\n", *copy->dmRecipientOrgUnitNum);
658 else
659 printf("<NULL>\n");
660 printf("\t\tdmToHands = %s\n", copy->dmToHands);
662 printf("\t\terror = %s\n", isds_strerror(copy->error));
663 printf("\t\tdmStatus = %s\n", copy->dmStatus);
664 printf("\t\tdmID = %s\n", copy->dmID);
665 printf("\t}\n");
668 printf("}\n");
671 void print_message_status_change(
672 const struct isds_message_status_change *changed_status) {
673 printf("message_status_change = ");
675 if (!changed_status) {
676 printf("NULL\n");
677 return;
680 printf("{\n");
682 printf("\tdmID = %s\n", changed_status->dmID);
684 printf("\tdmMessageStatus = ");
685 print_dmMessageStatus(changed_status->dmMessageStatus);
687 printf("\ttime = ");
688 print_timeval(changed_status->time);
690 printf("}\n");
693 void compare_hashes(const struct isds_hash *hash1,
694 const struct isds_hash *hash2) {
695 isds_error err;
697 printf("Comparing hashes... ");
698 err = isds_hash_cmp(hash1, hash2);
699 if (err == IE_SUCCESS)
700 printf("Hashes equal\n");
701 else if
702 (err == IE_NOTEQUAL) printf("Hashes differ\n");
703 else
704 printf("isds_hash_cmp() failed: %s\n", isds_strerror(err));
708 int progressbar(double upload_total, double upload_current,
709 double download_total, double download_current,
710 void *data) {
712 printf("Progress: upload %0f/%0f, download %0f/%0f, data=%p\n",
713 upload_current, upload_total, download_current, download_total,
714 data);
715 if (data) {
716 printf("Aborting transfer...\n");
717 return 1;
719 return 0;
723 int mmap_file(const char *file, int *fd, void **buffer, size_t *length) {
724 struct stat file_info;
726 if (!file || !fd || !buffer || !length) return -1;
729 *fd = open(file, O_RDONLY);
730 if (*fd == -1) {
731 fprintf(stderr, "%s: Could not open file: %s\n", file, strerror(errno));
732 return -1;
735 if (-1 == fstat(*fd, &file_info)) {
736 fprintf(stderr, "%s: Could not get file size: %s\n", file,
737 strerror(errno));
738 close(*fd);
739 return -1;
741 if (file_info.st_size < 0) {
742 fprintf(stderr, "File `%s' has negative size: %" PRIdMAX "\n", file,
743 (intmax_t) file_info.st_size);
744 close(*fd);
745 return -1;
747 *length = file_info.st_size;
749 if (!*length) {
750 /* Empty region cannot be mmapped */
751 *buffer = NULL;
752 } else {
753 *buffer = mmap(NULL, *length, PROT_READ, MAP_PRIVATE, *fd, 0);
754 if (*buffer == MAP_FAILED) {
755 fprintf(stderr, "%s: Could not map file to memory: %s\n", file,
756 strerror(errno));
757 close(*fd);
758 return -1;
762 return 0;
766 int munmap_file(int fd, void *buffer, size_t length) {
767 int err = 0;
768 long int page_size = sysconf(_SC_PAGE_SIZE);
769 size_t pages = (length % page_size) ?
770 ((length / page_size) + 1) * page_size:
771 length;
773 if (length) {
774 err = munmap(buffer, pages);
775 if (err) {
776 fprintf(stderr,
777 "Could not unmap memory at %p and length %zu: %s\n",
778 buffer, pages, strerror(errno));
782 err = close(fd);
783 if (err) {
784 fprintf(stderr, "Could close file descriptor %d: %s\n", fd,
785 strerror(errno));
788 return err;
792 static int save_data_to_file(const char *file, const void *data,
793 const size_t length) {
794 int fd;
795 ssize_t written, left = length;
797 if (!file) return -1;
798 if (length > 0 && !data) return -1;
800 fd = open(file, O_WRONLY|O_TRUNC|O_CREAT, 0666);
801 if (fd == -1) {
802 fprintf(stderr, "%s: Could not open file for writing: %s\n",
803 file, strerror(errno));
804 return -1;
807 printf("Writing %zu bytes to file `%s'...\n", length, file);
808 while (left) {
809 written = write(fd, data + length - left, left);
810 if (written == -1) {
811 fprintf(stderr, "%s: Could not save file: %s\n",
812 file, strerror(errno));
813 close(fd);
814 return -1;
816 left-=written;
819 if (-1 == close(fd)) {
820 fprintf(stderr, "%s: Closing file failed: %s\n",
821 file, strerror(errno));
822 return -1;
825 printf("Done.\n");
826 return 0;
830 int save_data(const char *message, const void *data, const size_t length) {
831 if (message)
832 printf("%s\n", message);
833 return save_data_to_file("output", data, length);