int stream_thread(SceSize args, void *argp){
    int mem_size;
    SceDisplayFrameBuf param;
    param.size = sizeof(SceDisplayFrameBuf);
    sceKernelWaitSema(async_mutex, 1, NULL);
    for (;;){
        sceDisplayGetFrameBuf(&param, SCE_DISPLAY_SETBUF_NEXTFRAME);
        int i,j,z,ptr;
        z=0;
        uint32_t* fb = param.base;
        for (i=0;i < param.height; i++){
            ptr = param.pitch * i;
            z = 512 * i;
            for (j=0;j < param.width; j+=2){
                rescale_buffer[z++]=fb[ptr+j];
            }
        }
        mem = encodeARGB(&jpeg_encoder, rescale_buffer, 480, 272, 512, &mem_size);
        sceNetSendto(stream_skt, mem, mem_size, 0, (SceNetSockaddr*)&addrFrom, sizeof(addrFrom));
    }
}