Diff for /qemu/migration-tcp.c between versions 1.1.1.2 and 1.1.1.3

version 1.1.1.2, 2018/04/24 17:20:15 version 1.1.1.3, 2018/04/24 17:33:40
Line 76  static void tcp_wait_for_connect(void *o Line 76  static void tcp_wait_for_connect(void *o
     }      }
 }  }
   
 MigrationState *tcp_start_outgoing_migration(const char *host_port,  MigrationState *tcp_start_outgoing_migration(Monitor *mon,
                                                const char *host_port,
                                              int64_t bandwidth_limit,                                               int64_t bandwidth_limit,
                                              int detach)                                               int detach,
                                                int blk,
                                                int inc)
 {  {
     struct sockaddr_in addr;      struct sockaddr_in addr;
     FdMigrationState *s;      FdMigrationState *s;
Line 96  MigrationState *tcp_start_outgoing_migra Line 99  MigrationState *tcp_start_outgoing_migra
     s->mig_state.get_status = migrate_fd_get_status;      s->mig_state.get_status = migrate_fd_get_status;
     s->mig_state.release = migrate_fd_release;      s->mig_state.release = migrate_fd_release;
   
       s->mig_state.blk = blk;
       s->mig_state.shared = inc;
   
     s->state = MIG_STATE_ACTIVE;      s->state = MIG_STATE_ACTIVE;
     s->mon_resume = NULL;      s->mon = NULL;
     s->bandwidth_limit = bandwidth_limit;      s->bandwidth_limit = bandwidth_limit;
     s->fd = socket(PF_INET, SOCK_STREAM, 0);      s->fd = qemu_socket(PF_INET, SOCK_STREAM, 0);
     if (s->fd == -1) {      if (s->fd == -1) {
         qemu_free(s);          qemu_free(s);
         return NULL;          return NULL;
Line 107  MigrationState *tcp_start_outgoing_migra Line 113  MigrationState *tcp_start_outgoing_migra
   
     socket_set_nonblock(s->fd);      socket_set_nonblock(s->fd);
   
     if (!detach)      if (!detach) {
         migrate_fd_monitor_suspend(s);          migrate_fd_monitor_suspend(s, mon);
       }
   
     do {      do {
         ret = connect(s->fd, (struct sockaddr *)&addr, sizeof(addr));          ret = connect(s->fd, (struct sockaddr *)&addr, sizeof(addr));
Line 139  static void tcp_accept_incoming_migratio Line 146  static void tcp_accept_incoming_migratio
     int c, ret;      int c, ret;
   
     do {      do {
         c = accept(s, (struct sockaddr *)&addr, &addrlen);          c = qemu_accept(s, (struct sockaddr *)&addr, &addrlen);
     } while (c == -1 && socket_error() == EINTR);      } while (c == -1 && socket_error() == EINTR);
   
     dprintf("accepted migration\n");      dprintf("accepted migration\n");
Line 186  int tcp_start_incoming_migration(const c Line 193  int tcp_start_incoming_migration(const c
         return -EINVAL;          return -EINVAL;
     }      }
   
     s = socket(PF_INET, SOCK_STREAM, 0);      s = qemu_socket(PF_INET, SOCK_STREAM, 0);
     if (s == -1)      if (s == -1)
         return -socket_error();          return -socket_error();
   

Removed from v.1.1.1.2  
changed lines
  Added in v.1.1.1.3


unix.superglobalmegacorp.com