specfold.c 48 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <structures.h>
  4. #include <tkglobals.h>
  5. #include <pnames.h>
  6. #include <filetype.h>
  7. #include <processno.h>
  8. #include <modeno.h>
  9. #include <arrays.h>
  10. #include <flags.h>
  11. #include <logic.h>
  12. #include <fmnts.h>
  13. /*
  14. * Copyright (c) 1983-2013 Trevor Wishart and Composers Desktop Project Ltd
  15. * http://www.trevorwishart.co.uk
  16. * http://www.composersdesktop.com
  17. *
  18. This file is part of the CDP System.
  19. The CDP System is free software; you can redistribute it
  20. and/or modify it under the terms of the GNU Lesser General Public
  21. License as published by the Free Software Foundation; either
  22. version 2.1 of the License, or (at your option) any later version.
  23. The CDP System is distributed in the hope that it will be useful,
  24. but WITHOUT ANY WARRANTY; without even the implied warranty of
  25. MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  26. GNU Lesser General Public License for more details.
  27. You should have received a copy of the GNU Lesser General Public
  28. License along with the CDP System; if not, write to the Free Software
  29. Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
  30. 02111-1307 USA
  31. *
  32. */
  33. #include <formants.h>
  34. #include <globcon.h>
  35. #include <cdpmain.h>
  36. #include <math.h>
  37. #include <mixxcon.h>
  38. #include <osbind.h>
  39. #include <standalone.h>
  40. #include <speccon.h>
  41. #include <ctype.h>
  42. #include <sfsys.h>
  43. #include <string.h>
  44. #include <srates.h>
  45. #ifdef unix
  46. #define round lround
  47. #endif
  48. #define searchsize rampbrksize
  49. char errstr[2400];
  50. int anal_infiles = 1;
  51. int sloom = 0;
  52. int sloombatch = 0;
  53. const char* cdp_version = "7.0.0";
  54. /* CDP LIBRARY FUNCTIONS TRANSFERRED HERE */
  55. static int set_param_data(aplptr ap, int special_data,int maxparamcnt,int paramcnt,char *paramlist);
  56. static int set_vflgs(aplptr ap,char *optflags,int optcnt,char *optlist,
  57. char *varflags,int vflagcnt, int vparamcnt,char *varlist);
  58. static int setup_parameter_storage_and_constants(int storage_cnt,dataptr dz);
  59. static int initialise_is_int_and_no_brk_constants(int storage_cnt,dataptr dz);
  60. static int mark_parameter_types(dataptr dz,aplptr ap);
  61. static int establish_application(dataptr dz);
  62. static int application_init(dataptr dz);
  63. static int initialise_vflags(dataptr dz);
  64. static int setup_input_param_defaultval_stores(int tipc,aplptr ap);
  65. static int setup_and_init_input_param_activity(dataptr dz,int tipc);
  66. static int get_tk_cmdline_word(int *cmdlinecnt,char ***cmdline,char *q);
  67. static int assign_file_data_storage(int infilecnt,dataptr dz);
  68. /* CDP LIB FUNCTION MODIFIED TO AVOID CALLING setup_particular_application() */
  69. static int parse_sloom_data(int argc,char *argv[],char ***cmdline,int *cmdlinecnt,dataptr dz);
  70. /* SIMPLIFICATION OF LIB FUNC TO APPLY TO JUST THIS FUNCTION */
  71. static int allocate_specfold_buffer(dataptr dz);
  72. static int parse_infile_and_check_type(char **cmdline,dataptr dz);
  73. static int handle_the_outfile(int *cmdlinecnt,char ***cmdline,int is_launched,dataptr dz);
  74. static int setup_the_application(dataptr dz);
  75. static int setup_the_param_ranges_and_defaults(dataptr dz);
  76. static int check_the_param_validity_and_consistency(dataptr dz);
  77. static int get_the_process_no(char *prog_identifier_from_cmdline,dataptr dz);
  78. static int setup_and_init_input_brktable_constants(dataptr dz,int brkcnt);
  79. static int get_the_mode_from_cmdline(char *str,dataptr dz);
  80. /* BYPASS LIBRARY GLOBAL FUNCTION TO GO DIRECTLY TO SPECIFIC APPLIC FUNCTIONS */
  81. static int do_specfold(dataptr dz);
  82. static void doperm(int *perm,int permlen,dataptr dz);
  83. static void hinsert(int m,int t,int *perm,int permlen);
  84. static void hprefix(int m,int *perm,int permlen);
  85. static void hshuflup(int k,int *perm,int permlen);
  86. /**************************************** MAIN *********************************************/
  87. int main(int argc,char *argv[])
  88. {
  89. int exit_status;
  90. dataptr dz = NULL;
  91. char **cmdline = argv;
  92. int cmdlinecnt = argc;
  93. aplptr ap;
  94. int is_launched = FALSE;
  95. if(argc==2 && (strcmp(argv[1],"--version") == 0)) {
  96. fprintf(stdout,"%s\n",cdp_version);
  97. fflush(stdout);
  98. return 0;
  99. }
  100. /* CHECK FOR SOUNDLOOM */
  101. if((sloom = sound_loom_in_use(&argc,&argv)) > 1) {
  102. sloom = 0;
  103. sloombatch = 1;
  104. }
  105. if(sflinit("cdp")){
  106. sfperror("cdp: initialisation\n");
  107. return(FAILED);
  108. }
  109. /* SET UP THE PRINCIPLE DATASTRUCTURE */
  110. if((exit_status = establish_datastructure(&dz))<0) { // CDP LIB
  111. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  112. return(FAILED);
  113. }
  114. if(!sloom) {
  115. if(argc == 1) {
  116. usage1();
  117. return(FAILED);
  118. } else if(argc == 2) {
  119. usage2(argv[1]);
  120. return(FAILED);
  121. }
  122. if((exit_status = make_initial_cmdline_check(&argc,&argv))<0) { // CDP LIB
  123. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  124. return(FAILED);
  125. }
  126. cmdline = argv;
  127. cmdlinecnt = argc;
  128. if((get_the_process_no(argv[0],dz))<0)
  129. return(FAILED);
  130. cmdline++;
  131. cmdlinecnt--;
  132. dz->maxmode = 3;
  133. if((exit_status = get_the_mode_from_cmdline(cmdline[0],dz))<0) {
  134. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  135. return(exit_status);
  136. }
  137. cmdline++;
  138. cmdlinecnt--;
  139. if((exit_status = setup_the_application(dz))<0) {
  140. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  141. return(FAILED);
  142. }
  143. if((exit_status = count_and_allocate_for_infiles(cmdlinecnt,cmdline,dz))<0) { // CDP LIB
  144. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  145. return(FAILED);
  146. }
  147. } else {
  148. //parse_TK_data() =
  149. if((exit_status = parse_sloom_data(argc,argv,&cmdline,&cmdlinecnt,dz))<0) {
  150. exit_status = print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  151. return(exit_status);
  152. }
  153. }
  154. ap = dz->application;
  155. // parse_infile_and_hone_type() =
  156. if((exit_status = parse_infile_and_check_type(cmdline,dz))<0) {
  157. exit_status = print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  158. return(FAILED);
  159. }
  160. // setup_param_ranges_and_defaults() =
  161. if((exit_status = setup_the_param_ranges_and_defaults(dz))<0) {
  162. exit_status = print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  163. return(FAILED);
  164. }
  165. // open_first_infile CDP LIB
  166. if((exit_status = open_first_infile(cmdline[0],dz))<0) {
  167. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  168. return(FAILED);
  169. }
  170. cmdlinecnt--;
  171. cmdline++;
  172. if((exit_status = handle_the_outfile(&cmdlinecnt,&cmdline,is_launched,dz))<0) {
  173. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  174. return(FAILED);
  175. }
  176. // handle_formants() redundant
  177. // handle_formant_quiksearch() redundant
  178. // handle_special_data() redundant
  179. if((exit_status = read_parameters_and_flags(&cmdline,&cmdlinecnt,dz))<0) { // CDP LIB
  180. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  181. return(FAILED);
  182. }
  183. //allocate_large_buffers() ... replaced by CDP LIB
  184. dz->extra_bufcnt = 0;
  185. dz->bptrcnt = 4;
  186. if((exit_status = establish_spec_bufptrs_and_extra_buffers(dz))<0) {
  187. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  188. return(FAILED);
  189. }
  190. if((exit_status = allocate_specfold_buffer(dz))< 0) {
  191. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  192. return(FAILED);
  193. }
  194. //check_param_validity_and_consistency .....
  195. if((exit_status = check_the_param_validity_and_consistency(dz))<0) {
  196. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  197. return(FAILED);
  198. }
  199. is_launched = TRUE;
  200. //spec_process_file =
  201. if((exit_status = do_specfold(dz))< 0) {
  202. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  203. return(FAILED);
  204. }
  205. if((exit_status = complete_output(dz))<0) { // CDP LIB
  206. print_messages_and_close_sndfiles(exit_status,is_launched,dz);
  207. return(FAILED);
  208. }
  209. exit_status = print_messages_and_close_sndfiles(FINISHED,is_launched,dz); // CDP LIB
  210. free(dz);
  211. return(SUCCEEDED);
  212. }
  213. /**********************************************
  214. REPLACED CDP LIB FUNCTIONS
  215. **********************************************/
  216. /****************************** SET_PARAM_DATA *********************************/
  217. int set_param_data(aplptr ap, int special_data,int maxparamcnt,int paramcnt,char *paramlist)
  218. {
  219. ap->special_data = (char)special_data;
  220. ap->param_cnt = (char)paramcnt;
  221. ap->max_param_cnt = (char)maxparamcnt;
  222. if(ap->max_param_cnt>0) {
  223. if((ap->param_list = (char *)malloc((size_t)(ap->max_param_cnt+1)))==NULL) {
  224. sprintf(errstr,"INSUFFICIENT MEMORY: for param_list\n");
  225. return(MEMORY_ERROR);
  226. }
  227. strcpy(ap->param_list,paramlist);
  228. }
  229. return(FINISHED);
  230. }
  231. /****************************** SET_VFLGS *********************************/
  232. int set_vflgs
  233. (aplptr ap,char *optflags,int optcnt,char *optlist,char *varflags,int vflagcnt, int vparamcnt,char *varlist)
  234. {
  235. ap->option_cnt = (char) optcnt; /*RWD added cast */
  236. if(optcnt) {
  237. if((ap->option_list = (char *)malloc((size_t)(optcnt+1)))==NULL) {
  238. sprintf(errstr,"INSUFFICIENT MEMORY: for option_list\n");
  239. return(MEMORY_ERROR);
  240. }
  241. strcpy(ap->option_list,optlist);
  242. if((ap->option_flags = (char *)malloc((size_t)(optcnt+1)))==NULL) {
  243. sprintf(errstr,"INSUFFICIENT MEMORY: for option_flags\n");
  244. return(MEMORY_ERROR);
  245. }
  246. strcpy(ap->option_flags,optflags);
  247. }
  248. ap->vflag_cnt = (char) vflagcnt;
  249. ap->variant_param_cnt = (char) vparamcnt;
  250. if(vflagcnt) {
  251. if((ap->variant_list = (char *)malloc((size_t)(vflagcnt+1)))==NULL) {
  252. sprintf(errstr,"INSUFFICIENT MEMORY: for variant_list\n");
  253. return(MEMORY_ERROR);
  254. }
  255. strcpy(ap->variant_list,varlist);
  256. if((ap->variant_flags = (char *)malloc((size_t)(vflagcnt+1)))==NULL) {
  257. sprintf(errstr,"INSUFFICIENT MEMORY: for variant_flags\n");
  258. return(MEMORY_ERROR);
  259. }
  260. strcpy(ap->variant_flags,varflags);
  261. }
  262. return(FINISHED);
  263. }
  264. /***************************** APPLICATION_INIT **************************/
  265. int application_init(dataptr dz)
  266. {
  267. int exit_status;
  268. int storage_cnt;
  269. int tipc, brkcnt;
  270. aplptr ap = dz->application;
  271. if(ap->vflag_cnt>0)
  272. initialise_vflags(dz);
  273. tipc = ap->max_param_cnt + ap->option_cnt + ap->variant_param_cnt;
  274. ap->total_input_param_cnt = (char)tipc;
  275. if(tipc>0) {
  276. if((exit_status = setup_input_param_range_stores(tipc,ap))<0)
  277. return(exit_status);
  278. if((exit_status = setup_input_param_defaultval_stores(tipc,ap))<0)
  279. return(exit_status);
  280. if((exit_status = setup_and_init_input_param_activity(dz,tipc))<0)
  281. return(exit_status);
  282. }
  283. brkcnt = tipc;
  284. if(brkcnt>0) {
  285. if((exit_status = setup_and_init_input_brktable_constants(dz,brkcnt))<0)
  286. return(exit_status);
  287. }
  288. if((storage_cnt = tipc + ap->internal_param_cnt)>0) {
  289. if((exit_status = setup_parameter_storage_and_constants(storage_cnt,dz))<0)
  290. return(exit_status);
  291. if((exit_status = initialise_is_int_and_no_brk_constants(storage_cnt,dz))<0)
  292. return(exit_status);
  293. }
  294. if((exit_status = mark_parameter_types(dz,ap))<0)
  295. return(exit_status);
  296. // establish_infile_constants() replaced by
  297. dz->infilecnt = 1;
  298. //establish_bufptrs_and_extra_buffers():
  299. return FINISHED;
  300. }
  301. /******************************** SETUP_AND_INIT_INPUT_BRKTABLE_CONSTANTS ********************************/
  302. int setup_and_init_input_brktable_constants(dataptr dz,int brkcnt)
  303. {
  304. int n;
  305. if((dz->brk = (double **)malloc(brkcnt * sizeof(double *)))==NULL) {
  306. sprintf(errstr,"setup_and_init_input_brktable_constants(): 1\n");
  307. return(MEMORY_ERROR);
  308. }
  309. if((dz->brkptr = (double **)malloc(brkcnt * sizeof(double *)))==NULL) {
  310. sprintf(errstr,"setup_and_init_input_brktable_constants(): 6\n");
  311. return(MEMORY_ERROR);
  312. }
  313. if((dz->brksize = (int *)malloc(brkcnt * sizeof(int)))==NULL) {
  314. sprintf(errstr,"setup_and_init_input_brktable_constants(): 2\n");
  315. return(MEMORY_ERROR);
  316. }
  317. if((dz->firstval = (double *)malloc(brkcnt * sizeof(double)))==NULL) {
  318. sprintf(errstr,"setup_and_init_input_brktable_constants(): 3\n");
  319. return(MEMORY_ERROR);
  320. }
  321. if((dz->lastind = (double *)malloc(brkcnt * sizeof(double)))==NULL) {
  322. sprintf(errstr,"setup_and_init_input_brktable_constants(): 4\n");
  323. return(MEMORY_ERROR);
  324. }
  325. if((dz->lastval = (double *)malloc(brkcnt * sizeof(double)))==NULL) {
  326. sprintf(errstr,"setup_and_init_input_brktable_constants(): 5\n");
  327. return(MEMORY_ERROR);
  328. }
  329. if((dz->brkinit = (int *)malloc(brkcnt * sizeof(int)))==NULL) {
  330. sprintf(errstr,"setup_and_init_input_brktable_constants(): 7\n");
  331. return(MEMORY_ERROR);
  332. }
  333. for(n=0;n<brkcnt;n++) {
  334. dz->brk[n] = NULL;
  335. dz->brkptr[n] = NULL;
  336. dz->brkinit[n] = 0;
  337. dz->brksize[n] = 0;
  338. }
  339. return(FINISHED);
  340. }
  341. /********************** SETUP_PARAMETER_STORAGE_AND_CONSTANTS ********************/
  342. /* RWD mallo changed to calloc; helps debug verison run as release! */
  343. int setup_parameter_storage_and_constants(int storage_cnt,dataptr dz)
  344. {
  345. if((dz->param = (double *)calloc(storage_cnt, sizeof(double)))==NULL) {
  346. sprintf(errstr,"setup_parameter_storage_and_constants(): 1\n");
  347. return(MEMORY_ERROR);
  348. }
  349. if((dz->iparam = (int *)calloc(storage_cnt, sizeof(int) ))==NULL) {
  350. sprintf(errstr,"setup_parameter_storage_and_constants(): 2\n");
  351. return(MEMORY_ERROR);
  352. }
  353. if((dz->is_int = (char *)calloc(storage_cnt, sizeof(char)))==NULL) {
  354. sprintf(errstr,"setup_parameter_storage_and_constants(): 3\n");
  355. return(MEMORY_ERROR);
  356. }
  357. if((dz->no_brk = (char *)calloc(storage_cnt, sizeof(char)))==NULL) {
  358. sprintf(errstr,"setup_parameter_storage_and_constants(): 5\n");
  359. return(MEMORY_ERROR);
  360. }
  361. return(FINISHED);
  362. }
  363. /************** INITIALISE_IS_INT_AND_NO_BRK_CONSTANTS *****************/
  364. int initialise_is_int_and_no_brk_constants(int storage_cnt,dataptr dz)
  365. {
  366. int n;
  367. for(n=0;n<storage_cnt;n++) {
  368. dz->is_int[n] = (char)0;
  369. dz->no_brk[n] = (char)0;
  370. }
  371. return(FINISHED);
  372. }
  373. /***************************** MARK_PARAMETER_TYPES **************************/
  374. int mark_parameter_types(dataptr dz,aplptr ap)
  375. {
  376. int n, m; /* PARAMS */
  377. for(n=0;n<ap->max_param_cnt;n++) {
  378. switch(ap->param_list[n]) {
  379. case('0'): break; /* dz->is_active[n] = 0 is default */
  380. case('i'): dz->is_active[n] = (char)1; dz->is_int[n] = (char)1;dz->no_brk[n] = (char)1; break;
  381. case('I'): dz->is_active[n] = (char)1; dz->is_int[n] = (char)1; break;
  382. case('d'): dz->is_active[n] = (char)1; dz->no_brk[n] = (char)1; break;
  383. case('D'): dz->is_active[n] = (char)1; /* normal case: double val or brkpnt file */ break;
  384. default:
  385. sprintf(errstr,"Programming error: invalid parameter type in mark_parameter_types()\n");
  386. return(PROGRAM_ERROR);
  387. }
  388. } /* OPTIONS */
  389. for(n=0,m=ap->max_param_cnt;n<ap->option_cnt;n++,m++) {
  390. switch(ap->option_list[n]) {
  391. case('i'): dz->is_active[m] = (char)1; dz->is_int[m] = (char)1; dz->no_brk[m] = (char)1; break;
  392. case('I'): dz->is_active[m] = (char)1; dz->is_int[m] = (char)1; break;
  393. case('d'): dz->is_active[m] = (char)1; dz->no_brk[m] = (char)1; break;
  394. case('D'): dz->is_active[m] = (char)1; /* normal case: double val or brkpnt file */ break;
  395. default:
  396. sprintf(errstr,"Programming error: invalid option type in mark_parameter_types()\n");
  397. return(PROGRAM_ERROR);
  398. }
  399. } /* VARIANTS */
  400. for(n=0,m=ap->max_param_cnt + ap->option_cnt;n < ap->variant_param_cnt; n++, m++) {
  401. switch(ap->variant_list[n]) {
  402. case('0'): break;
  403. case('i'): dz->is_active[m] = (char)1; dz->is_int[m] = (char)1; dz->no_brk[m] = (char)1; break;
  404. case('I'): dz->is_active[m] = (char)1; dz->is_int[m] = (char)1; break;
  405. case('d'): dz->is_active[m] = (char)1; dz->no_brk[m] = (char)1; break;
  406. case('D'): dz->is_active[m] = (char)1; /* normal case: double val or brkpnt file */ break;
  407. default:
  408. sprintf(errstr,"Programming error: invalid variant type in mark_parameter_types()\n");
  409. return(PROGRAM_ERROR);
  410. }
  411. } /* INTERNAL */
  412. for(n=0,
  413. m=ap->max_param_cnt + ap->option_cnt + ap->variant_param_cnt; n<ap->internal_param_cnt; n++,m++) {
  414. switch(ap->internal_param_list[n]) {
  415. case('0'): break; /* dummy variables: variables not used: but important for internal paream numbering!! */
  416. case('i'): dz->is_int[m] = (char)1; dz->no_brk[m] = (char)1; break;
  417. case('d'): dz->no_brk[m] = (char)1; break;
  418. default:
  419. sprintf(errstr,"Programming error: invalid internal param type in mark_parameter_types()\n");
  420. return(PROGRAM_ERROR);
  421. }
  422. }
  423. return(FINISHED);
  424. }
  425. /***************************** HANDLE_THE_OUTFILE **************************/
  426. int handle_the_outfile(int *cmdlinecnt,char ***cmdline,int is_launched,dataptr dz)
  427. {
  428. int exit_status;
  429. char *filename = NULL;
  430. filename = (*cmdline)[0];
  431. strcpy(dz->outfilename,filename);
  432. if((exit_status = create_sized_outfile(filename,dz))<0)
  433. return(exit_status);
  434. (*cmdline)++;
  435. (*cmdlinecnt)--;
  436. return(FINISHED);
  437. }
  438. /***************************** ESTABLISH_APPLICATION **************************/
  439. int establish_application(dataptr dz)
  440. {
  441. aplptr ap;
  442. if((dz->application = (aplptr)malloc(sizeof (struct applic)))==NULL) {
  443. sprintf(errstr,"establish_application()\n");
  444. return(MEMORY_ERROR);
  445. }
  446. ap = dz->application;
  447. memset((char *)ap,0,sizeof(struct applic));
  448. return(FINISHED);
  449. }
  450. /************************* INITIALISE_VFLAGS *************************/
  451. int initialise_vflags(dataptr dz)
  452. {
  453. int n;
  454. if((dz->vflag = (char *)malloc(dz->application->vflag_cnt * sizeof(char)))==NULL) {
  455. sprintf(errstr,"INSUFFICIENT MEMORY: vflag store,\n");
  456. return(MEMORY_ERROR);
  457. }
  458. for(n=0;n<dz->application->vflag_cnt;n++)
  459. dz->vflag[n] = FALSE;
  460. return FINISHED;
  461. }
  462. /************************* SETUP_INPUT_PARAM_DEFAULTVALS *************************/
  463. int setup_input_param_defaultval_stores(int tipc,aplptr ap)
  464. {
  465. int n;
  466. if((ap->default_val = (double *)malloc(tipc * sizeof(double)))==NULL) {
  467. sprintf(errstr,"INSUFFICIENT MEMORY for application default values store\n");
  468. return(MEMORY_ERROR);
  469. }
  470. for(n=0;n<tipc;n++)
  471. ap->default_val[n] = 0.0;
  472. return(FINISHED);
  473. }
  474. /***************************** SETUP_AND_INIT_INPUT_PARAM_ACTIVITY **************************/
  475. int setup_and_init_input_param_activity(dataptr dz,int tipc)
  476. {
  477. int n;
  478. if((dz->is_active = (char *)malloc((size_t)tipc))==NULL) {
  479. sprintf(errstr,"setup_and_init_input_param_activity()\n");
  480. return(MEMORY_ERROR);
  481. }
  482. for(n=0;n<tipc;n++)
  483. dz->is_active[n] = (char)0;
  484. return(FINISHED);
  485. }
  486. /************************* SETUP_THE_APPLICATION *******************/
  487. int setup_the_application(dataptr dz)
  488. {
  489. int exit_status;
  490. aplptr ap;
  491. if((exit_status = establish_application(dz))<0) // GLOBAL
  492. return(FAILED);
  493. ap = dz->application;
  494. // SEE parstruct FOR EXPLANATION of next 2 functions
  495. switch(dz->mode) {
  496. case(0): //fall thro
  497. case(2): exit_status = set_param_data(ap,0,3,3,"iii"); break;
  498. case(1): exit_status = set_param_data(ap,0,3,2,"ii0"); break;
  499. }
  500. if(exit_status < 0)
  501. return(FAILED);
  502. if((exit_status = set_vflgs(ap,"",0,"","a",1,0,"0"))<0)
  503. return(FAILED);
  504. // set_legal_infile_structure -->
  505. dz->has_otherfile = FALSE;
  506. // assign_process_logic -->
  507. dz->input_data_type = ANALFILE_ONLY;
  508. dz->process_type = EQUAL_ANALFILE;
  509. dz->outfiletype = ANALFILE_OUT;
  510. dz->maxmode = 3;
  511. return application_init(dz); //GLOBAL
  512. }
  513. /************************* PARSE_INFILE_AND_CHECK_TYPE *******************/
  514. int parse_infile_and_check_type(char **cmdline,dataptr dz)
  515. {
  516. int exit_status;
  517. infileptr infile_info;
  518. if(!sloom) {
  519. if((infile_info = (infileptr)malloc(sizeof(struct filedata)))==NULL) {
  520. sprintf(errstr,"INSUFFICIENT MEMORY for infile structure to test file data.");
  521. return(MEMORY_ERROR);
  522. } else if((exit_status = cdparse(cmdline[0],infile_info))<0) {
  523. sprintf(errstr,"Failed tp parse input file %s\n",cmdline[0]);
  524. return(PROGRAM_ERROR);
  525. } else if(infile_info->filetype != ANALFILE) {
  526. sprintf(errstr,"File %s is not of correct type\n",cmdline[0]);
  527. return(DATA_ERROR);
  528. } else if((exit_status = copy_parse_info_to_main_structure(infile_info,dz))<0) {
  529. sprintf(errstr,"Failed to copy file parsing information\n");
  530. return(PROGRAM_ERROR);
  531. }
  532. free(infile_info);
  533. }
  534. dz->clength = dz->wanted / 2;
  535. dz->chwidth = dz->nyquist/(double)(dz->clength-1);
  536. dz->halfchwidth = dz->chwidth/2.0;
  537. return(FINISHED);
  538. }
  539. /************************* SETUP_THE_PARAM_RANGES_AND_DEFAULTS *******************/
  540. int setup_the_param_ranges_and_defaults(dataptr dz)
  541. {
  542. int exit_status;
  543. aplptr ap = dz->application;
  544. // set_param_ranges()
  545. ap->total_input_param_cnt = (char)(ap->max_param_cnt + ap->option_cnt + ap->variant_param_cnt);
  546. // NB total_input_param_cnt is > 0 !!!s
  547. if((exit_status = setup_input_param_range_stores(ap->total_input_param_cnt,ap))<0)
  548. return(FAILED);
  549. // get_param_ranges()
  550. ap->lo[0] = 1;
  551. ap->hi[0] = dz->clength - 4;
  552. ap->default_val[0] = 0;
  553. ap->lo[1] = 4;
  554. ap->hi[1] = dz->clength;
  555. ap->default_val[1] = dz->clength/2;
  556. switch(dz->mode) {
  557. case(0):
  558. ap->lo[2] = 1;
  559. ap->hi[2] = dz->clength;
  560. ap->default_val[2] = 1;
  561. break;
  562. case(2):
  563. ap->lo[2] = 1;
  564. ap->hi[2] = 64;
  565. ap->default_val[2] = 1;
  566. break;
  567. }
  568. dz->maxmode = 3;
  569. if(!sloom)
  570. put_default_vals_in_all_params(dz);
  571. return(FINISHED);
  572. }
  573. /********************************* PARSE_SLOOM_DATA *********************************/
  574. int parse_sloom_data(int argc,char *argv[],char ***cmdline,int *cmdlinecnt,dataptr dz)
  575. {
  576. int exit_status;
  577. int cnt = 1, infilecnt;
  578. int filesize, insams, inbrksize;
  579. double dummy;
  580. int true_cnt = 0;
  581. aplptr ap;
  582. while(cnt<=PRE_CMDLINE_DATACNT) {
  583. if(cnt > argc) {
  584. sprintf(errstr,"Insufficient data sent from TK\n");
  585. return(DATA_ERROR);
  586. }
  587. switch(cnt) {
  588. case(1):
  589. if(sscanf(argv[cnt],"%d",&dz->process)!=1) {
  590. sprintf(errstr,"Cannot read process no. sent from TK\n");
  591. return(DATA_ERROR);
  592. }
  593. break;
  594. case(2):
  595. if(sscanf(argv[cnt],"%d",&dz->mode)!=1) {
  596. sprintf(errstr,"Cannot read mode no. sent from TK\n");
  597. return(DATA_ERROR);
  598. }
  599. if(dz->mode > 0)
  600. dz->mode--;
  601. //setup_particular_application() =
  602. if((exit_status = setup_the_application(dz))<0)
  603. return(exit_status);
  604. ap = dz->application;
  605. break;
  606. case(3):
  607. if(sscanf(argv[cnt],"%d",&infilecnt)!=1) {
  608. sprintf(errstr,"Cannot read infilecnt sent from TK\n");
  609. return(DATA_ERROR);
  610. }
  611. if(infilecnt < 1) {
  612. true_cnt = cnt + 1;
  613. cnt = PRE_CMDLINE_DATACNT; /* force exit from loop after assign_file_data_storage */
  614. }
  615. if((exit_status = assign_file_data_storage(infilecnt,dz))<0)
  616. return(exit_status);
  617. break;
  618. case(INPUT_FILETYPE+4):
  619. if(sscanf(argv[cnt],"%d",&dz->infile->filetype)!=1) {
  620. sprintf(errstr,"Cannot read filetype sent from TK (%s)\n",argv[cnt]);
  621. return(DATA_ERROR);
  622. }
  623. break;
  624. case(INPUT_FILESIZE+4):
  625. if(sscanf(argv[cnt],"%d",&filesize)!=1) {
  626. sprintf(errstr,"Cannot read infilesize sent from TK\n");
  627. return(DATA_ERROR);
  628. }
  629. dz->insams[0] = filesize;
  630. break;
  631. case(INPUT_INSAMS+4):
  632. if(sscanf(argv[cnt],"%d",&insams)!=1) {
  633. sprintf(errstr,"Cannot read insams sent from TK\n");
  634. return(DATA_ERROR);
  635. }
  636. dz->insams[0] = insams;
  637. break;
  638. case(INPUT_SRATE+4):
  639. if(sscanf(argv[cnt],"%d",&dz->infile->srate)!=1) {
  640. sprintf(errstr,"Cannot read srate sent from TK\n");
  641. return(DATA_ERROR);
  642. }
  643. break;
  644. case(INPUT_CHANNELS+4):
  645. if(sscanf(argv[cnt],"%d",&dz->infile->channels)!=1) {
  646. sprintf(errstr,"Cannot read channels sent from TK\n");
  647. return(DATA_ERROR);
  648. }
  649. break;
  650. case(INPUT_STYPE+4):
  651. if(sscanf(argv[cnt],"%d",&dz->infile->stype)!=1) {
  652. sprintf(errstr,"Cannot read stype sent from TK\n");
  653. return(DATA_ERROR);
  654. }
  655. break;
  656. case(INPUT_ORIGSTYPE+4):
  657. if(sscanf(argv[cnt],"%d",&dz->infile->origstype)!=1) {
  658. sprintf(errstr,"Cannot read origstype sent from TK\n");
  659. return(DATA_ERROR);
  660. }
  661. break;
  662. case(INPUT_ORIGRATE+4):
  663. if(sscanf(argv[cnt],"%d",&dz->infile->origrate)!=1) {
  664. sprintf(errstr,"Cannot read origrate sent from TK\n");
  665. return(DATA_ERROR);
  666. }
  667. break;
  668. case(INPUT_MLEN+4):
  669. if(sscanf(argv[cnt],"%d",&dz->infile->Mlen)!=1) {
  670. sprintf(errstr,"Cannot read Mlen sent from TK\n");
  671. return(DATA_ERROR);
  672. }
  673. break;
  674. case(INPUT_DFAC+4):
  675. if(sscanf(argv[cnt],"%d",&dz->infile->Dfac)!=1) {
  676. sprintf(errstr,"Cannot read Dfac sent from TK\n");
  677. return(DATA_ERROR);
  678. }
  679. break;
  680. case(INPUT_ORIGCHANS+4):
  681. if(sscanf(argv[cnt],"%d",&dz->infile->origchans)!=1) {
  682. sprintf(errstr,"Cannot read origchans sent from TK\n");
  683. return(DATA_ERROR);
  684. }
  685. break;
  686. case(INPUT_SPECENVCNT+4):
  687. if(sscanf(argv[cnt],"%d",&dz->infile->specenvcnt)!=1) {
  688. sprintf(errstr,"Cannot read specenvcnt sent from TK\n");
  689. return(DATA_ERROR);
  690. }
  691. dz->specenvcnt = dz->infile->specenvcnt;
  692. break;
  693. case(INPUT_WANTED+4):
  694. if(sscanf(argv[cnt],"%d",&dz->wanted)!=1) {
  695. sprintf(errstr,"Cannot read wanted sent from TK\n");
  696. return(DATA_ERROR);
  697. }
  698. break;
  699. case(INPUT_WLENGTH+4):
  700. if(sscanf(argv[cnt],"%d",&dz->wlength)!=1) {
  701. sprintf(errstr,"Cannot read wlength sent from TK\n");
  702. return(DATA_ERROR);
  703. }
  704. break;
  705. case(INPUT_OUT_CHANS+4):
  706. if(sscanf(argv[cnt],"%d",&dz->out_chans)!=1) {
  707. sprintf(errstr,"Cannot read out_chans sent from TK\n");
  708. return(DATA_ERROR);
  709. }
  710. break;
  711. /* RWD these chanegs to samps - tk will have to deal with that! */
  712. case(INPUT_DESCRIPTOR_BYTES+4):
  713. if(sscanf(argv[cnt],"%d",&dz->descriptor_samps)!=1) {
  714. sprintf(errstr,"Cannot read descriptor_samps sent from TK\n");
  715. return(DATA_ERROR);
  716. }
  717. break;
  718. case(INPUT_IS_TRANSPOS+4):
  719. if(sscanf(argv[cnt],"%d",&dz->is_transpos)!=1) {
  720. sprintf(errstr,"Cannot read is_transpos sent from TK\n");
  721. return(DATA_ERROR);
  722. }
  723. break;
  724. case(INPUT_COULD_BE_TRANSPOS+4):
  725. if(sscanf(argv[cnt],"%d",&dz->could_be_transpos)!=1) {
  726. sprintf(errstr,"Cannot read could_be_transpos sent from TK\n");
  727. return(DATA_ERROR);
  728. }
  729. break;
  730. case(INPUT_COULD_BE_PITCH+4):
  731. if(sscanf(argv[cnt],"%d",&dz->could_be_pitch)!=1) {
  732. sprintf(errstr,"Cannot read could_be_pitch sent from TK\n");
  733. return(DATA_ERROR);
  734. }
  735. break;
  736. case(INPUT_DIFFERENT_SRATES+4):
  737. if(sscanf(argv[cnt],"%d",&dz->different_srates)!=1) {
  738. sprintf(errstr,"Cannot read different_srates sent from TK\n");
  739. return(DATA_ERROR);
  740. }
  741. break;
  742. case(INPUT_DUPLICATE_SNDS+4):
  743. if(sscanf(argv[cnt],"%d",&dz->duplicate_snds)!=1) {
  744. sprintf(errstr,"Cannot read duplicate_snds sent from TK\n");
  745. return(DATA_ERROR);
  746. }
  747. break;
  748. case(INPUT_BRKSIZE+4):
  749. if(sscanf(argv[cnt],"%d",&inbrksize)!=1) {
  750. sprintf(errstr,"Cannot read brksize sent from TK\n");
  751. return(DATA_ERROR);
  752. }
  753. if(inbrksize > 0) {
  754. switch(dz->input_data_type) {
  755. case(WORDLIST_ONLY):
  756. break;
  757. case(PITCH_AND_PITCH):
  758. case(PITCH_AND_TRANSPOS):
  759. case(TRANSPOS_AND_TRANSPOS):
  760. dz->tempsize = inbrksize;
  761. break;
  762. case(BRKFILES_ONLY):
  763. case(UNRANGED_BRKFILE_ONLY):
  764. case(DB_BRKFILES_ONLY):
  765. case(ALL_FILES):
  766. case(ANY_NUMBER_OF_ANY_FILES):
  767. if(dz->extrabrkno < 0) {
  768. sprintf(errstr,"Storage location number for brktable not established by CDP.\n");
  769. return(DATA_ERROR);
  770. }
  771. if(dz->brksize == NULL) {
  772. sprintf(errstr,"CDP has not established storage space for input brktable.\n");
  773. return(PROGRAM_ERROR);
  774. }
  775. dz->brksize[dz->extrabrkno] = inbrksize;
  776. break;
  777. default:
  778. sprintf(errstr,"TK sent brktablesize > 0 for input_data_type [%d] not using brktables.\n",
  779. dz->input_data_type);
  780. return(PROGRAM_ERROR);
  781. }
  782. break;
  783. }
  784. break;
  785. case(INPUT_NUMSIZE+4):
  786. if(sscanf(argv[cnt],"%d",&dz->numsize)!=1) {
  787. sprintf(errstr,"Cannot read numsize sent from TK\n");
  788. return(DATA_ERROR);
  789. }
  790. break;
  791. case(INPUT_LINECNT+4):
  792. if(sscanf(argv[cnt],"%d",&dz->linecnt)!=1) {
  793. sprintf(errstr,"Cannot read linecnt sent from TK\n");
  794. return(DATA_ERROR);
  795. }
  796. break;
  797. case(INPUT_ALL_WORDS+4):
  798. if(sscanf(argv[cnt],"%d",&dz->all_words)!=1) {
  799. sprintf(errstr,"Cannot read all_words sent from TK\n");
  800. return(DATA_ERROR);
  801. }
  802. break;
  803. case(INPUT_ARATE+4):
  804. if(sscanf(argv[cnt],"%f",&dz->infile->arate)!=1) {
  805. sprintf(errstr,"Cannot read arate sent from TK\n");
  806. return(DATA_ERROR);
  807. }
  808. break;
  809. case(INPUT_FRAMETIME+4):
  810. if(sscanf(argv[cnt],"%lf",&dummy)!=1) {
  811. sprintf(errstr,"Cannot read frametime sent from TK\n");
  812. return(DATA_ERROR);
  813. }
  814. dz->frametime = (float)dummy;
  815. break;
  816. case(INPUT_WINDOW_SIZE+4):
  817. if(sscanf(argv[cnt],"%f",&dz->infile->window_size)!=1) {
  818. sprintf(errstr,"Cannot read window_size sent from TK\n");
  819. return(DATA_ERROR);
  820. }
  821. break;
  822. case(INPUT_NYQUIST+4):
  823. if(sscanf(argv[cnt],"%lf",&dz->nyquist)!=1) {
  824. sprintf(errstr,"Cannot read nyquist sent from TK\n");
  825. return(DATA_ERROR);
  826. }
  827. break;
  828. case(INPUT_DURATION+4):
  829. if(sscanf(argv[cnt],"%lf",&dz->duration)!=1) {
  830. sprintf(errstr,"Cannot read duration sent from TK\n");
  831. return(DATA_ERROR);
  832. }
  833. break;
  834. case(INPUT_MINBRK+4):
  835. if(sscanf(argv[cnt],"%lf",&dz->minbrk)!=1) {
  836. sprintf(errstr,"Cannot read minbrk sent from TK\n");
  837. return(DATA_ERROR);
  838. }
  839. break;
  840. case(INPUT_MAXBRK+4):
  841. if(sscanf(argv[cnt],"%lf",&dz->maxbrk)!=1) {
  842. sprintf(errstr,"Cannot read maxbrk sent from TK\n");
  843. return(DATA_ERROR);
  844. }
  845. break;
  846. case(INPUT_MINNUM+4):
  847. if(sscanf(argv[cnt],"%lf",&dz->minnum)!=1) {
  848. sprintf(errstr,"Cannot read minnum sent from TK\n");
  849. return(DATA_ERROR);
  850. }
  851. break;
  852. case(INPUT_MAXNUM+4):
  853. if(sscanf(argv[cnt],"%lf",&dz->maxnum)!=1) {
  854. sprintf(errstr,"Cannot read maxnum sent from TK\n");
  855. return(DATA_ERROR);
  856. }
  857. break;
  858. default:
  859. sprintf(errstr,"case switch item missing: parse_sloom_data()\n");
  860. return(PROGRAM_ERROR);
  861. }
  862. cnt++;
  863. }
  864. if(cnt!=PRE_CMDLINE_DATACNT+1) {
  865. sprintf(errstr,"Insufficient pre-cmdline params sent from TK\n");
  866. return(DATA_ERROR);
  867. }
  868. if(true_cnt)
  869. cnt = true_cnt;
  870. *cmdlinecnt = 0;
  871. while(cnt < argc) {
  872. if((exit_status = get_tk_cmdline_word(cmdlinecnt,cmdline,argv[cnt]))<0)
  873. return(exit_status);
  874. cnt++;
  875. }
  876. return(FINISHED);
  877. }
  878. /********************************* GET_TK_CMDLINE_WORD *********************************/
  879. int get_tk_cmdline_word(int *cmdlinecnt,char ***cmdline,char *q)
  880. {
  881. if(*cmdlinecnt==0) {
  882. if((*cmdline = (char **)malloc(sizeof(char *)))==NULL) {
  883. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline array.\n");
  884. return(MEMORY_ERROR);
  885. }
  886. } else {
  887. if((*cmdline = (char **)realloc(*cmdline,((*cmdlinecnt)+1) * sizeof(char *)))==NULL) {
  888. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline array.\n");
  889. return(MEMORY_ERROR);
  890. }
  891. }
  892. if(((*cmdline)[*cmdlinecnt] = (char *)malloc((strlen(q) + 1) * sizeof(char)))==NULL) {
  893. sprintf(errstr,"INSUFFICIENT MEMORY for TK cmdline item %d.\n",(*cmdlinecnt)+1);
  894. return(MEMORY_ERROR);
  895. }
  896. strcpy((*cmdline)[*cmdlinecnt],q);
  897. (*cmdlinecnt)++;
  898. return(FINISHED);
  899. }
  900. /****************************** ASSIGN_FILE_DATA_STORAGE *********************************/
  901. int assign_file_data_storage(int infilecnt,dataptr dz)
  902. {
  903. int exit_status;
  904. int no_sndfile_system_files = FALSE;
  905. dz->infilecnt = infilecnt;
  906. if((exit_status = allocate_filespace(dz))<0)
  907. return(exit_status);
  908. if(no_sndfile_system_files)
  909. dz->infilecnt = 0;
  910. return(FINISHED);
  911. }
  912. /*********************** CHECK_THE_PARAM_VALIDITY_AND_CONSISTENCY *********************/
  913. int check_the_param_validity_and_consistency(dataptr dz)
  914. {
  915. int n, i, j, k, m;
  916. int chan_offset, chans_to_process, half_fold, no_of_folds;
  917. float *chancentre = dz->flbufptr[2];
  918. dz->iparam[0]--; // Change from 1-N to 0-(N-1) counting-range
  919. if(dz->iparam[0] + dz->iparam[1] > dz->clength) {
  920. sprintf(errstr,"Top channel to modify (%d) beyond top of spectrum (%d)\n",dz->iparam[0] + dz->iparam[1],dz->clength - 1);
  921. return(DATA_ERROR);
  922. }
  923. if(dz->mode==0) {
  924. if(ODD(dz->iparam[1])) {
  925. sprintf(errstr,"number of channels to fold must be even.\n");
  926. return(DATA_ERROR);
  927. }
  928. if(dz->iparam[2] >= dz->iparam[1]) {
  929. sprintf(errstr,"Folding is greater than number of channels to fold.\n");
  930. return(DATA_ERROR);
  931. }
  932. }
  933. if((dz->iparray = (int **)malloc(2 * sizeof(int *)))==NULL) {
  934. sprintf(errstr,"INSUFFICIENT MEMORY for internal integer arrays.\n");
  935. return(MEMORY_ERROR);
  936. }
  937. if((dz->iparray[0] = (int *)malloc(dz->clength * sizeof(int)))==NULL) {
  938. sprintf(errstr,"INSUFFICIENT MEMORY for internal integer array 1.\n");
  939. return(MEMORY_ERROR);
  940. }
  941. if((dz->iparray[1] = (int *)malloc(dz->clength * sizeof(int)))==NULL) {
  942. sprintf(errstr,"INSUFFICIENT MEMORY for internal integer array 2.\n");
  943. return(MEMORY_ERROR);
  944. }
  945. chan_offset = dz->iparam[0];
  946. chans_to_process = dz->iparam[1];
  947. for(n=0;n<dz->clength;n++) { // Copy in all chan-nos (no perm)
  948. dz->iparray[0][n] = n; // and record centre-frq of all channels
  949. chancentre[n] = (float)(dz->chwidth * n);
  950. }
  951. switch(dz->mode) {
  952. case(0): // FOLD
  953. half_fold = chans_to_process/2;
  954. no_of_folds = dz->iparam[2];
  955. for(n=0;n<chans_to_process;n++) // Original foldable channels in order
  956. dz->iparray[0][chan_offset + n] = chan_offset + n;
  957. k = 0;
  958. j = 1; // Label the 2 arrays
  959. for(i = 0; i < no_of_folds;i++) {
  960. n = 0;
  961. m = 1;
  962. while(n < half_fold) { // Copy first half of channels, to alternate channels
  963. dz->iparray[j][chan_offset + m] = dz->iparray[k][chan_offset + n++];
  964. m += 2;
  965. }
  966. m = chans_to_process - 2; // Copy second half of channels, to alternate channels, reading downwards
  967. while(n < chans_to_process) {
  968. dz->iparray[j][chan_offset + m] = dz->iparray[k][chan_offset + n++];
  969. m -= 2;
  970. }
  971. if(k==1) { // Swap arrays
  972. k = 0;
  973. j = 1;
  974. } else {
  975. k = 1;
  976. j = 0;
  977. }
  978. }
  979. if(ODD(no_of_folds)) { // Ensure the result ends up in array[0]
  980. for(n=0;n<chans_to_process;n++)
  981. dz->iparray[0][chan_offset + n] = dz->iparray[1][chan_offset + n];
  982. }
  983. break;
  984. case(1): // INVERT
  985. for(n=0,m = chans_to_process-1;n<chans_to_process;n++,m--) // Invert selected channels
  986. dz->iparray[0][chan_offset + n] = chan_offset + m;
  987. break;
  988. case(2): // RANDOMISE
  989. srand((int)dz->iparam[2]); // Initialise random generator
  990. for(n=0;n<chans_to_process;n++) // Copy in all values (no perm)
  991. dz->iparray[0][n] = n; // Perm the appropriate range of values
  992. doperm(dz->iparray[1],chans_to_process,dz);
  993. for(n=0;n<chans_to_process;n++) // Copy to the to-be-permd channels, the permd_values (suitably offset)
  994. dz->iparray[0][n + chan_offset] = dz->iparray[1][n] + chan_offset;
  995. break;
  996. }
  997. return FINISHED;
  998. }
  999. /************************* redundant functions: to ensure libs compile OK *******************/
  1000. int assign_process_logic(dataptr dz)
  1001. {
  1002. return(FINISHED);
  1003. }
  1004. void set_legal_infile_structure(dataptr dz)
  1005. {}
  1006. int set_legal_internalparam_structure(int process,int mode,aplptr ap)
  1007. {
  1008. return(FINISHED);
  1009. }
  1010. int setup_internal_arrays_and_array_pointers(dataptr dz)
  1011. {
  1012. return(FINISHED);
  1013. }
  1014. int establish_bufptrs_and_extra_buffers(dataptr dz)
  1015. {
  1016. return(FINISHED);
  1017. }
  1018. int get_process_no(char *prog_identifier_from_cmdline,dataptr dz)
  1019. {
  1020. return(FINISHED);
  1021. }
  1022. int read_special_data(char *str,dataptr dz)
  1023. {
  1024. return(FINISHED);
  1025. }
  1026. int inner_loop
  1027. (int *peakscore,int *descnt,int *in_start_portion,int *least,int *pitchcnt,int windows_in_buf,dataptr dz)
  1028. {
  1029. return(FINISHED);
  1030. }
  1031. /********************************************************************************************/
  1032. int get_the_process_no(char *prog_identifier_from_cmdline,dataptr dz)
  1033. {
  1034. if (!strcmp(prog_identifier_from_cmdline,"specfold")) dz->process = SPECFOLD;
  1035. else {
  1036. fprintf(stderr,"Unknown program identification string '%s'\n",prog_identifier_from_cmdline);
  1037. return(USAGE_ONLY);
  1038. }
  1039. return(FINISHED);
  1040. }
  1041. /******************************** USAGE1 ********************************/
  1042. int usage1(void)
  1043. {
  1044. return usage2("specfold");
  1045. }
  1046. /******************************** USAGE2 ********************************/
  1047. int usage2(char *str)
  1048. {
  1049. if(!strcmp(str,"specfold")) {
  1050. fprintf(stdout,
  1051. "USAGE: specfold specfold 1 inanalfile outanalfile stt len cnt [-a]\n"
  1052. "USAGE: specfold specfold 2 inanalfile outanalfile stt len [-a]\n"
  1053. "USAGE: specfold specfold 3 inanalfile outanalfile stt len seed [-a]\n"
  1054. "\n"
  1055. "MODE 1 : Fold the spectrum.\n"
  1056. "\n"
  1057. "Channels in fold group are split into 2 equal sets of consective channels.\n"
  1058. "Values in first set are moved from channel N to channel 2N\n"
  1059. "Values in 2nd set are assigned to remaining channels, in descending order.\n"
  1060. "\n"
  1061. "MODE 2 : Invert the spectrum.\n"
  1062. "MODE 2 : Randomise the spectrum.\n"
  1063. "\n"
  1064. "STT Lowest spectrum channel to process.\n"
  1065. "LEN Number of channels to process (>= 4)\n"
  1066. " For Folding (Mode 1) this must be an even number.\n"
  1067. "CNT (Mode 1) Number of folds (less than \"len\").\n"
  1068. "SEED (Mode 3) Seed value sets a specific random perm of channels.\n"
  1069. "-a Process the amplitudes only.\n");
  1070. } else
  1071. fprintf(stdout,"Unknown option '%s'\n",str);
  1072. return(USAGE_ONLY);
  1073. }
  1074. int usage3(char *str1,char *str2)
  1075. {
  1076. fprintf(stderr,"Insufficient parameters on command line.\n");
  1077. return(USAGE_ONLY);
  1078. }
  1079. /**************************** DO_SPECFOLD ****************************/
  1080. int do_specfold(dataptr dz)
  1081. {
  1082. int exit_status, wc, windows_in_buf, cc, vc, newcc, newvc, chans_to_fold = dz->iparam[1], chan_offset = dz->iparam[0];
  1083. int chantop = chan_offset + chans_to_fold;
  1084. int *perm = dz->iparray[0];
  1085. float *newspec = dz->flbufptr[1], *chancentre = dz->flbufptr[1];
  1086. double frqoffset, newfrq;
  1087. int samps_read;
  1088. while((samps_read = fgetfbufEx(dz->bigfbuf, dz->buflen,dz->ifd[0],0)) > 0) {
  1089. if(samps_read < 0) {
  1090. sprintf(errstr,"Failed to read data from input file.\n");
  1091. return(SYSTEM_ERROR);
  1092. }
  1093. dz->flbufptr[0] = dz->bigfbuf;
  1094. windows_in_buf = samps_read/dz->wanted;
  1095. for(wc=0; wc<windows_in_buf; wc++, dz->total_windows++) {
  1096. for(cc=chan_offset,vc=chan_offset*2;cc < chantop;cc++,vc += 2) { // Fold spectrum into newspec
  1097. newcc = perm[cc];
  1098. newvc = newcc * 2; // Index of amplitude
  1099. if(dz->vflag[0]) {
  1100. frqoffset = dz->flbufptr[0][FREQ] - chancentre[cc];
  1101. newfrq = (float)(chancentre[newcc] + frqoffset);
  1102. if(newfrq >= dz->nyquist) { // Fold any nyquist overflow around 0
  1103. newfrq -= dz->nyquist;
  1104. newvc = 0;
  1105. }
  1106. newspec[newvc++] = dz->flbufptr[0][AMPP];
  1107. newspec[newvc] = (float)newfrq;
  1108. } else
  1109. newspec[newvc] = dz->flbufptr[0][AMPP];
  1110. }
  1111. for(cc=chan_offset,vc=chan_offset*2;cc < chantop;cc++,vc += 2) { // Copy newspec back into orig
  1112. dz->flbufptr[0][AMPP] = newspec[AMPP];
  1113. if(dz->vflag[0])
  1114. dz->flbufptr[0][FREQ] = newspec[FREQ];
  1115. }
  1116. dz->flbufptr[0] += dz->wanted;
  1117. }
  1118. if((exit_status = write_samps(dz->bigfbuf,windows_in_buf * dz->wanted,dz))<0)
  1119. return(exit_status);
  1120. }
  1121. return FINISHED;
  1122. }
  1123. /**************************** ALLOCATE_SPECFOLD_BUFFER ******************************/
  1124. //TW REVISED: buffers no longer multiples of secsize
  1125. int allocate_specfold_buffer(dataptr dz)
  1126. {
  1127. // int bigbufsize;
  1128. // int exit_status;
  1129. unsigned int buffersize;
  1130. if(dz->bptrcnt <= 0) {
  1131. sprintf(errstr,"bufptr not established in allocate_single_buffer()\n");
  1132. return(PROGRAM_ERROR);
  1133. }
  1134. buffersize = (dz->wanted) * BUF_MULTIPLIER;
  1135. dz->buflen = buffersize;
  1136. buffersize += 2 * dz->wanted; //Calculation buffer
  1137. if((dz->bigfbuf = (float*) malloc(buffersize * sizeof(float)))==NULL) {
  1138. sprintf(errstr,"INSUFFICIENT MEMORY for sound buffers.\n");
  1139. return(MEMORY_ERROR);
  1140. }
  1141. dz->big_fsize = dz->buflen;
  1142. dz->flbufptr[1] = dz->bigfbuf + dz->big_fsize;
  1143. dz->flbufptr[2] = dz->flbufptr[1] + dz->wanted;
  1144. dz->flbufptr[3] = dz->flbufptr[2] + dz->wanted;
  1145. return(FINISHED);
  1146. }
  1147. /********************************** DOPERM etc *******************************/
  1148. void doperm(int *perm,int permlen,dataptr dz)
  1149. {
  1150. int n, t;
  1151. for(n=0;n<permlen;n++) {
  1152. t = (int)floor(drand48() * (n+1));
  1153. if(t==n) {
  1154. hprefix(n,perm,permlen);
  1155. } else {
  1156. hinsert(n,t,perm,permlen);
  1157. }
  1158. }
  1159. }
  1160. void hinsert(int m,int t,int *perm,int permlen)
  1161. {
  1162. hshuflup(t+1,perm,permlen);
  1163. perm[t+1] = m;
  1164. }
  1165. void hprefix(int m,int *perm,int permlen)
  1166. {
  1167. hshuflup(0,perm,permlen);
  1168. perm[0] = m;
  1169. }
  1170. void hshuflup(int k,int *perm,int permlen)
  1171. {
  1172. int n, *i;
  1173. int z = permlen - 1;
  1174. i = perm+z;
  1175. for(n = z;n > k;n--) {
  1176. *i = *(i-1);
  1177. i--;
  1178. }
  1179. }
  1180. /****************************** GET_MODE *********************************/
  1181. int get_the_mode_from_cmdline(char *str,dataptr dz)
  1182. {
  1183. char temp[200], *p;
  1184. if(sscanf(str,"%s",temp)!=1) {
  1185. sprintf(errstr,"Cannot read mode of program.\n");
  1186. return(USAGE_ONLY);
  1187. }
  1188. p = temp + strlen(temp) - 1;
  1189. while(p >= temp) {
  1190. if(!isdigit(*p)) {
  1191. fprintf(stderr,"Invalid mode of program entered.\n");
  1192. return(USAGE_ONLY);
  1193. }
  1194. p--;
  1195. }
  1196. if(sscanf(str,"%d",&dz->mode)!=1) {
  1197. fprintf(stderr,"Cannot read mode of program.\n");
  1198. return(USAGE_ONLY);
  1199. }
  1200. if(dz->mode <= 0 || dz->mode > dz->maxmode) {
  1201. fprintf(stderr,"Program mode value [%d] is out of range [1 - %d].\n",dz->mode,dz->maxmode);
  1202. return(USAGE_ONLY);
  1203. }
  1204. dz->mode--; /* CHANGE TO INTERNAL REPRESENTATION OF MODE NO */
  1205. return(FINISHED);
  1206. }