43:   "no CSI structure available",
	44:   "level 2 halted",
	45:   "resource deadlock avoided",
	46:   "no locks available",
	50:   "invalid exchange",
	51:   "invalid request descriptor",
	52:   "exchange full",
	53:   "no anode",
	54:   "invalid request code",
	55:   "invalid slot",
	56:   "file locking deadlock error",
	59:   "bad font file format",
	60:   "device not a stream",

	43:   "no CSI structure available",
	44:   "level 2 halted",
	45:   "resource deadlock avoided",
	46:   "no locks available",
	50:   "invalid exchange",
	51:   "invalid request descriptor",
	52:   "exchange full",
	53:   "no anode",
	54:   "invalid request code",
	55:   "invalid slot",
	56:   "file locking deadlock error",
	59:   "bad font file format",
	60:   "device not a stream",

	43:   "no CSI structure available",
	44:   "level 2 halted",
	45:   "resource deadlock avoided",
	46:   "no locks available",
	50:   "invalid exchange",
	51:   "invalid request descriptor",
	52:   "exchange full",
	53:   "no anode",
	54:   "invalid request code",
	55:   "invalid slot",
	56:   "file locking deadlock error",
	59:   "bad font file format",
	60:   "device not a stream",

  }

  public void testCustomScheduler_deadlock() throws InterruptedException, BrokenBarrierException {
    final CyclicBarrier inGetNextSchedule = new CyclicBarrier(2);
    // This will flakily deadlock, so run it multiple times to increase the flake likelihood
    for (int i = 0; i < 1000; i++) {
      Service service =
          new AbstractScheduledService() {
            @Override

  }

  public void testCustomScheduler_deadlock() throws InterruptedException, BrokenBarrierException {
    final CyclicBarrier inGetNextSchedule = new CyclicBarrier(2);
    // This will flakily deadlock, so run it multiple times to increase the flake likelihood
    for (int i = 0; i < 1000; i++) {
      Service service =
          new AbstractScheduledService() {
            @Override

		t.Run(tt.Name, func(t *testing.T) {
			r, w := net.Pipe()
			go w.Write([]byte(tt.in))
			var val any

			// If Decode reads beyond what w.Write writes above,
			// it will block, and the test will deadlock.
			if err := NewDecoder(r).Decode(&val); err != nil {
				t.Errorf("%s: NewDecoder(%s).Decode error: %v", tt.Where, tt.in, err)
			}
			r.Close()
			w.Close()
		})
	}
}

	29:  "illegal seek",
	30:  "read-only file system",
	31:  "too many links",
	32:  "broken pipe",
	33:  "numerical argument out of domain",
	34:  "numerical result out of range",
	35:  "resource deadlock avoided",
	36:  "file name too long",
	37:  "no locks available",
	38:  "function not implemented",
	39:  "directory not empty",
	40:  "too many levels of symbolic links",
	42:  "no message of desired type",

	// from the SchedulingQueue.
	// If there are no new pods to schedule, it will be hanging there
	// and if done in this goroutine it will be blocking closing
	// SchedulingQueue, in effect causing a deadlock on shutdown.
	go wait.UntilWithContext(ctx, sched.ScheduleOne, 0)

	<-ctx.Done()
	sched.SchedulingQueue.Close()

	// If the plugins satisfy the io.Closer interface, they are closed.

                this.state = 6;
                ioe = ioe0;
            }
        case 4: /* failed to connect - reset the transport */
            // thread is cleaned up by connect routine, joining it here causes a deadlock
            this.thread = null;
            this.state = 6;
            break;
        default:
            log.error("Invalid state: " + this.state);
            this.thread = null;

	29:  "illegal seek",
	30:  "read-only file system",
	31:  "too many links",
	32:  "broken pipe",
	33:  "numerical argument out of domain",
	34:  "numerical result out of range",
	35:  "resource deadlock avoided",
	36:  "file name too long",
	37:  "no locks available",
	38:  "function not implemented",
	39:  "directory not empty",
	40:  "too many levels of symbolic links",
	42:  "no message of desired type",