Lines Matching refs:conn_state
197 static ConnState *conn_state;
681 /* Handle a transaction for conn_state[conn_no]. There is incoming
685 leaves conn_state[conn_no] in a not-in-use state. */
693 assert(conn_state[conn_no].in_use);
697 Int sd = conn_state[conn_no].conn_sd;
740 if (conn_state[conn_no].file_fd == 0) {
745 conn_state[conn_no].file_fd,
746 conn_state[conn_no].file_size);
758 if (conn_state[conn_no].file_fd != 0) {
768 conn_count, conn_state[conn_no].session_id, filename );
786 conn_state[conn_no].file_fd = fd;
787 conn_state[conn_no].file_size = stat_buf.st_size;
789 res = mk_Frame_le64_le64("OPOK", conn_state[conn_no].session_id,
790 conn_state[conn_no].file_size);
792 conn_count, conn_state[conn_no].session_id, filename );
805 if (req_session_id != conn_state[conn_no].session_id) {
811 if (ok && conn_state[conn_no].file_fd == 0) {
819 if (ok && req_len + req_offset > conn_state[conn_no].file_size) {
828 size_t nRead = pread(conn_state[conn_no].file_fd,
863 conn_state[conn_no].stats_n_rdok_frames++;
864 conn_state[conn_no].stats_n_read_unz_bytes += req_len;
865 conn_state[conn_no].stats_n_read_z_bytes += zLen;
915 if (conn_state[conn_no].conn_sd > 0)
916 close(conn_state[conn_no].conn_sd);
917 if (conn_state[conn_no].file_fd > 0)
918 close(conn_state[conn_no].file_fd);
920 if (conn_state[conn_no].stats_n_rdok_frames > 0) {
923 conn_count, conn_state[conn_no].session_id,
924 conn_state[conn_no].stats_n_rdok_frames,
925 conn_state[conn_no].stats_n_read_unz_bytes / 1000000,
926 conn_state[conn_no].stats_n_read_z_bytes / 1000000,
927 (double)conn_state[conn_no].stats_n_read_unz_bytes
928 / (double)conn_state[conn_no].stats_n_read_z_bytes);
930 conn_count, conn_state[conn_no].session_id);
935 memset(&conn_state[conn_no], 0, sizeof(conn_state[conn_no]));
1098 conn_state = my_malloc(M_CONNECTIONS * sizeof conn_state[0]);
1104 memset(conn_state, 0, M_CONNECTIONS * sizeof conn_state[0]);
1171 if (!conn_state[i].in_use)
1186 memset(&conn_state[i], 0, sizeof(conn_state[i]));
1187 conn_state[i].in_use = True;
1188 conn_state[i].conn_sd = new_sd;
1189 conn_state[i].file_fd = 0; /* not known yet */
1190 conn_state[i].session_id = next_session_id++;
1205 entries in conn_state. */
1213 if (!conn_state[i].in_use)
1215 assert(conn_state[i].conn_sd > 2);
1216 tmp_pollfd[j].fd = conn_state[i].conn_sd;
1239 figure out which conn_state[] entry that corresponds
1255 if (conn_state[i].stats_n_rdok_frames > 0
1256 && (conn_state[i].stats_n_rdok_frames % 1000) == 0) {
1259 conn_count, conn_state[conn_no].session_id,
1260 conn_state[conn_no].stats_n_rdok_frames,
1261 conn_state[conn_no].stats_n_read_unz_bytes / 1000000,
1262 conn_state[conn_no].stats_n_read_z_bytes / 1000000);
