Lines Matching refs:cs
4557 migrateCachedSocket *cs; in migrateGetSocket() local
4563 cs = dictFetchValue(server.migrate_cached_sockets,name); in migrateGetSocket()
4564 if (cs) { in migrateGetSocket()
4566 cs->last_use_time = server.unixtime; in migrateGetSocket()
4567 return cs; in migrateGetSocket()
4574 cs = dictGetVal(de); in migrateGetSocket()
4575 close(cs->fd); in migrateGetSocket()
4576 zfree(cs); in migrateGetSocket()
4601 cs = zmalloc(sizeof(*cs)); in migrateGetSocket()
4602 cs->fd = fd; in migrateGetSocket()
4603 cs->last_dbid = -1; in migrateGetSocket()
4604 cs->last_use_time = server.unixtime; in migrateGetSocket()
4605 dictAdd(server.migrate_cached_sockets,name,cs); in migrateGetSocket()
4606 return cs; in migrateGetSocket()
4612 migrateCachedSocket *cs; in migrateCloseSocket() local
4617 cs = dictFetchValue(server.migrate_cached_sockets,name); in migrateCloseSocket()
4618 if (!cs) { in migrateCloseSocket()
4623 close(cs->fd); in migrateCloseSocket()
4624 zfree(cs); in migrateCloseSocket()
4634 migrateCachedSocket *cs = dictGetVal(de); in migrateCloseTimedoutSockets() local
4636 if ((server.unixtime - cs->last_use_time) > MIGRATE_SOCKET_CACHE_TTL) { in migrateCloseTimedoutSockets()
4637 close(cs->fd); in migrateCloseTimedoutSockets()
4638 zfree(cs); in migrateCloseTimedoutSockets()
4651 migrateCachedSocket *cs; in migrateCommand() local
4728 cs = migrateGetSocket(c,c->argv[1],c->argv[2],timeout); in migrateCommand()
4729 if (cs == NULL) { in migrateCommand()
4737 int select = cs->last_dbid != dbid; /* Should we emit SELECT? */ in migrateCommand()
4785 nwritten = syncWrite(cs->fd,buf+pos,towrite,timeout); in migrateCommand()
4798 if (select && syncReadLine(cs->fd, buf1, sizeof(buf1), timeout) <= 0) in migrateCommand()
4809 if (syncReadLine(cs->fd, buf2, sizeof(buf2), timeout) <= 0) { in migrateCommand()
4816 cs->last_dbid = -1; in migrateCommand()
4868 cs->last_dbid = dbid; in migrateCommand()