/* (c) Copyright 2000-2002 convergence integrated media GmbH. (c) Copyright 2002 convergence GmbH. All rights reserved. Written by Denis Oliver Kropp , Andreas Hundt and Sven Neumann . Fast memcpy code was taken from xine (see below). This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ /* * Copyright (C) 2001 the xine project * * This file is part of xine, a unix video player. * * xine is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * xine is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA * * These are the MMX/MMX2/SSE optimized versions of memcpy * * This code was adapted from Linux Kernel sources by Nick Kurshev to * the mplayer program. (http://mplayer.sourceforge.net) * * Miguel Freitas split the #ifdefs into several specialized functions that * are benchmarked at runtime by xine. Some original comments from Nick * have been preserved documenting some MMX/SSE oddities. * Also added kernel memcpy function that seems faster than glibc one. * */ /* Original comments from mplayer (file: aclib.c) This part of code was taken by me from Linux-2.4.3 and slightly modified for MMX, MMX2, SSE instruction set. I have done it since linux uses page aligned blocks but mplayer uses weakly ordered data and original sources can not speedup them. Only using PREFETCHNTA and MOVNTQ together have effect! From IA-32 Intel Architecture Software Developer's Manual Volume 1, Order Number 245470: "10.4.6. Cacheability Control, Prefetch, and Memory Ordering Instructions" Data referenced by a program can be temporal (data will be used again) or non-temporal (data will be referenced once and not reused in the immediate future). To make efficient use of the processor's caches, it is generally desirable to cache temporal data and not cache non-temporal data. Overloading the processor's caches with non-temporal data is sometimes referred to as "polluting the caches". The non-temporal data is written to memory with Write-Combining semantics. The PREFETCHh instructions permits a program to load data into the processor at a suggested cache level, so that it is closer to the processors load and store unit when it is needed. If the data is already present in a level of the cache hierarchy that is closer to the processor, the PREFETCHh instruction will not result in any data movement. But we should you PREFETCHNTA: Non-temporal data fetch data into location close to the processor, minimizing cache pollution. The MOVNTQ (store quadword using non-temporal hint) instruction stores packed integer data from an MMX register to memory, using a non-temporal hint. The MOVNTPS (store packed single-precision floating-point values using non-temporal hint) instruction stores packed floating-point data from an XMM register to memory, using a non-temporal hint. The SFENCE (Store Fence) instruction controls write ordering by creating a fence for memory store operations. This instruction guarantees that the results of every store instruction that precedes the store fence in program order is globally visible before any store instruction that follows the fence. The SFENCE instruction provides an efficient way of ensuring ordering between procedures that produce weakly-ordered data and procedures that consume that data. If you have questions please contact with me: Nick Kurshev: nickols_k@mail.ru. */ /* mmx v.1 Note: Since we added alignment of destinition it speedups of memory copying on PentMMX, Celeron-1 and P2 upto 12% versus standard (non MMX-optimized) version. Note: on K6-2+ it speedups memory copying upto 25% and on K7 and P3 about 500% (5 times). */ /* Additional notes on gcc assembly and processors: [MF] prefetch is specific for AMD processors, the intel ones should be prefetch0, prefetch1, prefetch2 which are not recognized by my gcc. prefetchnta is supported both on athlon and pentium 3. therefore i will take off prefetchnta instructions from the mmx1 version to avoid problems on pentium mmx and k6-2. quote of the day: "Using prefetches efficiently is more of an art than a science" */ #include #include #include #include #include #include #include #include #include #include #include #include #ifdef STRICT_CHECKING #include #endif #define BUFSIZE 1024 #ifndef HAVE_ASM_SSE /* P3 processor has only one SSE decoder so can execute only 1 sse insn per cpu clock, but it has 3 mmx decoders (include load/store unit) and executes 3 mmx insns per cpu clock. P4 processor has some chances, but after reading: http://www.emulators.com/pentium4.htm I have doubts. Anyway SSE2 version of this code can be written better. */ #undef HAVE_SSE #endif #undef HAVE_ONLY_MMX1 #if defined(HAVE_ASM_MMX) && !defined(HAVE_ASM_MMX2) && !defined(HAVE_ASM_3DNOW) && !defined(HAVE_ASM_SSE) /* means: mmx v.1. Note: Since we added alignment of destinition it speedups of memory copying on PentMMX, Celeron-1 and P2 upto 12% versus standard (non MMX-optimized) version. Note: on K6-2+ it speedups memory copying upto 25% and on K7 and P3 about 500% (5 times). */ #define HAVE_ONLY_MMX1 #endif #undef HAVE_K6_2PLUS #if !defined( HAVE_ASM_MMX2) && defined( HAVE_ASM_3DNOW) #define HAVE_K6_2PLUS #endif /* definitions */ #define BLOCK_SIZE 4096 #define CONFUSION_FACTOR 0 //Feel free to fine-tune the above 2, it might be possible to get some speedup with them :) #if defined(ARCH_X86) || defined (ARCH_X86_64) /* for small memory blocks (<256 bytes) this version is faster */ #define small_memcpy(to,from,n)\ {\ register unsigned long int dummy;\ __asm__ __volatile__(\ "rep; movsb"\ :"=&D"(to), "=&S"(from), "=&c"(dummy)\ :"0" (to), "1" (from),"2" (n)\ : "memory");\ } /* for small memory blocks (<256 bytes) this version is faster */ #define small_memset(to,val,n)\ {\ register unsigned long int dummy;\ __asm__ __volatile__(\ "rep; stosb"\ :"=&D"(to), "=&c"(dummy)\ :"0" (to), "1" (n), "a"((char)val)\ :"memory");\ } static inline unsigned long long int rdtsc() { struct timeval tv; gettimeofday (&tv, NULL); return (tv.tv_sec * 1000000 + tv.tv_usec); // unsigned long long int x; // __asm__ volatile (".byte 0x0f, 0x31" : "=A" (x)); // return x; } #else #define small_memcpy(to,from,n) memcpy( to,from,n ) #define small_memset(to,val,n) memset(to,val,n) char *veejay_strncpy( char *dest, const char *src, size_t n ) { memcpy ( dest, src, n ); dest[n] = '\0'; return dest; } char *veejay_strncat( char *s1, char *s2, size_t n ) { return strncat( s1,s2, n); } static void yuyv_plane_clear_job( void *arg ) { vj_task_arg_t *v = (vj_task_arg_t*) arg; int len = v->strides[0]; uint8_t *t = v->input[0]; unsigned int i; i = len; for( ; i > 0 ; i -- ) { t[0] = 0; t[1] = 128; t[2] = 0; t[3] = 128; t += 4; } } void yuyv_plane_clear( size_t len, void *to ) { if( vj_task_available() ) { uint8_t * t = (uint8_t*) to; uint8_t *in[4] = { t, NULL,NULL,NULL }; int strides[4] = { len, 0,0,0 }; vj_task_run( in, in, NULL, NULL, 1, &yuyv_plane_clear_job ); } else { uint8_t *t = (uint8_t*) to; unsigned int i; i = len; for( ; i > 0 ; i -- ) { t[0] = 0; t[1] = 128; t[2] = 0; t[3] = 128; t += 4; } } } static inline unsigned long long int rdtsc() { struct timeval tv; gettimeofday (&tv, NULL); return (tv.tv_sec * 1000000 + tv.tv_usec); } #endif #if defined(ARCH_X86) || defined (ARCH_X86_64) static inline void * __memcpy(void * to, const void * from, size_t n) { int d0, d1, d2; if ( n < 4 ) { small_memcpy(to,from,n); } else __asm__ __volatile__( "rep ; movsl\n\t" "testb $2,%b4\n\t" "je 1f\n\t" "movsw\n" "1:\ttestb $1,%b4\n\t" "je 2f\n\t" "movsb\n" "2:" : "=&c" (d0), "=&D" (d1), "=&S" (d2) :"0" (n/4), "q" (n),"1" ((long) to),"2" ((long) from) : "memory"); return(to); } #undef _MMREG_SIZE #ifdef HAVE_SSE #define _MMREG_SIZE 16 #else #define _MMREG_SIZE 64 #endif #ifdef HAVE_ASM_AVX #define AVX_MMREG_SIZE 32 #endif #ifdef HAVE_ASM_SSE #define SSE_MMREG_SIZE 16 #endif #ifdef HAVE_ASM_MMX #define MMX_MMREG_SIZE 8 #endif #undef PREFETCH #undef EMMS #undef _MIN_LEN #ifdef HAVE_ASM_MMX2 //@ was ifndef HAVE_MMX1 #define _MIN_LEN 0x40 #else #define _MIN_LEN 0x800 /* 2K blocks */ #endif #ifdef HAVE_ASM_MMX2 #define PREFETCH "prefetchnta" #elif defined ( HAVE_ASM_3DNOW ) #define PREFETCH "prefetch" #else #define PREFETCH "/nop" #endif /* On K6 femms is faster of emms. On K7 femms is directly mapped on emms. */ #ifdef HAVE_ASM_3DNOW #define EMMS "femms" #else #define EMMS "emms" #endif #undef MOVNTQ #ifdef HAVE_ASM_MMX2 #define MOVNTQ "movntq" #else #define MOVNTQ "movq" #endif char *veejay_strncpy( char *dest, const char *src, size_t n ) { dest[n] = '\0'; if( n < 0xff ) { small_memcpy( dest,src, n ); } else if ( n < 512 ) { small_memcpy( dest,src, n ); } else { return veejay_memcpy( dest,src, n ); } return dest; } char *veejay_strncat( char *s1, char *s2, size_t n ) { #ifdef STRICT_CHECKING assert( strlen(s2) == n ); #endif //@ run forward char *s = s1; while(*s != '\0' ) *s ++; //@ small if( n < 0xff ) { s2[n] = '\0'; small_memcpy( s, s2, n+1); } else if ( n < 512 ) // bit smaller { s2[n] = '\0'; small_memcpy( s, s2, n+1); } else { s2[n] = '\0'; return veejay_memcpy(s,s2, n+1 ); } return s1; } void prefetch_memory( void *from ) { #ifndef HAVE_MMX1 __asm__ __volatile__ ( PREFETCH" (%0)\n" PREFETCH" 64(%0)\n" PREFETCH" 128(%0)\n" PREFETCH" 192(%0)\n" PREFETCH" 256(%0)\n" :: "r" (from)); #else #ifdef HAVE_ASM_SSE __asm__ __volatile__ ( PREFETCH" 320(%0)\n" :: "r" (from)); #endif #endif } static uint8_t ppmask[16] = { 0,128,128,0, 128,128,0,128, 128,0,128,128,0,128,128, 0 }; static uint8_t yuyv_mmreg_[_MMREG_SIZE]; void yuyv_plane_init() { unsigned int i; for( i = 0; i < _MMREG_SIZE ;i ++ ) yuyv_mmreg_[i] = ( (i%2) ? 128: 0 ); } static void yuyv_plane_clear_job( void *arg ) { vj_task_arg_t *v = (vj_task_arg_t*) arg; int len = v->strides[0]; uint8_t *t = v->input[0]; unsigned int i; #ifdef HAVE_ASM_MMX2 __asm __volatile( "movq (%0), %%mm0\n" :: "r" (yuyv_mmreg_) : "memory" ); i = len >> 7; len = len % 128; for(; i > 0 ; i -- ) { __asm __volatile( PREFETCH" 320(%0)\n" MOVNTQ" %%mm0, (%0)\n" MOVNTQ" %%mm0, 8(%0)\n" MOVNTQ" %%mm0, 16(%0)\n" MOVNTQ" %%mm0, 24(%0)\n" MOVNTQ" %%mm0, 32(%0)\n" MOVNTQ" %%mm0, 40(%0)\n" MOVNTQ" %%mm0, 48(%0)\n" MOVNTQ" %%mm0, 56(%0)\n" MOVNTQ" %%mm0, 64(%0)\n" MOVNTQ" %%mm0, 72(%0)\n" MOVNTQ" %%mm0, 80(%0)\n" MOVNTQ" %%mm0, 88(%0)\n" MOVNTQ" %%mm0, 96(%0)\n" MOVNTQ" %%mm0, 104(%0)\n" MOVNTQ" %%mm0, 112(%0)\n" MOVNTQ" %%mm0, 120(%0)\n" :: "r" (t) : "memory" ); t += 128; } #else #ifdef HAVE_ASM_MMX __asm __volatile( "movq (%0), %%mm0\n\t" :: "r" (yuyv_mmreg_): "memory"); i = len >> 6; len = len % 64; for(; i > 0 ; i -- ) { __asm__ __volatile__ ( "movq %%mm0, (%0)\n" "movq %%mm0, 8(%0)\n" "movq %%mm0, 16(%0)\n" "movq %%mm0, 24(%0)\n" "movq %%mm0, 32(%0)\n" "movq %%mm0, 40(%0)\n" "movq %%mm0, 48(%0)\n" "movq %%mm0, 56(%0)\n" :: "r" (t) : "memory"); t += 64; } #endif #endif #ifdef HAVE_ASM_MMX i = len >> 3; len = i % 8; for( ; i > 0; i -- ) { __asm__ __volatile__ ( "movq %%mm0, (%0)\n" :: "r" (t) : "memory" ); t += 8; } #endif i = len; for( ; i > 0 ; i -- ) { t[0] = 0; t[1] = 128; t[2] = 0; t[3] = 128; t += 4; } } void yuyv_plane_clear( size_t len, void *to ) { uint8_t *t = (uint8_t*) to; unsigned int i; if( vj_task_available() ) { int strides[4] = { len, 0,0, 0 }; uint8_t *in[4] = { t, NULL,NULL,NULL}; vj_task_run( in,in, NULL,strides, 1,(performer_job_routine) &yuyv_plane_clear_job ); return; } #ifdef HAVE_ASM_MMX2 __asm __volatile( "movq (%0), %%mm0\n" :: "r" (yuyv_mmreg_) : "memory" ); i = len >> 7; len = len % 128; for(; i > 0 ; i -- ) { __asm __volatile( PREFETCH" 320(%0)\n" MOVNTQ" %%mm0, (%0)\n" MOVNTQ" %%mm0, 8(%0)\n" MOVNTQ" %%mm0, 16(%0)\n" MOVNTQ" %%mm0, 24(%0)\n" MOVNTQ" %%mm0, 32(%0)\n" MOVNTQ" %%mm0, 40(%0)\n" MOVNTQ" %%mm0, 48(%0)\n" MOVNTQ" %%mm0, 56(%0)\n" MOVNTQ" %%mm0, 64(%0)\n" MOVNTQ" %%mm0, 72(%0)\n" MOVNTQ" %%mm0, 80(%0)\n" MOVNTQ" %%mm0, 88(%0)\n" MOVNTQ" %%mm0, 96(%0)\n" MOVNTQ" %%mm0, 104(%0)\n" MOVNTQ" %%mm0, 112(%0)\n" MOVNTQ" %%mm0, 120(%0)\n" :: "r" (t) : "memory" ); t += 128; } #else #ifdef HAVE_ASM_MMX __asm __volatile( "movq (%0), %%mm0\n\t" :: "r" (yuyv_mmreg_): "memory"); i = len >> 6; len = len % 64; for(; i > 0 ; i -- ) { __asm__ __volatile__ ( "movq %%mm0, (%0)\n" "movq %%mm0, 8(%0)\n" "movq %%mm0, 16(%0)\n" "movq %%mm0, 24(%0)\n" "movq %%mm0, 32(%0)\n" "movq %%mm0, 40(%0)\n" "movq %%mm0, 48(%0)\n" "movq %%mm0, 56(%0)\n" :: "r" (t) : "memory"); t += 64; } #endif #endif #ifdef HAVE_ASM_MMX i = len >> 3; len = i % 8; for( ; i > 0; i -- ) { __asm__ __volatile__ ( "movq %%mm0, (%0)\n" :: "r" (t) : "memory" ); t += 8; } #endif i = len; for( ; i > 0 ; i -- ) { t[0] = 0; t[1] = 128; t[2] = 0; t[3] = 128; t += 4; } } void packed_plane_clear( size_t len, void *to ) { uint8_t *t = (uint8_t*) to; unsigned int i; uint8_t *m = (uint8_t*) &ppmask; #ifdef HAVE_ASM_MMX __asm __volatile( "movq (%0), %%mm0\n\t" :: "r" (m)); i = len / 64; len = len % 64; for(; i > 0 ; i -- ) { __asm__ __volatile__ ( "movq %%mm0, (%0)\n" "movq %%mm0, 8(%0)\n" "movq %%mm0, 16(%0)\n" "movq %%mm0, 24(%0)\n" "movq %%mm0, 32(%0)\n" "movq %%mm0, 40(%0)\n" "movq %%mm0, 48(%0)\n" "movq %%mm0, 56(%0)\n" :: "r" (t) : "memory"); t += 64; } #endif i = len; for( ; i > 0 ; i -- ) { t[0] = 0; t[1] = 128; t[2] = 0; t[3] = 128; t += 4; } } #ifdef HAVE_ASM_AVX static void * avx_memcpy(void * to, const void * from, size_t len) { void *retval; size_t i; retval = to; /* PREFETCH has effect even for MOVSB instruction ;) */ __asm__ __volatile__ ( " prefetchnta (%0)\n" " prefetchnta 32(%0)\n" " prefetchnta 64(%0)\n" " prefetchnta 96(%0)\n" " prefetchnta 128(%0)\n" " prefetchnta 160(%0)\n" " prefetchnta 192(%0)\n" " prefetchnta 224(%0)\n" " prefetchnta 256(%0)\n" " prefetchnta 288(%0)\n" : : "r" (from) ); if(len >= _MIN_LEN) { register uintptr_t delta; /* Align destinition to MMREG_SIZE -boundary */ delta = ((uintptr_t)to)&(AVX_MMREG_SIZE-1); if(delta) { delta=AVX_MMREG_SIZE-delta; len -= delta; small_memcpy(to, from, delta); } i = len >> 7; /* len/128 */ len&=127; if(((uintptr_t)from) & 31) /* if SRC is misaligned */ for(; i>0; i--) { __asm__ __volatile__ ( "prefetchnta 320(%0)\n" "prefetchnta 352(%0)\n" "prefetchnta 384(%0)\n" "prefetchnta 416(%0)\n" "vmovups (%0), %%ymm0\n" "vmovups 32(%0), %%ymm1\n" "vmovups 64(%0), %%ymm2\n" "vmovups 96(%0), %%ymm3\n" "vmovntps %%ymm0, (%1)\n" "vmovntps %%ymm1, 32(%1)\n" "vmovntps %%ymm2, 64(%1)\n" "vmovntps %%ymm3, 96(%1)\n" :: "r" (from), "r" (to) : "memory"); from = ((const unsigned char *)from) + 128; to = ((unsigned char *)to) + 128; } else /* Only if SRC is aligned on 16-byte boundary. It allows to use movaps instead of movups, which required data to be aligned or a general-protection exception (#GP) is generated. */ for(; i>0; i--) { __asm__ __volatile__ ( "prefetchnta 320(%0)\n" "prefetchnta 352(%0)\n" "prefetchnta 384(%0)\n" "prefetchnta 416(%0)\n" "vmovaps (%0), %%ymm0\n" "vmovaps 32(%0), %%ymm1\n" "vmovaps 64(%0), %%ymm2\n" "vmovaps 96(%0), %%ymm3\n" "vmovntps %%ymm0, (%1)\n" "vmovntps %%ymm1, 32(%1)\n" "vmovntps %%ymm2, 64(%1)\n" "vmovntps %%ymm3, 96(%1)\n" :: "r" (from), "r" (to) : "memory"); from = ((const unsigned char *)from) + 128; to = ((unsigned char *)to) + 128; } /* since movntq is weakly-ordered, a "sfence" * is needed to become ordered again. */ __asm__ __volatile__ ("sfence":::"memory"); } /* * Now do the tail of the block */ if(len) __memcpy(to, from, len); return retval; } #endif /* HAVE_ASM_AVX */ #ifdef HAVE_ASM_MMX #define _MMX1_MIN_LEN 0x800 /* 2k blocks */ static void * mmx_memcpy(void * to, const void * from, size_t len) { void *retval; size_t i; retval = to; if(len >= _MMX1_MIN_LEN) { register uintptr_t delta; /* Align destinition to MMREG_SIZE -boundary */ delta = ((uintptr_t)to)&(MMX_MMREG_SIZE-1); if(delta) { delta=MMX_MMREG_SIZE-delta; len -= delta; small_memcpy(to, from, delta); } i = len >> 6; /* len/64 */ len&=63; for(; i>0; i--) { __asm__ __volatile__ ( "movq (%0), %%mm0\n" "movq 8(%0), %%mm1\n" "movq 16(%0), %%mm2\n" "movq 24(%0), %%mm3\n" "movq 32(%0), %%mm4\n" "movq 40(%0), %%mm5\n" "movq 48(%0), %%mm6\n" "movq 56(%0), %%mm7\n" "movq %%mm0, (%1)\n" "movq %%mm1, 8(%1)\n" "movq %%mm2, 16(%1)\n" "movq %%mm3, 24(%1)\n" "movq %%mm4, 32(%1)\n" "movq %%mm5, 40(%1)\n" "movq %%mm6, 48(%1)\n" "movq %%mm7, 56(%1)\n" :: "r" (from), "r" (to) : "memory"); from = ((const unsigned char *)from) + 64; to = ((unsigned char *)to) + 64; } __asm__ __volatile__ ("emms":::"memory"); } /* * Now do the tail of the block */ if(len) __memcpy(to, from, len); return retval; } #endif #ifdef HAVE_ASM_MMX2 static void * mmx2_memcpy(void * to, const void * from, size_t len) { void *retval; size_t i; retval = to; /* PREFETCH has effect even for MOVSB instruction ;) */ __asm__ __volatile__ ( " prefetchnta (%0)\n" " prefetchnta 32(%0)\n" " prefetchnta 64(%0)\n" " prefetchnta 96(%0)\n" " prefetchnta 128(%0)\n" " prefetchnta 160(%0)\n" " prefetchnta 192(%0)\n" " prefetchnta 224(%0)\n" " prefetchnta 256(%0)\n" " prefetchnta 288(%0)\n" : : "r" (from) ); if(len >= _MIN_LEN) { register uintptr_t delta; /* Align destinition to MMREG_SIZE -boundary */ delta = ((uintptr_t)to)&(MMX_MMREG_SIZE-1); if(delta) { delta=MMX_MMREG_SIZE-delta; len -= delta; small_memcpy(to, from, delta); } i = len >> 6; /* len/64 */ len&=63; for(; i>0; i--) { __asm__ __volatile__ ( "prefetchnta 320(%0)\n" "prefetchnta 352(%0)\n" "movq (%0), %%mm0\n" "movq 8(%0), %%mm1\n" "movq 16(%0), %%mm2\n" "movq 24(%0), %%mm3\n" "movq 32(%0), %%mm4\n" "movq 40(%0), %%mm5\n" "movq 48(%0), %%mm6\n" "movq 56(%0), %%mm7\n" "movntq %%mm0, (%1)\n" "movntq %%mm1, 8(%1)\n" "movntq %%mm2, 16(%1)\n" "movntq %%mm3, 24(%1)\n" "movntq %%mm4, 32(%1)\n" "movntq %%mm5, 40(%1)\n" "movntq %%mm6, 48(%1)\n" "movntq %%mm7, 56(%1)\n" :: "r" (from), "r" (to) : "memory"); from = ((const unsigned char *)from) + 64; to = ((unsigned char *)to) + 64; } /* since movntq is weakly-ordered, a "sfence" * is needed to become ordered again. */ __asm__ __volatile__ ("sfence":::"memory"); __asm__ __volatile__ ("emms":::"memory"); } /* * Now do the tail of the block */ if(len) __memcpy(to, from, len); return retval; } #endif #if defined (HAVE_ASM_SSE) || defined (HAVE_ASM_MMX) || defined( HAVE_ASM_MMX2 ) static void *fast_memcpy(void * to, const void * from, size_t len) { void *retval; size_t i; retval = to; unsigned char *t = to; unsigned char *f = (unsigned char *)from; #ifndef HAVE_ONLY_MMX1 /* PREFETCH has effect even for MOVSB instruction ;) */ __asm__ __volatile__ ( PREFETCH" (%0)\n" PREFETCH" 64(%0)\n" PREFETCH" 128(%0)\n" PREFETCH" 192(%0)\n" PREFETCH" 256(%0)\n" : : "r" (f) ); #endif if(len >= _MIN_LEN) { register unsigned long int delta; /* Align destinition to MMREG_SIZE -boundary */ delta = ((unsigned long int)to)&(_MMREG_SIZE-1); if(delta) { delta=_MMREG_SIZE-delta; len -= delta; small_memcpy(t, f, delta); } i = len >> 6; /* len/64 */ len&=63; /* This algorithm is top effective when the code consequently reads and writes blocks which have size of cache line. Size of cache line is processor-dependent. It will, however, be a minimum of 32 bytes on any processors. It would be better to have a number of instructions which perform reading and writing to be multiple to a number of processor's decoders, but it's not always possible. */ #ifdef HAVE_SSE /* Only P3 (may be Cyrix3) */ if(((unsigned long)f) & 15) /* if SRC is misaligned */ for(; i>0; i--) { __asm__ __volatile__ ( PREFETCH" 320(%0)\n" "movups (%0), %%xmm0\n" "movups 16(%0), %%xmm1\n" "movups 32(%0), %%xmm2\n" "movups 48(%0), %%xmm3\n" "movntps %%xmm0, (%1)\n" "movntps %%xmm1, 16(%1)\n" "movntps %%xmm2, 32(%1)\n" "movntps %%xmm3, 48(%1)\n" :: "r" (f), "r" (t) : "memory"); f+=64; t+=64; } else /* Only if SRC is aligned on 16-byte boundary. It allows to use movaps instead of movups, which required data to be aligned or a general-protection exception (#GP) is generated. */ for(; i>0; i--) { __asm__ __volatile__ ( PREFETCH" 320(%0)\n" "movaps (%0), %%xmm0\n" "movaps 16(%0), %%xmm1\n" "movaps 32(%0), %%xmm2\n" "movaps 48(%0), %%xmm3\n" "movntps %%xmm0, (%1)\n" "movntps %%xmm1, 16(%1)\n" "movntps %%xmm2, 32(%1)\n" "movntps %%xmm3, 48(%1)\n" :: "r" (f), "r" (t) : "memory"); // f+=64; // t+=64; f=((const unsigned char *)f)+64; t=((unsigned char *)t)+64; } #else // Align destination at BLOCK_SIZE boundary for(; ((int)to & (BLOCK_SIZE-1)) && i>0; i--) { __asm__ __volatile__ ( #ifndef HAVE_ONLY_MMX1 PREFETCH" 320(%0)\n" #endif "movq (%0), %%mm0\n" "movq 8(%0), %%mm1\n" "movq 16(%0), %%mm2\n" "movq 24(%0), %%mm3\n" "movq 32(%0), %%mm4\n" "movq 40(%0), %%mm5\n" "movq 48(%0), %%mm6\n" "movq 56(%0), %%mm7\n" MOVNTQ" %%mm0, (%1)\n" MOVNTQ" %%mm1, 8(%1)\n" MOVNTQ" %%mm2, 16(%1)\n" MOVNTQ" %%mm3, 24(%1)\n" MOVNTQ" %%mm4, 32(%1)\n" MOVNTQ" %%mm5, 40(%1)\n" MOVNTQ" %%mm6, 48(%1)\n" MOVNTQ" %%mm7, 56(%1)\n" :: "r" (f), "r" (t) : "memory"); // f+=64; // t+=64; f=((const unsigned char *)f)+64; t=((unsigned char *)t)+64; } // Pure Assembly cuz gcc is a bit unpredictable ;) if(i>=BLOCK_SIZE/64) asm volatile( "xor %%"REG_a", %%"REG_a" \n\t" ".balign 16 \n\t" "1: \n\t" "movl (%0, %%"REG_a"), %%ebx \n\t" "movl 32(%0, %%"REG_a"), %%ebx \n\t" "movl 64(%0, %%"REG_a"), %%ebx \n\t" "movl 96(%0, %%"REG_a"), %%ebx \n\t" "add $128, %%"REG_a" \n\t" "cmp %3, %%"REG_a" \n\t" " jb 1b \n\t" "xor %%"REG_a", %%"REG_a" \n\t" ".balign 16 \n\t" "2: \n\t" "movq (%0, %%"REG_a"), %%mm0\n" "movq 8(%0, %%"REG_a"), %%mm1\n" "movq 16(%0, %%"REG_a"), %%mm2\n" "movq 24(%0, %%"REG_a"), %%mm3\n" "movq 32(%0, %%"REG_a"), %%mm4\n" "movq 40(%0, %%"REG_a"), %%mm5\n" "movq 48(%0, %%"REG_a"), %%mm6\n" "movq 56(%0, %%"REG_a"), %%mm7\n" MOVNTQ" %%mm0, (%1, %%"REG_a")\n" MOVNTQ" %%mm1, 8(%1, %%"REG_a")\n" MOVNTQ" %%mm2, 16(%1, %%"REG_a")\n" MOVNTQ" %%mm3, 24(%1, %%"REG_a")\n" MOVNTQ" %%mm4, 32(%1, %%"REG_a")\n" MOVNTQ" %%mm5, 40(%1, %%"REG_a")\n" MOVNTQ" %%mm6, 48(%1, %%"REG_a")\n" MOVNTQ" %%mm7, 56(%1, %%"REG_a")\n" "add $64, %%"REG_a" \n\t" "cmp %3, %%"REG_a" \n\t" "jb 2b \n\t" #if CONFUSION_FACTOR > 0 // a few percent speedup on out of order executing CPUs "mov %5, %%"REG_a" \n\t" "2: \n\t" "movl (%0), %%ebx \n\t" "movl (%0), %%ebx \n\t" "movl (%0), %%ebx \n\t" "movl (%0), %%ebx \n\t" "dec %%"REG_a" \n\t" " jnz 2b \n\t" #endif "xor %%"REG_a", %%"REG_a" \n\t" "add %3, %0 \n\t" "add %3, %1 \n\t" "sub %4, %2 \n\t" "cmp %4, %2 \n\t" " jae 1b \n\t" : "+r" (from), "+r" (to), "+r" (i) : "r" ((long)BLOCK_SIZE), "i" (BLOCK_SIZE/64), "i" ((long)CONFUSION_FACTOR) : "%"REG_a, "%ebx" ); for(; i>0; i--) { __asm__ __volatile__ ( #ifndef HAVE_ONLY_MMX1 PREFETCH" 320(%0)\n" #endif "movq (%0), %%mm0\n" "movq 8(%0), %%mm1\n" "movq 16(%0), %%mm2\n" "movq 24(%0), %%mm3\n" "movq 32(%0), %%mm4\n" "movq 40(%0), %%mm5\n" "movq 48(%0), %%mm6\n" "movq 56(%0), %%mm7\n" MOVNTQ" %%mm0, (%1)\n" MOVNTQ" %%mm1, 8(%1)\n" MOVNTQ" %%mm2, 16(%1)\n" MOVNTQ" %%mm3, 24(%1)\n" MOVNTQ" %%mm4, 32(%1)\n" MOVNTQ" %%mm5, 40(%1)\n" MOVNTQ" %%mm6, 48(%1)\n" MOVNTQ" %%mm7, 56(%1)\n" :: "r" (from), "r" (to) : "memory"); from=((const unsigned char *)from)+64; to=((unsigned char *)to)+64; } #endif /* Have SSE */ #ifdef HAVE_ASM_MMX2 /* since movntq is weakly-ordered, a "sfence" * is needed to become ordered again. */ __asm__ __volatile__ ("sfence":::"memory"); #endif #ifndef HAVE_SSE /* enables to use FPU */ __asm__ __volatile__ (EMMS:::"memory"); #endif } /* * Now do the tail of the block */ if(len) small_memcpy(t, f, len); return retval; } #endif void fast_memset_finish() { #ifdef HAVE_ASM_MMX2 /* since movntq is weakly-ordered, a "sfence" * * is needed to become ordered again. */ __asm__ __volatile__ ("sfence":::"memory"); #endif #ifdef HAVE_ASM_MMX /* enables to use FPU */ __asm__ __volatile__ (EMMS:::"memory"); #endif } void fast_memset_dirty(void * to, int val, size_t len) { size_t i; unsigned char mm_reg[_MMREG_SIZE], *pmm_reg; unsigned char *t = to; if(len >= _MIN_LEN) { register unsigned long int delta; delta = ((unsigned long int)to)&(_MMREG_SIZE-1); if(delta) { delta=_MMREG_SIZE-delta; len -= delta; small_memset(t, val, delta); } i = len >> 7; /* len/128 */ len&=127; pmm_reg = mm_reg; small_memset(pmm_reg,val,sizeof(mm_reg)); #ifdef HAVE_ASM_SSE /* Only P3 (may be Cyrix3) */ __asm__ __volatile__( "movups (%0), %%xmm0\n" :: "r"(mm_reg):"memory"); for(; i>0; i--) { __asm__ __volatile__ ( "movntps %%xmm0, (%0)\n" "movntps %%xmm0, 16(%0)\n" "movntps %%xmm0, 32(%0)\n" "movntps %%xmm0, 48(%0)\n" "movntps %%xmm0, 64(%0)\n" "movntps %%xmm0, 80(%0)\n" "movntps %%xmm0, 96(%0)\n" "movntps %%xmm0, 112(%0)\n" :: "r" (t) : "memory"); t+=128; } #else __asm__ __volatile__( "movq (%0), %%mm0\n" :: "r"(mm_reg):"memory"); for(; i>0; i--) { __asm__ __volatile__ ( MOVNTQ" %%mm0, (%0)\n" MOVNTQ" %%mm0, 8(%0)\n" MOVNTQ" %%mm0, 16(%0)\n" MOVNTQ" %%mm0, 24(%0)\n" MOVNTQ" %%mm0, 32(%0)\n" MOVNTQ" %%mm0, 40(%0)\n" MOVNTQ" %%mm0, 48(%0)\n" MOVNTQ" %%mm0, 56(%0)\n" MOVNTQ" %%mm0, 64(%0)\n" MOVNTQ" %%mm0, 72(%0)\n" MOVNTQ" %%mm0, 80(%0)\n" MOVNTQ" %%mm0, 88(%0)\n" MOVNTQ" %%mm0, 96(%0)\n" MOVNTQ" %%mm0, 104(%0)\n" MOVNTQ" %%mm0, 112(%0)\n" MOVNTQ" %%mm0, 120(%0)\n" :: "r" (t) : "memory"); t+=128; } #endif /* Have SSE */ //#ifdef HAVE_ASM_MMX2 // /* since movntq is weakly-ordered, a "sfence" // * is needed to become ordered again. */ // __asm__ __volatile__ ("sfence":::"memory"); //#endif //#ifndef HAVE_ASM_SSE // /* enables to use FPU */ // __asm__ __volatile__ (EMMS:::"memory"); //#endif } /* * Now do the tail of the block */ if(len) small_memset(t, val, len); } #if defined (HAVE_ASM_MMX) /* Fast memory set. See comments for fast_memcpy */ void * fast_memset(void * to, int val, size_t len) { void *retval; size_t i; unsigned char mm_reg[_MMREG_SIZE], *pmm_reg; unsigned char *t = to; retval = to; // veejay_msg(0, "clear %d bytes in %p",len,val); if(len >= _MIN_LEN) { register unsigned long int delta; delta = ((unsigned long int)to)&(_MMREG_SIZE-1); if(delta) { delta=_MMREG_SIZE-delta; len -= delta; small_memset(t, val, delta); } i = len >> 7; /* len/128 */ len&=127; pmm_reg = mm_reg; small_memset(pmm_reg,val,sizeof(mm_reg)); /*#ifdef HAVE_ASM_SSE //Only P3 (may be Cyrix3) __asm__ __volatile__( "movups (%0), %%xmm0\n" :: "r"(mm_reg):"memory"); for(; i>0; i--) { __asm__ __volatile__ ( "movntps %%xmm0, (%0)\n" "movntps %%xmm0, 16(%0)\n" "movntps %%xmm0, 32(%0)\n" "movntps %%xmm0, 48(%0)\n" "movntps %%xmm0, 64(%0)\n" "movntps %%xmm0, 80(%0)\n" "movntps %%xmm0, 96(%0)\n" "movntps %%xmm0, 112(%0)\n" :: "r" (t) : "memory"); t+=128; } #else */ __asm__ __volatile__( "movq (%0), %%mm0\n" :: "r"(mm_reg):"memory"); for(; i>0; i--) { __asm__ __volatile__ ( MOVNTQ" %%mm0, (%0)\n" MOVNTQ" %%mm0, 8(%0)\n" MOVNTQ" %%mm0, 16(%0)\n" MOVNTQ" %%mm0, 24(%0)\n" MOVNTQ" %%mm0, 32(%0)\n" MOVNTQ" %%mm0, 40(%0)\n" MOVNTQ" %%mm0, 48(%0)\n" MOVNTQ" %%mm0, 56(%0)\n" MOVNTQ" %%mm0, 64(%0)\n" MOVNTQ" %%mm0, 72(%0)\n" MOVNTQ" %%mm0, 80(%0)\n" MOVNTQ" %%mm0, 88(%0)\n" MOVNTQ" %%mm0, 96(%0)\n" MOVNTQ" %%mm0, 104(%0)\n" MOVNTQ" %%mm0, 112(%0)\n" MOVNTQ" %%mm0, 120(%0)\n" :: "r" (t) : "memory"); t+=128; } #ifdef HAVE_ASM_MMX2 /* since movntq is weakly-ordered, a "sfence" * is needed to become ordered again. */ __asm__ __volatile__ ("sfence":::"memory"); /* enables to use FPU */ __asm__ __volatile__ (EMMS:::"memory"); #endif } /* * Now do the tail of the block */ if(len) small_memset(t, val, len); return retval; } #endif static void *linux_kernel_memcpy(void *to, const void *from, size_t len) { return __memcpy(to,from,len); } #endif static struct { char *name; void *(*function)(void *to, const void *from, size_t len); unsigned long long time; } memcpy_method[] = { { NULL, NULL, 0}, { "glibc memcpy()", memcpy, 0}, #if defined(ARCH_X86) || defined(ARCH_X86_64) { "linux kernel memcpy()", linux_kernel_memcpy, 0}, #endif #ifdef HAVE_ASM_AVX { "AVX optimized memcpy()", avx_memcpy, 0 }, #endif #ifdef HAVE_ASM_MMX { "MMX optimized memcpy()", mmx_memcpy, 0 }, #endif #ifdef HAVE_ASM_MMX2 { "MMX2 optimized memcpy()", mmx2_memcpy, 0 }, #endif #if defined (HAVE_ASM_MMX) || defined( HAVE_ASM_SSE ) { "MMX/MMX2/SSE optimized memcpy()", fast_memcpy, 0}, #endif // { "aclib optimized ac_memcpy()", (void*) ac_memcpy, 0 }, { NULL, NULL, 0}, }; static struct { char *name; void *(*function)(void *to, uint8_t c, size_t len); unsigned long long time; } memset_method[] = { { NULL, NULL, 0}, { "glibc memset()", (void*)memset, 0}, #if defined(HAVE_ASM_MMX) || defined(HAVE_ASM_MMX2) { "MMX/MMX2 optimized memset()", (void*) fast_memset, 0}, #endif { NULL, NULL, 0}, }; void *(* veejay_memcpy)(void *to, const void *from, size_t len) = 0; void *(* veejay_memset)(void *what, uint8_t val, size_t len ) = 0; char *get_memcpy_descr( void ) { int i = 1; int best = 1; for (i=1; memcpy_method[i].name; i++) { if( memcpy_method[i].time <= memcpy_method[best].time ) best = i; } char *res = strdup( memcpy_method[best].name ); return res; } void find_best_memcpy() { /* save library size on platforms without special memcpy impl. */ unsigned long long int t; char *buf1, *buf2; int i, best = 0; int bufsize = 720 * 576 * 3; if( bufsize == 0 ) bufsize = BUFSIZE * 2000; if (!(buf1 = (char*) malloc( bufsize * sizeof(char) ))) return; if (!(buf2 = (char*) malloc( bufsize * sizeof(char) ))) { free( buf1 ); return; } memset(buf1,0, bufsize); memset(buf2,0, bufsize); /* make sure buffers are present on physical memory */ memcpy( buf1, buf2, bufsize); memcpy( buf2, buf1, bufsize ); int c = MAX_WORKERS; int k; for( k = 0; k < c; k ++ ) { for (i=1; memcpy_method[i].name; i++) { t = rdtsc(); memcpy_method[i].function( buf1 , buf2 , bufsize ); t = rdtsc() - t; memcpy_method[i].time = t; if (best == 0 || t < memcpy_method[best].time) best = i; } if (best) { veejay_memcpy = memcpy_method[best].function; } } free( buf1 ); free( buf2 ); } void find_best_memset() { /* save library size on platforms without special memcpy impl. */ unsigned long long t; char *buf1, *buf2; int i, best = 0; if (!(buf1 = (char*) malloc( BUFSIZE * 2000 * sizeof(char) ))) return; if (!(buf2 = (char*) malloc( BUFSIZE * 2000 * sizeof(char) ))) { free( buf1 ); return; } for( i = 0; i < (BUFSIZE*2000); i ++ ) { buf1[i] = 0; buf2[i] = 0; } for (i=1; memset_method[i].name; i++) { t = rdtsc(); memset_method[i].function( buf1 , 0 , 2000 * BUFSIZE ); t = rdtsc() - t; memset_method[i].time = t; if (best == 0 || t < memset_method[best].time) best = i; } if (best) { veejay_memset = memset_method[best].function; } free( buf1 ); free( buf2 ); } static void vj_frame_copy_job( void *arg ) { int i; vj_task_arg_t *info = (vj_task_arg_t*) arg; #ifdef STRICT_CHECKING assert( task_get_workers() > 0 ); #endif for( i = 0; i < 4; i ++ ) { #ifdef STRICT_CHECKING if( info->strides[i] > 0 ) { assert( info->output[i] != NULL ); assert( info->input[i] != NULL ); } #endif if( info->strides[i] <= 0 || info->output[i] == NULL || info->output[i] == NULL ) continue; veejay_memcpy( info->output[i], info->input[i], info->strides[i] ); } } static void vj_frame_clear_job( void *arg ) { int i; vj_task_arg_t *info = (vj_task_arg_t*) arg; #ifdef STRICT_CHECKING assert( task_get_workers() > 0 ); #endif for( i = 0; i < 4; i ++ ) { #ifdef STRICT_CHECKING if( info->strides[i] > 0 ) { assert( info->input[i] != NULL ); assert( info->output[i] != NULL ); } #endif if( info->strides[i] > 0 ) veejay_memset( info->input[i], info->iparam, info->strides[i] ); } } static void vj_frame_copyN( uint8_t **input, uint8_t **output, int *strides ) { vj_task_run( input, output, NULL, strides,4,(performer_job_routine) &vj_frame_copy_job ); } static void vj_frame_clearN( uint8_t **input, int *strides, unsigned int val ) { vj_task_set_int( val ); vj_task_run( input, input, NULL, strides,3, (performer_job_routine) &vj_frame_clear_job ); } /*test pattern: int len = job->strides[0]; for( i = 0; i < len; i ++ ) img[0][i] = 255 - ( 15 * job->id ); len = job->strides[1]; for( i = 0; i < len; i ++ ) { img[1][i] = 128; img[2][i] = 128; } */ static inline void vj_frame_slow1( const uint8_t *a, const uint8_t *b, uint8_t *dst, const int len, const float frac ) { #ifndef HAVE_ASM_MMX int i; for( i = 0; i < len; i ++ ) { dst[i] = a[i] + ( frac * ( b[i] - a[i] ) ); } #else uint32_t ialpha = (256 * frac); unsigned int i; ialpha |= ialpha << 16; __asm __volatile ("\n\t pxor %%mm6, %%mm6" ::); for (i = 0; i < len; i += 4) { __asm __volatile ("\n\t movq %[alpha], %%mm3" "\n\t movq %[src2], %%mm0" "\n\t psllq $32, %%mm3" "\n\t movq %[alpha], %%mm2" "\n\t movq %[src1], %%mm1" "\n\t por %%mm3, %%mm2" "\n\t punpcklbw %%mm6, %%mm0" "\n\t punpcklbw %%mm6, %%mm1" "\n\t psubsw %%mm1, %%mm0" "\n\t pmullw %%mm2, %%mm0" "\n\t psrlw $8, %%mm0" "\n\t paddb %%mm1, %%mm0" "\n\t packuswb %%mm0, %%mm0\n\t" MOVNTQ" %%mm0, %[dest]\n\t" : [dest] "=m" (*(dst + i)) : [src1] "m" (*(a + i)) , [src2] "m" (*(b + i)) , [alpha] "m" (ialpha)); } #endif } #define ALIGN 8 static void vj_frame_slow_job( void *arg ) { vj_task_arg_t *job = (vj_task_arg_t*) arg; int i,j; uint8_t **img = job->output; const uint8_t **p0_buffer = job->input; const uint8_t **p1_buffer = job->temp; const float frac = job->fparam; for ( i = 0; i < 3; i ++ ) { uint8_t *a = __builtin_assume_aligned(p0_buffer[i],ALIGN); uint8_t *b = __builtin_assume_aligned(p1_buffer[i],ALIGN); uint8_t *d = __builtin_assume_aligned(img[i], ALIGN); const unsigned int len = job->strides[i]; vj_frame_slow1(d,a,b,len,frac ); } } void vj_frame_slow_threaded( uint8_t **p0_buffer, uint8_t **p1_buffer, uint8_t **img, int len, int uv_len,const float frac ) { if( vj_task_available() ) { int strides[4] = { len, uv_len, uv_len, 0 }; vj_task_set_float( frac ); vj_task_run( p0_buffer, img, p1_buffer,strides, 4,(performer_job_routine) &vj_frame_slow_job ); } else { int i; if( uv_len != len ) { for( i = 0; i < len ; i ++ ) { img[0][i] = p0_buffer[0][i] + ( frac * (p1_buffer[0][i] - p0_buffer[0][i])); } for( i = 0; i < uv_len ; i ++ ) { img[1][i] = p0_buffer[1][i] + ( frac * (p1_buffer[1][i] - p0_buffer[1][i])); img[2][i] = p0_buffer[2][i] + ( frac * (p1_buffer[2][i] - p0_buffer[2][i])); } } else { for( i = 0; i < len ; i ++ ) { img[0][i] = p0_buffer[0][i] + ( frac * (p1_buffer[0][i] - p0_buffer[0][i])); img[1][i] = p0_buffer[1][i] + ( frac * (p1_buffer[1][i] - p0_buffer[1][i])); img[2][i] = p0_buffer[2][i] + ( frac * (p1_buffer[2][i] - p0_buffer[2][i])); } } } } void vj_frame_simple_clear( uint8_t **input, int *strides, int v ) { int i; for( i = 0; i < 4; i ++ ) { if( input[i] == NULL || strides[i] == 0 ) continue; veejay_memset( input[i], v , strides[i] ); } } void vj_frame_simple_copy( uint8_t **input, uint8_t **output, int *strides ) { int i; for( i = 0; i < 4; i ++ ) { #ifdef STRICT_CHECKING if( strides[i] > 0 ) { assert( input[i] != NULL ); assert( output[i] != NULL ); } #endif if( input[i] != NULL && output[i] != NULL && strides[i] > 0 ) veejay_memcpy( output[i],input[i], strides[i] ); } } typedef void *(*frame_copy_routine)( uint8_t **input, uint8_t **output, int *strides ); typedef void *(*frame_clear_routine)( uint8_t **input, int *strides, unsigned int val ); frame_copy_routine vj_frame_copy = 0; frame_clear_routine vj_frame_clear = 0; //void *(*vj_frame_copy)( uint8_t **input, uint8_t **output, int *strides ) = 0; //void *(*vj_frame_clear)( uint8_t **input, int *strides, unsigned int val ) = 0; void vj_frame_copy1( uint8_t *input, uint8_t *output, int size ) { uint8_t *in[4] = { input, NULL,NULL,NULL }; uint8_t *ou[4] = { output,NULL,NULL,NULL }; int strides[4] = { size,0,0,0 }; vj_frame_copy( in, ou, strides ); } void vj_frame_clear1( uint8_t *input, unsigned int val, int size ) { uint8_t *in[4] = { input, NULL,NULL,NULL }; int strides[4] = { size,0,0,0 }; vj_frame_clear( in, strides, val ); } int find_best_threaded_memcpy(int w, int h) { uint8_t *src = (uint8_t*) vj_malloc(sizeof(uint8_t) * w * h * 4 ); uint8_t *dst = (uint8_t*) vj_malloc(sizeof(uint8_t) * w * h * 4 ); int planes[4] = { w * h, w * h, w * h , w * h }; uint8_t *source[4] = { src, src + (w*h), src + (w * h * 2), src + (w * h * 3), }; uint8_t *dest[4] = { dst,dst + (w*h), dst + (w*h*2), dst + (w * h * 3)}; memset( src, 0, sizeof(uint8_t) * w * h * 4 ); memset( dst, 0, sizeof(uint8_t) * w * h * 4 ); long c = 1000; long k; unsigned long long stats[c]; unsigned long long sstats[c]; task_init(); int cpus = task_num_cpus(); int preferred_tasks = 1; int warn_user = 0; if( w <= 720 && h <= 480 ) { preferred_tasks = 1; //@ classic, run in 1/4 PAL, low res, fast, keep it outside threadpooling. } else { preferred_tasks = (cpus * 2 ); } char *str2 = getenv( "VEEJAY_MULTITHREAD_TASKS" ); int num_tasks = preferred_tasks; if( str2 != NULL ) { num_tasks = atoi( str2 ); if( num_tasks >= MAX_WORKERS ) { veejay_msg(0, "Maximum number of tasks is %d tasks.", MAX_WORKERS); return -1; } if( num_tasks > 1 ) { veejay_msg(VEEJAY_MSG_DEBUG, "Testing your system ..."); if( task_start( num_tasks ) != num_tasks ) { veejay_msg(0,"Failed to launch %d threads ?!", num_tasks); veejay_msg(0,"Please set env VEEJAY_MULTITHREAD_TASKS=0"); return -1; } for( k = 0; k < c; k ++ ) { unsigned long long t = rdtsc(); vj_frame_copyN( source,dest,planes ); t = rdtsc() - t; stats[k] = t; } int sum = 0,j; for( k = 0; k < c ;k ++ ) sum += stats[k]; unsigned long long best_time = (sum / c ); veejay_msg(VEEJAY_MSG_DEBUG, "Timing results for copying %2.2f MB data with %d thread(s): %2.2f ms", (c * (w*h) *4) /1048576.0f, num_tasks, (float) best_time*0.1f); task_stop( num_tasks ); for( k = 0; k < c; k ++ ) { unsigned long long t = rdtsc(); for( j = 0; j < 4; j ++ ) { veejay_memcpy( dest[j], source[j], planes[j] ); } t = rdtsc() - t; sstats[k] = t; } int ssum = 0; for( k = 0; k < c; k ++ ) ssum += sstats[k]; unsigned long long best_single_time = (ssum/c); veejay_msg(VEEJAY_MSG_DEBUG, "Timing results for copying %2.2f MB data with no multithreading: %2.2f ms", (c * (w*h) *4) /1048576.0f, (float) best_single_time*0.1f); } else { veejay_msg( VEEJAY_MSG_DEBUG, "Not multithreading pixel operations (VEEJAY_MULTITHREAD_TASKS=%d)", num_tasks); } } if( warn_user && num_tasks > 1){ veejay_msg(VEEJAY_MSG_WARNING, "(Experimental) Enabling multicore support!"); } if( num_tasks > 1 ) { veejay_msg( VEEJAY_MSG_INFO, "Using %d threads scheduled over %d cpus in performer.", num_tasks, cpus ); veejay_msg( VEEJAY_MSG_DEBUG,"Use envvar VEEJAY_MULTITHREAD_TASKS= to customize."); vj_frame_copy = (frame_copy_routine) vj_frame_copyN; vj_frame_clear= (frame_clear_routine) vj_frame_clearN; } else { vj_frame_copy = (frame_copy_routine) vj_frame_simple_copy; vj_frame_clear = (frame_clear_routine) vj_frame_simple_clear; } free(src); free(dst); return num_tasks; }