-int canqueue_ends_dispose_kern(struct canque_ends_t *qends, int sync)
-{
- int delayed;
-
- DEBUGQUE("canqueue_ends_dispose_kern\n");
- canqueue_block_inlist(qends);
- canqueue_block_outlist(qends);
-
- /*Wait for sending of all pending messages in the output FIFOs*/
- if(sync)
- canqueue_ends_sync_all_kern(qends);
-
- /* Finish or kill all outgoing edges listed in inends */
- delayed=canqueue_ends_kill_inlist(qends, 1);
- /* Kill all incoming edges listed in outends */
- delayed|=canqueue_ends_kill_outlist(qends);
-
- wake_up(&qends->endinfo.fileinfo.readq);
- wake_up(&qends->endinfo.fileinfo.writeq);
- wake_up(&qends->endinfo.fileinfo.emptyq);
-
- if(delayed){
- canqueue_ends_dispose_postpone(qends);
-
- DEBUGQUE("canqueue_ends_dispose_kern delayed\n");
- return 1;
- }
-
- free(qends);
- DEBUGQUE("canqueue_ends_dispose_kern finished\n");
- return 0;
-}
+// int canqueue_ends_dispose_kern(struct canque_ends_t *qends, int sync)
+// {
+// int delayed;
+//
+// DEBUGQUE("canqueue_ends_dispose_kern\n");
+// canqueue_block_inlist(qends);
+// canqueue_block_outlist(qends);
+//
+// /*Wait for sending of all pending messages in the output FIFOs*/
+// if(sync)
+// canqueue_ends_sync_all_kern(qends);
+//
+// /* Finish or kill all outgoing edges listed in inends */
+// delayed=canqueue_ends_kill_inlist(qends, 1);
+// /* Kill all incoming edges listed in outends */
+// delayed|=canqueue_ends_kill_outlist(qends);
+//
+// // wake_up(&qends->endinfo.fileinfo.readq);
+// // wake_up(&qends->endinfo.fileinfo.writeq);
+// // wake_up(&qends->endinfo.fileinfo.emptyq);
+//
+// if(delayed){
+// canqueue_ends_dispose_postpone(qends);
+//
+// DEBUGQUE("canqueue_ends_dispose_kern delayed\n");
+// return 1;
+// }
+//
+// free(qends);
+// DEBUGQUE("canqueue_ends_dispose_kern finished\n");
+// return 0;
+// }