Revision 59e008ed chunker_player/chunker_player.c
| chunker_player/chunker_player.c | ||
|---|---|---|
| 48 | 48 |
return -1; |
| 49 | 49 |
} |
| 50 | 50 |
|
| 51 |
void CheckForRepoAddress(char* Param)
|
|
| 51 |
int CheckForRepoAddress(char* Param)
|
|
| 52 | 52 |
{
|
| 53 |
int result = 0; |
|
| 54 |
/* |
|
| 53 | 55 |
char* pch; |
| 54 | 56 |
if(strncasecmp(Param,"repo_address=",13)==0) |
| 55 | 57 |
{
|
| 56 | 58 |
pch=strtok(Param+13,","); |
| 57 | 59 |
strncpy(RepoAddress,pch,2048); |
| 58 | 60 |
} |
| 61 |
*/ |
|
| 62 |
//strcpy(RepoAddress,"repo-wut.napa-wine.eu:9832"); |
|
| 63 |
strcpy(RepoAddress,"repository.disi.unitn.it:9832"); |
|
| 64 |
result = 1; |
|
| 65 |
|
|
| 66 |
return result; |
|
| 59 | 67 |
} |
| 60 | 68 |
|
| 61 | 69 |
void sigproc() |
| ... | ... | |
| 94 | 102 |
repoclient=NULL; |
| 95 | 103 |
LastTimeRepoPublish.tv_sec=0; |
| 96 | 104 |
LastTimeRepoPublish.tv_usec=0; |
| 105 |
eventbase = event_base_new(); |
|
| 97 | 106 |
napaInitLog(LOG_DEBUG, NULL, NULL); |
| 98 | 107 |
repInit("");
|
| 99 | 108 |
#endif |
| ... | ... | |
| 397 | 406 |
if(ScheduledChunkLosses) |
| 398 | 407 |
free(ScheduledChunkLosses); |
| 399 | 408 |
#endif |
| 409 |
|
|
| 410 |
#ifdef PSNR_PUBLICATION |
|
| 411 |
repClose(repoclient); |
|
| 412 |
event_base_free(eventbase); |
|
| 413 |
#endif |
|
| 400 | 414 |
return 0; |
| 401 | 415 |
} |
| 402 | 416 |
|
| ... | ... | |
| 591 | 605 |
// printf ("\tpch=%s\n",pch);
|
| 592 | 606 |
parameters_vector[par_count] = (char*) malloc(sizeof(char)*(strlen(pch)+1)); |
| 593 | 607 |
strcpy(parameters_vector[par_count], pch); |
| 594 |
// Find repo_address |
|
| 595 |
CheckForRepoAddress(parameters_vector[par_count]); |
|
| 596 | 608 |
pch = strtok (NULL, " "); |
| 597 | 609 |
par_count++; |
| 598 | 610 |
} |
| ... | ... | |
| 678 | 690 |
} |
| 679 | 691 |
#endif |
| 680 | 692 |
|
| 681 |
for(i=1; i<par_count; i++) |
|
| 682 |
free(parameters_vector[i]); |
|
| 683 |
|
|
| 684 | 693 |
#ifdef PSNR_PUBLICATION |
| 694 |
// Find repo_address |
|
| 695 |
if(CheckForRepoAddress(parameters_vector[par_count])) {
|
|
| 696 |
|
|
| 685 | 697 |
// Open Repository |
| 686 | 698 |
if(repoclient) |
| 687 | 699 |
repClose(repoclient); |
| ... | ... | |
| 689 | 701 |
|
| 690 | 702 |
repoclient = repOpen(RepoAddress,0); |
| 691 | 703 |
if (repoclient == NULL) |
| 692 |
fatal("Unable to initialize PSNR publication in repoclient %s", RepoAddress);
|
|
| 704 |
printf("Unable to initialize PSNR publication in repoclient %s\n", RepoAddress);
|
|
| 705 |
} |
|
| 706 |
else {
|
|
| 707 |
printf("Repository address not present in streames launch string. Publication disabled\n");
|
|
| 708 |
} |
|
| 693 | 709 |
#endif |
| 694 | 710 |
|
| 711 |
for(i=1; i<par_count; i++) |
|
| 712 |
free(parameters_vector[i]); |
|
| 713 |
|
|
| 695 | 714 |
// Read the Network ID |
| 696 | 715 |
int Error=true; |
| 697 | 716 |
char Line1[255], Line2[255]; |
Also available in: Unified diff