@@ -7,7 +7,7 @@ all: imgmover imgmover.exe

 imgmover: imgmover.c roboto_regular.c

 	$(CC) $(CFLAGS) -Iexternal/raylib/include/ imgmover.c external/raylib/libraylib.a -lm $(LDFLAGS) -o imgmover

-imgmover.exe: imgmover.c roboto_regular.c

+imgmover.exe: imgmover.c win32_pipe.c roboto_regular.c

 	sh -c "if [ ! -e test-icon_256x256.png ] ; then convert -size 256x256 xc:white test-icon_256x256.png ; fi"

 	toolchain-zig/compile.sh imgmover.c -c -o imgmover-windows.o

 	toolchain-zig/compile.sh win32_pipe.c -c -o win32_pipe-windows.o

@@ -33,6 +33,7 @@

  *      20250329 Background loading of thumbnails.

  *      20250330 Refine background loading.

  *      20250413 Background loading for windows target.

+ *      20250420 Fix background loading for windows target.

  *

  * Author: Dario Rodriguez dario@darionomono.com

  * (c) Dario Rodriguez 2025

@@ -48,6 +49,9 @@

 #include <sys/stat.h>

 #include <sys/time.h>

 #include <pthread.h>

+#if !defined(__linux__) && !defined(ANDROID)

+#include "win32_pipe.h"

+#endif

 #include "raylib.h"

 #include "roboto_regular.c"

@@ -328,6 +332,8 @@ int bg_freeunmarked(bg_t *bg);

 void *bg_thread(void *);

 static int mypipe(int fds[2]);

+static int mypiperead(int fd, char *buf, int count);

+static int mypipewrite(int fd, char *buf, int count);

 int

 main(int argc, char *argv[])

@@ -345,6 +351,9 @@ main(int argc, char *argv[])

         int is_scrolling;

         int leftscrollposstart;

         char *sel_menu,*sel_submenu;

+#if !defined(__linux__) && !defined(ANDROID)

+        win32pipe_init();

+#endif

         if((im=im_init("Fichero\nAjustes\nSalir\n\nEditar\nNuevo directorio\n\nAyuda\nInformación sobre el programa\n\n",ROOTDIR))==NULL) {

                 return(1);

         }

@@ -470,6 +479,9 @@ fprintf(stderr,"SELECTED: \"%s\"->\"%s\"\n",sel_menu,sel_submenu);

                 EndDrawing();

         }

         im_free(im),im=NULL;

+#if !defined(__linux__) && !defined(ANDROID)

+        win32pipe_fini();

+#endif

         return(0);

 }

@@ -656,6 +668,10 @@ im_menubar_mouse(menubar_t *menubar, Vector2 mousepos, int lmbpressed, int lmbre

         *sel_menu=NULL;

         *sel_submenu=NULL;

         flag_outsideall=1;

+#if 1

+if(lmbpressed || lmbdown)

+ fprintf(stderr,"in_menubar_mouse: lmbpressed:%i lmbdown:%i\n",lmbpressed,lmbdown);

+#endif

         for(i=0;i<menubar->sizemenudata;i++) {

                 int insidetitle,currentoption;

                 insidetitle=is_imutil_insidexywh(mousepos,&(menubar->menudata[i]->xywh),0);

@@ -1877,8 +1893,17 @@ bg_free(bg_t *bg)

                 return; /* nothing to do */

         if(bg->flag_threadstarted) {

                 char dummy=1;

-                write(bg->pipe[WR],&dummy,1);

+#if 1

+fprintf(stderr,"bg_free: notifying thread to exit\n");

+#endif

+                mypipewrite(bg->pipe[WR],&dummy,1);

+#if 1

+fprintf(stderr,"bg_free: joining thread\n");

+#endif

                 pthread_join(bg->thread,NULL);

+#if 1

+fprintf(stderr,"bg_free: thread joined OK\n");

+#endif

                 bg->flag_threadstarted=0;

         }

         if(bg->pipe[0]!=-1)

@@ -1934,7 +1959,7 @@ bg_add(bg_t *bg, char *path)

 {

         int i;

         bgload_t *bgload;

-        int dummy;

+        char dummy;

         if(bg==NULL)

                 return(-1);

         for(i=0,bgload=bg->bgload;i<bg->sizebgload;i++,bgload++) {

@@ -1942,7 +1967,7 @@ bg_add(bg_t *bg, char *path)

                         bgload->is_todo=1;

                         bgload->has_mark=1;

                         dummy=0;

-                        write(bg->pipe[WR],&dummy,1);

+                        mypipewrite(bg->pipe[WR],&dummy,1);

                         return(0); /* already on list */

                 }

         }

@@ -1955,7 +1980,7 @@ bg_add(bg_t *bg, char *path)

                         bgload->has_mark=1;

                         dummy=0;

                         bgload->lended_to_thread=1;

-                        write(bg->pipe[WR],&dummy,1);

+                        mypipewrite(bg->pipe[WR],&dummy,1);

                         return(0); /* added to list */

                 }

         }

