| 1914 | } |
| 1915 | |
| 1916 | char *receiveSynchronousResponse(connection *conn) { |
| 1917 | char buf[256]; |
| 1918 | /* Read the reply from the server. */ |
| 1919 | if (connSyncReadLine(conn,buf,sizeof(buf),server.repl_syncio_timeout*1000) == -1) |
| 1920 | { |
| 1921 | return sdscatprintf(sdsempty(),"-Reading from master: %s", |
| 1922 | strerror(errno)); |
| 1923 | } |
| 1924 | server.repl_transfer_lastio = server.unixtime; |
| 1925 | return sdsnew(buf); |
| 1926 | } |
| 1927 | |
| 1928 | /* Send a pre-formatted multi-bulk command to the connection. */ |
| 1929 | char* sendCommandRaw(connection *conn, sds cmd) { |
no test coverage detected