You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In revision cb09f3e the example_distributed "proc2" program actually does NOT run the generated query -- it executes a "Pause" API call. Yet just the WSQ runtime itself causes the following problem on shutdown.
[newton@wasp ~/wavescript/apps/reuters/runtime/example_distributed] (master)$ WSQ_VERBOSE=2 ./proc2
<WSQ> WSQ_Init: Starting Scheme runtime system.
<WSQ> Loading WaveScope compiler, machine type ta6le... finished.
<WSQ> Loading runtime manager... finished.
<WSQ> Registering WSQ runtime interface with control module.
<WSQ> Bringing up WSQ runtime system (forking threads)...
<WSQ> Query output goes to stdout (not redirecting).
<WSQ> Returning to control module...
<WSQ> Query base name (used for .c/.exe) set to: "proc2query"
<WSQ> Pausing stream engine.
PAUSING WSQ engine, run compiled query manually...
<WSQ> WSQ_BeginTransaction 1001
<WSQ> WSQ_BeginSubgraph 101
<WSQ> WSQ_AddOp 20 "ConnectRemoteIn" in: out: 20 args: ("localhost" "9877" "bigint TIMESTAMP, string SYMBOL, bigint EXCHTIMESTAMP, bigint RECEIVEDTIME, double BID, double BIDSIZE, double ASK, double ASKSIZE")
<WSQ> WSQ_AddOp 21 "Printer" in: 20 out: args: ("NETSTRM:")
<WSQ> WSQ_EndSubgraph 101
<WSQ> WSQ_EndTransaction
>>> ASSEMBLED PROG:
((include
"/home/newton/wavescript/apps/reuters/runtime/wsqlib.ws")
(define edge_20
(assert-type
(Stream
(Record
(Row TIMESTAMP
Int64
(Row SYMBOL
String
(Row EXCHTIMESTAMP
Int64
(Row RECEIVEDTIME
Int64
(Row BID
Double
(Row BIDSIZE
Double
(Row ASK Double (Row ASKSIZE Double '_rowvar_461))))))))))
(app wsq_connect_in "localhost" 9877)))
(define ignored_462 (app wsq_printer "NETSTRM: " edge_20))
(define main (assert-type (Stream #()) ignored_462)))
<WSQ> Compiling generated WS program.
<WSQ> Compiling query to run timers in REAL time (using usleep)....
wsparse process started.
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/internal.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/sigseg_copyalways.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/internal_wsc2.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/hashtables.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/apps/reuters/wsqlib.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/stdlib.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/unix.ws
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/lib/socket.ws
Suppressing repeated include of file!: "/home/newton/Dropbox/working_copies/wavescript/lib/stdlib.ws"
Suppressing repeated include of file!: "/home/newton/Dropbox/working_copies/wavescript/lib/unix.ws"
Using wsparse process on file: /home/newton/Dropbox/working_copies/wavescript/apps/reuters/taq_reader.ws
Suppressing repeated include of file!: "/home/newton/Dropbox/working_copies/wavescript/lib/stdlib.ws"
Suppressing repeated include of file!: "/home/newton/Dropbox/working_copies/wavescript/lib/unix.ws"
Typecheck complete, program types:
edge_20 :: Stream TAQ_Tup;
ignored_462 :: Stream ();
BASE :: Stream ();
Output of metaprogram evaluation:
------------------------------------------------------------
<WSQ> Creating incoming (client) socket, host localhost port: 9877
------------------------------------------------------------
Metaprogram evaluation succeeded.
Monomorphism achieved.
--> adding include "sys/types.h"
--> adding include "sys/socket.h"
--> adding include "netinet/in.h"
--> adding include "socket_wrappers.c"
--> adding include "pthread.h"
--> adding include "unistd.h"
--> adding include "stdio.h"
--> adding include "unix_wrappers.c"
TIMER RATES: (500.0)
ZERO TIMERS ()
Generated output to files ("proc2query.c").
Total compile time:
(time (begin (run-wscomp) ...))
52 collections
566 ms elapsed cpu time, including 123 ms collecting
566 ms elapsed real time, including 126 ms collecting
438870992 bytes allocated, including 437174560 bytes reclaimed
Linking extra libraries requested by query file: -lpthread -lgc
gcc -g -O0 -DWS_REAL_TIMERS -DWSC2 -lpthread -lgc -lm -I /home/newton/wavescript/lib -I /home/newton/wavescript/src/linked_lib -o proc2query.exe proc2query.c -lpthread -lgc -lm
proc2query.c: In function 'wsq_printer_1':
proc2query.c:142:5: warning: format '%lld' expects type 'long long int', but argument 2 has type 'int64_t'
proc2query.c:149:5: warning: format '%lld' expects type 'long long int', but argument 2 has type 'int64_t'
proc2query.c:167:5: warning: format '%lld' expects type 'long long int', but argument 2 has type 'int64_t'
0.15user 0.02system 0:00.18elapsed 91%CPU (0avgtext+0avgdata 77104maxresident)k
0inputs+936outputs (0major+9863minor)pagefaults 0swaps
Compiled .c output successfully.
1946 5641 98970 proc2query.c
<WSQ> Finished compilation (1.884148815 seconds); back to control program...
<WSQ> EndTransaction NOT running query because stream engine paused.
Done Sleeping. Shutting down WSQ Engine...
<WSQ> Shutting down query engine.
*** stack smashing detected ***: ./proc2 terminated
======= Backtrace: =========
/lib/x86_64-linux-gnu/libc.so.6(__fortify_fail+0x37)[0x7f14466261d7]
/lib/x86_64-linux-gnu/libc.so.6(__fortify_fail+0x0)[0x7f14466261a0]
./proc2(main+0x116)[0x4078ca]
/lib/x86_64-linux-gnu/libc.so.6(__libc_start_main+0xff)[0x7f1446546eff]
./proc2[0x4076f9]
======= Memory map: ========
00400000-00442000 r-xp 00000000 09:00 26215821 /home/newton/Dropbox/working_copies/wavescript/apps/reuters/runtime/example_distributed/proc2
00642000-00643000 r--p 00042000 09:00 26215821 /home/newton/Dropbox/working_copies/wavescript/apps/reuters/runtime/example_distributed/proc2
00643000-00644000 rw-p 00043000 09:00 26215821 /home/newton/Dropbox/working_copies/wavescript/apps/reuters/runtime/example_distributed/proc2
00644000-007f7000 rw-p 00000000 00:00 0
01a4a000-01a6b000 rw-p 00000000 00:00 0 [heap]
40200000-40688000 rwxp 00000000 00:00 0
407cc000-409d0000 rwxp 00000000 00:00 0
40a46000-41052000 rwxp 00000000 00:00 0
4106a000-412ee000 rwxp 00000000 00:00 0
4134a000-415ce000 rwxp 00000000 00:00 0
416e1000-421f5000 rwxp 00000000 00:00 0
42305000-48fdd000 rwxp 00000000 00:00 0
7f1446312000-7f1446327000 r-xp 00000000 09:00 31725013 /lib/x86_64-linux-gnu/libgcc_s.so.1
7f1446327000-7f1446526000 ---p 00015000 09:00 31725013 /lib/x86_64-linux-gnu/libgcc_s.so.1
7f1446526000-7f1446527000 r--p 00014000 09:00 31725013 /lib/x86_64-linux-gnu/libgcc_s.so.1
7f1446527000-7f1446528000 rw-p 00015000 09:00 31725013 /lib/x86_64-linux-gnu/libgcc_s.so.1
7f1446528000-7f14466b2000 r-xp 00000000 09:00 31724403 /lib/x86_64-linux-gnu/libc-2.13.so
7f14466b2000-7f14468b1000 ---p 0018a000 09:00 31724403 /lib/x86_64-linux-gnu/libc-2.13.so
7f14468b1000-7f14468b5000 r--p 00189000 09:00 31724403 /lib/x86_64-linux-gnu/libc-2.13.so
7f14468b5000-7f14468b6000 rw-p 0018d000 09:00 31724403 /lib/x86_64-linux-gnu/libc-2.13.so
7f14468b6000-7f14468bc000 rw-p 00000000 00:00 0
7f14468bc000-7f14468c3000 r-xp 00000000 09:00 31724419 /lib/x86_64-linux-gnu/librt-2.13.so
7f14468c3000-7f1446ac2000 ---p 00007000 09:00 31724419 /lib/x86_64-linux-gnu/librt-2.13.so
7f1446ac2000-7f1446ac3000 r--p 00006000 09:00 31724419 /lib/x86_64-linux-gnu/librt-2.13.so
7f1446ac3000-7f1446ac4000 rw-p 00007000 09:00 31724419 /lib/x86_64-linux-gnu/librt-2.13.so
7f1446ac4000-7f1446adc000 r-xp 00000000 09:00 31724417 /lib/x86_64-linux-gnu/libpthread-2.13.so
7f1446adc000-7f1446cdc000 ---p 00018000 09:00 31724417 /lib/x86_64-linux-gnu/libpthread-2.13.so
7f1446cdc000-7f1446cdd000 r--p 00018000 09:00 31724417 /lib/x86_64-linux-gnu/libpthread-2.13.so
7f1446cdd000-7f1446cde000 rw-p 00019000 09:00 31724417 /lib/x86_64-linux-gnu/libpthread-2.13.so
7f1446cde000-7f1446ce2000 rw-p 00000000 00:00 0
7f1446ce2000-7f1446d22000 r-xp 00000000 09:00 634 /lib/libncurses.so.5.7
7f1446d22000-7f1446f21000 ---p 00040000 09:00 634 /lib/libncurses.so.5.7
7f1446f21000-7f1446f25000 r--p 0003f000 09:00 634 /lib/libncurses.so.5.7
7f1446f25000-7f1446f26000 rw-p 00043000 09:00 634 /lib/libncurses.so.5.7
7f1446f26000-7f1446f28000 r-xp 00000000 09:00 31724406 /lib/x86_64-linux-gnu/libdl-2.13.so
7f1446f28000-7f1447128000 ---p 00002000 09:00 31724406 /lib/x86_64-linux-gnu/libdl-2.13.so
7f1447128000-7f1447129000 r--p 00002000 09:00 31724406 /lib/x86_64-linux-gnu/libdl-2.13.so
7f1447129000-7f144712a000 rw-p 00003000 09:00 31724406 /lib/x86_64-linux-gnu/libdl-2.13.so
7f144712a000-7f14471ae000 r-xp 00000000 09:00 31724407 /lib/x86_64-linux-gnu/libm-2.13.so
7f14471ae000-7f14473ad000 ---p 00084000 09:00 31724407 /lib/x86_64-linux-gnu/libm-2.13.so
7f14473ad000-7f14473ae000 r--p 00083000 09:00 31724407 /lib/x86_64-linux-gnu/libm-2.13.so
7f14473ae000-7f14473af000 rw-p 00084000 09:00 31724407 /lib/x86_64-linux-gnu/libm-2.13.so
7f14473af000-7f14473d0000 r-xp 00000000 09:00 31724400 /lib/x86_64-linux-gnu/ld-2.13.so
7f1447595000-7f144759a000 rw-p 00000000 00:00 0
7f14475cb000-7f14475cf000 rw-p 00000000 00:00 0
7f14475cf000-7f14475d0000 r--p 00020000 09:00 31724400 /lib/x86_64-linux-gnu/ld-2.13.so
7f14475d0000-7f14475d2000 rw-p 00021000 09:00 31724400 /lib/x86_64-linux-gnu/ld-2.13.so
7fff9c6e8000-7fff9c70b000 rw-p 00000000 00:00 0 [stack]
7fff9c7ff000-7fff9c800000 r-xp 00000000 00:00 0 [vdso]
ffffffffff600000-ffffffffff601000 r-xp 00000000 00:00 0 [vsyscall]
Aborted
The text was updated successfully, but these errors were encountered:
In revision cb09f3e the example_distributed "proc2" program actually does NOT run the generated query -- it executes a "Pause" API call. Yet just the WSQ runtime itself causes the following problem on shutdown.
The text was updated successfully, but these errors were encountered: