| 3085 | } |
| 3086 | |
| 3087 | char *receiveSynchronousResponse(redisMaster *mi, connection *conn) { |
| 3088 | char buf[256]; |
| 3089 | /* Read the reply from the server. */ |
| 3090 | if (connSyncReadLine(conn,buf,sizeof(buf),g_pserver->repl_syncio_timeout*1000) == -1) |
| 3091 | { |
| 3092 | return sdscatprintf(sdsempty(),"-Reading from master: %s", |
| 3093 | strerror(errno)); |
| 3094 | } |
| 3095 | mi->repl_transfer_lastio = g_pserver->unixtime; |
| 3096 | return sdsnew(buf); |
| 3097 | } |
| 3098 | |
| 3099 | /* Send a pre-formatted multi-bulk command to the connection. */ |
| 3100 | char* sendCommandRaw(connection *conn, sds cmd) { |
no test coverage detected