@@ -1998,7 +2023,10 @@ bg_thread(void *parambg)

         int i;

         bgload_t *bgload;

         while(1) {

-                read(bg->pipe[RD],&dummy,1);

+                mypiperead(bg->pipe[RD],&dummy,1);

+#if 1

+fprintf(stderr,"Thread received byte: %i\n",(int)((unsigned char)dummy));

+#endif

                 if(dummy!=0)

                         break; /* was told to exit */

                 for(i=0,bgload=bg->bgload;i<bg->sizebgload;i++,bgload++) {

@@ -2019,20 +2047,45 @@ bg_thread(void *parambg)

                 }

         }

         pthread_exit(NULL);

+        return(NULL);

 }

 #if !defined(__linux__) && !defined(ANDROID)

-#include "win32_pipe.h"

 static int

 mypipe(int fds[2])

 {

-        return(win32_pipe(fds));

+        return(win32pipe_pipe(fds));

+}

+

+static int

+mypiperead(int fd, char *buf, int count)

+{

+        return(win32pipe_read(fd,buf,count));

+}

+

+static int

+mypipewrite(int fd, char *buf, int count)

+{

+        return(win32pipe_write(fd,buf,count));

 }

 #else

 static int

-mypipe(char fds[2])

+mypipe(int fds[2])

 {

         return(pipe(fds));

 }

+

+static int

+mypiperead(int fd, char *buf, int count)

+{

+        return(read(fd,buf,count));

+}

+

+static int

+mypipewrite(int fd, char *buf, int count)

+{

+        return(write(fd,buf,count));

+}

 #endif

+

@@ -1,4 +1,20 @@

+#if !defined(__linux__) && !defined(ANDROID)

 #include <winsock2.h>

+typedef SOCKET socket_t; /* https://stackoverflow.com/questions/10817252/why-is-invalid-socket-defined-as-0-in-winsock2-h-c */

+#ifndef SHUT_WR

+#define SHUT_WR SD_SEND

+#endif

+#ifndef SHUT_RD

+#define SHUT_RD SD_RECEIVE

+#endif

+#define close(s) closesocket(s)

+#else

+#include <sys/socket.h>

+#include <netinet/in.h>

+#include <fcntl.h>

+typedef int socket_t;

+#define INVALID_SOCKET -1

+#endif

 #ifndef FILLIPV4ADDR

 #define FILLIPV4ADDR(a,family,addr,port) \

@@ -8,37 +24,66 @@

                 s.sin_port=htons(port)

 #endif

-#ifndef SHUT_WR

-#define SHUT_WR SD_SEND

+

+#if 1

+#include <stdio.h>

 #endif

-#ifndef SHUT_RD

-#define SHUT_RD SD_RECEIVE

+static int *

+win32pipe_initvalue(void)

+{

+        static int init=0;

+        return(&init);

+}

+

+int

+win32pipe_init(void)

+{

+        int *init;

+        init=win32pipe_initvalue();

+        if(*init!=0)

+                return(0);

+        *init=1;

+#if !defined(__linux__) && !defined(ANDROID)

+        {

+                WSADATA wsaData;

+                return(WSAStartup(0x202,&wsaData));

+        }

+#else

+        return(0);

 #endif

+}

-#define close(s) closesocket(s)

+void

+win32pipe_fini(void)

+{

+        int *init;

+        init=win32pipe_initvalue();

+        if(*init==0)

+                return;

+#if !defined(__linux__) && !defined(ANDROID)

+        WSACleanup();

+#endif

+        *init=0;

+}

 int

-win32_pipe(int fds[2])

+win32pipe_pipe(int fds[2])

 {

-        int serverfd,workfd,clientfd;

-        struct sockaddr_in c,s;

-        int sizes,sizec;

+        socket_t serverfd,workfd,clientfd;

+        struct sockaddr_in s;

+        int sizes;

+        win32pipe_init();

         FILLIPV4ADDR(s,AF_INET,htonl(INADDR_ANY),0);

-        serverfd=workfd=clientfd=-1;

-        if((serverfd=socket(AF_INET,SOCK_STREAM,0))==-1

+        serverfd=workfd=clientfd=INVALID_SOCKET;

+        if((serverfd=socket(AF_INET,SOCK_STREAM,0))==INVALID_SOCKET

           || bind(serverfd,(struct sockaddr *)&s,sizeof(s))!=0

-          || listen(serverfd,1)==-1

+          || listen(serverfd,4)==-1

           || (sizes=sizeof(s))!=sizeof(s)

           || getsockname(serverfd,(struct sockaddr *)&s,&sizes)==-1

-          || memcpy(&c,&s,sizeof(c))==NULL

-          || (clientfd=socket(AF_INET,SOCK_STREAM,0))==-1

-          || connect(clientfd,(struct sockaddr *)&c,sizeof(c))==-1

-          || (sizes=sizeof(s))!=sizeof(s)

+          || (clientfd=socket(AF_INET,SOCK_STREAM,0))==INVALID_SOCKET

+          || connect(clientfd,(struct sockaddr *)&s,sizeof(s))==-1

           || (workfd=accept(serverfd,(struct sockaddr *)&s,&sizes))==-1

-          || (sizec=sizeof(c))!=sizeof(c)

-          || getsockname(workfd,(struct sockaddr *)&c,&sizec)==-1

-          || memcmp(&c,&s,sizeof(c))!=0

         ) {

                 if(serverfd!=-1)

                         close(serverfd),serverfd=-1;

@@ -46,7 +91,14 @@ win32_pipe(int fds[2])

                         close(clientfd),clientfd=-1;

                 if(workfd!=-1)

                         close(workfd),workfd=-1;

+#if 1

+fprintf(stderr,"win32_pipe error creating socket\n");

+#endif

+                return(-1);

         }

+#if 1

+fprintf(stderr,"win32_pipe socket generated\n");

+#endif

         close(serverfd),serverfd=-1;

         shutdown(workfd,SHUT_WR);

         shutdown(clientfd,SHUT_RD);

@@ -55,3 +107,16 @@ win32_pipe(int fds[2])

         return(0);

 }

+int

+win32pipe_read(int fd, char *buf, int count)

+{

+        return(recv(fd,buf,count,0));

+}

+

+int

+win32pipe_write(int fd, char *buf, int count)

+{

+        return(send(fd,buf,count,0));

+}

+

+

@@ -1,2 +1,7 @@

+int win32pipe_init(void);

+void win32pipe_fini(void);

+int win32pipe_pipe(int fds[2]);

+int win32pipe_read(int fd, char *buf, int count);

+int win32pipe_write(int fd, char *buf, int count);

+

-int win32_pipe(int fds[2]);