Replace memcpy with memmove

Author: knizhnik

contrib/pg_dtm/sockhub/sockhub.c

@@ -367,7 +367,7 @@ void ShubLoop(Shub* shub)
                                 }
                             }
                             /* Move partly fetched message header (if any) to the beginning of buffer */
-                            memcpy(shub->out_buffer, shub->out_buffer + pos, available - pos);
+                            memmove(shub->out_buffer, shub->out_buffer + pos, available - pos);
                             shub->out_buffer_used = available - pos;
                         } else { /* receive request from client */
                             int chan = i;
@@ -454,7 +454,7 @@ void ShubLoop(Shub* shub)
                                         shub->params->error_handler("Failed to write to inet socket", SHUB_RECOVERABLE_ERROR);
                                         reconnect(shub);
                                     }
-                                    memcpy(shub->in_buffer, shub->in_buffer + pos, available -= pos);
+                                    memmove(shub->in_buffer, shub->in_buffer + pos, available -= pos);
                                     pos = 0;
                                 } else {
                                     available -= pos;

contrib/pg_dtm/sockhub/start-async-clients.sh

@@ -1,4 +1,4 @@
-n_clients=10
+n_clients=8
 n_iters=10000
 pkill -9 sockub
 pkill -9 test-async-client

contrib/pg_dtm/sockhub/test-server.c

@@ -93,7 +93,7 @@ int main(int argc, char* argv[])
                                 if (msg->hdr.code == MSG_DISCONNECT) { 
                                     assert(msg->hdr.size == 0);
                                     printf("Disconnect client [%d:%d]\n", i, msg->hdr.chan);
-                                    memcpy(buf + pos, buf + pos + sizeof(ShubMessageHdr), available - pos - sizeof(ShubMessageHdr));
+                                    memmove(buf + pos, buf + pos + sizeof(ShubMessageHdr), available - pos - sizeof(ShubMessageHdr));
                                     available -= sizeof(ShubMessageHdr);
                                 } else {                                     
                                     assert(sizeof(ShubMessageHdr) + msg->hdr.size == sizeof(Message));