正在显示
2 个修改的文件
包含
2 行增加
和
2 行删除
| @@ -304,7 +304,7 @@ int SrsKafkaCache::flush(SrsKafkaPartition* partition, int key, SrsKafkaPartitio | @@ -304,7 +304,7 @@ int SrsKafkaCache::flush(SrsKafkaPartition* partition, int key, SrsKafkaPartitio | ||
| 304 | } | 304 | } |
| 305 | 305 | ||
| 306 | // remove the messages from cache. | 306 | // remove the messages from cache. |
| 307 | - if (pc->size() == nb_msgs) { | 307 | + if ((int)pc->size() == nb_msgs) { |
| 308 | pc->clear(); | 308 | pc->clear(); |
| 309 | } else { | 309 | } else { |
| 310 | pc->erase(pc->begin(), pc->begin() + nb_msgs); | 310 | pc->erase(pc->begin(), pc->begin() + nb_msgs); |
| @@ -723,7 +723,7 @@ int SrsServer::acquire_pid_file() | @@ -723,7 +723,7 @@ int SrsServer::acquire_pid_file() | ||
| 723 | 723 | ||
| 724 | // write the pid | 724 | // write the pid |
| 725 | string pid = srs_int2str(getpid()); | 725 | string pid = srs_int2str(getpid()); |
| 726 | - if (write(fd, pid.c_str(), pid.length()) != pid.length()) { | 726 | + if (write(fd, pid.c_str(), pid.length()) != (int)pid.length()) { |
| 727 | ret = ERROR_SYSTEM_PID_WRITE_FILE; | 727 | ret = ERROR_SYSTEM_PID_WRITE_FILE; |
| 728 | srs_error("write our pid error! pid=%s file=%s ret=%#x", pid.c_str(), pid_file.c_str(), ret); | 728 | srs_error("write our pid error! pid=%s file=%s ret=%#x", pid.c_str(), pid_file.c_str(), ret); |
| 729 | return ret; | 729 | return ret; |
-
请 注册 或 登录 后发表评论