| 989 | } |
| 990 | |
| 991 | void blmoveGenericCommand(client *c, int wherefrom, int whereto, mstime_t timeout) { |
| 992 | robj *key = lookupKeyWrite(c->db, c->argv[1]); |
| 993 | if (checkType(c,key,OBJ_LIST)) return; |
| 994 | |
| 995 | if (key == NULL) { |
| 996 | if (c->flags & CLIENT_DENY_BLOCKING) { |
| 997 | /* Blocking against an empty list when blocking is not allowed |
| 998 | * returns immediately. */ |
| 999 | addReplyNull(c); |
| 1000 | } else { |
| 1001 | /* The list is empty and the client blocks. */ |
| 1002 | struct listPos pos = {wherefrom, whereto}; |
| 1003 | blockForKeys(c,BLOCKED_LIST,c->argv + 1,1,timeout,c->argv[2],&pos,NULL); |
| 1004 | } |
| 1005 | } else { |
| 1006 | /* The list exists and has elements, so |
| 1007 | * the regular lmoveCommand is executed. */ |
| 1008 | serverAssertWithInfo(c,key,listTypeLength(key) > 0); |
| 1009 | lmoveGenericCommand(c,wherefrom,whereto); |
| 1010 | } |
| 1011 | } |
| 1012 | |
| 1013 | /* BLMOVE <source> <destination> (LEFT|RIGHT) (LEFT|RIGHT) <timeout> */ |
| 1014 | void blmoveCommand(client *c) { |
no test coverage detected