?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
Indentation fix, cleanup.
[AROS.git] / rom / filesys / console_handler / support.c
blob71bb66eb987fdede5209b38a60ddcc18f1ce4e3e
1 /*
2 Copyright © 1995-2015, The AROS Development Team. All rights reserved.
3 $Id$
4
5 Desc: Support functions for console handler.
6 Lang: english
7 */
8
9 /****************************************************************************************/
10
11 #define CYCLIC_HISTORY_WALK 0
12
13 /****************************************************************************************/
14
15 #include <proto/exec.h>
16 #include <exec/libraries.h>
17 #include <exec/resident.h>
18 #include <exec/memory.h>
19 #include <exec/io.h>
20 #include <exec/errors.h>
21 #include <exec/alerts.h>
22 #include <utility/tagitem.h>
23 #include <dos/exall.h>
24 #include <dos/dosasl.h>
25 #include <intuition/intuition.h>
26 #include <intuition/sghooks.h>
27 #include <proto/dos.h>
28 #include <proto/intuition.h>
29 #include <proto/input.h>
30 #include <devices/conunit.h>
31
32 #define SDEBUG 0
33 #define DEBUG 0
34 #include <aros/debug.h>
35
36 #include <string.h>
37 #include <stdio.h>
38 #include <ctype.h>
39
40 #include "con_handler_intern.h"
41 #include "support.h"
42 #include "completion.h"
43
44 #define ioReq(x) ((struct IORequest *)x)
45
46 void replypkt(struct DosPacket *dp, SIPTR res1)
47 {
48 struct MsgPort *mp;
49 struct Message *mn;
50
51 mp = dp->dp_Port;
52 mn = dp->dp_Link;
53 mn->mn_Node.ln_Name = (char*) dp;
54 dp->dp_Port = &((struct Process*) FindTask(NULL))->pr_MsgPort;
55 dp->dp_Res1 = res1;
56 PutMsg(mp, mn);
57 }
58 void replypkt2(struct DosPacket *dp, SIPTR res1, SIPTR res2)
59 {
60 dp->dp_Res2 = res2;
61 replypkt(dp, res1);
62 }
63
64
65 /******************************************************************************************/
66
67 static const UBYTE up_seq[] = { 'A' };
68 static const UBYTE down_seq[] = { 'B' };
69 static const UBYTE right_seq[] = { 'C' };
70 static const UBYTE left_seq[] = { 'D' };
71 static const UBYTE shift_up_seq[] = { 'T' };
72 static const UBYTE shift_down_seq[] = { 'S' };
73 static const UBYTE shift_right_seq[] = { ' ', '@' };
74 static const UBYTE shift_left_seq[] = { ' ', 'A' };
75 static const UBYTE shift_tab_seq[] = { 'Z' };
76 static const UBYTE help_seq[] = { '?', '~' };
77 static const UBYTE f1_seq[] = { '0', '~' };
78 static const UBYTE f2_seq[] = { '1', '~' };
79 static const UBYTE f3_seq[] = { '2', '~' };
80 static const UBYTE f4_seq[] = { '3', '~' };
81 static const UBYTE f5_seq[] = { '4', '~' };
82 static const UBYTE f6_seq[] = { '5', '~' };
83 static const UBYTE f7_seq[] = { '6', '~' };
84 static const UBYTE f8_seq[] = { '7', '~' };
85 static const UBYTE f9_seq[] = { '8', '~' };
86 static const UBYTE f10_seq[] = { '9', '~' };
87 static const UBYTE paste_seq[] = { '0', ' ', 'v' };
88 static const UBYTE f11_seq[] = { '2', '0', '~' };
89 static const UBYTE f12_seq[] = { '2', '1', '~' };
90 static const UBYTE shift_f1_seq[] = { '1', '0', '~' };
91 static const UBYTE shift_f2_seq[] = { '1', '1', '~' };
92 static const UBYTE shift_f3_seq[] = { '1', '2', '~' };
93 static const UBYTE shift_f4_seq[] = { '1', '3', '~' };
94 static const UBYTE shift_f5_seq[] = { '1', '4', '~' };
95 static const UBYTE shift_f6_seq[] = { '1', '5', '~' };
96 static const UBYTE shift_f7_seq[] = { '1', '6', '~' };
97 static const UBYTE shift_f8_seq[] = { '1', '7', '~' };
98 static const UBYTE shift_f9_seq[] = { '1', '8', '~' };
99 static const UBYTE shift_f10_seq[] = { '1', '9', '~' };
100 static const UBYTE shift_f11_seq[] = { '3', '0', '~' };
101 static const UBYTE shift_f12_seq[] = { '3', '1', '~' };
102 static const UBYTE insert_seq[] = { '4', '0', '~' };
103 static const UBYTE pageup_seq[] = { '4', '1', '~' };
104 static const UBYTE pagedown_seq[] = { '4', '2', '~' };
105 static const UBYTE pause_seq[] = { '4', '3', '~' };
106 static const UBYTE break_seq[] = { '5', '3', '~' };
107 static const UBYTE home_seq[] = { '4', '4', '~' };
108 static const UBYTE end_seq[] = { '4', '5', '~' };
109 static const UBYTE shift_insert_seq[] = { '5', '0', '~' };
110 static const UBYTE shift_pageup_seq[] = { '5', '1', '~' };
111 static const UBYTE shift_pagedown_seq[] = { '5', '2', '~' };
112 static const UBYTE shift_home_seq[] = { '5', '4', '~' };
113 static const UBYTE shift_end_seq[] = { '5', '5', '~' };
114
115 /* F11, F12, insert, pageup, pagedown, ... seq taken from
116 RKRM: Devices/Console/Reading from the Console Device/Information about the Input Stream */
117
118 static CONST struct csimatch
119 {
120 CONST UBYTE *seq;
121 WORD len;
122 WORD inp;
123 }
124 csimatchtable[] =
125 {
126 {up_seq , 1, INP_CURSORUP },
127 {down_seq , 1, INP_CURSORDOWN },
128 {right_seq , 1, INP_CURSORRIGHT },
129 {left_seq , 1, INP_CURSORLEFT },
130 {shift_up_seq , 1, INP_SHIFT_CURSORUP },
131 {shift_down_seq , 1, INP_SHIFT_CURSORDOWN },
132 {shift_right_seq , 2, INP_SHIFT_CURSORRIGHT },
133 {shift_left_seq , 2, INP_SHIFT_CURSORLEFT },
134 {shift_tab_seq , 1, INP_SHIFT_TAB },
135 {help_seq , 2, INP_HELP },
136 {f1_seq , 2, INP_F1 },
137 {f2_seq , 2, INP_F2 },
138 {f3_seq , 2, INP_F3 },
139 {f4_seq , 2, INP_F4 },
140 {f5_seq , 2, INP_F5 },
141 {f6_seq , 2, INP_F6 },
142 {f7_seq , 2, INP_F7 },
143 {f8_seq , 2, INP_F8 },
144 {f9_seq , 2, INP_F9 },
145 {f10_seq , 2, INP_F10 },
146 {f11_seq , 3, INP_F11 },
147 {f12_seq , 3, INP_F12 },
148 {shift_f1_seq , 3, INP_SHIFT_F1 },
149 {shift_f2_seq , 3, INP_SHIFT_F2 },
150 {shift_f3_seq , 3, INP_SHIFT_F3 },
151 {shift_f4_seq , 3, INP_SHIFT_F4 },
152 {shift_f5_seq , 3, INP_SHIFT_F5 },
153 {shift_f6_seq , 3, INP_SHIFT_F6 },
154 {shift_f7_seq , 3, INP_SHIFT_F7 },
155 {shift_f8_seq , 3, INP_SHIFT_F8 },
156 {shift_f9_seq , 3, INP_SHIFT_F9 },
157 {shift_f10_seq , 3, INP_SHIFT_F10 },
158 {shift_f11_seq , 3, INP_SHIFT_F11 },
159 {shift_f12_seq , 3, INP_SHIFT_F12 },
160 {insert_seq , 3, INP_INSERT },
161 {pageup_seq , 3, INP_PAGEUP },
162 {pagedown_seq , 3, INP_PAGEDOWN },
163 {pause_seq , 3, INP_PAUSE },
164 {break_seq , 3, INP_BREAK },
165 {home_seq , 3, INP_HOME },
166 {end_seq , 3, INP_END },
167 {shift_insert_seq , 3, INP_SHIFT_INSERT },
168 {shift_pageup_seq , 3, INP_SHIFT_PAGEUP },
169 {shift_pagedown_seq , 3, INP_SHIFT_PAGEDOWN },
170 {shift_home_seq , 3, INP_SHIFT_HOME },
171 {shift_end_seq , 3, INP_SHIFT_END },
172 {paste_seq , 3, INP_PASTE },
173 {0 , 0, 0 }
174 };
175
176
177 /******************************************************************************************/
178
179 static UBYTE hex2val(char c)
180 {
181 if (c >= '0' && c <= '9')
182 return c - '0';
183 c &= ~0x20;
184 return c - 'A' + 10;
185 }
186 /* strtoul() not used because it is much larger and uses .bss
187 * TODO: Sanity checks. */
188 static IPTR string2val(const char *s, WORD len)
189 {
190 IPTR v = 0;
191
192 if (s[0] == '0' && (s[1] == 'x' || s[1] == 'X'))
193 {
194 s += 2;
195 while (len-- > 0 && *s)
196 {
197 v <<= 4;
198 v |= hex2val(*s);
199 s++;
200 }
201 }
202 else
203 {
204 while (len-- > 0 && *s)
205 {
206 v *= 10;
207 v += *s - '0';
208 s++;
209 }
210 }
211 return v;
212 }
213
214 BOOL parse_filename(struct filehandle *fh, char *filename, struct NewWindow *nw)
215 {
216 char *param;
217 UBYTE c;
218 WORD paramid = 1;
219 LONG paramval = 0;
220 BOOL ok = TRUE, done = FALSE, paramok = FALSE;
221
222 ASSERT_VALID_PTR(fh);
223 ASSERT_VALID_PTR(nw);
224
225 param = filename;
226 ASSERT_VALID_PTR(param);
227
228 while (!done)
229 {
230 c = *filename++;
231
232 switch (c)
233 {
234 case '0':
235 case '1':
236 case '2':
237 case '3':
238 case '4':
239 case '5':
240 case '6':
241 case '7':
242 case '8':
243 case '9':
244 if (paramid <= 4)
245 {
246 paramval *= 10;
247 paramval += c - '0';
248 }
249 paramok = TRUE;
250 break;
251
252 case '\0':
253 done = TRUE;
254 /* fall through */
255
256 case '/':
257 if (paramok)
258 {
259 UWORD paramlen = filename - param - 1;
260
261 switch (paramid)
262 {
263 case 1:
264 nw->LeftEdge = paramval;
265 break;
266
267 case 2:
268 nw->TopEdge = paramval;
269 break;
270
271 case 3:
272 nw->Width = paramval;
273 break;
274
275 case 4:
276 nw->Height = paramval;
277 break;
278
279 case 5:
280 if ((fh->wintitle = AllocVec(paramlen + 1, MEMF_PUBLIC)))
281 {
282 CopyMem(param, fh->wintitle, paramlen);
283 fh->wintitle[paramlen] = '\0';
284 nw->Title = fh->wintitle;
285 }
286 break;
287
288 default:
289 if (!strnicmp(param, "WAIT", paramlen))
290 {
291 fh->flags |= FHFLG_WAIT;
292 }
293 else if (!strnicmp(param, "CLOSE", paramlen))
294 {
295 nw->Flags |= WFLG_CLOSEGADGET;
296 }
297 else if (!strnicmp(param, "NOCLOSE", paramlen))
298 {
299 nw->Flags &= ~WFLG_CLOSEGADGET;
300 }
301 else if (!strnicmp(param, "AUTO", paramlen))
302 {
303 fh->flags |= FHFLG_AUTO;
304 }
305 else if (!strnicmp(param, "INACTIVE", paramlen))
306 {
307 nw->Flags &= ~WFLG_ACTIVATE;
308 }
309 else if (!strnicmp(param, "NODEPTH", paramlen))
310 {
311 nw->Flags &= ~WFLG_DEPTHGADGET;
312 }
313 else if (!strnicmp(param, "NOSIZE", paramlen))
314 {
315 nw->Flags &= ~WFLG_SIZEGADGET;
316 }
317 else if (!strnicmp(param, "NODRAG", paramlen))
318 {
319 nw->Flags &= ~WFLG_DRAGBAR;
320 }
321 else if (!strnicmp(param, "NOBORDER", paramlen))
322 {
323 nw->Flags |= WFLG_BORDERLESS;
324 }
325 else if (!strnicmp(param, "BACKDROP", paramlen))
326 {
327 nw->Flags |= WFLG_BACKDROP;
328 nw->Flags &= ~(WFLG_DRAGBAR | WFLG_SIZEGADGET);
329 }
330 else if (!strnicmp(param, "SIMPLE", paramlen))
331 {
332 /* TODO */
333 }
334 else if (!strnicmp(param, "SMART", paramlen))
335 {
336 /* TODO */
337 }
338 else if (!strnicmp(param, "ALT", paramlen))
339 {
340 /* TODO: style "ALT30/30/200/200" */
341 }
342 else if (!strnicmp(param, "WINDOW", 6))
343 {
344 /* Do we need some sanity checks here? */
345 fh->otherwindow = (struct Window*) string2val(param + 6, paramlen - 6);
346 }
347 else if (!strnicmp(param, "SCREEN", 6))
348 {
349 if ((fh->screenname = AllocVec(paramlen - 5, MEMF_PUBLIC)))
350 {
351 CopyMem(param + 6, fh->screenname, paramlen - 6);
352 fh->screenname[paramlen - 6] = '\0';
353 }
354 }
355 else if (!strnicmp(param, "BOOT", paramlen)) /* Private parameter */
356 {
357 fh->flags |= FHFLG_BOOTCON;
358 }
359 break;
360
361 } /* switch(paramid) */
362
363 paramok = FALSE;
364
365 } /* if (paramok) */
366
367 paramval = 0;
368 paramid++;
369 param = filename;
370 break;
371
372 default:
373 if (paramid < 5)
374 {
375 done = TRUE;
376 ok = FALSE;
377 }
378 else
379 paramok = TRUE;
380 break;
381
382 } /* switch(c) */
383
384 } /* while (!done) */
385
386 return ok;
387 }
388
389 /******************************************************************************************/
390
391 void do_write(struct filehandle *fh, APTR data, ULONG length)
392 {
393 fh->conwriteio.io_Command = CMD_WRITE;
394 fh->conwriteio.io_Data = data;
395 fh->conwriteio.io_Length = length;
396
397 DoIO((struct IORequest *) &fh->conwriteio);
398 }
399
400 /******************************************************************************************/
401
402 void do_movecursor(struct filehandle *fh, UBYTE direction, UBYTE howmuch)
403 {
404 UBYTE seq[6]; /* 9B <N> <N> <N> <dir> <0> */
405 ULONG size;
406
407 if (howmuch > 0)
408 {
409 seq[0] = 0x9B;
410
411 if (howmuch == 1)
412 {
413 seq[1] = direction;
414 size = 2;
415 }
416 else
417 {
418 sprintf(&seq[1], "%d%c", howmuch, direction);
419 size = strlen(seq);
420 }
421
422 do_write(fh, seq, size);
423 }
424 }
425
426 /******************************************************************************************/
427
428 void do_cursorvisible(struct filehandle *fh, BOOL on)
429 {
430 UBYTE seq[4];
431 ULONG size = 0;
432
433 seq[size++] = 0x9B;
434 if (!on)
435 seq[size++] = '0';
436 seq[size++] = ' ';
437 seq[size++] = 'p';
438
439 do_write(fh, seq, size);
440 }
441
442 /******************************************************************************************/
443
444 void do_deletechar(struct filehandle *fh)
445 {
446 UBYTE seq[] =
447 { 0x9B, 'P' };
448
449 do_write(fh, seq, 2);
450 }
451
452 /******************************************************************************************/
453
454 void do_eraseinline(struct filehandle *fh)
455 {
456 UBYTE seq[] =
457 { 0x9B, 'K' };
458
459 do_write(fh, seq, 2);
460 }
461
462 /******************************************************************************************/
463
464 void do_eraseindisplay(struct filehandle *fh)
465 {
466 UBYTE seq[] =
467 { 0x9B, 'J' };
468
469 do_write(fh, seq, 2);
470 }
471 /******************************************************************************************/
472 static void copy_from_pastebuf(struct filehandle * fh)
473 {
474 if (fh->conbufferpos >= fh->conbuffersize && fh->pastebuffer && fh->pastebufferpos < fh->pastebuffersize)
475 {
476 ULONG len = CONSOLEBUFFER_SIZE;
477 ULONG pastelen = fh->pastebuffersize - fh->pastebufferpos;
478 if (pastelen < len)
479 len = pastelen;
480
481 D(bug("Copying %d bytes from paste buffer\n", len));
482
483 fh->conbufferpos = 0;
484 CopyMem(fh->pastebuffer + fh->pastebufferpos, &fh->consolebuffer, len);
485 fh->conbuffersize = len;
486 fh->pastebufferpos += len;
487 if (fh->pastebufferpos >= fh->pastebuffersize)
488 {
489 FreeMem(fh->pastebuffer, PASTEBUFSIZE);
490 fh->pastebuffer = 0;
491 }
492 }
493 }
494
495 WORD scan_input(struct filehandle *fh, UBYTE *buffer)
496 {
497 CONST
498 struct csimatch *match;
499 UBYTE c;
500 WORD result = INP_DONE;
501
502 copy_from_pastebuf(fh);
503
504 if (fh->conbufferpos < fh->conbuffersize)
505 {
506 c = fh->consolebuffer[fh->conbufferpos++];
507 D(bug("scan_input: check char %d\n", c));
508 switch (c)
509 {
510 case 3:
511 case 4:
512 case 5:
513 case 6:
514 result = INP_CTRL_C - 3 + (WORD) c;
515 break;
516
517 case 8:
518 /* FIXME: Ugh... Race condition, anyone? The qualifier might
519 have changed between the keypress and the time we do this */
520 if (PeekQualifier() & (IEQUALIFIER_LSHIFT | IEQUALIFIER_RSHIFT))
521 {
522 result = INP_SHIFT_BACKSPACE;
523 }
524 else
525 {
526 result = INP_BACKSPACE;
527 }
528 break;
529
530 case 9:
531 result = INP_TAB;
532 break;
533
534 case 10:
535 result = INP_LINEFEED;
536 break;
537
538 case 12: /* CTRL-L */
539 *buffer = c;
540 result = INP_ECHO_STRING;
541 break;
542
543 case 13:
544 result = INP_RETURN;
545 break;
546
547 case 127:
548 if (PeekQualifier() & (IEQUALIFIER_LSHIFT | IEQUALIFIER_RSHIFT))
549 {
550 result = INP_SHIFT_DELETE;
551 }
552 else
553 {
554 result = INP_DELETE;
555 }
556 break;
557
558 case 24:
559 result = INP_CONTROL_X;
560 break;
561
562 case 28: /* CTRL-\ */
563 result = INP_EOF;
564 break;
565
566 case 0x9B: /* CSI */
567 result = INP_UNKNOWN;
568
569 match = csimatchtable;
570 for (; match->seq; match++)
571 {
572 if (!strncmp(match->seq, &(fh->consolebuffer[fh->conbufferpos]), match->len))
573 {
574 result = match->inp;
575 fh->conbufferpos += match->len;
576 break;
577 }
578 }
579 break;
580
581 default:
582 /* normal keys */
583 *buffer = c;
584 result = INP_STRING;
585 break;
586
587 } /* switch(c) */
588
589 } /* if (fh->conbufferpos < fh->conbuffersize) */
590
591 D(bug("scan_input: result %d\n", result));
592
593 return result;
594 }
595
596 /******************************************************************************************/
597
598 void add_to_history(struct filehandle *fh)
599 {
600 BOOL add_to_history = FALSE;
601
602 fh->inputbuffer[fh->inputsize] = '\0';
603
604 /* Don't add emptry strings */
605 if (fh->inputbuffer[fh->inputstart] == '\0')
606 return;
607
608 if (fh->historysize == 0)
609 {
610 add_to_history = TRUE;
611 }
612 else
613 {
614 WORD old_historypos;
615
616 old_historypos = fh->historypos - 1;
617 if (old_historypos < 0)
618 old_historypos = fh->historysize - 1;
619
620 if (strcmp(&fh->inputbuffer[fh->inputstart], fh->historybuffer[old_historypos]))
621 {
622 /* add to history only if different from last history entry */
623
624 add_to_history = TRUE;
625 }
626 }
627
628 if (add_to_history)
629 {
630 if (fh->historysize < CMD_HISTORY_SIZE)
631 fh->historysize++;
632
633 strcpy(fh->historybuffer[fh->historypos], &fh->inputbuffer[fh->inputstart]);
634
635 fh->historypos++;
636 if (fh->historypos >= CMD_HISTORY_SIZE)
637 fh->historypos = 0;
638 }
639
640 fh->historyviewpos = fh->historypos;
641 }
642
643 /******************************************************************************************/
644
645 void history_walk(struct filehandle *fh, WORD inp)
646 {
647 if (fh->historysize)
648 {
649 #if !CYCLIC_HISTORY_WALK
650 BOOL walk_to_empty_string = FALSE;
651 #endif
652 WORD len;
653
654 switch (inp)
655 {
656 case INP_SHIFT_CURSORUP:
657 fh->historyviewpos = 0;
658 break;
659
660 case INP_SHIFT_CURSORDOWN:
661 fh->historyviewpos = fh->historysize - 1;
662 ;
663 break;
664
665 case INP_CURSORUP:
666 #if CYCLIC_HISTORY_WALK
667 fh->historyviewpos--;
668 if (fh->historyviewpos < 0) fh->historyviewpos = fh->historysize - 1;
669 #else
670 if (fh->historyviewpos != -1)
671 {
672 fh->historyviewpos--;
673 if (fh->historyviewpos < 0 && fh->historysize == CMD_HISTORY_SIZE)
674 fh->historyviewpos = CMD_HISTORY_SIZE - 1;
675 if (fh->historyviewpos == fh->historypos)
676 fh->historyviewpos = -1;
677 }
678 if (fh->historyviewpos == -1)
679 walk_to_empty_string = TRUE;
680 #endif
681 break;
682
683 case INP_CURSORDOWN:
684 #if CYCLIC_HISTORY_WALK
685 fh->historyviewpos++;
686 if (fh->historyviewpos >= fh->historysize) fh->historyviewpos = 0;
687 #else
688 if (fh->historyviewpos != fh->historypos)
689 {
690 if (fh->historyviewpos == -1 && fh->historysize == CMD_HISTORY_SIZE)
691 fh->historyviewpos = fh->historypos;
692 fh->historyviewpos = (fh->historyviewpos + 1) % CMD_HISTORY_SIZE;
693 }
694 if (fh->historyviewpos == fh->historypos)
695 walk_to_empty_string = TRUE;
696 #endif
697 break;
698 }
699
700 if (fh->inputpos > fh->inputstart)
701 {
702 do_movecursor(fh, CUR_LEFT, fh->inputpos - fh->inputstart);
703 }
704
705 do_eraseinline(fh);
706
707 fh->inputsize = fh->inputstart;
708 fh->inputpos = fh->inputstart;
709
710 #if !CYCLIC_HISTORY_WALK
711 if (!walk_to_empty_string)
712 {
713 #endif
714 len = strlen(fh->historybuffer[fh->historyviewpos]);
715 if (len > (INPUTBUFFER_SIZE - fh->inputstart))
716 {
717 len = INPUTBUFFER_SIZE - fh->inputstart;
718 }
719
720 if (len > 0)
721 {
722 CopyMem(fh->historybuffer[fh->historyviewpos], &fh->inputbuffer[fh->inputstart], len);
723
724 fh->inputsize += len;
725 fh->inputpos += len;
726
727 do_write(fh, &fh->inputbuffer[fh->inputstart], len);
728 }
729
730 #if !CYCLIC_HISTORY_WALK
731 } /* if (!walk_to_empty_string) */
732 #endif
733
734 } /* if (fh->historysize) */
735 }
736
737 /****************************************************************************************/
738
739 static const STRPTR CONCLIP_PORTNAME = "ConClip.rendezvous";
740
741 struct MyEditHookMsg
742 {
743 struct Message msg;
744 struct SGWork *sgw;
745 WORD code;
746 };
747
748 static void do_paste(struct filehandle * fh)
749 {
750 struct MsgPort replyport, *port;
751 struct SGWork sgw;
752 struct MyEditHookMsg msg;
753 struct StringInfo sinfo;
754
755 if (!(port = FindPort(CONCLIP_PORTNAME)))
756 {
757 D(bug("ConClip not running, but we got a ConClip paste request"));
758 return;
759 }
760
761 D(bug("PASTE REQUEST!\n"));
762
763 replyport.mp_Node.ln_Type = NT_MSGPORT;
764 replyport.mp_Node.ln_Name = NULL;
765 replyport.mp_Node.ln_Pri = 0;
766 replyport.mp_Flags = PA_SIGNAL;
767 replyport.mp_SigBit = SIGB_SINGLE;
768 replyport.mp_SigTask = FindTask(NULL);
769 NEWLIST(&replyport.mp_MsgList);
770
771 msg.msg.mn_Node.ln_Type = NT_MESSAGE;
772 msg.msg.mn_ReplyPort = &replyport;
773 msg.msg.mn_Length = sizeof(msg);
774
775 msg.code = 'V';
776 msg.sgw = &sgw;
777
778 /* FIXME: Ensure no fields are left uninitialized */
779
780 sgw.Gadget = 0;
781 sgw.WorkBuffer = AllocMem(PASTEBUFSIZE, MEMF_CLEAR | MEMF_ANY);
782 sgw.PrevBuffer = 0;
783 sgw.IEvent = 0;
784 sgw.Code = 'V';
785 sgw.Actions = 0;
786 sgw.LongInt = 0;
787 sgw.GadgetInfo = 0;
788 sgw.EditOp = EO_BIGCHANGE;
789 sgw.BufferPos = 0;
790 sgw.NumChars = 0;
791
792 /* ConClip only ever looks at MaxChars in StringInfo */
793 sinfo.MaxChars = PASTEBUFSIZE;
794 sgw.StringInfo = &sinfo;
795
796 SetSignal(0, SIGF_SINGLE);
797 PutMsg(port, &msg.msg);
798 WaitPort(&replyport);
799
800 D(bug("Pasting %d bytes\n", sgw.BufferPos));
801
802 if (fh->pastebuffer)
803 FreeMem(fh->pastebuffer, PASTEBUFSIZE);
804 fh->pastebuffer = sgw.WorkBuffer;
805 fh->pastebuffersize = sgw.BufferPos;
806 fh->pastebufferpos = 0;
807 }
808
809 /****************************************************************************************/
810
811 BOOL process_input(struct filehandle *fh)
812 {
813 UBYTE c;
814 WORD inp;
815 while ((inp = scan_input(fh, &c)) != INP_DONE)
816 {
817 D(bug("Input Code: %d\n", inp));
818
819 switch (inp)
820 {
821 case INP_CURSORLEFT:
822 if (fh->inputpos > fh->inputstart)
823 {
824 fh->inputpos--;
825 do_movecursor(fh, CUR_LEFT, 1);
826 }
827 break;
828
829 case INP_SHIFT_CURSORLEFT: /* move to beginning of line */
830 case INP_HOME:
831 if (fh->inputpos > fh->inputstart)
832 {
833 do_movecursor(fh, CUR_LEFT, fh->inputpos - fh->inputstart);
834 fh->inputpos = fh->inputstart;
835 }
836 break;
837
838 case INP_CURSORRIGHT:
839 if (fh->inputpos < fh->inputsize)
840 {
841 fh->inputpos++;
842 do_movecursor(fh, CUR_RIGHT, 1);
843 }
844 break;
845
846 case INP_SHIFT_CURSORRIGHT: /* move to end of line */
847 case INP_END:
848 if (fh->inputpos != fh->inputsize)
849 {
850 do_movecursor(fh, CUR_RIGHT, fh->inputsize - fh->inputpos);
851 fh->inputpos = fh->inputsize;
852 }
853 break;
854
855 case INP_CURSORUP: /* walk through cmd history */
856 case INP_CURSORDOWN:
857 case INP_SHIFT_CURSORUP:
858 case INP_SHIFT_CURSORDOWN:
859 history_walk(fh, inp);
860 break;
861
862 case INP_BACKSPACE:
863 if (fh->inputpos > fh->inputstart)
864 {
865 do_movecursor(fh, CUR_LEFT, 1);
866
867 if (fh->inputpos == fh->inputsize)
868 {
869 do_deletechar(fh);
870
871 fh->inputsize--;
872 fh->inputpos--;
873 }
874 else
875 {
876 WORD chars_right = fh->inputsize - fh->inputpos;
877
878 fh->inputsize--;
879 fh->inputpos--;
880
881 do_cursorvisible(fh, FALSE);
882 do_write(fh, &fh->inputbuffer[fh->inputpos + 1], chars_right);
883 do_deletechar(fh);
884 do_movecursor(fh, CUR_LEFT, chars_right);
885 do_cursorvisible(fh, TRUE);
886
887 memmove(&fh->inputbuffer[fh->inputpos], &fh->inputbuffer[fh->inputpos + 1], chars_right);
888
889 }
890 }
891 break;
892
893 case INP_SHIFT_BACKSPACE:
894 if (fh->inputpos > fh->inputstart)
895 {
896 do_movecursor(fh, CUR_LEFT, fh->inputpos - fh->inputstart);
897 if (fh->inputpos == fh->inputsize)
898 {
899 do_eraseinline(fh);
900
901 fh->inputpos = fh->inputsize = fh->inputstart;
902 }
903 else
904 {
905 WORD chars_right = fh->inputsize - fh->inputpos;
906
907 do_cursorvisible(fh, FALSE);
908 do_write(fh, &fh->inputbuffer[fh->inputpos], chars_right);
909 do_eraseinline(fh);
910 do_movecursor(fh, CUR_LEFT, chars_right);
911 do_cursorvisible(fh, TRUE);
912
913 memmove(&fh->inputbuffer[fh->inputstart], &fh->inputbuffer[fh->inputpos], chars_right);
914
915 fh->inputsize -= (fh->inputpos - fh->inputstart);
916 fh->inputpos = fh->inputstart;
917 }
918 }
919 break;
920
921 case INP_DELETE:
922 if (fh->inputpos < fh->inputsize)
923 {
924 fh->inputsize--;
925
926 if (fh->inputpos == fh->inputsize)
927 {
928 do_deletechar(fh);
929 }
930 else
931 {
932 WORD chars_right = fh->inputsize - fh->inputpos;
933
934 do_cursorvisible(fh, FALSE);
935 do_write(fh, &fh->inputbuffer[fh->inputpos + 1], chars_right);
936 do_deletechar(fh);
937 do_movecursor(fh, CUR_LEFT, chars_right);
938 do_cursorvisible(fh, TRUE);
939
940 memmove(&fh->inputbuffer[fh->inputpos], &fh->inputbuffer[fh->inputpos + 1], chars_right);
941 }
942 }
943 break;
944
945 case INP_SHIFT_DELETE:
946 if (fh->inputpos < fh->inputsize)
947 {
948 fh->inputsize = fh->inputpos;
949 do_eraseinline(fh);
950 }
951 break;
952
953 case INP_CONTROL_X:
954 if ((fh->inputsize - fh->inputstart) > 0)
955 {
956 if (fh->inputpos > fh->inputstart)
957 {
958 do_movecursor(fh, CUR_LEFT, fh->inputpos - fh->inputstart);
959 }
960 do_eraseinline(fh);
961
962 fh->inputpos = fh->inputsize = fh->inputstart;
963 }
964 break;
965
966 case INP_ECHO_STRING:
967 do_write(fh, &c, 1);
968 break;
969
970 case INP_STRING:
971 if (fh->inputsize < INPUTBUFFER_SIZE)
972 {
973 do_write(fh, &c, 1);
974
975 if (fh->inputpos == fh->inputsize)
976 {
977 fh->inputbuffer[fh->inputpos++] = c;
978 fh->inputsize++;
979 }
980 else
981 {
982 WORD chars_right = fh->inputsize - fh->inputpos;
983
984 do_cursorvisible(fh, FALSE);
985 do_write(fh, &fh->inputbuffer[fh->inputpos], chars_right);
986 do_movecursor(fh, CUR_LEFT, chars_right);
987 do_cursorvisible(fh, TRUE);
988
989 memmove(&fh->inputbuffer[fh->inputpos + 1], &fh->inputbuffer[fh->inputpos], chars_right);
990 fh->inputbuffer[fh->inputpos++] = c;
991 fh->inputsize++;
992 }
993 }
994 break;
995
996 case INP_EOF:
997 D(bug("[CON] Read EOF (window closing)\n"));
998
999 if (fh->flags & FHFLG_WAITFORCLOSE)
1000 return TRUE;
1001
1002 fh->flags |= FHFLG_EOF;
1003 if (fh->flags & FHFLG_AUTO && fh->window)
1004 {
1005 if (fh->flags & FHFLG_CONSOLEDEVICEOPEN)
1006 {
1007 /* Close the device, it will be re-opened if needed */
1008 CloseDevice((struct IORequest *) fh->conreadio);
1009 fh->flags &= ~FHFLG_CONSOLEDEVICEOPEN;
1010 }
1011 /* Only now close the window itself */
1012 CloseWindow(fh->window);
1013 fh->window = NULL;
1014 }
1015
1016 /* fall through */
1017
1018 case INP_RETURN:
1019 if (fh->inputsize < INPUTBUFFER_SIZE)
1020 {
1021 if (inp != INP_EOF)
1022 {
1023 c = '\n';
1024 do_write(fh, &c, 1);
1025 add_to_history(fh);
1026
1027 fh->inputbuffer[fh->inputsize++] = '\n';
1028 }
1029
1030 fh->inputstart = fh->inputsize;
1031 fh->inputpos = fh->inputstart;
1032
1033 if (fh->inputsize)
1034 HandlePendingReads(fh);
1035
1036 if ((fh->flags & FHFLG_EOF) && (fh->flags & FHFLG_READPENDING))
1037 {
1038 struct Message *msg = (struct Message*) RemHead((struct List *) &fh->pendingReads);
1039 struct DosPacket *dp = (struct DosPacket*) msg->mn_Node.ln_Name;
1040
1041 if (dp)
1042 {
1043 replypkt2(dp, 0, 0);
1044 fh->flags &= ~FHFLG_EOF;
1045 }
1046
1047 if (IsListEmpty(&fh->pendingReads))
1048 fh->flags &= ~FHFLG_READPENDING;
1049 }
1050
1051 } /* if (fh->inputsize < INPUTBUFFER_SIZE) */
1052 break;
1053
1054 case INP_LINEFEED:
1055 if (fh->inputsize < INPUTBUFFER_SIZE)
1056 {
1057 c = '\n';
1058 do_write(fh, &c, 1);
1059 add_to_history(fh);
1060
1061 fh->inputbuffer[fh->inputsize++] = c;
1062 fh->inputstart = fh->inputsize;
1063 fh->inputpos = fh->inputsize;
1064 }
1065 break;
1066
1067 case INP_CTRL_C:
1068 case INP_CTRL_D:
1069 case INP_CTRL_E:
1070 case INP_CTRL_F:
1071 if (fh->breaktask)
1072 {
1073 Signal(fh->breaktask, 1L << (12 + inp - INP_CTRL_C));
1074 }
1075 break;
1076
1077 case INP_TAB:
1078 Completion(fh, FALSE);
1079 break;
1080
1081 case INP_SHIFT_TAB:
1082 Completion(fh, TRUE);
1083 break;
1084
1085 case INP_PASTE:
1086 do_paste(fh);
1087 break;
1088
1089 } /* switch(inp) */
1090
1091 } /* while((inp = scan_input(fh, &c)) != INP_DONE) */
1092
1093 return FALSE;
1094 }
1095
1096 BOOL answer_write_request(struct filehandle *fh, struct DosPacket *dp)
1097 {
1098 UBYTE *buffer = (UBYTE*) dp->dp_Arg2;
1099 LONG length = dp->dp_Arg3;
1100
1101 #if RMB_FREEZES_OUTPUT
1102 struct Window *conwindow;
1103
1104 conwindow = ((struct ConUnit *) fh->conwriteio.io_Unit)->cu_Window;
1105
1106 while ((PeekQualifier() & IEQUALIFIER_RBUTTON) && conwindow && (conwindow == IntuitionBase->ActiveWindow))
1107 {
1108 Delay(2);
1109 }
1110 #endif
1111
1112 if ((dp->dp_Port->mp_Flags & PF_ACTION) == PA_SIGNAL && dp->dp_Port->mp_SigTask)
1113 {
1114 fh->lastwritetask = dp->dp_Port->mp_SigTask;
1115 }
1116
1117 do_write(fh, buffer, length);
1118 replypkt2(dp, length, 0);
1119
1120 return TRUE;
1121 }
1122
1123 void answer_read_request(struct filehandle *fh, struct DosPacket *dp, ULONG dp_Arg3)
1124 {
1125 ULONG readlen;
1126
1127 readlen = (fh->inputsize < dp_Arg3) ? fh->inputsize : dp_Arg3;
1128
1129 CopyMem(fh->inputbuffer, (UBYTE*) dp->dp_Arg2, readlen);
1130 CopyMem(fh->inputbuffer + readlen, fh->inputbuffer, fh->inputsize - readlen);
1131
1132 fh->inputsize -= readlen;
1133 fh->inputpos -= readlen;
1134 fh->inputstart -= readlen;
1135
1136 replypkt2(dp, readlen, 0);
1137 }
1138
1139 void HandlePendingReads(struct filehandle *fh)
1140 {
1141 if (fh->flags & FHFLG_READPENDING)
1142 {
1143 struct DosPacket *dp;
1144 struct Message *msg, *next_msg;
1145
1146 ForeachNodeSafe(&fh->pendingReads, msg, next_msg)
1147 {
1148 Remove((struct Node *) msg);
1149 dp = (struct DosPacket*) msg->mn_Node.ln_Name;
1150 answer_read_request(fh, dp, dp->dp_Arg3);
1151
1152 if (fh->inputsize == 0)
1153 break;
1154
1155 }
1156 if (IsListEmpty(&fh->pendingReads))
1157 fh->flags &= ~FHFLG_READPENDING;
1158 }
1159
1160 if (fh->inputsize)
1161 {
1162 fh->flags |= FHFLG_CANREAD;
1163 fh->canreadsize = fh->inputsize;
1164 }
1165 }
1166
1167 void con_read(struct filehandle *fh, struct DosPacket *dp)
1168 {
1169 if (fh->flags & FHFLG_CANREAD)
1170 {
1171 ULONG readlen = (fh->canreadsize < dp->dp_Arg3) ? fh->canreadsize : dp->dp_Arg3;
1172
1173 answer_read_request(fh, dp, readlen);
1174
1175 fh->canreadsize -= readlen;
1176 if (fh->canreadsize == 0)
1177 fh->flags &= ~FHFLG_CANREAD;
1178
1179 }
1180 else
1181 {
1182 if (fh->flags & FHFLG_EOF)
1183 {
1184 replypkt2(dp, 0, 0);
1185 fh->flags &= ~FHFLG_EOF;
1186 }
1187 else
1188 {
1189 AddTail((struct List *) &fh->pendingReads, (struct Node *) dp->dp_Link);
1190 fh->flags |= FHFLG_READPENDING;
1191 }
1192 }
1193 }
Mirror of AROS' svn.