Fossil

Diff
Login

Diff

Differences From Artifact [cc749b7254]:

To Artifact [0e2cdc621f]:


846
847
848
849
850
851
852
853
854
855
856
857





858
859

860
861
862
863


864
865
866
867
868
869
870
871
872





873

874
875
876
877
878
879
880
846
847
848
849
850
851
852





853
854
855
856
857
858

859




860
861
862
863
864
865
866
867



868
869
870
871
872
873
874
875
876
877
878
879
880
881







-
-
-
-
-
+
+
+
+
+

-
+
-
-
-
-
+
+






-
-
-
+
+
+
+
+

+







** routine is called by the client.
**
** Records are pushed to the server if pushFlag is true.  Records
** are pulled if pullFlag is true.  A full sync occurs if both are
** true.
*/
void client_sync(
  int pushFlag,          /* True to do a push (or a sync) */
  int pullFlag,          /* True to do a pull (or a sync) */
  int cloneFlag,         /* True if this is a clone */
  int configRcvMask,     /* Receive these configuration items */
  int configSendMask     /* Send these configuration items */
  int pushFlag,           /* True to do a push (or a sync) */
  int pullFlag,           /* True to do a pull (or a sync) */
  int cloneFlag,          /* True if this is a clone */
  int configRcvMask,      /* Receive these configuration items */
  int configSendMask      /* Send these configuration items */
){
  int go = 1;        /* Loop until zero */
  int go = 1;             /* Loop until zero */
  const char *zSCode = db_get("server-code", "x");
  const char *zPCode = db_get("project-code", 0);
  int nCard = 0;         /* Number of cards sent or received */
  int nCycle = 0;        /* Number of round trips to the server */
  int nCard = 0;          /* Number of cards sent or received */
  int nCycle = 0;         /* Number of round trips to the server */
  int size;               /* Size of a config value */
  int nFileSend = 0;
  int origConfigRcvMask;  /* Original value of configRcvMask */
  int nFileRecv;          /* Number of files received */
  int mxPhantomReq = 200; /* Max number of phantoms to request per comm */
  const char *zCookie;    /* Server cookie */
  Blob send;        /* Text we are sending to the server */
  Blob recv;        /* Reply we got back from the server */
  Xfer xfer;        /* Transfer data */
  Blob send;              /* Text we are sending to the server */
  Blob recv;              /* Reply we got back from the server */
  Xfer xfer;              /* Transfer data */
  const char *zSCode = db_get("server-code", "x");
  const char *zPCode = db_get("project-code", 0);

  socket_global_init();
  memset(&xfer, 0, sizeof(xfer));
  xfer.pIn = &recv;
  xfer.pOut = &send;
  xfer.mxSend = db_get_int("max-upload", 250000);

  assert( pushFlag | pullFlag | cloneFlag | configRcvMask | configSendMask );
  assert( !g.urlIsFile );          /* This only works for networking */
1174
1175
1176
1177
1178
1179
1180
1181


1182
1183
1184
1175
1176
1177
1178
1179
1180
1181

1182
1183
1184
1185
1186







-
+
+



    /* If we have one or more files queued to send, then go
    ** another round 
    */
    if( xfer.nFileSent+xfer.nDeltaSent>0 ){
      go = 1;
    }
  };
  http_close();
  transport_close();
  socket_global_shutdown();
  db_multi_exec("DROP TABLE onremote");
  db_end_transaction(0);
}