Raas Ahsan RaasAhsan

[info] running org.simpleapp.example.Example 
1
2
3
4
5
IOTrace: 13 frames captured, 0 omitted
╭ flatMap
│ ╰╮

IOTrace: 0 omitted frames
╭ flatMap
│ ╰╮
│  ├ org.simpleapp.example.Example.main (Example.scala:21)
│  ├ org.simpleapp.example.Example.main (Example.scala:-1)
│  ├ sun.reflect.NativeMethodAccessorImpl.invoke0 (NativeMethodAccessorImpl.java:-2)
│  ├ sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
│  ├ sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
│  ├ java.lang.reflect.Method.invoke (Method.java:498)

Useful FFMPEG commands

Print out GOP picture types

$ ffprobe -v quiet -print_format json -i vods/1/low/segment-0.ts -show_frames | \
    jq -r '.frames[] | select(.media_type=="video") | .pict_type' | \
    tr -d '\n'
IBBBPPBPBPBPBPBPBBPBBBPBBBPBBPBBBPBBBPBPBBBPBBBPIBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPIBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBPIBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBBPBBPIBBBPBBBPBBBPBBBPBBPBBBPBBBPBBBPBBBPBPBBBPBBBPBP

	use std::sync::mpsc::{sync_channel, Receiver, SyncSender};
	use std::thread;

	enum Message {
	Chunk(Vec<u8>),
	Flush,
	}

	struct TxWrite {
	tx: SyncSender<Message>,

	object Lambda extends App {

	sealed trait Term
	sealed trait Var[I <: Index] extends Term
	sealed trait App[T1 <: Term, T2 <: Term] extends Term
	sealed trait Abs[T1 <: Term] extends Term
	sealed trait If[T1 <: Term, T2 <: Term, T3 <: Term] extends Term
	sealed trait Bool[T1 <: Boolean] extends Term

	sealed trait Index

	import cats.effect._
	import cats.effect.kernel.Resource
	import cats.syntax.all._

	trait Shared[F[_], A] {
	def resource: Resource[F, A]
	}

	object Shared {
	def allocate[F[_], A](resource: Resource[F, A])(implicit F: Concurrent[F]): Resource[F, (Shared[F, A], A)] = {

	import cats.effect._
	import org.http4s.implicits._
	import org.http4s.server.blaze.BlazeServerBuilder
	import org.http4s.server.middleware.Logger
	import scala.concurrent.ExecutionContext.global

	object BlazeServer extends IOApp {

	def server: IO[Nothing] = {
	val app = Logger.httpApp(true, true)(routes.orNotFound)

	import java.util.concurrent.atomic.*;
	import java.util.concurrent.*;

	public class Main {
	private static ExecutorService executor = Executors.newFixedThreadPool(2);
	private static int iterations = 10000000;

	public static class Runner {
	// writes to canceled happen before a CAS on suspended
	// reads on canceled happen after a CAS on suspended

	package tapl;

	terminals true false if then else value steporvalue Bool Nat subterm succ nv

	syntax

	t ::= true \|
	false \|
	if t then t else t \|
	0 \|