Lines Matching defs:conn_state
176 static ConnState conn_state[M_CONNECTIONS];
660 /* Handle a transaction for conn_state[conn_no]. There is incoming
664 leaves conn_state[conn_no] in a not-in-use state. */
672 assert(conn_state[conn_no].in_use);
676 Int sd = conn_state[conn_no].conn_sd;
719 if (conn_state[conn_no].file_fd == 0) {
724 conn_state[conn_no].file_fd,
725 conn_state[conn_no].file_size);
737 if (conn_state[conn_no].file_fd != 0) {
747 conn_count, conn_state[conn_no].session_id, filename );
765 conn_state[conn_no].file_fd = fd;
766 conn_state[conn_no].file_size = stat_buf.st_size;
768 res = mk_Frame_le64_le64("OPOK", conn_state[conn_no].session_id,
769 conn_state[conn_no].file_size);
771 conn_count, conn_state[conn_no].session_id, filename );
784 if (req_session_id != conn_state[conn_no].session_id) {
790 if (ok && conn_state[conn_no].file_fd == 0) {
798 if (ok && req_len + req_offset > conn_state[conn_no].file_size) {
807 size_t nRead = pread(conn_state[conn_no].file_fd,
842 conn_state[conn_no].stats_n_rdok_frames++;
843 conn_state[conn_no].stats_n_read_unz_bytes += req_len;
844 conn_state[conn_no].stats_n_read_z_bytes += zLen;
894 if (conn_state[conn_no].conn_sd > 0)
895 close(conn_state[conn_no].conn_sd);
896 if (conn_state[conn_no].file_fd > 0)
897 close(conn_state[conn_no].file_fd);
899 if (conn_state[conn_no].stats_n_rdok_frames > 0) {
902 conn_count, conn_state[conn_no].session_id,
903 conn_state[conn_no].stats_n_rdok_frames,
904 conn_state[conn_no].stats_n_read_unz_bytes / 1000000,
905 conn_state[conn_no].stats_n_read_z_bytes / 1000000,
906 (double)conn_state[conn_no].stats_n_read_unz_bytes
907 / (double)conn_state[conn_no].stats_n_read_z_bytes);
909 conn_count, conn_state[conn_no].session_id);
914 memset(&conn_state[conn_no], 0, sizeof(conn_state[conn_no]));
1060 memset(&conn_state, 0, sizeof(conn_state));
1127 if (!conn_state[i].in_use)
1140 memset(&conn_state[i], 0, sizeof(conn_state[i]));
1141 conn_state[i].in_use = True;
1142 conn_state[i].conn_sd = new_sd;
1143 conn_state[i].file_fd = 0; /* not known yet */
1144 conn_state[i].session_id = next_session_id++;
1156 entries in conn_state. */
1160 if (!conn_state[i].in_use)
1162 assert(conn_state[i].conn_sd > 2);
1163 tmp_pollfd[j].fd = conn_state[i].conn_sd;
1186 figure out which conn_state[] entry that corresponds
1202 if (conn_state[i].stats_n_rdok_frames > 0
1203 && (conn_state[i].stats_n_rdok_frames % 1000) == 0) {
1206 conn_count, conn_state[conn_no].session_id,
1207 conn_state[conn_no].stats_n_rdok_frames,
1208 conn_state[conn_no].stats_n_read_unz_bytes / 1000000,
1209 conn_state[conn_no].stats_n_read_z_bytes / 1000000);
