search.c 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820
  1. /*
  2. * Copyright (c) 1983-2023 Trevor Wishart and Composers Desktop Project Ltd
  3. * http://www.trevorwishart.co.uk
  4. * http://www.composersdesktop.com
  5. *
  6. This file is part of the CDP System.
  7. The CDP System is free software; you can redistribute it
  8. and/or modify it under the terms of the GNU Lesser General Public
  9. License as published by the Free Software Foundation; either
  10. version 2.1 of the License, or (at your option) any later version.
  11. The CDP System is distributed in the hope that it will be useful,
  12. but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. GNU Lesser General Public License for more details.
  15. You should have received a copy of the GNU Lesser General Public
  16. License along with the CDP System; if not, write to the Free Software
  17. Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  18. 02111-1307 USA
  19. *
  20. */
  21. #include <stdio.h>
  22. #include <stdlib.h>
  23. #include <structures.h>
  24. #include <tkglobals.h>
  25. #include <pnames.h>
  26. #include <filetype.h>
  27. #include <processno.h>
  28. #include <modeno.h>
  29. #include <logic.h>
  30. #include <globcon.h>
  31. #include <cdpmain.h>
  32. #include <math.h>
  33. #include <mixxcon.h>
  34. #include <osbind.h>
  35. #include <standalone.h>
  36. #include <ctype.h>
  37. #include <sfsys.h>
  38. #include <string.h>
  39. #include <srates.h>
  40. #include <limits.h>
  41. #if defined unix || defined __GNUC__
  42. #define round(x) lround((x))
  43. #endif
  44. #ifndef HUGE
  45. #define HUGE 3.40282347e+38F
  46. #endif
  47. char errstr[2400];
  48. int anal_infiles = 1;
  49. int sloom = 0;
  50. int sloombatch = 0;
  51. const char* cdp_version = "7.1.0";
  52. //CDP LIB REPLACEMENTS
  53. static int setup_search_application(dataptr dz);
  54. static int parse_sloom_data(int argc,char *argv[],char ***cmdline,int *cmdlinecnt,dataptr dz);
  55. static int parse_infile_and_check_type(char **cmdline,dataptr dz);
  56. static int establish_application(dataptr dz);
  57. static int initialise_vflags(dataptr dz);
  58. static int assign_file_data_storage(int infilecnt,dataptr dz);
  59. static int get_tk_cmdline_word(int *cmdlinecnt,char ***cmdline,char *q);
  60. static int get_the_process_no(char *prog_identifier_from_cmdline,dataptr dz);
  61. static int search(dataptr dz);
  62. /**************************************** MAIN *********************************************/
  63. int main(int argc,char *argv[])
  64. {
  65. int exit_status;
  66. dataptr dz = NULL;
  67. char **cmdline;
  68. int cmdlinecnt;
  69. int n;
  70. //aplptr ap;
  71. int is_launched = FALSE;
  72. if(argc==2 && (strcmp(argv[1],"--version") == 0)) {
  73. fprintf(stdout,"%s\n",cdp_version);
  74. fflush(stdout);
  75. return 0;
  76. }
  77. /* CHECK FOR SOUNDLOOM */
  78. if((sloom = sound_loom_in_use(&argc,&argv)) > 1) {
  79. sloom = 0;
  80. sloombatch = 1;
  81. }
  82. if(sflinit("cdp")){
  83. sfperror("cdp: initialisation\n");
  84. return(FAILED);
  85. }
  86. /* SET UP THE PRINCIPLE DATASTRUCTURE */
  87. if((exit_status = establish_datastructure(&dz))<0) { // CDP LIB
  88. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  89. return(FAILED);
  90. }
  91. if(!sloom) {
  92. if(argc == 1) {
  93. usage1();
  94. return(FAILED);
  95. } else if(argc == 2) {
  96. usage2(argv[1]);
  97. return(FAILED);
  98. }
  99. }
  100. if(!sloom) {
  101. if((exit_status = make_initial_cmdline_check(&argc,&argv))<0) { // CDP LIB
  102. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  103. return(FAILED);
  104. }
  105. cmdline = argv;
  106. cmdlinecnt = argc;
  107. if((get_the_process_no(argv[0],dz))<0)
  108. return(FAILED);
  109. cmdline++;
  110. cmdlinecnt--;
  111. // setup_particular_application =
  112. if((exit_status = setup_search_application(dz))<0) {
  113. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  114. return(FAILED);
  115. }
  116. if((exit_status = count_and_allocate_for_infiles(cmdlinecnt,cmdline,dz))<0) { // CDP LIB
  117. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  118. return(FAILED);
  119. }
  120. } else {
  121. //parse_TK_data() =
  122. if((exit_status = parse_sloom_data(argc,argv,&cmdline,&cmdlinecnt,dz))<0) {
  123. exit_status = print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  124. return(exit_status);
  125. }
  126. }
  127. //ap = dz->application;
  128. // parse_infile_and_hone_type() =
  129. if((exit_status = parse_infile_and_check_type(cmdline,dz))<0) {
  130. exit_status = print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  131. return(FAILED);
  132. }
  133. // open_first_infile CDP LIB
  134. if((exit_status = open_first_infile(cmdline[0],dz))<0) {
  135. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  136. return(FAILED);
  137. }
  138. cmdlinecnt--;
  139. cmdline++;
  140. if((exit_status = handle_extra_infiles(&cmdline,&cmdlinecnt,dz))<0) {
  141. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  142. return(FAILED);
  143. }
  144. is_launched = TRUE;
  145. dz->bufcnt = 1;
  146. if((dz->sampbuf = (float **)malloc(sizeof(float *) * (dz->bufcnt+1)))==NULL) {
  147. sprintf(errstr,"INSUFFICIENT MEMORY establishing sample buffers.\n");
  148. return(MEMORY_ERROR);
  149. }
  150. if((dz->sbufptr = (float **)malloc(sizeof(float *) * dz->bufcnt))==NULL) {
  151. sprintf(errstr,"INSUFFICIENT MEMORY establishing sample buffer pointers.\n");
  152. return(MEMORY_ERROR);
  153. }
  154. for(n = 0;n <dz->bufcnt; n++)
  155. dz->sampbuf[n] = dz->sbufptr[n] = (float *)0;
  156. dz->sampbuf[n] = (float *)0;
  157. if((exit_status = create_sndbufs(dz))<0) { // CDP LIB
  158. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  159. return(FAILED);
  160. }
  161. //spec_process_file =
  162. if((exit_status = search(dz))<0) {
  163. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  164. return(FAILED);
  165. }
  166. if((exit_status = complete_output(dz))<0) { // CDP LIB
  167. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  168. return(FAILED);
  169. }
  170. exit_status = print_messages_and_close_sndfiles(FINISHED,is_launched,dz); // CDP LIB
  171. free(dz);
  172. return(SUCCEEDED);
  173. }
  174. /**********************************************
  175. REPLACED CDP LIB FUNCTIONS
  176. **********************************************/
  177. /****************************** SET_PARAM_DATA *********************************/
  178. int set_param_data(aplptr ap, int special_data,int maxparamcnt,int paramcnt,char *paramlist)
  179. {
  180. ap->special_data = (char)special_data;
  181. ap->param_cnt = (char)paramcnt;
  182. ap->max_param_cnt = (char)maxparamcnt;
  183. if(ap->max_param_cnt>0) {
  184. if((ap->param_list = (char *)malloc((size_t)(ap->max_param_cnt+1)))==NULL) {
  185. sprintf(errstr,"INSUFFICIENT MEMORY: for param_list\n");
  186. return(MEMORY_ERROR);
  187. }
  188. strcpy(ap->param_list,paramlist);
  189. }
  190. return(FINISHED);
  191. }
  192. /****************************** SET_VFLGS *********************************/
  193. int set_vflgs
  194. (aplptr ap,char *optflags,int optcnt,char *optlist,char *varflags,int vflagcnt, int vparamcnt,char *varlist)
  195. {
  196. ap->option_cnt = (char) optcnt; /*RWD added cast */
  197. if(optcnt) {
  198. if((ap->option_list = (char *)malloc((size_t)(optcnt+1)))==NULL) {
  199. sprintf(errstr,"INSUFFICIENT MEMORY: for option_list\n");
  200. return(MEMORY_ERROR);
  201. }
  202. strcpy(ap->option_list,optlist);
  203. if((ap->option_flags = (char *)malloc((size_t)(optcnt+1)))==NULL) {
  204. sprintf(errstr,"INSUFFICIENT MEMORY: for option_flags\n");
  205. return(MEMORY_ERROR);
  206. }
  207. strcpy(ap->option_flags,optflags);
  208. }
  209. ap->vflag_cnt = (char) vflagcnt;
  210. ap->variant_param_cnt = (char) vparamcnt;
  211. if(vflagcnt) {
  212. if((ap->variant_list = (char *)malloc((size_t)(vflagcnt+1)))==NULL) {
  213. sprintf(errstr,"INSUFFICIENT MEMORY: for variant_list\n");
  214. return(MEMORY_ERROR);
  215. }
  216. strcpy(ap->variant_list,varlist);
  217. if((ap->variant_flags = (char *)malloc((size_t)(vflagcnt+1)))==NULL) {
  218. sprintf(errstr,"INSUFFICIENT MEMORY: for variant_flags\n");
  219. return(MEMORY_ERROR);
  220. }
  221. strcpy(ap->variant_flags,varflags);
  222. }
  223. return(FINISHED);
  224. }
  225. /***************************** APPLICATION_INIT **************************/
  226. int application_init(dataptr dz)
  227. {
  228. int tipc;
  229. aplptr ap = dz->application;
  230. if(ap->vflag_cnt>0)
  231. initialise_vflags(dz);
  232. tipc = ap->max_param_cnt + ap->option_cnt + ap->variant_param_cnt;
  233. ap->total_input_param_cnt = (char)tipc;
  234. //THERE ARE NO INPUTFILE brktables USED IN THIS PROCESS
  235. dz->infilecnt = 1;
  236. //establish_bufptrs_and_extra_buffers():
  237. return(FINISHED);
  238. }
  239. /***************************** ESTABLISH_APPLICATION **************************/
  240. int establish_application(dataptr dz)
  241. {
  242. aplptr ap;
  243. if((dz->application = (aplptr)malloc(sizeof (struct applic)))==NULL) {
  244. sprintf(errstr,"establish_application()\n");
  245. return(MEMORY_ERROR);
  246. }
  247. ap = dz->application;
  248. memset((char *)ap,0,sizeof(struct applic));
  249. return(FINISHED);
  250. }
  251. /************************* INITIALISE_VFLAGS *************************/
  252. int initialise_vflags(dataptr dz)
  253. {
  254. int n;
  255. if((dz->vflag = (char *)malloc(dz->application->vflag_cnt * sizeof(char)))==NULL) {
  256. sprintf(errstr,"INSUFFICIENT MEMORY: vflag store,\n");
  257. return(MEMORY_ERROR);
  258. }
  259. for(n=0;n<dz->application->vflag_cnt;n++)
  260. dz->vflag[n] = FALSE;
  261. return FINISHED;
  262. }
  263. /************************* SETUP_SEARCH_APPLICATION *******************/
  264. int setup_search_application(dataptr dz)
  265. {
  266. int exit_status;
  267. aplptr ap;
  268. if((exit_status = establish_application(dz))<0) // GLOBAL
  269. return(FAILED);
  270. ap = dz->application;
  271. // SEE parstruct FOR EXPLANATION of next 2 functions
  272. if((exit_status = set_param_data(ap,0 ,0,0,""))<0)
  273. return(FAILED);
  274. if((exit_status = set_vflgs(ap,"",0,"","",0,0,""))<0)
  275. return(FAILED);
  276. // set_legal_infile_structure -->
  277. dz->has_otherfile = FALSE;
  278. // assign_process_logic -->
  279. dz->input_data_type = MANY_SNDFILES;
  280. dz->process_type = OTHER_PROCESS;
  281. dz->outfiletype = NO_OUTPUTFILE;
  282. return application_init(dz); //GLOBAL
  283. }
  284. /************************* PARSE_INFILE_AND_CHECK_TYPE *******************/
  285. int parse_infile_and_check_type(char **cmdline,dataptr dz)
  286. {
  287. int exit_status;
  288. infileptr infile_info;
  289. if(!sloom) {
  290. if((infile_info = (infileptr)malloc(sizeof(struct filedata)))==NULL) {
  291. sprintf(errstr,"INSUFFICIENT MEMORY for infile structure to test file data.");
  292. return(MEMORY_ERROR);
  293. } else if((exit_status = cdparse(cmdline[0],infile_info))<0) {
  294. sprintf(errstr,"Failed to parse input file %s\n",cmdline[0]);
  295. return(PROGRAM_ERROR);
  296. } else if(infile_info->filetype != SNDFILE) {
  297. sprintf(errstr,"File %s is not of correct type\n",cmdline[0]);
  298. return(DATA_ERROR);
  299. } else if((exit_status = copy_parse_info_to_main_structure(infile_info,dz))<0) {
  300. sprintf(errstr,"Failed to copy file parsing information\n");
  301. return(PROGRAM_ERROR);
  302. }
  303. free(infile_info);
  304. }
  305. return(FINISHED);
  306. }
  307. /********************************* PARSE_SLOOM_DATA *********************************/
  308. int parse_sloom_data(int argc,char *argv[],char ***cmdline,int *cmdlinecnt,dataptr dz)
  309. {
  310. int exit_status;
  311. int cnt = 1, infilecnt;
  312. int filesize, insams, inbrksize;
  313. double dummy;
  314. int true_cnt = 0;
  315. //aplptr ap;
  316. while(cnt<=PRE_CMDLINE_DATACNT) {
  317. if(cnt > argc) {
  318. sprintf(errstr,"Insufficient data sent from TK\n");
  319. return(DATA_ERROR);
  320. }
  321. switch(cnt) {
  322. case(1):
  323. if(sscanf(argv[cnt],"%d",&dz->process)!=1) {
  324. sprintf(errstr,"Cannot read process no. sent from TK\n");
  325. return(DATA_ERROR);
  326. }
  327. break;
  328. case(2):
  329. if(sscanf(argv[cnt],"%d",&dz->mode)!=1) {
  330. sprintf(errstr,"Cannot read mode no. sent from TK\n");
  331. return(DATA_ERROR);
  332. }
  333. if(dz->mode > 0)
  334. dz->mode--;
  335. //setup_particular_application() =
  336. if((exit_status = setup_search_application(dz))<0)
  337. return(exit_status);
  338. //ap = dz->application;
  339. break;
  340. case(3):
  341. if(sscanf(argv[cnt],"%d",&infilecnt)!=1) {
  342. sprintf(errstr,"Cannot read infilecnt sent from TK\n");
  343. return(DATA_ERROR);
  344. }
  345. if(infilecnt < 1) {
  346. true_cnt = cnt + 1;
  347. cnt = PRE_CMDLINE_DATACNT; /* force exit from loop after assign_file_data_storage */
  348. }
  349. if((exit_status = assign_file_data_storage(infilecnt,dz))<0)
  350. return(exit_status);
  351. break;
  352. case(INPUT_FILETYPE+4):
  353. if(sscanf(argv[cnt],"%d",&dz->infile->filetype)!=1) {
  354. sprintf(errstr,"Cannot read filetype sent from TK (%s)\n",argv[cnt]);
  355. return(DATA_ERROR);
  356. }
  357. break;
  358. case(INPUT_FILESIZE+4):
  359. if(sscanf(argv[cnt],"%d",&filesize)!=1) {
  360. sprintf(errstr,"Cannot read infilesize sent from TK\n");
  361. return(DATA_ERROR);
  362. }
  363. dz->insams[0] = filesize;
  364. break;
  365. case(INPUT_INSAMS+4):
  366. if(sscanf(argv[cnt],"%d",&insams)!=1) {
  367. sprintf(errstr,"Cannot read insams sent from TK\n");
  368. return(DATA_ERROR);
  369. }
  370. dz->insams[0] = insams;
  371. break;
  372. case(INPUT_SRATE+4):
  373. if(sscanf(argv[cnt],"%d",&dz->infile->srate)!=1) {
  374. sprintf(errstr,"Cannot read srate sent from TK\n");
  375. return(DATA_ERROR);
  376. }
  377. break;
  378. case(INPUT_CHANNELS+4):
  379. if(sscanf(argv[cnt],"%d",&dz->infile->channels)!=1) {
  380. sprintf(errstr,"Cannot read channels sent from TK\n");
  381. return(DATA_ERROR);
  382. }
  383. break;
  384. case(INPUT_STYPE+4):
  385. if(sscanf(argv[cnt],"%d",&dz->infile->stype)!=1) {
  386. sprintf(errstr,"Cannot read stype sent from TK\n");
  387. return(DATA_ERROR);
  388. }
  389. break;
  390. case(INPUT_ORIGSTYPE+4):
  391. if(sscanf(argv[cnt],"%d",&dz->infile->origstype)!=1) {
  392. sprintf(errstr,"Cannot read origstype sent from TK\n");
  393. return(DATA_ERROR);
  394. }
  395. break;
  396. case(INPUT_ORIGRATE+4):
  397. if(sscanf(argv[cnt],"%d",&dz->infile->origrate)!=1) {
  398. sprintf(errstr,"Cannot read origrate sent from TK\n");
  399. return(DATA_ERROR);
  400. }
  401. break;
  402. case(INPUT_MLEN+4):
  403. if(sscanf(argv[cnt],"%d",&dz->infile->Mlen)!=1) {
  404. sprintf(errstr,"Cannot read Mlen sent from TK\n");
  405. return(DATA_ERROR);
  406. }
  407. break;
  408. case(INPUT_DFAC+4):
  409. if(sscanf(argv[cnt],"%d",&dz->infile->Dfac)!=1) {
  410. sprintf(errstr,"Cannot read Dfac sent from TK\n");
  411. return(DATA_ERROR);
  412. }
  413. break;
  414. case(INPUT_ORIGCHANS+4):
  415. if(sscanf(argv[cnt],"%d",&dz->infile->origchans)!=1) {
  416. sprintf(errstr,"Cannot read origchans sent from TK\n");
  417. return(DATA_ERROR);
  418. }
  419. break;
  420. case(INPUT_SPECENVCNT+4):
  421. if(sscanf(argv[cnt],"%d",&dz->infile->specenvcnt)!=1) {
  422. sprintf(errstr,"Cannot read specenvcnt sent from TK\n");
  423. return(DATA_ERROR);
  424. }
  425. dz->specenvcnt = dz->infile->specenvcnt;
  426. break;
  427. case(INPUT_WANTED+4):
  428. if(sscanf(argv[cnt],"%d",&dz->wanted)!=1) {
  429. sprintf(errstr,"Cannot read wanted sent from TK\n");
  430. return(DATA_ERROR);
  431. }
  432. break;
  433. case(INPUT_WLENGTH+4):
  434. if(sscanf(argv[cnt],"%d",&dz->wlength)!=1) {
  435. sprintf(errstr,"Cannot read wlength sent from TK\n");
  436. return(DATA_ERROR);
  437. }
  438. break;
  439. case(INPUT_OUT_CHANS+4):
  440. if(sscanf(argv[cnt],"%d",&dz->out_chans)!=1) {
  441. sprintf(errstr,"Cannot read out_chans sent from TK\n");
  442. return(DATA_ERROR);
  443. }
  444. break;
  445. /* RWD these chanegs to samps - tk will have to deal with that! */
  446. case(INPUT_DESCRIPTOR_BYTES+4):
  447. if(sscanf(argv[cnt],"%d",&dz->descriptor_samps)!=1) {
  448. sprintf(errstr,"Cannot read descriptor_samps sent from TK\n");
  449. return(DATA_ERROR);
  450. }
  451. break;
  452. case(INPUT_IS_TRANSPOS+4):
  453. if(sscanf(argv[cnt],"%d",&dz->is_transpos)!=1) {
  454. sprintf(errstr,"Cannot read is_transpos sent from TK\n");
  455. return(DATA_ERROR);
  456. }
  457. break;
  458. case(INPUT_COULD_BE_TRANSPOS+4):
  459. if(sscanf(argv[cnt],"%d",&dz->could_be_transpos)!=1) {
  460. sprintf(errstr,"Cannot read could_be_transpos sent from TK\n");
  461. return(DATA_ERROR);
  462. }
  463. break;
  464. case(INPUT_COULD_BE_PITCH+4):
  465. if(sscanf(argv[cnt],"%d",&dz->could_be_pitch)!=1) {
  466. sprintf(errstr,"Cannot read could_be_pitch sent from TK\n");
  467. return(DATA_ERROR);
  468. }
  469. break;
  470. case(INPUT_DIFFERENT_SRATES+4):
  471. if(sscanf(argv[cnt],"%d",&dz->different_srates)!=1) {
  472. sprintf(errstr,"Cannot read different_srates sent from TK\n");
  473. return(DATA_ERROR);
  474. }
  475. break;
  476. case(INPUT_DUPLICATE_SNDS+4):
  477. if(sscanf(argv[cnt],"%d",&dz->duplicate_snds)!=1) {
  478. sprintf(errstr,"Cannot read duplicate_snds sent from TK\n");
  479. return(DATA_ERROR);
  480. }
  481. break;
  482. case(INPUT_BRKSIZE+4):
  483. if(sscanf(argv[cnt],"%d",&inbrksize)!=1) {
  484. sprintf(errstr,"Cannot read brksize sent from TK\n");
  485. return(DATA_ERROR);
  486. }
  487. if(inbrksize > 0) {
  488. switch(dz->input_data_type) {
  489. case(WORDLIST_ONLY):
  490. break;
  491. case(PITCH_AND_PITCH):
  492. case(PITCH_AND_TRANSPOS):
  493. case(TRANSPOS_AND_TRANSPOS):
  494. dz->tempsize = inbrksize;
  495. break;
  496. case(BRKFILES_ONLY):
  497. case(UNRANGED_BRKFILE_ONLY):
  498. case(DB_BRKFILES_ONLY):
  499. case(ALL_FILES):
  500. case(ANY_NUMBER_OF_ANY_FILES):
  501. if(dz->extrabrkno < 0) {
  502. sprintf(errstr,"Storage location number for brktable not established by CDP.\n");
  503. return(DATA_ERROR);
  504. }
  505. if(dz->brksize == NULL) {
  506. sprintf(errstr,"CDP has not established storage space for input brktable.\n");
  507. return(PROGRAM_ERROR);
  508. }
  509. dz->brksize[dz->extrabrkno] = inbrksize;
  510. break;
  511. default:
  512. sprintf(errstr,"TK sent brktablesize > 0 for input_data_type [%d] not using brktables.\n",
  513. dz->input_data_type);
  514. return(PROGRAM_ERROR);
  515. }
  516. break;
  517. }
  518. break;
  519. case(INPUT_NUMSIZE+4):
  520. if(sscanf(argv[cnt],"%d",&dz->numsize)!=1) {
  521. sprintf(errstr,"Cannot read numsize sent from TK\n");
  522. return(DATA_ERROR);
  523. }
  524. break;
  525. case(INPUT_LINECNT+4):
  526. if(sscanf(argv[cnt],"%d",&dz->linecnt)!=1) {
  527. sprintf(errstr,"Cannot read linecnt sent from TK\n");
  528. return(DATA_ERROR);
  529. }
  530. break;
  531. case(INPUT_ALL_WORDS+4):
  532. if(sscanf(argv[cnt],"%d",&dz->all_words)!=1) {
  533. sprintf(errstr,"Cannot read all_words sent from TK\n");
  534. return(DATA_ERROR);
  535. }
  536. break;
  537. case(INPUT_ARATE+4):
  538. if(sscanf(argv[cnt],"%f",&dz->infile->arate)!=1) {
  539. sprintf(errstr,"Cannot read arate sent from TK\n");
  540. return(DATA_ERROR);
  541. }
  542. break;
  543. case(INPUT_FRAMETIME+4):
  544. if(sscanf(argv[cnt],"%lf",&dummy)!=1) {
  545. sprintf(errstr,"Cannot read frametime sent from TK\n");
  546. return(DATA_ERROR);
  547. }
  548. dz->frametime = (float)dummy;
  549. break;
  550. case(INPUT_WINDOW_SIZE+4):
  551. if(sscanf(argv[cnt],"%f",&dz->infile->window_size)!=1) {
  552. sprintf(errstr,"Cannot read window_size sent from TK\n");
  553. return(DATA_ERROR);
  554. }
  555. break;
  556. case(INPUT_NYQUIST+4):
  557. if(sscanf(argv[cnt],"%lf",&dz->nyquist)!=1) {
  558. sprintf(errstr,"Cannot read nyquist sent from TK\n");
  559. return(DATA_ERROR);
  560. }
  561. break;
  562. case(INPUT_DURATION+4):
  563. if(sscanf(argv[cnt],"%lf",&dz->duration)!=1) {
  564. sprintf(errstr,"Cannot read duration sent from TK\n");
  565. return(DATA_ERROR);
  566. }
  567. break;
  568. case(INPUT_MINBRK+4):
  569. if(sscanf(argv[cnt],"%lf",&dz->minbrk)!=1) {
  570. sprintf(errstr,"Cannot read minbrk sent from TK\n");
  571. return(DATA_ERROR);
  572. }
  573. break;
  574. case(INPUT_MAXBRK+4):
  575. if(sscanf(argv[cnt],"%lf",&dz->maxbrk)!=1) {
  576. sprintf(errstr,"Cannot read maxbrk sent from TK\n");
  577. return(DATA_ERROR);
  578. }
  579. break;
  580. case(INPUT_MINNUM+4):
  581. if(sscanf(argv[cnt],"%lf",&dz->minnum)!=1) {
  582. sprintf(errstr,"Cannot read minnum sent from TK\n");
  583. return(DATA_ERROR);
  584. }
  585. break;
  586. case(INPUT_MAXNUM+4):
  587. if(sscanf(argv[cnt],"%lf",&dz->maxnum)!=1) {
  588. sprintf(errstr,"Cannot read maxnum sent from TK\n");
  589. return(DATA_ERROR);
  590. }
  591. break;
  592. default:
  593. sprintf(errstr,"case switch item missing: parse_sloom_data()\n");
  594. return(PROGRAM_ERROR);
  595. }
  596. cnt++;
  597. }
  598. if(cnt!=PRE_CMDLINE_DATACNT+1) {
  599. sprintf(errstr,"Insufficient pre-cmdline params sent from TK\n");
  600. return(DATA_ERROR);
  601. }
  602. if(true_cnt)
  603. cnt = true_cnt;
  604. *cmdlinecnt = 0;
  605. while(cnt < argc) {
  606. if((exit_status = get_tk_cmdline_word(cmdlinecnt,cmdline,argv[cnt]))<0)
  607. return(exit_status);
  608. cnt++;
  609. }
  610. return(FINISHED);
  611. }
  612. /********************************* GET_TK_CMDLINE_WORD *********************************/
  613. int get_tk_cmdline_word(int *cmdlinecnt,char ***cmdline,char *q)
  614. {
  615. if(*cmdlinecnt==0) {
  616. if((*cmdline = (char **)malloc(sizeof(char *)))==NULL) {
  617. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline array.\n");
  618. return(MEMORY_ERROR);
  619. }
  620. } else {
  621. if((*cmdline = (char **)realloc(*cmdline,((*cmdlinecnt)+1) * sizeof(char *)))==NULL) {
  622. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline array.\n");
  623. return(MEMORY_ERROR);
  624. }
  625. }
  626. if(((*cmdline)[*cmdlinecnt] = (char *)malloc((strlen(q) + 1) * sizeof(char)))==NULL) {
  627. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline item %d.\n",(*cmdlinecnt)+1);
  628. return(MEMORY_ERROR);
  629. }
  630. strcpy((*cmdline)[*cmdlinecnt],q);
  631. (*cmdlinecnt)++;
  632. return(FINISHED);
  633. }
  634. /****************************** ASSIGN_FILE_DATA_STORAGE *********************************/
  635. int assign_file_data_storage(int infilecnt,dataptr dz)
  636. {
  637. int exit_status;
  638. int no_sndfile_system_files = FALSE;
  639. dz->infilecnt = infilecnt;
  640. if((exit_status = allocate_filespace(dz))<0)
  641. return(exit_status);
  642. if(no_sndfile_system_files)
  643. dz->infilecnt = 0;
  644. return(FINISHED);
  645. }
  646. /************************* redundant functions: to ensure libs compile OK *******************/
  647. int assign_process_logic(dataptr dz)
  648. {
  649. return(FINISHED);
  650. }
  651. void set_legal_infile_structure(dataptr dz)
  652. {}
  653. int set_legal_internalparam_structure(int process,int mode,aplptr ap)
  654. {
  655. return(FINISHED);
  656. }
  657. int setup_internal_arrays_and_array_pointers(dataptr dz)
  658. {
  659. return(FINISHED);
  660. }
  661. int establish_bufptrs_and_extra_buffers(dataptr dz)
  662. {
  663. return(FINISHED);
  664. }
  665. int read_special_data(char *str,dataptr dz)
  666. {
  667. return(FINISHED);
  668. }
  669. int inner_loop
  670. (int *peakscore,int *descnt,int *in_start_portion,int *least,int *pitchcnt,int windows_in_buf,dataptr dz)
  671. {
  672. return(FINISHED);
  673. }
  674. int get_process_no(char *prog_identifier_from_cmdline,dataptr dz)
  675. {
  676. return(FINISHED);
  677. }
  678. /******************************** USAGE1 ********************************/
  679. int usage1(void)
  680. {
  681. usage2("sigstart");
  682. return(USAGE_ONLY);
  683. }
  684. /********************************************************************************************/
  685. int get_the_process_no(char *prog_identifier_from_cmdline,dataptr dz)
  686. {
  687. if(!strcmp(prog_identifier_from_cmdline,"sigstart")) dz->process = SEARCH;
  688. else {
  689. sprintf(errstr,"Unknown program identification string '%s'\n",prog_identifier_from_cmdline);
  690. return(USAGE_ONLY);
  691. }
  692. return(FINISHED);
  693. }
  694. /******************************** USAGE2 ********************************/
  695. int usage2(char *str)
  696. {
  697. if(!strcmp(str,"sigstart")) {
  698. fprintf(stderr,
  699. "USAGE:\n"
  700. "search sigstart infile1 [infile2 infile3 .....]\n"
  701. "\n"
  702. "Find earlist time at which there is signal in any of the infiles.\n");
  703. } else
  704. fprintf(stdout,"Unknown option '%s'\n",str);
  705. return(USAGE_ONLY);
  706. }
  707. int usage3(char *str1,char *str2)
  708. {
  709. return(FINISHED);
  710. }
  711. /******************************** SEARCH ********************************/
  712. int search(dataptr dz)
  713. {
  714. int chans = dz->infile->channels;
  715. double srate = dz->infile->srate;
  716. int fileno, n, done;
  717. int minsamps = INT_MAX, samptime, bufstart;
  718. float *ibuf = dz->sampbuf[0];
  719. for(fileno = 0; fileno <dz->infilecnt;fileno++) {
  720. reset_filedata_counters(dz);
  721. dz->samps_left = dz->insams[fileno];
  722. fprintf(stdout,"INFO: Processing FILE %d\n",fileno+1);
  723. done = 0;
  724. bufstart = 0;
  725. while(dz->samps_left) {
  726. if((dz->ssampsread = fgetfbufEx(ibuf, dz->buflen,dz->ifd[fileno],0)) < 0) {
  727. sprintf(errstr,"Can't read samples from input soundfile %d\n",fileno);
  728. return(SYSTEM_ERROR);
  729. }
  730. dz->samps_left -= dz->ssampsread;
  731. dz->total_samps_read += dz->ssampsread;
  732. for(n=0;n<dz->buflen;n++) {
  733. if(ibuf[n] > 0.0 || ibuf[n] < 0.0) {
  734. samptime = bufstart + n;
  735. minsamps = min(minsamps,samptime);
  736. done = 1;
  737. break;
  738. }
  739. }
  740. if(done)
  741. break;
  742. bufstart += dz->ssampsread;
  743. }
  744. if(sndcloseEx(dz->ifd[fileno]) < 0) {
  745. fprintf(stdout, "WARNING: Can't close input soundfile %d\n",fileno+1);
  746. fflush(stdout);
  747. }
  748. dz->ifd[fileno] = -1;
  749. }
  750. fprintf(stdout,"INFO: SIGNAL FIRST OCCURS AT %lf seconds\n",(double)(minsamps/chans)/srate);
  751. fflush(stdout);
  752. return FINISHED;
  753. }